Subscription: {
    active: boolean;
    batch_size: number;
    consumer: string;
    endpoint: string;
    id: string;
    names: string;
    path: string;
    position: number;
    producer: string;
    retries: number;
    retry_timeout_secs: number;
    streams: string;
    updated: Date;
}

Subscriptions connect producer and consumer services using pattern matching rules

  • id The subscription unique id
  • producer The producer service
  • consumer The consumer service
  • path The path on the consumer service (appended to url - policy name by convention)
  • streams: regex rules to filter by substringeams (aggregates, systems, process managers)
  • names: regex rules to filter by event names
  • position The position in the stream - last acked id
  • updated The last update timestamp
  • batch_size The pull batch size (default 100)
  • retries The number of retries before pausing (default 3)
  • retry_timeout_sec Seconds between retries with exponential backoff (default 10)
  • endpoint Calculated field combining consumer url with path

Type declaration

  • active: boolean
  • batch_size: number
  • consumer: string
  • endpoint: string
  • id: string
  • names: string
  • path: string
  • position: number
  • producer: string
  • retries: number
  • retry_timeout_secs: number
  • streams: string
  • updated: Date

Generated using TypeDoc