p2p

Sep 3, 2024

Changes in this version

+ const AtomicTxGossipHandlerID

+ const SignatureRequestHandlerID

+ const TxGossipHandlerID

Jul 25, 2024

Changes in this version

+ var ErrUnexpected = &common.AppError

+ var ErrUnregisteredHandler = &common.AppError

Mar 21, 2024

Changes in this version

+ type ValidatorSubset interface

+ Top func(ctx context.Context, percentage float64) []ids.NodeID

type Validators

+ func (v *Validators) Top(ctx context.Context, percentage float64) []ids.NodeID

Feb 21, 2024

Changes in this version

type PeerTracker

+ 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)

Jan 29, 2024

Changes in this version

+ func ParseMessage(msg []byte) (uint64, []byte, bool)

+ func PrefixMessage(prefix, msg []byte) []byte

+ func ProtocolPrefix(handlerID uint64) []byte

Jan 18, 2024

Changes in this version

type Network

+ func (n *Network) AddHandler(handlerID uint64, handler Handler) error

+ func (n *Network) NewClient(handlerID uint64, options ...ClientOption) *Client

+ type TestHandler struct

+ AppGossipF func(ctx context.Context, nodeID ids.NodeID, gossipBytes []byte)

+ AppRequestF func(ctx context.Context, nodeID ids.NodeID, deadline time.Time, ...) ([]byte, error)

+ CrossChainAppRequestF func(ctx context.Context, chainID ids.ID, deadline time.Time, requestBytes []byte) ([]byte, error)

+ func (t TestHandler) AppGossip(ctx context.Context, nodeID ids.NodeID, gossipBytes []byte)

+ func (t TestHandler) AppRequest(ctx context.Context, nodeID ids.NodeID, deadline time.Time, ...) ([]byte, error)

+ func (t TestHandler) CrossChainAppRequest(ctx context.Context, chainID ids.ID, deadline time.Time, requestBytes []byte) ([]byte, error)

type ThrottlerHandler

+ func NewThrottlerHandler(handler Handler, throttler Throttler, log logging.Logger) *ThrottlerHandler

+ func (t ThrottlerHandler) CrossChainAppRequest(ctx context.Context, chainID ids.ID, deadline time.Time, requestBytes []byte) ([]byte, error)

type ValidatorHandler

+ func NewValidatorHandler(handler Handler, validatorSet ValidatorSet, log logging.Logger) *ValidatorHandler

+ func (v ValidatorHandler) CrossChainAppRequest(ctx context.Context, chainID ids.ID, deadline time.Time, requestBytes []byte) ([]byte, error)

Dec 2, 2023

Changes in this version

+ type ClientOption interface

+ func WithValidatorSampling(validators *Validators) ClientOption

+ type Network struct

+ Peers *Peers

+ func NewNetwork(log logging.Logger, sender common.AppSender, metrics prometheus.Registerer, ...) *Network

+ 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) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error

+ func (n *Network) CrossChainAppRequestFailed(ctx context.Context, chainID ids.ID, requestID uint32) error

+ func (n *Network) CrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error

+ func (n *Network) Disconnected(_ context.Context, nodeID ids.NodeID) error

+ func (n *Network) NewAppProtocol(handlerID uint64, handler Handler, options ...ClientOption) (*Client, error)

+ type PeerTracker struct

+ func NewPeerTracker(log logging.Logger, metricsNamespace string, registerer prometheus.Registerer) (*PeerTracker, error)

+ func (p *PeerTracker) Connected(nodeID ids.NodeID, nodeVersion *version.Application)

+ func (p *PeerTracker) Disconnected(nodeID ids.NodeID)

+ func (p *PeerTracker) GetAnyPeer(minVersion *version.Application) (ids.NodeID, bool)

+ func (p *PeerTracker) Size() int

+ func (p *PeerTracker) TrackBandwidth(nodeID ids.NodeID, bandwidth float64)

+ func (p *PeerTracker) TrackPeer(nodeID ids.NodeID)

Nov 23, 2023

Changes in this version

type ThrottlerHandler

+ Log logging.Logger

type ValidatorHandler

+ Log logging.Logger

Sep 19, 2023

Changes in this version

+ var ErrNotValidator = errors.New("not a validator")

+ var ErrThrottled = errors.New("throttled")

+ type SlidingWindowThrottler struct

+ func NewSlidingWindowThrottler(period time.Duration, limit int) *SlidingWindowThrottler

+ func (s *SlidingWindowThrottler) Handle(nodeID ids.NodeID) bool

+ type Throttler interface

+ Handle func(nodeID ids.NodeID) bool

+ type ThrottlerHandler struct

+ Throttler Throttler

+ func (t ThrottlerHandler) AppGossip(ctx context.Context, nodeID ids.NodeID, gossipBytes []byte) error

+ func (t ThrottlerHandler) AppRequest(ctx context.Context, nodeID ids.NodeID, deadline time.Time, ...) ([]byte, error)

+ type ValidatorHandler struct

+ ValidatorSet ValidatorSet

+ func (v ValidatorHandler) AppGossip(ctx context.Context, nodeID ids.NodeID, gossipBytes []byte) error

+ func (v ValidatorHandler) AppRequest(ctx context.Context, nodeID ids.NodeID, deadline time.Time, ...) ([]byte, error)

+ type ValidatorSet interface

+ Has func(ctx context.Context, nodeID ids.NodeID) bool

Aug 24, 2023

Changes in this version

+ type NoOpHandler struct

+ func (NoOpHandler) AppGossip(context.Context, ids.NodeID, []byte) error

+ func (NoOpHandler) AppRequest(context.Context, ids.NodeID, time.Time, []byte) ([]byte, error)

+ func (NoOpHandler) CrossChainAppRequest(context.Context, ids.ID, time.Time, []byte) ([]byte, error)

+ type NodeSampler interface

+ Sample func(ctx context.Context, limit int) []ids.NodeID

+ type Peers struct

+ func (p *Peers) Connected(_ context.Context, nodeID ids.NodeID, _ *version.Application) error

+ func (p *Peers) Disconnected(_ context.Context, nodeID ids.NodeID) error

+ func (p *Peers) Sample(_ context.Context, limit int) []ids.NodeID

+ type Validators struct

+ func NewValidators(log logging.Logger, subnetID ids.ID, validators validators.State, ...) *Validators

+ func (v *Validators) Has(ctx context.Context, nodeID ids.NodeID) bool

+ func (v *Validators) Sample(ctx context.Context, limit int) []ids.NodeID

Aug 2, 2023

Changes in this version

+ var ErrAppRequestFailed = errors.New("app request failed")

+ var ErrExistingAppProtocol = errors.New("existing app protocol")

+ var ErrNoPeers = errors.New("no peers")

+ var ErrRequestPending = errors.New("request pending")

+ var ErrUnrequestedResponse = errors.New("unrequested response")

+ type AppResponseCallback func(nodeID ids.NodeID, responseBytes []byte, err error)

+ type Client struct

+ func (c *Client) AppGossip(ctx context.Context, appGossipBytes []byte) error

+ func (c *Client) AppGossipSpecific(ctx context.Context, nodeIDs set.Set[ids.NodeID], 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

+ func (c *Client) CrossChainAppRequest(ctx context.Context, chainID ids.ID, appRequestBytes []byte, ...) error

+ type CrossChainAppResponseCallback func(chainID ids.ID, responseBytes []byte, err error)

+ type Handler interface

+ AppGossip func(ctx context.Context, nodeID ids.NodeID, gossipBytes []byte) error

+ AppRequest func(ctx context.Context, nodeID ids.NodeID, deadline time.Time, ...) ([]byte, error)

+ CrossChainAppRequest func(ctx context.Context, chainID ids.ID, deadline time.Time, requestBytes []byte) ([]byte, error)

+ type Router struct

+ func NewRouter(log logging.Logger, sender common.AppSender) *Router

+ func (r *Router) AppGossip(ctx context.Context, nodeID ids.NodeID, gossip []byte) error

+ func (r *Router) AppRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error

+ func (r *Router) AppRequestFailed(_ context.Context, nodeID ids.NodeID, requestID uint32) error

+ func (r *Router) AppResponse(_ context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error

+ func (r *Router) Connected(_ context.Context, nodeID ids.NodeID, _ *version.Application) error

+ func (r *Router) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error

+ func (r *Router) CrossChainAppRequestFailed(_ context.Context, chainID ids.ID, requestID uint32) error

+ func (r *Router) CrossChainAppResponse(_ context.Context, chainID ids.ID, requestID uint32, response []byte) error

+ func (r *Router) Disconnected(_ context.Context, nodeID ids.NodeID) error

+ func (r *Router) RegisterAppProtocol(handlerID uint64, handler Handler) (*Client, error)