Skip to main content Link Search Menu Expand Document (external link)

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