handlers

Documentation

Index

• type NoopSignatureRequestHandler
  • func (s *NoopSignatureRequestHandler) OnBlockSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) ([]byte, error)
  • func (s *NoopSignatureRequestHandler) OnMessageSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) ([]byte, error)
• type SignatureRequestHandler
  • func NewSignatureRequestHandler(backend warp.Backend, codec codec.Manager) *SignatureRequestHandler
  • func (s *SignatureRequestHandler) OnBlockSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) ([]byte, error)
  • func (s *SignatureRequestHandler) OnMessageSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) ([]byte, error)

Types

type NoopSignatureRequestHandler

type NoopSignatureRequestHandler struct{}

func (*NoopSignatureRequestHandler) OnBlockSignatureRequest

func (s *NoopSignatureRequestHandler) OnBlockSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, signatureRequest message.BlockSignatureRequest) ([]byte, error)

func (*NoopSignatureRequestHandler) OnMessageSignatureRequest

func (s *NoopSignatureRequestHandler) OnMessageSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, signatureRequest message.MessageSignatureRequest) ([]byte, error)

type SignatureRequestHandler

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

SignatureRequestHandler serves warp signature requests. It is a peer.RequestHandler for message.MessageSignatureRequest. TODO: After Etna, this handler can be removed and SignatureRequestHandlerP2P is sufficient.

func NewSignatureRequestHandler

func NewSignatureRequestHandler(backend warp.Backend, codec codec.Manager) *SignatureRequestHandler

func (*SignatureRequestHandler) OnBlockSignatureRequest

func (s *SignatureRequestHandler) OnBlockSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, request message.BlockSignatureRequest) ([]byte, error)

func (*SignatureRequestHandler) OnMessageSignatureRequest

func (s *SignatureRequestHandler) OnMessageSignatureRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, signatureRequest message.MessageSignatureRequest) ([]byte, error)

OnMessageSignatureRequest handles message.MessageSignatureRequest, and retrieves a warp signature for the requested message ID. Never returns an error Expects returned errors to be treated as FATAL Returns empty response if signature is not found Assumes ctx is active