Documentation ¶
Index ¶
- func BySequenceID(sequenceID string) eventsource.QueryOption
- func ByTimestamp(timestamp int64) eventsource.QueryOption
- func ByType(eventType string) eventsource.QueryOption
- func New() eventsource.Store
- func WithFilter(filter FilterFunc) eventsource.QueryOption
- func WithLimit(limit int) eventsource.QueryOption
- type FilterFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BySequenceID ¶ added in v2.2.0
func BySequenceID(sequenceID string) eventsource.QueryOption
func ByTimestamp ¶ added in v2.2.0
func ByTimestamp(timestamp int64) eventsource.QueryOption
func ByType ¶ added in v2.2.0
func ByType(eventType string) eventsource.QueryOption
func WithFilter ¶ added in v2.2.0
func WithFilter(filter FilterFunc) eventsource.QueryOption
Types ¶
type FilterFunc ¶ added in v2.2.0
type FilterFunc func(record eventsource.Record) bool
Click to show internal directories.
Click to hide internal directories.