Function layerCosmos

packages/infra/src/ClusterCosmos.ts:1111–1118

(config: ClusterCosmosConfig)

> => Layer.merge(layerMessageStorage(options), layerRunnerStorage(options))

export const layerCosmos = (config: ClusterCosmosConfig): Layer.Layer<
  MessageStorage.MessageStorage | RunnerStorage.RunnerStorage,
  never,
  ShardingConfig.ShardingConfig
> =>
  layerStorage({ prefix: config.prefix }).pipe(
    Layer.provide(CosmosClientLayer(Redacted.value(config.url), config.dbName))
  )