ShardManager overview
Added in v1.0.0
Table of contents
context
ShardManager
Signature
export declare const ShardManager: any
Added in v1.0.0
layers
live
Signature
export declare const live: any
Added in v1.0.0
models
ShardManager (interface)
Signature
export interface ShardManager {
readonly getShardingEvents: Stream.Stream<ShardingEvent.ShardingEvent>
readonly register: (pod: Pod.Pod) => Effect.Effect<void>
readonly unregister: (podAddress: PodAddress.PodAddress) => Effect.Effect<void>
readonly notifyUnhealthyPod: (podAddress: PodAddress.PodAddress) => Effect.Effect<void>
readonly checkAllPodsHealth: Effect.Effect<void>
readonly getAssignments: Effect.Effect<HashMap.HashMap<ShardId.ShardId, Option.Option<PodAddress.PodAddress>>>
/* @internal */
readonly rebalance: (rebalanceImmediately: boolean) => Effect.Effect<void>
/* @internal */
readonly persistPods: Effect.Effect<void>
}
Added in v1.0.0
symbols
ShardManagerTypeId
Signature
export declare const ShardManagerTypeId: typeof ShardManagerTypeId
Added in v1.0.0
ShardManagerTypeId (type alias)
Signature
export type ShardManagerTypeId = typeof ShardManagerTypeId
Added in v1.0.0