filter

Documentation

Index

• type MessageFilter
  • func NewMessageFilter(cfg *config.Config) *MessageFilter
  • func (f *MessageFilter) Filter(msg *amqp.Delivery) bool
  • func (f *MessageFilter) GetCompilationErrors() []error

Types

type MessageFilter

type MessageFilter struct {
	// contains filtered or unexported fields
}

func NewMessageFilter

func NewMessageFilter(cfg *config.Config) *MessageFilter

func (*MessageFilter) Filter

func (f *MessageFilter) Filter(msg *amqp.Delivery) bool

func (*MessageFilter) GetCompilationErrors

func (f *MessageFilter) GetCompilationErrors() []error

GetCompilationErrors returns any errors encountered during pattern compilation