filter

Documentation

Index

• Constants
• type AddressFilter
  • func (f *AddressFilter) Execute(_ context.Context, transaction *fetch.Transaction) (bool, error)
• type AddressFilterOpts
• type Filter
  • func NewAddressFilter(o AddressFilterOpts) Filter
  • func NewTransferFilter(o TransferFilterOpts) Filter
• type TransferFilter
  • func (f *TransferFilter) Execute(_ context.Context, transaction *fetch.Transaction) (bool, error)
• type TransferFilterOpts

Constants

const (
	KRNVoucherAddress = "0x8bab657c88eb3c724486d113e650d2c659aa23d2"
	SRFVoucherAddress = "0x45d747172e77d55575c197cba9451bc2cd8f4958"
)

Types

type AddressFilter

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

func (*AddressFilter) Execute

func (f *AddressFilter) Execute(_ context.Context, transaction *fetch.Transaction) (bool, error)

type AddressFilterOpts

type AddressFilterOpts struct {
	Logg logf.Logger
}

type Filter

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

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

func NewAddressFilter

func NewAddressFilter(o AddressFilterOpts) Filter

func NewTransferFilter

func NewTransferFilter(o TransferFilterOpts) Filter

type TransferFilter

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

func (*TransferFilter) Execute

func (f *TransferFilter) Execute(_ context.Context, transaction *fetch.Transaction) (bool, error)

type TransferFilterOpts

type TransferFilterOpts struct {
	Logg logf.Logger
	Pub  *pub.Pub
}