filters

Documentation

Index

• type EventTypeFilter
  • func (e EventTypeFilter) Filter(msg bus.Message) error
• type RefreshFilter
  • func (r *RefreshFilter) Filter(msg bus.Message) error

Types

type EventTypeFilter

type EventTypeFilter struct {
	AllowedEventTypes []string
}

EventTypeFilter returns nil for allowed events. Returns dispatcher.ErrNack for all others.

func (EventTypeFilter) Filter

func (e EventTypeFilter) Filter(msg bus.Message) error

Filter returns nil for allowed events. Returns dispatcher.ErrNack for all others.

type RefreshFilter

type RefreshFilter struct {
	EventStore eventstore.EventStore
}

RefreshFilter calls refresh on an eventstore

func (*RefreshFilter) Filter

func (r *RefreshFilter) Filter(msg bus.Message) error

Filter just calls refrest on an event store.