tss

Apr 27, 2022

Changes in this version

type Mgr

+ Keys map[string][][]byte

+ func (mgr *Mgr) RefreshKeys(ctx context.Context) error

Nov 12, 2021

Changes in this version

+ func Connect(host string, port string, timeout time.Duration, logger log.Logger) (*grpc.ClientConn, error)

+ type LockableStream struct

+ func NewLockableStream(stream Stream) *LockableStream

+ func (l *LockableStream) CloseSend() error

+ func (l *LockableStream) Recv() (*tofnd.MessageOut, error)

+ func (l *LockableStream) Send(in *tofnd.MessageIn) error

+ type Mgr struct

+ Logger log.Logger

+ Timeout time.Duration

+ func NewMgr(client rpc.Client, multiSigClient rpc.MultiSigClient, cliCtx sdkClient.Context, ...) *Mgr

+ func (mgr *Mgr) ProcessHeartBeatEvent(e tmEvents.Event) error

+ func (mgr *Mgr) ProcessKeygenMsg(e tmEvents.Event) error

+ func (mgr *Mgr) ProcessKeygenStart(e tmEvents.Event) error

+ func (mgr *Mgr) ProcessNewBlockHeader(blockHeight int64)

+ func (mgr *Mgr) ProcessSignMsg(e tmEvents.Event) error

+ func (mgr *Mgr) ProcessSignStart(e tmEvents.Event) error

+ func (mgr *Mgr) Recover(recoverJSON []byte) error

+ type Session struct

+ ID string

+ TimeoutAt int64

+ func (s *Session) Timeout()

+ func (s *Session) WaitForTimeout()

+ type Stream interface

+ CloseSend func() error

+ Recv func() (*tofnd.MessageOut, error)

+ Send func(in *tofnd.MessageIn) error

+ type TimeoutQueue struct

+ func NewTimeoutQueue() *TimeoutQueue

+ func (q *TimeoutQueue) Dequeue() *Session

+ func (q *TimeoutQueue) Enqueue(ID string, timeoutAt int64) *Session

+ func (q *TimeoutQueue) Top() *Session