threshold

Dec 17, 2025

Changes in this version

+ var ErrAlreadyComplete = errors.New("threshold: operation already complete")

+ var ErrDataTooLong = errors.New("threshold: data too long")

+ var ErrDataTooShort = errors.New("threshold: data too short")

+ var ErrDuplicateKeyShare = errors.New("threshold: duplicate key share index")

+ var ErrDuplicateSignatureShare = errors.New("threshold: duplicate signature share index")

+ var ErrInsufficientShares = errors.New("threshold: insufficient shares for threshold")

+ var ErrInvalidConfig = errors.New("threshold: invalid configuration")

+ var ErrInvalidEncoding = errors.New("threshold: invalid encoding")

+ var ErrInvalidKeyShare = errors.New("threshold: invalid key share")

+ var ErrInvalidMessage = errors.New("threshold: invalid protocol message")

+ var ErrInvalidNonce = errors.New("threshold: invalid nonce")

+ var ErrInvalidPartyCount = errors.New("threshold: invalid party count")

+ var ErrInvalidPartyIndex = errors.New("threshold: party index out of range")

+ var ErrInvalidPublicKey = errors.New("threshold: invalid public key")

+ var ErrInvalidRound = errors.New("threshold: invalid protocol round")

+ var ErrInvalidSignature = errors.New("threshold: invalid signature")

+ var ErrInvalidSignatureShare = errors.New("threshold: invalid signature share")

+ var ErrInvalidState = errors.New("threshold: invalid state for operation")

+ var ErrInvalidThreshold = errors.New("threshold: invalid threshold value")

+ var ErrKeyShareCorrupted = errors.New("threshold: key share data corrupted")

+ var ErrKeyShareMismatch = errors.New("threshold: key share does not match group key")

+ var ErrMessageFromSelf = errors.New("threshold: cannot process own message")

+ var ErrMessageFromWrongParty = errors.New("threshold: message from unexpected party")

+ var ErrMissingMessage = errors.New("threshold: missing message from party")

+ var ErrNonceCommitmentMismatch = errors.New("threshold: nonce commitment mismatch")

+ var ErrNonceMissing = errors.New("threshold: nonce state required")

+ var ErrNonceReused = errors.New("threshold: nonce already used")

+ var ErrNotInitialized = errors.New("threshold: not initialized")

+ var ErrProtocolAborted = errors.New("threshold: protocol aborted")

+ var ErrSchemeNotFound = errors.New("threshold: scheme not registered")

+ var ErrSchemeNotSupported = errors.New("threshold: operation not supported by scheme")

+ var ErrSignatureShareMismatch = errors.New("threshold: signature share does not match")

+ var ErrSignatureVerificationFailed = errors.New("threshold: signature verification failed")

+ var ErrThresholdTooHigh = errors.New("threshold: threshold must be less than total parties")

+ var ErrVersionMismatch = errors.New("threshold: version mismatch")

+ func GetAbortingParty(err error) int

+ func HasScheme(id SchemeID) bool

+ func IsIdentifiableAbort(err error) bool

+ func RegisterScheme(scheme Scheme)

+ type Aggregator interface

+ Aggregate func(ctx context.Context, message []byte, shares []SignatureShare, ...) (Signature, error)

+ GroupKey func() PublicKey

+ VerifyShare func(message []byte, share SignatureShare, publicShare []byte) error

+ type DKG interface

+ GroupKey func() PublicKey

+ NumRounds func() int

+ Round1 func(ctx context.Context) (DKGMessage, error)

+ Round2 func(ctx context.Context, round1Messages map[int]DKGMessage) (DKGMessage, error)

+ Round3 func(ctx context.Context, round2Messages map[int]DKGMessage) (KeyShare, error)

+ type DKGConfig struct

+ PartyID []byte

+ PartyIndex int

+ Rand io.Reader

+ Threshold int

+ TotalParties int

+ func (c DKGConfig) Validate() error

+ type DKGMessage interface

+ Bytes func() []byte

+ FromParty func() int

+ Round func() int

+ type DealerConfig struct

+ Rand io.Reader

+ Threshold int

+ TotalParties int

+ func (c DealerConfig) Validate() error

+ type IdentifiableAbortError struct

+ PartyIndex int

+ Proof []byte

+ Reason string

+ Round int

+ func (e *IdentifiableAbortError) Error() string

+ type KeyRefresh interface

+ Round1 func(ctx context.Context) (DKGMessage, error)

+ Round2 func(ctx context.Context, round1Messages map[int]DKGMessage) (KeyShare, error)

+ type KeyShare interface

+ Bytes func() []byte

+ GroupKey func() PublicKey

+ Index func() int

+ PublicShare func() []byte

+ SchemeID func() SchemeID

+ Threshold func() int

+ TotalParties func() int

+ type NonceCommitment interface

+ Bytes func() []byte

+ FromParty func() int

+ type NonceState interface

+ Bytes func() []byte

+ FromParty func() int

+ type PublicKey interface

+ Bytes func() []byte

+ Equal func(other PublicKey) bool

+ SchemeID func() SchemeID

+ type QuickSign struct

+ func NewQuickSign(schemeID SchemeID, groupKey PublicKey, threshold int) (*QuickSign, error)

+ func (q *QuickSign) GroupKey() PublicKey

+ func (q *QuickSign) SignAndAggregate(ctx context.Context, message []byte, signers []Signer) (Signature, error)

+ func (q *QuickSign) Threshold() int

+ func (q *QuickSign) Verify(message []byte, signature Signature) bool

+ type Resharing interface

+ GenerateReshareMessages func(ctx context.Context, newThreshold, newTotal int) ([]DKGMessage, error)

+ ProcessReshareMessages func(ctx context.Context, messages []DKGMessage) (KeyShare, error)

+ type Scheme interface

+ ID func() SchemeID

+ KeyShareSize func() int

+ Name func() string

+ NewAggregator func(groupKey PublicKey) (Aggregator, error)

+ NewDKG func(config DKGConfig) (DKG, error)

+ NewSigner func(share KeyShare) (Signer, error)

+ NewTrustedDealer func(config DealerConfig) (TrustedDealer, error)

+ NewVerifier func(groupKey PublicKey) (Verifier, error)

+ ParseKeyShare func(data []byte) (KeyShare, error)

+ ParsePublicKey func(data []byte) (PublicKey, error)

+ ParseSignature func(data []byte) (Signature, error)

+ ParseSignatureShare func(data []byte) (SignatureShare, error)

+ PublicKeySize func() int

+ SignatureShareSize func() int

+ SignatureSize func() int

+ func GetScheme(id SchemeID) (Scheme, error)

+ func MustGetScheme(id SchemeID) Scheme

+ type SchemeAdapter struct

+ func NewAdapter(share KeyShare) (*SchemeAdapter, error)

+ func (a *SchemeAdapter) Aggregate(ctx context.Context, message []byte, shares []SignatureShare) (Signature, error)

+ func (a *SchemeAdapter) GroupKey() PublicKey

+ func (a *SchemeAdapter) Index() int

+ func (a *SchemeAdapter) PublicShare() []byte

+ func (a *SchemeAdapter) SchemeID() SchemeID

+ func (a *SchemeAdapter) SignShare(ctx context.Context, message []byte, signers []int) (SignatureShare, error)

+ func (a *SchemeAdapter) Threshold() int

+ func (a *SchemeAdapter) Verify(message []byte, signature Signature) bool

+ func (a *SchemeAdapter) VerifyBytes(message, signature []byte) bool

+ func (a *SchemeAdapter) VerifyShare(message []byte, share SignatureShare, publicShare []byte) error

+ type SchemeID uint8

+ const SchemeBLS

+ const SchemeCMP

+ const SchemeFROST

+ const SchemeRingtail

+ const SchemeUnknown

+ func ListSchemes() []SchemeID

+ func (s SchemeID) IsPostQuantum() bool

+ func (s SchemeID) String() string

+ func (s SchemeID) SupportsNonInteractive() bool

+ type SchemeInfo struct

+ DKGRounds int

+ Description string

+ ID SchemeID

+ KeyShareSize int

+ Name string

+ NonInteractive bool

+ PostQuantum bool

+ SignatureSize int

+ SigningRounds int

+ func AllSchemeInfo() []*SchemeInfo

+ func GetSchemeInfo(id SchemeID) (*SchemeInfo, error)

+ type SessionManager struct

+ func NewSessionManager() *SessionManager

+ func (m *SessionManager) CleanupExpired(ctx context.Context) int

+ func (m *SessionManager) CreateSession(id string, scheme SchemeID, message []byte, groupKey PublicKey, threshold int, ...) (*SigningSession, error)

+ func (m *SessionManager) DeleteSession(id string)

+ func (m *SessionManager) GetSession(id string) (*SigningSession, error)

+ func (m *SessionManager) ListSessions() []string

+ type SessionState uint8

+ const SessionStateAggregating

+ const SessionStateComplete

+ const SessionStateFailed

+ const SessionStateNew

+ const SessionStateNonceGeneration

+ const SessionStateSigning

+ func (s SessionState) String() string

+ type ShareError struct

+ Err error

+ Index int

+ func (e *ShareError) Error() string

+ func (e *ShareError) Unwrap() error

+ type Signature interface

+ Bytes func() []byte

+ SchemeID func() SchemeID

+ type SignatureShare interface

+ Bytes func() []byte

+ Index func() int

+ SchemeID func() SchemeID

+ type Signer interface

+ Index func() int

+ KeyShare func() KeyShare

+ NonceGen func(ctx context.Context) (NonceCommitment, NonceState, error)

+ PublicShare func() []byte

+ SignShare func(ctx context.Context, message []byte, signers []int, nonce NonceState) (SignatureShare, error)

+ type SigningSession struct

+ Commitments map[int]NonceCommitment

+ CreatedAt time.Time

+ Error error

+ GroupKey PublicKey

+ ID string

+ Message []byte

+ Participants []int

+ PublicShares map[int][]byte

+ Result Signature

+ SchemeID SchemeID

+ Shares map[int]SignatureShare

+ State SessionState

+ Threshold int

+ Timeout time.Duration

+ UpdatedAt time.Time

+ func NewSigningSession(id string, scheme SchemeID, message []byte, groupKey PublicKey, threshold int, ...) *SigningSession

+ func (s *SigningSession) AddCommitment(index int, commitment NonceCommitment) error

+ func (s *SigningSession) AddParticipant(index int, publicShare []byte) error

+ func (s *SigningSession) AddShare(index int, share SignatureShare) error

+ func (s *SigningSession) Complete(signature Signature)

+ func (s *SigningSession) Fail(err error)

+ func (s *SigningSession) GetCommitments() []NonceCommitment

+ func (s *SigningSession) GetShares() []SignatureShare

+ func (s *SigningSession) HasEnoughCommitments() bool

+ func (s *SigningSession) HasEnoughShares() bool

+ func (s *SigningSession) IsExpired() bool

+ type TrustedDealer interface

+ GenerateShares func(ctx context.Context) ([]KeyShare, PublicKey, error)

+ type Verifier interface

+ GroupKey func() PublicKey

+ Verify func(message []byte, signature Signature) bool

+ VerifyBytes func(message, signature []byte) bool