timer

Documentation

Index

• Constants
• type BlockNotifier
• type BlockSubscriber
  • func NewBlockSubscriber(timer *Timer, tendermint *http.HTTP, log *logan.Entry) *BlockSubscriber
  • func (b *BlockSubscriber) Run(ctx context.Context)
• type Timer
  • func NewTimer(tendermint *http.HTTP, log *logan.Entry) *Timer
  • func (t *Timer) CurrentBlock() uint64
  • func (t *Timer) SubscribeToBlocks(name string, f BlockNotifier)

Constants

const (
	BlockServiceName = "block-subscriber"
	BlockQuery       = "tm.event = 'NewBlock'"
	ChanelCap        = 100
)

Types

type BlockNotifier

type BlockNotifier func(height uint64) error

type BlockSubscriber

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

BlockSubscriber subscribes to the NewBlock events on the tendermint core. New blocks indexes will be pushed to the timer and used in future for session timestamping

func NewBlockSubscriber

func NewBlockSubscriber(timer *Timer, tendermint *http.HTTP, log *logan.Entry) *BlockSubscriber

NewBlockSubscriber creates the subscriber instance for listening new blocks

func (*BlockSubscriber) Run

func (b *BlockSubscriber) Run(ctx context.Context)

type Timer

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

Timer provides the source for timestamping all operations in the tss system. Use Notifier to receive notification about new blocks in your service

func NewTimer

func NewTimer(tendermint *http.HTTP, log *logan.Entry) *Timer

func (*Timer) CurrentBlock

func (t *Timer) CurrentBlock() uint64

func (*Timer) SubscribeToBlocks

func (t *Timer) SubscribeToBlocks(name string, f BlockNotifier)

SubscribeToBlocks adds receiver method to notify fot the new block events