moonbitstack/moonzero/service

README
U
Balancer
U
BidiCall
U
BidiStreamFactory
U
BidiStreamHandler
U
Breaker
U
Call
U
ClientDeps
U
ClientStreamHandler
U
Clock
U
Conf
U
CorsConf
U
Discovery
U
Endpoint
U
FileEntry
U
Files
U
Group
U
Interceptor
U
Invoker
U
JwtRoute
U
Layer
U
Lease
U
LoadBalancedChannel
U
LogLevel
U
Logger
U
ManualClock
U
Mapper
U
MaxConns
U
MethodTimeout
U
Middleware
U
MiddlewaresConf
U
Once
U
PeriodLimit
U
PeriodResult
U
Pool
U
PrivateKeyConf
U
Promise
U
RedisPeriodLimit
U
RedisTokenLimit
U
Refusal
U
Refused
U
Registrar
U
RequestLog
U
Resolve
U
RestConf
U
RestEngine
U
Ring
U
RouteOptions
U
RoutineGroup
U
RpcChannel
U
RpcClientConf
U
RpcClientMiddlewaresConf
U
RpcCluster
U
RpcGroup
U
RpcHandler
U
RpcMetrics
U
RpcServer
U
RpcServerConf
U
RpcServerMiddlewaresConf
U
Server
U
ServerDeps
U
ServerMetrics
U
ServerStreamHandler
U
Service
U
ServiceConf
U
ServiceGroup
U
Shedder
U
ShutdownCoordinator
U
SignatureConf
U
SignatureInput
U
SignatureKey
U
SignatureVerifier
U
Single
U
StableRunner
U
StatConf
U
TaskRunner
U
Ticket
U
TokenBucket
U
Unavailable
U
Update
U
VerifiedContent
U
View
U
Watcher
V
auth
V
breaker
V
canonical_key
V
chain
V
chunk
V
client_breaker
V
client_duration
V
client_interceptors
V
client_prometheus
V
client_timeout
V
client_tracing
V
content_security
V
cors
V
default_latency_buckets
V
duration_key
V
entry
V
exposition_content_type
V
file_server
V
group_by
V
hold
V
jwt_authorized
V
jwt_sign
V
jwt_verify
V
layer
V
level_name
V
logging
V
logx
V
map_reduce
V
map_reduce_parallel
V
max_conns
V
maxbytes
V
media_type_of
V
message_key
V
metrics
V
metrics_handler
V
mount_metrics
V
not_allowed
V
not_found
V
period_limit
V
period_script
V
plain_text
V
port
V
rate_limit
V
recovery
V
redis_period_limit
V
redis_rate_limit
V
refusal
V
request_id
V
retry
V
retry_with_backoff
V
rpc_port
V
server_auth
V
server_breaker
V
server_interceptors
V
server_prometheus
V
server_recover
V
server_shedding
V
server_stat
V
server_timeout
V
server_tracing
V
set_log_level
V
set_log_sink
V
set_log_writer
V
shedding
V
stamp_key
V
status_code
V
status_name
V
status_of_code
V
structured_logging
V
timed_out
V
timeout
V
token_script
V
too_large
V
too_many
V
trace_clock
V
trace_id_of
V
tracer
V
tracing
V
unavailable
V
verify_signature

moonbitstack/moonzero/service does not have a README file

Service

pub(all) struct Service {
  name : String
  start : async () -> Unit
}

One service in a group: a name, so a failure can say which one it was, and the body that runs it until it is cancelled.

Service::new

source

fn Service::new(name : String, start : async () -> Unit) -> Service

A named service.

ServiceGroup

source

pub struct ServiceGroup {
  services : Array[Service]
}

Several services run as one process (← go-zero's service.Group).

Every service is a task that runs until it returns or is cancelled, so a server loop and a background refresher share one lifetime: when the first fails, the rest are cancelled and the failure reaches the caller rather than leaving half a process running.

ServiceGroup::add

source

fn ServiceGroup::add(self : ServiceGroup, service : Service) -> Unit

Add a service to the group.

ServiceGroup::add_fn

source

fn ServiceGroup::add_fn(self : ServiceGroup, name : String, start : async () -> Unit) -> Unit

Add a service under name.

ServiceGroup::names

source

fn ServiceGroup::names(self : ServiceGroup) -> Array[String]

The names of the services in the group, in the order they were added.

ServiceGroup::new

source

fn ServiceGroup::new() -> ServiceGroup

A group with nothing in it.

ServiceGroup::start

source

async fn ServiceGroup::start(self : ServiceGroup) -> Unit

Run every service concurrently and return when all of them have finished.

A service that fails cancels the others, so a group either runs or reports what stopped it — it never leaves a member behind.

Source Files

group.mbt

Install

Download zip

A service framework for MoonBit.

go-zeromicroservicemicroservicesservice-frameworkframeworkrestrpczrpcgrpcmiddlewarecircuit-breakerrate-limitload-sheddingload-balancingservice-discoverymetricstracingloggingconfigyamljwtsignaturecorsgzipssefile-serverp2csingleflightcacheredissqlprometheusopentelemetrygraceful-shutdownmoonapiservermoonbit

moonbitstack

Apache-2.0