signer

Documentation

Index

• Variables
• func DialL2EthClientWithTimeout(ctx context.Context, url string, disableHTTP2 bool) (*ethclient.Client, error)
• type Metrics
  • func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics
• type Processor
  • func NewProcessor(cfg common.Configuration, contx context.Context, tssInstance tsslib.Server, ...) (*Processor, error)
  • func (p *Processor) CacheSign(key string, value []byte) bool
  • func (p *Processor) CacheVerify(key string, value bool) bool
  • func (p *Processor) EstimateGas(ctx context.Context, tx *etht.Transaction, rawContract *bind.BoundContract, ...) (*etht.Transaction, error)
  • func (p *Processor) GetSign(key string) ([]byte, bool)
  • func (p *Processor) GetVerify(key string) (bool, bool)
  • func (p *Processor) Keygen()
  • func (p *Processor) ObserveTssGroup()
  • func (p *Processor) ProcessMessage()
  • func (p *Processor) RetryTransaction(tx *etht.Transaction, rawContract *bind.BoundContract) (*etht.Transaction, error)
  • func (p *Processor) Sign()
  • func (p *Processor) SignGo(resId tdtypes.JSONRPCStringID, sign tsscommon.NodeSignRequest, ...) error
  • func (p *Processor) SignRollBack()
  • func (p *Processor) SignSlash()
  • func (p *Processor) Start()
  • func (p *Processor) Stop()
  • func (p *Processor) UpdateWaitSignEvents(uniqueId string, msg common.SignStateRequest)
  • func (p *Processor) UpdateWaitSignSlashMsgs(msg common.SlashRequest)
  • func (p *Processor) Verify()
  • func (p *Processor) VerifyRollBack()
  • func (p *Processor) VerifySlash()

Variables

var (
	FallbackGasTipCap = big.NewInt(1500000000)
)

Functions

func DialL2EthClientWithTimeout

func DialL2EthClientWithTimeout(ctx context.Context, url string, disableHTTP2 bool) (
	*ethclient.Client, error)

DialL2EthClientWithTimeout attempts to dial the L2 provider using the provided URL. If the dial doesn't complete within dial.DefaultTimeout seconds, this method will return an error.

Types

type Metrics

type Metrics struct {
	AskChannelCount  metrics.Gauge
	SignChannelCount metrics.Gauge
}

Metrics contains metrics exposed by this package.

func PrometheusMetrics

func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics

type Processor

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

func NewProcessor

func NewProcessor(cfg common.Configuration, contx context.Context, tssInstance tsslib.Server, privKey *ecdsa.PrivateKey, pubkeyByte []byte, pubKeyHex string, nodeStore types.NodeStore, address ethc.Address) (*Processor, error)

func (*Processor) CacheSign

func (p *Processor) CacheSign(key string, value []byte) bool

func (*Processor) CacheVerify

func (p *Processor) CacheVerify(key string, value bool) bool

func (*Processor) EstimateGas

func (p *Processor) EstimateGas(ctx context.Context, tx *etht.Transaction, rawContract *bind.BoundContract, address ethc.Address) (*etht.Transaction, error)

func (*Processor) GetSign

func (p *Processor) GetSign(key string) ([]byte, bool)

func (*Processor) GetVerify

func (p *Processor) GetVerify(key string) (bool, bool)

func (*Processor) Keygen

func (p *Processor) Keygen()

func (*Processor) ObserveTssGroup

func (p *Processor) ObserveTssGroup()

func (*Processor) ProcessMessage

func (p *Processor) ProcessMessage()

func (*Processor) RetryTransaction

func (p *Processor) RetryTransaction(tx *etht.Transaction, rawContract *bind.BoundContract) (*etht.Transaction, error)

func (*Processor) Sign

func (p *Processor) Sign()

func (*Processor) SignGo

func (p *Processor) SignGo(resId tdtypes.JSONRPCStringID, sign tsscommon.NodeSignRequest, logger zerolog.Logger) error

func (*Processor) SignRollBack

func (p *Processor) SignRollBack()

func (*Processor) SignSlash

func (p *Processor) SignSlash()

func (*Processor) Start

func (p *Processor) Start()

func (*Processor) Stop

func (p *Processor) Stop()

func (*Processor) UpdateWaitSignEvents

func (p *Processor) UpdateWaitSignEvents(uniqueId string, msg common.SignStateRequest)

func (*Processor) UpdateWaitSignSlashMsgs

func (p *Processor) UpdateWaitSignSlashMsgs(msg common.SlashRequest)

func (*Processor) Verify

func (p *Processor) Verify()

func (*Processor) VerifyRollBack

func (p *Processor) VerifyRollBack()

func (*Processor) VerifySlash

func (p *Processor) VerifySlash()