Documentation

Index

Constants

View Source
const (
	EventFilter       FilterType = 0
	StreamFilter      FilterType = 1
	NoMaxSearchWindow int        = -1
)

Variables

This section is empty.

Functions

This section is empty.

Types

type FilterType

type FilterType int

type SubscriptionFilter

type SubscriptionFilter struct {
	FilterType FilterType
	Prefixes   []string
	Regex      string
}

func NewEventPrefixFilter

func NewEventPrefixFilter(prefixes []string) SubscriptionFilter

func NewEventRegexFilter

func NewEventRegexFilter(regex string) SubscriptionFilter

func NewStreamPrefixFilter

func NewStreamPrefixFilter(prefixes []string) SubscriptionFilter

func NewStreamRegexFilter

func NewStreamRegexFilter(regex string) SubscriptionFilter

type SubscriptionFilterOptions

type SubscriptionFilterOptions struct {
	MaxSearchWindow    int
	CheckpointInterval int
	CheckpointReached  func(checkpoint position.Position)
	SubscriptionFilter SubscriptionFilter
}

func NewDefaultSubscriptionFilterOptions

func NewDefaultSubscriptionFilterOptions(filter SubscriptionFilter) SubscriptionFilterOptions

func NewSubscriptionFilterOptions

func NewSubscriptionFilterOptions(maxSearchWindow int, checkpointInterval int, checkpointReached func(checkpoint position.Position), filter SubscriptionFilter) SubscriptionFilterOptions