acp118

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, *common.AppError)
• type SignatureAggregator
  • func NewSignatureAggregator(log logging.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, finished bool, ...)
• type Verifier

Constants

const HandlerID = p2p.SignatureRequestHandlerID

Types

type Handler

type Handler struct {
	p2p.NoOpHandler
	// contains filtered or unexported fields
}

Handler signs warp messages

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, *common.AppError)

type SignatureAggregator

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

SignatureAggregator aggregates validator signatures for warp messages

func NewSignatureAggregator

func NewSignatureAggregator(log logging.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,
	finished bool,
	_ 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(
		ctx context.Context,
		message *warp.UnsignedMessage,
		justification []byte,
	) *common.AppError
}

Verifier verifies that a warp message should be signed