poller

Documentation

Index

• func AwaitBlocks(wssHost string, height chan int64)
• type BlockHeightNotifier
• type BlockHeightObserver
• type Data
• type EventDataNewBlockHeader
• type Header
• type Querier
  • func (q *Querier) Notify(chain string, height int64)
  • func (q *Querier) Subscribe(o BlockHeightObserver, chainID string) (bool, error)
  • func (q *Querier) Unsubscribe(o BlockHeightObserver, chainID string) (bool, error)
• type Result
• type TendermintNewBlockHeader

Functions

func AwaitBlocks

func AwaitBlocks(wssHost string, height chan int64)

Types

type BlockHeightNotifier

type BlockHeightNotifier interface {
	Subscribe(o BlockHeightObserver, chainID string) (bool, error)
	Unsubscribe(o BlockHeightObserver, chainID string) (bool, error)
	Notify(chain string, height int64)
}

Observers get notified when a new block is published to the chain.

type BlockHeightObserver

type BlockHeightObserver interface {
	Get() chan uint64
}

type Data

type Data struct {
	Value EventDataNewBlockHeader
}

type EventDataNewBlockHeader

type EventDataNewBlockHeader struct {
	Header Header `json:"header"`
	NumTxs string `json:"num_txs"` // Number of txs in a block
}

type Header

type Header struct {
	// basic block info
	ChainID string    `json:"chain_id"`
	Height  string    `json:"height"`
	Time    time.Time `json:"time"`
}

type Querier

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

func (*Querier) Notify

func (q *Querier) Notify(chain string, height int64)

func (*Querier) Subscribe

func (q *Querier) Subscribe(o BlockHeightObserver, chainID string) (bool, error)

func (*Querier) Unsubscribe

func (q *Querier) Unsubscribe(o BlockHeightObserver, chainID string) (bool, error)

type Result

type Result struct {
	Data Data
}

type TendermintNewBlockHeader

type TendermintNewBlockHeader struct {
	Result Result
}