signer

Documentation

Index

• Constants
• type ConstantsProvider
  • 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
  • func NewSigner(cfg config.BifrostSignerConfiguration, ...) (*Signer, error)
  • func (s *Signer) Start() error
  • func (s *Signer) Stop() error
• type SignerStorage
• type SignerStore
  • 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
  • func NewThorchainBlockScan(cfg config.BifrostBlockScannerConfiguration, ...) (*ThorchainBlockScan, error)
  • 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
  • func NewTxOutStoreItem(height int64, item types.TxOutItem, idx int64) TxOutStoreItem
  • func (s *TxOutStoreItem) Key() string
• type TxStatus

Constants

const (
	DefaultSignerLevelDBFolder = "signer_data"
)

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

func (*Signer) Start

func (s *Signer) Start() error

Start signer process

func (*Signer) Stop

func (s *Signer) Stop() error

Stop the signer process

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

func (s *SignerStore) Close() error

Close underlying db

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

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

type TxStatus

type TxStatus int

const (
	TxUnknown TxStatus = iota
	TxAvailable
	TxUnavailable
	TxSpent
)