The highest tagged major version is v2.

lp118

package

v0.1.1 Latest Latest Go to latest Published: Jul 30, 2025 License: BSD-3-Clause Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/luxfi/node

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Handler
- func NewCachedHandler(cacher cache.Cacher[ids.ID, []byte], verifier Verifier, signer warp.Signer) *Handler
- func NewHandler(verifier Verifier, signer warp.Signer) *Handler
- func (h *Handler) AppRequest(ctx context.Context, _ ids.NodeID, _ time.Time, requestBytes []byte) ([]byte, *core.AppError)
type SignatureAggregator
- func NewSignatureAggregator(log log.Logger, client *p2p.Client) *SignatureAggregator
- func (s *SignatureAggregator) AggregateSignatures(ctx context.Context, message *warp.Message, justification []byte, ...) (_ *warp.Message, aggregatedStake *big.Int, totalStake *big.Int, _ error)
type Verifier

Constants ¶

View Source

const HandlerID = p2p.SignatureRequestHandlerID

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

func NewCachedHandler ¶

func NewCachedHandler(
	cacher cache.Cacher[ids.ID, []byte],
	verifier Verifier,
	signer warp.Signer,
) *Handler

NewCachedHandler returns an instance of Handler that caches successful signatures.

func NewHandler ¶

func NewHandler(verifier Verifier, signer warp.Signer) *Handler

NewHandler returns an instance of Handler

func (*Handler) AppRequest ¶

func (h *Handler) AppRequest(
	ctx context.Context,
	_ ids.NodeID,
	_ time.Time,
	requestBytes []byte,
) ([]byte, *core.AppError)

type SignatureAggregator ¶

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

SignatureAggregator aggregates validator signatures for warp messages

func NewSignatureAggregator ¶

func NewSignatureAggregator(log log.Logger, client *p2p.Client) *SignatureAggregator

NewSignatureAggregator returns an instance of SignatureAggregator

func (*SignatureAggregator) AggregateSignatures ¶

func (s *SignatureAggregator) AggregateSignatures(
	ctx context.Context,
	message *warp.Message,
	justification []byte,
	validators []*warp.Validator,
	quorumNum uint64,
	quorumDen uint64,
) (
	_ *warp.Message,
	aggregatedStake *big.Int,
	totalStake *big.Int,
	_ error,
)

AggregateSignatures blocks until quorumNum/quorumDen signatures from validators are requested to be aggregated into a warp message or the context is canceled. Returns the signed message and the amount of stake that signed the message. Caller is responsible for providing a well-formed canonical validator set corresponding to the signer bitset in the message.

type Verifier ¶

type Verifier interface {
	// Verify verifies that the provided message is valid for this node to sign
	// based on the provided justification.
	//
	// Implementations of Verify are not expected to verify the NetworkID or
	// SourceChainID fields of the message. Verification of these fields should
	// be performed externally to Verify.
	Verify(
		ctx context.Context,
		message *warp.UnsignedMessage,
		justification []byte,
	) *core.AppError
}

Verifier verifies that a warp message should be signed

Source Files ¶

View all Source files

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