filter

package

v0.6.6-alpha Latest Latest Go to latest Published: Mar 13, 2023 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

type AddressFilterOpts struct {
	Cache         *sync.Map
	Logg          logf.Logger
	SystemAddress string
}

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(o AddressFilterOpts) Filter

func NewGasFilter(o GasFilterOpts) Filter

func NewRegisterFilter(o RegisterFilterOpts) Filter

func NewTransferFilter(o TransferFilterOpts) Filter

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

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

type GasFilterOpts struct {
	Logg          logf.Logger
	Pub           *pub.Pub
	SystemAddress string
}

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

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

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

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

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

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