observer

Documentation

Index

• Constants
• type Observer
  • func NewObserver(pubkeyMgr *pubkeymanager.PubKeyManager, ...) (*Observer, error)
  • func (o *Observer) Start() error
  • func (o *Observer) Stop() error
• type ObserverStorage
  • func NewObserverStorage(path string) (*ObserverStorage, error)
  • func (s *ObserverStorage) Close() error
  • func (s *ObserverStorage) GetOnDeckTxs() ([]types.TxIn, error)
  • func (s *ObserverStorage) SetOnDeckTxs(ondeck []types.TxIn) error
• type SignerCacheUpdater

Constants

const (
	OnDeckTxKey = "ondeck-tx"
)

Types

type Observer

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

Observer observer service

func NewObserver

func NewObserver(pubkeyMgr *pubkeymanager.PubKeyManager,
	chains map[common.Chain]chainclients.ChainClient,
	thorchainBridge *mayaclient.MayachainBridge,
	m *metrics.Metrics, dataPath string,
	tssKeysignMetricMgr *metrics.TssKeysignMetricMgr,
) (*Observer, error)

NewObserver create a new instance of Observer for chain

func (*Observer) Start

func (o *Observer) Start() error

func (*Observer) Stop

func (o *Observer) Stop() error

Stop the observer

type ObserverStorage

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

ObserverStorage save the ondeck tx in item to key value store , in case bifrost restart

func NewObserverStorage

func NewObserverStorage(path string) (*ObserverStorage, error)

NewObserverStorage create a new instance of LevelDBScannerStorage

func (*ObserverStorage) Close

func (s *ObserverStorage) Close() error

func (*ObserverStorage) GetOnDeckTxs

func (s *ObserverStorage) GetOnDeckTxs() ([]types.TxIn, error)

GetOnDeckTxs retrieve the ondeck tx from key value store

func (*ObserverStorage) SetOnDeckTxs

func (s *ObserverStorage) SetOnDeckTxs(ondeck []types.TxIn) error

SetOnDeckTxs save the ondeck tx to key value store

type SignerCacheUpdater

type SignerCacheUpdater func(hash string) error