txfeed

Documentation

Index

• Constants
• Variables
• type Tracker
  • func NewTracker(db dbm.DB, chain *protocol.Chain) *Tracker
  • func (t *Tracker) Create(ctx context.Context, alias, fil string) error
  • func (t *Tracker) Delete(ctx context.Context, alias string) error
  • func (t *Tracker) Get(ctx context.Context, alias string) (*TxFeed, error)
  • func (t *Tracker) GetTxfeedCh() chan *types.Tx
  • func (t *Tracker) Prepare(ctx context.Context) error
  • func (t *Tracker) TxFilter(tx *types.Tx) error
• type TxFeed
  • func Query(ctx context.Context, after string, limit int) ([]*TxFeed, string, error)

Constants

const (
	//FilterNumMax max txfeed filter amount.
	FilterNumMax = 1024
)

Variables

var (
	//ErrDuplicateAlias means error of duplicate feed alias.
	ErrDuplicateAlias = errors.New("duplicate feed alias")
	//ErrEmptyAlias means error of empty feed alias.
	ErrEmptyAlias = errors.New("empty feed alias")
	//ErrNumExceedlimit means txfeed filter number exceeds the limit.
	ErrNumExceedlimit = errors.New("txfeed exceed limit")
)

Types

type Tracker

type Tracker struct {
	DB      dbm.DB
	TxFeeds []*TxFeed
	// contains filtered or unexported fields
}

Tracker filter tracker object.

func NewTracker

func NewTracker(db dbm.DB, chain *protocol.Chain) *Tracker

NewTracker create new txfeed tracker.

func (*Tracker) Create

func (t *Tracker) Create(ctx context.Context, alias, fil string) error

Create create a txfeed filter.

func (*Tracker) Delete

func (t *Tracker) Delete(ctx context.Context, alias string) error

Delete delete txfeed with alias.

func (*Tracker) Get

func (t *Tracker) Get(ctx context.Context, alias string) (*TxFeed, error)

Get get txfeed filter with alias.

func (*Tracker) GetTxfeedCh

func (t *Tracker) GetTxfeedCh() chan *types.Tx

GetTxfeedCh return a txfeed channel.

func (*Tracker) Prepare

func (t *Tracker) Prepare(ctx context.Context) error

Prepare load and parse filters.

func (*Tracker) TxFilter

func (t *Tracker) TxFilter(tx *types.Tx) error

TxFilter filter tx from mempool.

type TxFeed

type TxFeed struct {
	ID     string `json:"id,omitempty"`
	Alias  string `json:"alias"`
	Filter string `json:"filter,omitempty"`
	Param  filter `json:"param,omitempty"`
}

TxFeed describe a filter

func Query

func Query(ctx context.Context, after string, limit int) ([]*TxFeed, string, error)

Query queries the Chain Core for txfeeds matching the query.