Documentation
¶
Index ¶
- Constants
- type ConstantsProvider
- type Signer
- type SignerStorage
- type SignerStore
- 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
- func (c *ThorchainBlockScan) FetchMemPool(height int64) (types.TxIn, 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
- type TxOutStoreItem
- type TxStatus
Constants ¶
View Source
const (
DefaultSignerLevelDBFolder = "signer_data"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConstantsProvider ¶
type ConstantsProvider struct {
// contains filtered or unexported fields
}
ConstantsProvider which will query thorchain to get the constants value per request it will also cache the constant values internally
func NewConstantsProvider ¶
func NewConstantsProvider(bridge thorclient.ThorchainBridge) *ConstantsProvider
NewConstantsProvider create a new instance of ConstantsProvider
func (*ConstantsProvider) EnsureConstants ¶
func (cp *ConstantsProvider) EnsureConstants(thorchainBlockHeight int64) error
func (*ConstantsProvider) GetInt64Value ¶
func (cp *ConstantsProvider) GetInt64Value(thorchainBlockHeight int64, key constants.ConstantName) (int64, error)
GetInt64Value get the constant value that match the given key
type Signer ¶
type Signer struct {
// contains filtered or unexported fields
}
Signer will pull the tx out from thorchain and then forward it to chain
func NewSigner ¶
func NewSigner(cfg config.BifrostSignerConfiguration, thorchainBridge thorclient.ThorchainBridge, thorKeys *thorclient.Keys, pubkeyMgr pubkeymanager.PubKeyValidator, tssServer *tssp.TssServer, chains map[common.Chain]chainclients.ChainClient, m *metrics.Metrics, tssKeysignMetricMgr *metrics.TssKeysignMetricMgr, obs *observer.Observer, ) (*Signer, error)
NewSigner create a new instance of signer
type SignerStorage ¶
type SignerStorage interface {
Set(item TxOutStoreItem) error
Batch(items []TxOutStoreItem) error
Get(key string) (TxOutStoreItem, error)
Has(key string) bool
Remove(item TxOutStoreItem) error
List() []TxOutStoreItem
OrderedLists() map[string][]TxOutStoreItem
Close() error
}
type SignerStore ¶
type SignerStore struct {
*blockscanner.LevelDBScannerStorage
// contains filtered or unexported fields
}
func NewSignerStore ¶
func NewSignerStore(levelDbFolder string, opts config.LevelDBOptions, passphrase string) (*SignerStore, error)
NewSignerStore create a new instance of SignerStore. If no folder is given, an in memory implementation is used.
func (*SignerStore) Batch ¶
func (s *SignerStore) Batch(items []TxOutStoreItem) error
func (*SignerStore) Get ¶
func (s *SignerStore) Get(keyString string) (item TxOutStoreItem, err error)
func (*SignerStore) GetInternalDb ¶
func (s *SignerStore) GetInternalDb() *leveldb.DB
func (*SignerStore) Has ¶
func (s *SignerStore) Has(key string) (ok bool)
Has check whether the given key exist in key value store
func (*SignerStore) List ¶
func (s *SignerStore) List() []TxOutStoreItem
List send back tx out to retry depending on arg failed only
func (*SignerStore) OrderedLists ¶
func (s *SignerStore) OrderedLists() map[string][]TxOutStoreItem
OrderedLists
func (*SignerStore) Remove ¶
func (s *SignerStore) Remove(item TxOutStoreItem) error
Remove remove the given item from key values store
func (*SignerStore) Set ¶
func (s *SignerStore) Set(item TxOutStoreItem) error
type ThorchainBlockScan ¶
type ThorchainBlockScan struct {
// contains filtered or unexported fields
}
func NewThorchainBlockScan ¶
func NewThorchainBlockScan(cfg config.BifrostBlockScannerConfiguration, scanStorage blockscanner.ScannerStorage, thorchain thorclient.ThorchainBridge, m *metrics.Metrics, pubkeyMgr pubkeymanager.PubKeyValidator) (*ThorchainBlockScan, error)
NewThorchainBlockScan create a new instance of thorchain block scanner
func (*ThorchainBlockScan) FetchMemPool ¶ added in v0.41.0
func (c *ThorchainBlockScan) FetchMemPool(height int64) (types.TxIn, error)
func (*ThorchainBlockScan) FetchTxs ¶
func (b *ThorchainBlockScan) FetchTxs(height, _ int64) (types.TxIn, error)
func (*ThorchainBlockScan) GetHeight ¶
func (b *ThorchainBlockScan) GetHeight() (int64, error)
func (*ThorchainBlockScan) GetKeygenMessages ¶
func (b *ThorchainBlockScan) GetKeygenMessages() <-chan ttypes.KeygenBlock
func (*ThorchainBlockScan) GetTxOutMessages ¶
func (b *ThorchainBlockScan) GetTxOutMessages() <-chan types.TxOut
GetMessages return the channel
type TxOutStoreItem ¶
type TxOutStoreItem struct {
TxOutItem types.TxOutItem
Status TxStatus
Height int64
Index int64
Round7Retry bool
Checkpoint []byte
SignedTx []byte
RetrievalKey string `json:"-"`
}
func NewTxOutStoreItem ¶
func NewTxOutStoreItem(height int64, item types.TxOutItem, idx int64) TxOutStoreItem
func (*TxOutStoreItem) Key ¶
func (s *TxOutStoreItem) Key() string
Source Files
Click to show internal directories.
Click to hide internal directories.