observer

package
v0.55.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2021 License: MIT Imports: 22 Imported by: 2

Documentation

Index

Constants

View Source
const (
	OnDeckTxKey = "ondeck-tx"
)

Variables

This section is empty.

Functions

This section is empty.

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) Start

func (o *Observer) Start() error

func (*Observer) Stop

func (o *Observer) Stop() error

Stop the observer

type ObserverStorage added in v0.41.0

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 added in v0.41.0

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

NewObserverStorage create a new instance of LevelDBScannerStorage

func (*ObserverStorage) Close added in v0.41.0

func (s *ObserverStorage) Close() error

func (*ObserverStorage) GetOnDeckTxs added in v0.41.0

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

GetOnDeckTxs retrieve the ondeck tx from key value store

func (*ObserverStorage) SetOnDeckTxs added in v0.41.0

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

SetOnDeckTxs save the ondeck tx to key value store

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL