Module: KubeMQ::PubSub::EventStoreStartPosition

Defined in:

lib/kubemq/pubsub/events_store_subscription.rb

Overview

Start-position constants for events store subscriptions.

Use with KubeMQ::PubSub::EventsStoreSubscription#start_position to control where the broker begins replaying persisted events.

See Also:

• EventsStoreSubscription

Constant Summary

START_NEW_ONLY =

Receive only events published after the subscription starts.

1

START_FROM_FIRST =

Replay from the first event ever stored on the channel.

2

START_FROM_LAST =

Replay from the most recent event on the channel.

3

START_AT_SEQUENCE =

Replay from a specific sequence number (set via start_position_value).

4

START_AT_TIME =

Replay from a specific Unix timestamp in nanoseconds (set via start_position_value).

5

START_AT_TIME_DELTA =

Replay events stored within the last N seconds (set via start_position_value).

6