signer

Documentation

Index

• Constants
• type ConstantsProvider
  • func NewConstantsProvider(bridge digitalclient.DigitaldollarBridge) *ConstantsProvider
  • func (cp *ConstantsProvider) EnsureConstants(digitaldollarBlockHeight int64) error
  • func (cp *ConstantsProvider) GetInt64Value(digitaldollarBlockHeight int64, key constants.ConstantName) (int64, error)
• type DigitaldollarBlockScan
  • func NewDigitaldollarBlockScan(cfg config.BifrostBlockScannerConfiguration, ...) (*DigitaldollarBlockScan, error)
  • func (c *DigitaldollarBlockScan) FetchMemPool(height int64) (types.TxIn, error)
  • func (b *DigitaldollarBlockScan) FetchTxs(height, _ int64) (types.TxIn, error)
  • func (b *DigitaldollarBlockScan) GetHeight() (int64, error)
  • func (b *DigitaldollarBlockScan) GetKeygenMessages() <-chan ttypes.KeygenBlock
  • func (b *DigitaldollarBlockScan) GetTxOutMessages() <-chan types.TxOut
• 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(key 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 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 digitaldollar to get the constants value per request it will also cache the constant values internally

func NewConstantsProvider

func NewConstantsProvider(bridge digitalclient.DigitaldollarBridge) *ConstantsProvider

NewConstantsProvider create a new instance of ConstantsProvider

func (*ConstantsProvider) EnsureConstants

func (cp *ConstantsProvider) EnsureConstants(digitaldollarBlockHeight int64) error

func (*ConstantsProvider) GetInt64Value

func (cp *ConstantsProvider) GetInt64Value(digitaldollarBlockHeight int64, key constants.ConstantName) (int64, error)

GetInt64Value get the constant value that match the given key

type DigitaldollarBlockScan

type DigitaldollarBlockScan struct {
	// contains filtered or unexported fields
}

func NewDigitaldollarBlockScan

func NewDigitaldollarBlockScan(cfg config.BifrostBlockScannerConfiguration, scanStorage blockscanner.ScannerStorage, digitaldollar digitalclient.DigitaldollarBridge, m *metrics.Metrics, pubkeyMgr pubkeymanager.PubKeyValidator) (*DigitaldollarBlockScan, error)

NewDigitaldollarBlockScan create a new instance of digitaldollar block scanner

func (*DigitaldollarBlockScan) FetchMemPool

func (c *DigitaldollarBlockScan) FetchMemPool(height int64) (types.TxIn, error)

func (*DigitaldollarBlockScan) FetchTxs

func (b *DigitaldollarBlockScan) FetchTxs(height, _ int64) (types.TxIn, error)

func (*DigitaldollarBlockScan) GetHeight

func (b *DigitaldollarBlockScan) GetHeight() (int64, error)

func (*DigitaldollarBlockScan) GetKeygenMessages

func (b *DigitaldollarBlockScan) GetKeygenMessages() <-chan ttypes.KeygenBlock

func (*DigitaldollarBlockScan) GetTxOutMessages

func (b *DigitaldollarBlockScan) GetTxOutMessages() <-chan types.TxOut

GetMessages return the channel

type Signer

type Signer struct {
	// contains filtered or unexported fields
}

Signer will pull the tx out from digitaldollar and then forward it to chain

func NewSigner

func NewSigner(cfg config.BifrostSignerConfiguration,
	digitaldollarBridge digitalclient.DigitaldollarBridge,
	thorKeys *digitalclient.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(key 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 TxOutStoreItem

type TxOutStoreItem struct {
	TxOutItem   types.TxOutItem
	Status      TxStatus
	Height      int64
	Index       int64
	Round7Retry bool
	Checkpoint  []byte
	SignedTx    []byte
}

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
)