execution

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrUnknownSenderParty        = bnbutils.ErrUnknownSenderParty
	ErrDuplicateFrame            = bnbutils.ErrDuplicateFrame
	ErrFrameTooLarge             = bnbutils.ErrFrameTooLarge
	ErrQueueFull                 = bnbutils.ErrQueueFull
	ErrStalledProtocol           = bnbutils.ErrStalledProtocol
	ErrDerivationContextMismatch = corederivation.ErrDerivationContextMismatch
)

Functions

This section is empty.

Types

type Params

type Params struct {
	SessionID             string
	LocalPartyID          string
	CorrelationID         string
	Stage                 string
	Algorithm             string
	DerivationContextHash string
	Party                 tsslib.Party
	PartyIDs              map[string]*tsslib.PartyID
	OutCh                 <-chan tsslib.Message
	Logger                *slog.Logger
	Debug                 bool
	Config                tssbnbutils.RunnerConfig
	Metrics               bnbutils.Metrics

	DKGECDSAEndCh  <-chan ecdsakeygen.LocalPartySaveData
	SignECDSAEndCh <-chan *common.SignatureData
	DoneCh         <-chan struct{}
}

type ProtocolExecution

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

func New

func New(p Params) *ProtocolExecution

func (*ProtocolExecution) ECDSAKeyShare

func (e *ProtocolExecution) ECDSAKeyShare() *ecdsakeygen.LocalPartySaveData

func (*ProtocolExecution) Run

func (e *ProtocolExecution) Run(ctx context.Context, transport Transport) (err error)

func (*ProtocolExecution) Signature

func (e *ProtocolExecution) Signature() *common.SignatureData

func (*ProtocolExecution) Stats

func (e *ProtocolExecution) Stats() StatsSnapshot

type StatsSnapshot

type StatsSnapshot struct {
	FramesSent uint64
	FramesRecv uint64
	DedupDrops uint64
}

type Transport

type Transport interface {
	SendFrame(ctx context.Context, frame protocol.Frame) error
	RecvFrame(ctx context.Context) (protocol.Frame, error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL