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

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