RunnerServer.ts overview

Since v1.0.0

Exports Grouped by Category

Layers

Layers

layer

The RunnerServer recieves 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, MessageStorage.MessageStorage | Sharding.Sharding | RpcServer.Protocol>

Source

Since v1.0.0

layerClientOnly

A Runners layer that is client only.

It will not register with the ShardManager and recieve 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,
  MessageStorage.MessageStorage | ShardingConfig | Runners.RpcClientProtocol
>

Source

Since v1.0.0

layerHandlers

Signature

declare const layerHandlers: Layer.Layer<
  Handler<"Ping"> | Handler<"Notify"> | Handler<"Effect"> | Handler<"Stream"> | Handler<"Envelope">,
  never,
  MessageStorage.MessageStorage | Sharding.Sharding
>

Source

Since v1.0.0

layerWithClients

A RunnerServer layer that includes the Runners & Sharding clients.

Signature

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

Source

Since v1.0.0