filter

Documentation

Index

• type Filter
  • func NewNoopFilter(o NoopFilterOpts) Filter
• type NoopFilter
  • func (f *NoopFilter) Execute(transaction fetch.Transaction) (bool, error)
• type NoopFilterOpts

Types

type Filter

type Filter interface {
	Execute(inputTransaction fetch.Transaction) (next bool, err error)
}

Filter defines a read only filter which must return next as true/false or an error

func NewNoopFilter

func NewNoopFilter(o NoopFilterOpts) Filter

type NoopFilter

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

func (*NoopFilter) Execute

func (f *NoopFilter) Execute(transaction fetch.Transaction) (bool, error)

type NoopFilterOpts

type NoopFilterOpts struct {
	Logg logf.Logger
}