/** * @since 1.0.0 */ import type * as Rpc from "@effect/rpc/Rpc"; import * as RpcServer from "@effect/rpc/RpcServer"; import * as Layer from "effect/Layer"; import * as MessageStorage from "./MessageStorage.js"; import * as RunnerHealth from "./RunnerHealth.js"; import * as Runners from "./Runners.js"; import type * as RunnerStorage from "./RunnerStorage.js"; import * as Sharding from "./Sharding.js"; import { ShardingConfig } from "./ShardingConfig.js"; /** * @since 1.0.0 * @category Layers */ export declare const layerHandlers: Layer.Layer | Rpc.Handler<"Notify"> | Rpc.Handler<"Effect"> | Rpc.Handler<"Stream"> | Rpc.Handler<"Envelope">, never, MessageStorage.MessageStorage | Sharding.Sharding>; /** * The `RunnerServer` receives messages from other Runners and forwards them to the * `Sharding` layer. * * It also responds to `Ping` requests. * * @since 1.0.0 * @category Layers */ export declare const layer: Layer.Layer; /** * A `RunnerServer` layer that includes the `Runners` & `Sharding` clients. * * @since 1.0.0 * @category Layers */ export declare const layerWithClients: Layer.Layer; /** * 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. * * @since 1.0.0 * @category Layers */ export declare const layerClientOnly: Layer.Layer; //# sourceMappingURL=RunnerServer.d.ts.map