Versions in this module Expand all Collapse all v1 v1.0.0 Jul 21, 2022 Changes in this version + type ChainRouter struct + func (cr *ChainRouter) AddChain(chain handler.Handler) + func (cr *ChainRouter) Benched(chainID ids.ID, nodeID ids.NodeID) + func (cr *ChainRouter) Connected(nodeID ids.NodeID, nodeVersion version.Application) + func (cr *ChainRouter) Disconnected(nodeID ids.NodeID) + func (cr *ChainRouter) HandleInbound(msg message.InboundMessage) + func (cr *ChainRouter) HealthCheck() (interface{}, error) + func (cr *ChainRouter) Initialize(nodeID ids.NodeID, log logging.Logger, msgCreator message.Creator, ...) error + func (cr *ChainRouter) RegisterRequest(nodeID ids.NodeID, chainID ids.ID, requestID uint32, op message.Op) + func (cr *ChainRouter) Shutdown() + func (cr *ChainRouter) Unbenched(chainID ids.ID, nodeID ids.NodeID) + type ExternalHandler interface + Connected func(nodeID ids.NodeID, nodeVersion version.Application) + Disconnected func(nodeID ids.NodeID) + type HealthConfig struct + MaxDropRate float64 + MaxDropRateHalflife time.Duration + MaxOutstandingDuration time.Duration + MaxOutstandingRequests int + MaxRunTimeRequests time.Duration + type InboundHandler interface + HandleInbound func(msg message.InboundMessage) + type InboundHandlerFunc func(msg message.InboundMessage) + func (f InboundHandlerFunc) HandleInbound(msg message.InboundMessage) + type InternalHandler interface + RegisterRequest func(nodeID ids.NodeID, chainID ids.ID, requestID uint32, op message.Op) + type Router interface + AddChain func(chain handler.Handler) + Initialize func(nodeID ids.NodeID, log logging.Logger, msgCreator message.Creator, ...) error + Shutdown func() v1.0.0-alpha Nov 22, 2022
Go to main page