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, ddchainBridge ddclient.DdchainBridge, m *metrics.Metrics, dataPath string, tssKeysignMetricMgr *metrics.TssKeysignMetricMgr, ) (*Observer, error)
NewObserver create a new instance of Observer for chain
func (*Observer) ObserveSigned ¶
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 will be cached in memory and skipped if they are later observed in the mempool or block.
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
Source Files
Click to show internal directories.
Click to hide internal directories.