observer

Documentation

Index

• Constants
• type Observer
  • func NewObserver(pubkeyMgr *pubkeymanager.PubKeyManager, ...) (*Observer, error)
  • func (o *Observer) ObserveSigned(txIn types.TxIn, allowFutureObservation bool)
  • func (o *Observer) Start() error
  • func (o *Observer) Stop() error
• type ObserverStorage
  • func NewObserverStorage(path string, opts config.LevelDBOptions) (*ObserverStorage, error)
  • func (s *ObserverStorage) Close() error
  • func (s *ObserverStorage) GetOnDeckTxs() ([]types.TxIn, error)
  • func (s *ObserverStorage) SetOnDeckTxs(ondeck []types.TxIn) error

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 thorclient.ThorchainBridge,
	m *metrics.Metrics, dataPath string,
	tssKeysignMetricMgr *metrics.TssKeysignMetricMgr,
) (*Observer, error)

NewObserver create a new instance of Observer for chain

func (*Observer) ObserveSigned

func (o *Observer) ObserveSigned(txIn types.TxIn, allowFutureObservation bool)

ObserveSigned is called when a tx is signed by the signer and returns an observation that should be immediately submitted. Observations passed to this method with 'allowFutureObservation' false will be cached in memory and skipped if they are later observed in the mempool or block.

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, opts config.LevelDBOptions) (*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