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

JetStreamPublisher overview

Added in v0.1.0


Table of contents


constructors

JetStreamPublisherConfig (interface)

Signature

export interface JetStreamPublisherConfig {
  readonly retrySchedule?: Schedule.Schedule<unknown, NATSError.JetStreamClientError>
}

Added in v0.1.0

make

Signature

export declare const make: (
  config?: JetStreamPublisherConfig
) => Effect.Effect<
  JetStreamPublisher,
  NATSError.JetStreamClientError | NATSError.NATSConnectionError,
  JetStreamClient.JetStreamClient | NATSConnection.NATSConnection
>

Added in v0.1.0

models

JetStreamPublishMessage (interface)

Signature

export interface JetStreamPublishMessage {
  subject: string
  payload: NATSCore.Payload
  options?: Partial<JetStream.JetStreamPublishOptions>
}

Added in v0.1.0

JetStreamPublisher (interface)

Signature

export interface JetStreamPublisher extends Publisher.Publisher<JetStreamPublishMessage> {
  readonly [TypeId]: TypeId
}

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