CobraInitSubscriptionManager standard naming for cobra command params.

NewSubscriptionManager constructor.

DefaultExponentialBackoffFactor is the factor we use between retries.

DefaultExponentialBackoffInitial is the initial delay for backoff retry.

DefaultTimestampCacheSize is the number of entries we will hold in a LRU cache for block timestamps.

ErrorHandlingBlock blocks the event stream until the handler can accept the event.

ErrorHandlingSkip processes up to the retry behavior on the stream, then skips to the next event.

FromBlockLatest is the special string that means subscribe from the current block.

MaxBatchSize is the maximum that a user can specific for their batch size.

StreamPathPrefix is the path prefix for event streams.

SubPathPrefix is the path prefix for subscriptions.

StreamInfo configures the stream to perform an action for each event.

SubscriptionInfo is the persisted data for the subscription.

SubscriptionManagerConf configuration.

SubscriptionManager provides REST APIs for managing events.