/** * Bun socket layers for Effect Cluster runners. * * The main `layer` builds a sharding layer for socket transport, choosing * serialization, runner health checks, runner storage, message storage, and * optional client-only mode from the supplied options. This module also * re-exports the shared socket client and server protocol layers and provides * `layerK8sHttpClient` for Kubernetes runner health checks. * * @stability unstable * @since 4.0.0 */ import { layerClientProtocol, layerSocketServer } from "@effect/platform-node-shared/NodeClusterSocket"; import * as K8sHttpClient from "effect/cluster/K8sHttpClient"; import * as MessageStorage from "effect/cluster/MessageStorage"; import * as Runners from "effect/cluster/Runners"; import * as RunnerStorage from "effect/cluster/RunnerStorage"; import type { Sharding } from "effect/cluster/Sharding"; import * as ShardingConfig from "effect/cluster/ShardingConfig"; import type * as Config from "effect/Config"; import * as Layer from "effect/Layer"; import type * as SocketServer from "effect/socket/SocketServer"; import type { SqlClient } from "effect/sql/SqlClient"; export { /** * Provides the cluster `RpcClientProtocol` using the shared socket client * implementation. * * @stability unstable * @category re-exports * @since 4.0.0 */ layerClientProtocol, /** * Provides the socket server used by Bun cluster runners through the shared * socket server implementation. * * @stability unstable * @category re-exports * @since 4.0.0 */ layerSocketServer }; /** * Creates Bun socket cluster layers, configuring serialization, storage, runner health, and optional client-only mode. * * @stability unstable * @category layers * @since 4.0.0 */ export declare const layer: (options?: { readonly serialization?: "binary" | "ndjson" | undefined; readonly serializationMaxBufferSize?: number | "unbounded" | undefined; readonly clientOnly?: ClientOnly | undefined; readonly storage?: Storage | undefined; readonly runnerHealth?: "ping" | "k8s" | undefined; readonly runnerHealthK8s?: { readonly namespace?: string | undefined; readonly labelSelector?: string | undefined; } | undefined; readonly shardingConfig?: Partial | undefined; }) => ClientOnly extends true ? Layer.Layer : Layer.Layer; /** * Layer that provides `K8sHttpClient`, using the Kubernetes service-account CA certificate when it is available. * * @stability unstable * @category layers * @since 4.0.0 */ export declare const layerK8sHttpClient: Layer.Layer; //# sourceMappingURL=BunClusterSocket.d.ts.map