Documentation ¶
Index ¶
- Constants
- Variables
- func ParseMessage(msg []byte) (uint64, []byte, bool)
- func PrefixMessage(prefix, msg []byte) []byte
- func ProtocolPrefix(handlerID uint64) []byte
- type AppResponseCallback
- type Client
- func (c *Client) AppGossip(ctx context.Context, config common.SendConfig, appGossipBytes []byte) error
- func (c *Client) AppRequest(ctx context.Context, nodeIDs set.Set[ids.NodeID], appRequestBytes []byte, ...) error
- func (c *Client) AppRequestAny(ctx context.Context, appRequestBytes []byte, onResponse AppResponseCallback) error
- type ClientOption
- type Handler
- type Network
- func (n *Network) AddHandler(handlerID uint64, handler Handler) error
- func (n *Network) AppGossip(ctx context.Context, nodeID ids.NodeID, msg []byte) error
- func (n *Network) AppRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error
- func (n *Network) AppRequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error
- func (n *Network) AppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error
- func (n *Network) Connected(_ context.Context, nodeID ids.NodeID, _ *version.Application) error
- func (n *Network) Disconnected(_ context.Context, nodeID ids.NodeID) error
- func (n *Network) NewClient(handlerID uint64, options ...ClientOption) *Client
- type NoOpHandler
- type NodeSampler
- type PeerTracker
- func (p *PeerTracker) Connected(nodeID ids.NodeID, nodeVersion *version.Application)
- func (p *PeerTracker) Disconnected(nodeID ids.NodeID)
- func (p *PeerTracker) RegisterFailure(nodeID ids.NodeID)
- func (p *PeerTracker) RegisterRequest(nodeID ids.NodeID)
- func (p *PeerTracker) RegisterResponse(nodeID ids.NodeID, bandwidth float64)
- func (p *PeerTracker) SelectPeer() (ids.NodeID, bool)
- func (p *PeerTracker) Size() int
- type Peers
- type SlidingWindowThrottler
- type TestHandler
- type Throttler
- type ThrottlerHandler
- type ValidatorHandler
- type ValidatorSet
- type ValidatorSubset
- type Validators
Constants ¶
const ( TxGossipHandlerID = iota AtomicTxGossipHandlerID // SignatureRequestHandlerID is specified in ACP-118: https://github.com/avalanche-foundation/ACPs/tree/main/ACPs/118-warp-signature-request SignatureRequestHandlerID )
Standardized identifiers for application protocol handlers
Variables ¶
var ( ErrRequestPending = errors.New("request pending") ErrNoPeers = errors.New("no peers") )
var ( // ErrUnexpected should be used to indicate that a request failed due to a // generic error ErrUnexpected = &common.AppError{ Code: -1, Message: "unexpected error", } // ErrUnregisteredHandler should be used to indicate that a request failed // due to it not matching a registered handler ErrUnregisteredHandler = &common.AppError{ Code: -2, Message: "unregistered handler", } // ErrNotValidator should be used to indicate that a request failed due to // the requesting peer not being a validator ErrNotValidator = &common.AppError{ Code: -3, Message: "not a validator", } // ErrThrottled should be used to indicate that a request failed due to the // requesting peer exceeding a rate limit ErrThrottled = &common.AppError{ Code: -4, Message: "throttled", } )
var ( ErrExistingAppProtocol = errors.New("existing app protocol") ErrUnrequestedResponse = errors.New("unrequested response") )
Functions ¶
func ParseMessage ¶
Parse a gossip or request message.
Returns: - The protocol ID. - The unprefixed protocol message. - A boolean indicating that parsing succeeded.
func PrefixMessage ¶
PrefixMessage prefixes the original message with the protocol identifier.
Only gossip and request messages need to be prefixed. Response messages don't need to be prefixed because request ids are tracked which map to the expected response handler.
func ProtocolPrefix ¶
Types ¶
type AppResponseCallback ¶
type AppResponseCallback func( ctx context.Context, nodeID ids.NodeID, responseBytes []byte, err error, )
AppResponseCallback is called upon receiving an AppResponse for an AppRequest issued by Client. Callers should check [err] to see whether the AppRequest failed or not.
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) AppGossip ¶
func (c *Client) AppGossip( ctx context.Context, config common.SendConfig, appGossipBytes []byte, ) error
AppGossip sends a gossip message to a random set of peers.
func (*Client) AppRequest ¶
func (c *Client) AppRequest( ctx context.Context, nodeIDs set.Set[ids.NodeID], appRequestBytes []byte, onResponse AppResponseCallback, ) error
AppRequest issues an arbitrary request to a node. [onResponse] is invoked upon an error or a response.
func (*Client) AppRequestAny ¶
func (c *Client) AppRequestAny( ctx context.Context, appRequestBytes []byte, onResponse AppResponseCallback, ) error
AppRequestAny issues an AppRequest to an arbitrary node decided by Client. If a specific node needs to be requested, use AppRequest instead. See AppRequest for more docs.
type ClientOption ¶
type ClientOption interface {
// contains filtered or unexported methods
}
ClientOption configures Client
func WithValidatorSampling ¶
func WithValidatorSampling(validators *Validators) ClientOption
WithValidatorSampling configures Client.AppRequestAny to sample validators
type Handler ¶
type Handler interface { // AppGossip is called when handling an AppGossip message. AppGossip( ctx context.Context, nodeID ids.NodeID, gossipBytes []byte, ) // AppRequest is called when handling an AppRequest message. // Sends a response with the response corresponding to [requestBytes] or // an application-defined error. AppRequest( ctx context.Context, nodeID ids.NodeID, deadline time.Time, requestBytes []byte, ) ([]byte, *common.AppError) }
Handler is the server-side logic for virtual machine application protocols.
type Network ¶
type Network struct { Peers *Peers // contains filtered or unexported fields }
Network exposes networking state and supports building p2p application protocols
func NewNetwork ¶
func NewNetwork( log logging.Logger, sender common.AppSender, registerer prometheus.Registerer, namespace string, ) (*Network, error)
NewNetwork returns an instance of Network
func (*Network) AddHandler ¶
AddHandler reserves an identifier for an application protocol
func (*Network) AppRequest ¶
func (*Network) AppRequestFailed ¶
func (*Network) AppResponse ¶
func (*Network) Disconnected ¶
type NodeSampler ¶
type NodeSampler interface { // Sample returns at most [limit] nodes. This may return fewer nodes if // fewer than [limit] are available. Sample(ctx context.Context, limit int) []ids.NodeID }
NodeSampler samples nodes in network
type PeerTracker ¶
type PeerTracker struct {
// contains filtered or unexported fields
}
Tracks the bandwidth of responses coming from peers, preferring to contact peers with known good bandwidth, connecting to new peers with an exponentially decaying probability.
func NewPeerTracker ¶
func NewPeerTracker( log logging.Logger, metricsNamespace string, registerer prometheus.Registerer, ignoredNodes set.Set[ids.NodeID], minVersion *version.Application, ) (*PeerTracker, error)
func (*PeerTracker) Connected ¶
func (p *PeerTracker) Connected(nodeID ids.NodeID, nodeVersion *version.Application)
Connected should be called when [nodeID] connects to this node.
func (*PeerTracker) Disconnected ¶
func (p *PeerTracker) Disconnected(nodeID ids.NodeID)
Disconnected should be called when [nodeID] disconnects from this node.
func (*PeerTracker) RegisterFailure ¶
func (p *PeerTracker) RegisterFailure(nodeID ids.NodeID)
Record that a request failed to [nodeID].
Adds the peer's bandwidth averager to the bandwidth heap.
func (*PeerTracker) RegisterRequest ¶
func (p *PeerTracker) RegisterRequest(nodeID ids.NodeID)
Record that we sent a request to [nodeID].
Removes the peer's bandwidth averager from the bandwidth heap.
func (*PeerTracker) RegisterResponse ¶
func (p *PeerTracker) RegisterResponse(nodeID ids.NodeID, bandwidth float64)
Record that we observed that [nodeID]'s bandwidth is [bandwidth].
Adds the peer's bandwidth averager to the bandwidth heap.
func (*PeerTracker) SelectPeer ¶
func (p *PeerTracker) SelectPeer() (ids.NodeID, bool)
SelectPeer that we could send a request to.
If we should track more peers, returns a random untracked peer, if any exist. Otherwise, with probability [randomPeerProbability] returns a random peer from [p.responsivePeers]. With probability [1-randomPeerProbability] returns the peer in [p.bandwidthHeap] with the highest bandwidth.
Returns false if there are no connected peers.
func (*PeerTracker) Size ¶
func (p *PeerTracker) Size() int
Returns the number of peers the node is connected to.
type Peers ¶
type Peers struct {
// contains filtered or unexported fields
}
Peers contains metadata about the current set of connected peers
type SlidingWindowThrottler ¶
type SlidingWindowThrottler struct {
// contains filtered or unexported fields
}
SlidingWindowThrottler is an implementation of the sliding window throttling algorithm.
func NewSlidingWindowThrottler ¶
func NewSlidingWindowThrottler(period time.Duration, limit int) *SlidingWindowThrottler
NewSlidingWindowThrottler returns a new instance of SlidingWindowThrottler. Nodes are throttled if they exceed [limit] messages during an interval of time over [period]. [period] and [limit] should both be > 0.
func (*SlidingWindowThrottler) Handle ¶
func (s *SlidingWindowThrottler) Handle(nodeID ids.NodeID) bool
Handle returns true if the amount of calls received in the last [s.period] time is less than [s.limit]
This is calculated by adding the current period's count to a weighted count of the previous period.
type TestHandler ¶
type TestHandler struct { AppGossipF func(ctx context.Context, nodeID ids.NodeID, gossipBytes []byte) AppRequestF func(ctx context.Context, nodeID ids.NodeID, deadline time.Time, requestBytes []byte) ([]byte, *common.AppError) }
type ThrottlerHandler ¶
type ThrottlerHandler struct {
// contains filtered or unexported fields
}
func NewThrottlerHandler ¶
func NewThrottlerHandler(handler Handler, throttler Throttler, log logging.Logger) *ThrottlerHandler
type ValidatorHandler ¶
type ValidatorHandler struct {
// contains filtered or unexported fields
}
ValidatorHandler drops messages from non-validators
func NewValidatorHandler ¶
func NewValidatorHandler( handler Handler, validatorSet ValidatorSet, log logging.Logger, ) *ValidatorHandler
type ValidatorSet ¶
type ValidatorSubset ¶
type Validators ¶
type Validators struct {
// contains filtered or unexported fields
}
Validators contains a set of nodes that are staking.
func NewValidators ¶
func NewValidators( peers *Peers, log logging.Logger, subnetID ids.ID, validators validators.State, maxValidatorSetStaleness time.Duration, ) *Validators