RunnerServer

4 exports Since v1.0.0 Source

Layers

layer

Since v1.0.0

The RunnerServer receives messages from other Runners and forwards them to the Sharding layer.

It also responds to Ping requests.

Signature

declare const layer: Layer.Layer<never, never, RpcServer.Protocol | Sharding.Sharding | MessageStorage.MessageStorage>

layerClientOnly

Since v1.0.0

A Runners layer that is client only.

It will not register with RunnerStorage and receive shard assignments, so this layer can be used to embed a cluster client inside another effect application.

Signature

declare const layerClientOnly: Layer.Layer<Sharding.Sharding | Runners.Runners, never, ShardingConfig | Runners.RpcClientProtocol | MessageStorage.MessageStorage | RunnerStorage.RunnerStorage>

layerHandlers

Since v1.0.0

Signature

declare const layerHandlers: any

layerWithClients

Since v1.0.0

A RunnerServer layer that includes the Runners & Sharding clients.

Signature

declare const layerWithClients: Layer.Layer<Sharding.Sharding | Runners.Runners, never, RpcServer.Protocol | ShardingConfig | Runners.RpcClientProtocol | MessageStorage.MessageStorage | RunnerStorage.RunnerStorage | RunnerHealth.RunnerHealth>