observer

package
v1.109.0 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2024 License: MIT Imports: 25 Imported by: 0

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,
	mayachainBridge 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

Jump to

Keyboard shortcuts

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