RunnerServer

4 exports Added in v1.0.0 Source

Layers

layer

Added in v1.0.0 Source

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

Added in v1.0.0 Source

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

Added in v1.0.0 Source

Signature

declare const layerHandlers: any;

layerWithClients

Added in v1.0.0 Source

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
>;