Versions in this module Expand all Collapse all v0 v0.1.0 Dec 24, 2020 Changes in this version + const DefaultMaxNonStakerPendingMsgs + const DefaultStakerPortion + type ChainRouter struct + func (sr *ChainRouter) Accepted(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + func (sr *ChainRouter) AcceptedFrontier(validatorID ids.ShortID, chainID ids.ID, requestID uint32, ...) + func (sr *ChainRouter) AddChain(chain *Handler) + func (sr *ChainRouter) Chits(validatorID ids.ShortID, chainID ids.ID, requestID uint32, votes []ids.ID) + func (sr *ChainRouter) Connected(validatorID ids.ShortID) + func (sr *ChainRouter) Disconnected(validatorID ids.ShortID) + func (sr *ChainRouter) EndInterval() + func (sr *ChainRouter) Get(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (sr *ChainRouter) GetAccepted(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (sr *ChainRouter) GetAcceptedFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (sr *ChainRouter) GetAcceptedFrontier(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time) + func (sr *ChainRouter) GetAcceptedFrontierFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (sr *ChainRouter) GetAncestors(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (sr *ChainRouter) GetAncestorsFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (sr *ChainRouter) GetFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (sr *ChainRouter) Gossip() + func (sr *ChainRouter) Initialize(nodeID ids.ShortID, log logging.Logger, timeouts *timeout.Manager, ...) + func (sr *ChainRouter) MultiPut(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containers [][]byte) + func (sr *ChainRouter) PullQuery(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (sr *ChainRouter) PushQuery(validatorID ids.ShortID, chainID ids.ID, requestID uint32, deadline time.Time, ...) + func (sr *ChainRouter) Put(validatorID ids.ShortID, chainID ids.ID, requestID uint32, containerID ids.ID, ...) + func (sr *ChainRouter) QueryFailed(validatorID ids.ShortID, chainID ids.ID, requestID uint32) + func (sr *ChainRouter) RemoveChain(chainID ids.ID) + func (sr *ChainRouter) Shutdown() + 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, ...) + 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, ...) + 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() + 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 + type Router interface + AddChain func(chain *Handler) + Initialize func(nodeID ids.ShortID, log logging.Logger, timeouts *timeout.Manager, ...) + RemoveChain func(chainID ids.ID) + Shutdown func()
Go to main page