JetStreamManager overview
Added in v0.1.0
Table of contents
Layers
layer
Signature
export declare const layer: (
options?: JetStream.JetStreamManagerOptions
) => Layer.Layer<JetStreamManager, NATSError.JetStreamManagerError, NATSConnection.NATSConnection>
Added in v0.1.0
models
JetStreamManager (interface)
Represents a NATS JetStream Manager
Signature
export interface JetStreamManager {
readonly [TypeId]: TypeId
readonly accountInfo: Effect.Effect<JetStream.JetStreamAccountStats, NATSError.JetStreamManagerError, never>
readonly advisoryStream: Stream.Stream<JetStream.Advisory, NATSError.JetStreamManagerError, never>
readonly options: Effect.Effect<JetStream.JetStreamManagerOptions, NATSError.JetStreamManagerError, never>
readonly consumers: JetStreamConsumerAPI.JetStreamConsumerAPI
readonly streams: JetStreamStreamAPI.JetStreamStreamAPI
readonly direct: JetStreamDirectStreamAPI.JetStreamDirectStreamAPI
/** @internal */
readonly jsm: JetStream.JetStreamManager
}
Added in v0.1.0
tags
JetStreamManager
Signature
export declare const JetStreamManager: Context.Tag<JetStreamManager, JetStreamManager>
Added in v0.1.0
type ids
TypeId
Signature
export declare const TypeId: typeof TypeId
Added in v0.1.0
TypeId (type alias)
Signature
export type TypeId = typeof TypeId
Added in v0.1.0