Versions in this module Expand all Collapse all v1 v1.4.9 Jul 5, 2021 v1.4.5 Jul 5, 2021 Changes in this version + const DefaultMaxNonStakerPendingMsgs + const DefaultStakerPortion + type ChainRouter struct + func (cr *ChainRouter) Accepted(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + func (cr *ChainRouter) AcceptedFrontier(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + func (cr *ChainRouter) AddChain(chain *Handler) + func (cr *ChainRouter) Benched(chainID ids.ID, validatorID ids.ShortID) + func (cr *ChainRouter) Chits(validatorID ids.ShortID, chainID ids.ID, requestID uint32, votes []ids.ID) + func (cr *ChainRouter) Connected(validatorID ids.ShortID) + func (cr *ChainRouter) Disconnected(validatorID ids.ShortID) + func (cr *ChainRouter) EndInterval() + func (cr *ChainRouter) Get(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (cr *ChainRouter) GetAccepted(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (cr *ChainRouter) GetAcceptedFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (cr *ChainRouter) GetAcceptedFrontier(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time) + func (cr *ChainRouter) GetAcceptedFrontierFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (cr *ChainRouter) GetAncestors(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (cr *ChainRouter) GetAncestorsFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (cr *ChainRouter) GetFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (cr *ChainRouter) Gossip() + func (cr *ChainRouter) HealthCheck() (interface{}, error) + func (cr *ChainRouter) Initialize(nodeID ids.ShortID, log logging.Logger, timeoutManager *timeout.Manager, ...) error + func (cr *ChainRouter) MultiPut(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containers [][]byte) + func (cr *ChainRouter) PullQuery(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (cr *ChainRouter) PushQuery(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (cr *ChainRouter) Put(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containerID ids.ID, ...) + func (cr *ChainRouter) QueryFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (cr *ChainRouter) RegisterRequest(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + func (cr *ChainRouter) RemoveChain(chainID ids.ID) + func (cr *ChainRouter) Shutdown() + func (cr *ChainRouter) Unbenched(chainID ids.ID, validatorID ids.ShortID) + type ExternalRouter interface + Accepted func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + AcceptedFrontier func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + Chits func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, votes []ids.ID) + Get func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + GetAccepted func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + GetAcceptedFrontier func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time) + GetAncestors func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + MultiPut func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containers [][]byte) + PullQuery func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + PushQuery func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + Put func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containerID ids.ID, ...) + RegisterRequest func(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + type Handler struct + func (h *Handler) Accepted(validatorID ids.ShortID, requestID uint32, containerIDs []ids.ID) bool + func (h *Handler) AcceptedFrontier(validatorID ids.ShortID, requestID uint32, containerIDs []ids.ID) bool + func (h *Handler) Chits(validatorID ids.ShortID, requestID uint32, votes []ids.ID) bool + func (h *Handler) Connected(validatorID ids.ShortID) + func (h *Handler) Context() *snow.Context + func (h *Handler) Disconnected(validatorID ids.ShortID) + func (h *Handler) Dispatch() + func (h *Handler) Engine() common.Engine + func (h *Handler) Get(validatorID ids.ShortID, requestID uint32, deadline time.Time, ...) bool + func (h *Handler) GetAccepted(validatorID ids.ShortID, requestID uint32, deadline time.Time, ...) bool + func (h *Handler) GetAcceptedFailed(validatorID ids.ShortID, requestID uint32) + func (h *Handler) GetAcceptedFrontier(validatorID ids.ShortID, requestID uint32, deadline time.Time) bool + func (h *Handler) GetAcceptedFrontierFailed(validatorID ids.ShortID, requestID uint32) + func (h *Handler) GetAncestors(validatorID ids.ShortID, requestID uint32, deadline time.Time, ...) bool + func (h *Handler) GetAncestorsFailed(validatorID ids.ShortID, requestID uint32) + func (h *Handler) GetFailed(validatorID ids.ShortID, requestID uint32) + func (h *Handler) Gossip() + func (h *Handler) Initialize(engine common.Engine, validators validators.Set, msgChan <-chan common.Message, ...) error + func (h *Handler) MultiPut(validatorID ids.ShortID, requestID uint32, containers [][]byte) bool + func (h *Handler) Notify(msg common.Message) + func (h *Handler) PullQuery(validatorID ids.ShortID, requestID uint32, deadline time.Time, ...) bool + func (h *Handler) PushQuery(validatorID ids.ShortID, requestID uint32, deadline time.Time, ...) bool + func (h *Handler) Put(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...) bool + func (h *Handler) QueryFailed(validatorID ids.ShortID, requestID uint32) + func (h *Handler) SetEngine(engine common.Engine) + func (h *Handler) Shutdown() + func (h *Handler) Timeout() + type HealthConfig struct + MaxDropRate float64 + MaxDropRateHalflife time.Duration + MaxOutstandingDuration time.Duration + MaxOutstandingRequests int + MaxRunTimeRequests time.Duration + type InternalRouter interface + Connected func(validatorID ids.ShortID) + Disconnected func(validatorID ids.ShortID) + GetAcceptedFailed func(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + GetAcceptedFrontierFailed func(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + GetAncestorsFailed func(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + GetFailed func(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + QueryFailed func(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + type MsgManager interface + AddPending func(ids.ShortID) bool + RemovePending func(ids.ShortID) + Utilization func(ids.ShortID) float64 + func NewMsgManager(vdrs validators.Set, log logging.Logger, msgTracker tracker.CountingTracker, ...) (MsgManager, error) + type Router interface + AddChain func(chain *Handler) + Initialize func(nodeID ids.ShortID, log logging.Logger, timeouts *timeout.Manager, ...) error + RemoveChain func(chainID ids.ID) + Shutdown func() + type Timer struct + Handler *Handler + Preempt chan struct{} + func (t *Timer) RegisterTimeout(d time.Duration)