Versions in this module Expand all Collapse all v1 v1.137.2 Nov 5, 2024 v1.137.1 Oct 24, 2024 Changes in this version + const DefaultSignerLevelDBFolder + type ConstantsProvider struct + func NewConstantsProvider(bridge thorclient.ThorchainBridge) *ConstantsProvider + func (cp *ConstantsProvider) EnsureConstants(thorchainBlockHeight int64) error + func (cp *ConstantsProvider) GetInt64Value(thorchainBlockHeight int64, key constants.ConstantName) (int64, error) + type Signer struct + func NewSigner(cfg config.BifrostSignerConfiguration, ...) (*Signer, error) + func (s *Signer) Start() error + func (s *Signer) Stop() error + type SignerStorage interface + Batch func(items []TxOutStoreItem) error + Close func() error + Get func(key string) (TxOutStoreItem, error) + Has func(key string) bool + List func() []TxOutStoreItem + OrderedLists func() map[string][]TxOutStoreItem + Remove func(item TxOutStoreItem) error + Set func(item TxOutStoreItem) error + type SignerStore struct + func NewSignerStore(levelDbFolder string, opts config.LevelDBOptions, passphrase string) (*SignerStore, error) + func (s *SignerStore) Batch(items []TxOutStoreItem) error + func (s *SignerStore) Close() error + func (s *SignerStore) Get(keyString string) (item TxOutStoreItem, err error) + func (s *SignerStore) GetInternalDb() *leveldb.DB + func (s *SignerStore) Has(key string) (ok bool) + func (s *SignerStore) List() []TxOutStoreItem + func (s *SignerStore) OrderedLists() map[string][]TxOutStoreItem + func (s *SignerStore) Remove(item TxOutStoreItem) error + func (s *SignerStore) Set(item TxOutStoreItem) error + type ThorchainBlockScan struct + func NewThorchainBlockScan(cfg config.BifrostBlockScannerConfiguration, ...) (*ThorchainBlockScan, error) + func (b *ThorchainBlockScan) FetchTxs(height, _ int64) (types.TxIn, error) + func (b *ThorchainBlockScan) GetHeight() (int64, error) + func (b *ThorchainBlockScan) GetKeygenMessages() <-chan ttypes.KeygenBlock + func (b *ThorchainBlockScan) GetTxOutMessages() <-chan types.TxOut + func (c *ThorchainBlockScan) FetchMemPool(height int64) (types.TxIn, error) + type TxOutStoreItem struct + Checkpoint []byte + Height int64 + Index int64 + RetrievalKey string + Round7Retry bool + SignedTx []byte + Status TxStatus + TxOutItem types.TxOutItem + func NewTxOutStoreItem(height int64, item types.TxOutItem, idx int64) TxOutStoreItem + func (s *TxOutStoreItem) Key() string + type TxStatus int + const TxAvailable + const TxSpent + const TxUnavailable + const TxUnknown