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;
}
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
Subscriptions connect producer and consumer services using pattern matching rules
id
The subscription unique idproducer
The producer serviceconsumer
The consumer servicepath
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 namesposition
The position in the stream - last acked idupdated
The last update timestampbatch_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