watcher

Documentation

Index

• Constants
• type TransactionHandler
• type Watcher
  • func (w *Watcher) RegisterHandler(handler TransactionHandler)
  • func (w *Watcher) Run()
  • func (w *Watcher) Sleep()

Constants

const SleepSeconds = 3

Types

type TransactionHandler

type TransactionHandler interface {
	Update(sdk.Transaction, uint64)
}

type Watcher

type Watcher struct {
	Ctx context.Context

	KVClient    common.IKVStore
	QueueClient common.IQueue
	Hydro       sdk.Hydro

	TransactionHandler *TransactionHandler
	// contains filtered or unexported fields
}

func (*Watcher) RegisterHandler

func (w *Watcher) RegisterHandler(handler TransactionHandler)

func (*Watcher) Run

func (w *Watcher) Run()

func (*Watcher) Sleep

func (w *Watcher) Sleep()

Sleep allows watcher to exit even thought it is sleeping