Type Alias JetStreamManager

JetStreamManager: {
    consumers: ConsumerAPI;
    streams: StreamAPI;
    advisories(): AsyncIterable<Advisory>;
    getAccountInfo(): Promise<JetStreamAccountStats>;
    getOptions(): JetStreamOptions;
    jetstream(): JetStreamClient;
}

The API for interacting with JetStream resources

Type declaration

  • consumers: ConsumerAPI

    JetStream API to interact with Consumers

  • streams: StreamAPI

    JetStream API to interact with Streams

  • advisories:function
    • Returns an async iteartor

      Returns AsyncIterable<Advisory>

  • getAccountInfo:function
  • getOptions:function
  • jetstream:function