txfeed

Documentation

Overview

Package txfeed implements Chain Core's transaction feeds.

Index

• Variables
• type Tracker
  • func (t *Tracker) Create(ctx context.Context, alias, fil, after string, clientToken string) (*TxFeed, error)
  • func (t *Tracker) Delete(ctx context.Context, id, alias string) error
  • func (t *Tracker) Find(ctx context.Context, id, alias string) (*TxFeed, error)
  • func (t *Tracker) Query(ctx context.Context, after string, limit int) ([]*TxFeed, string, error)
  • func (t *Tracker) Update(ctx context.Context, id, alias, after, prev string) (*TxFeed, error)
• type TxFeed

Variables

var ErrDuplicateAlias = errors.New("duplicate feed alias")

Types

type Tracker

type Tracker struct {
	DB pg.DB
}

func (*Tracker) Create

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

func (*Tracker) Delete

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

func (*Tracker) Find

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

func (*Tracker) Query

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

Query queries the Chain Core for txfeeds matching the query.

func (*Tracker) Update

func (t *Tracker) Update(ctx context.Context, id, alias, after, prev string) (*TxFeed, error)

type TxFeed

type TxFeed struct {
	ID     string  `json:"id,omitempty"`
	Alias  *string `json:"alias"`
	Filter string  `json:"filter,omitempty"`
	After  string  `json:"after,omitempty"`
}