Versions in this module Expand all Collapse all v1 v1.12.2 Mar 3, 2025 Changes in this version + type ChainRouter struct + func (cr *ChainRouter) AddChain(ctx context.Context, chain handler.Handler) + func (cr *ChainRouter) Benched(chainID ids.ID, nodeID ids.NodeID) + func (cr *ChainRouter) Connected(nodeID ids.NodeID, nodeVersion *version.Application, subnetID ids.ID) + func (cr *ChainRouter) Disconnected(nodeID ids.NodeID) + func (cr *ChainRouter) HandleInbound(ctx context.Context, msg message.InboundMessage) + func (cr *ChainRouter) HealthCheck(context.Context) (interface{}, error) + func (cr *ChainRouter) Initialize(nodeID ids.NodeID, log logging.Logger, timeoutManager timeout.Manager, ...) error + func (cr *ChainRouter) RegisterRequest(ctx context.Context, nodeID ids.NodeID, chainID ids.ID, requestID uint32, ...) + func (cr *ChainRouter) Shutdown(ctx context.Context) + func (cr *ChainRouter) Unbenched(chainID ids.ID, nodeID ids.NodeID) + type ExternalHandler interface + Connected func(nodeID ids.NodeID, nodeVersion *version.Application, subnetID ids.ID) + 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(context.Context, message.InboundMessage) + type InboundHandlerFunc func(context.Context, message.InboundMessage) + func (f InboundHandlerFunc) HandleInbound(ctx context.Context, msg message.InboundMessage) + type InternalHandler interface + RegisterRequest func(ctx context.Context, nodeID ids.NodeID, chainID ids.ID, requestID uint32, ...) + type Router interface + AddChain func(ctx context.Context, chain handler.Handler) + Initialize func(nodeID ids.NodeID, log logging.Logger, timeouts timeout.Manager, ...) error + Shutdown func(context.Context) + func Trace(router Router, tracer trace.Tracer) Router
Go to main page