Versions in this module Expand all Collapse all v1 v1.14.2 Aug 2, 2025 Changes in this version + const NormalOp + var ErrTimeout = &AppError + var ErrUndefined = &AppError + type AppError struct + Code int32 + Message string + func (e AppError) Error() string + type AppHandler interface + AppGossip func(ctx context.Context, nodeID ids.NodeID, msg []byte) error + AppRequest func(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + AppRequestFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32, appErr *AppError) error + AppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error + Connected func(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error + Disconnected func(ctx context.Context, nodeID ids.NodeID) error + type AppSender interface + SendAppError func(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error + SendAppGossip func(ctx context.Context, msg []byte) error + SendAppRequest func(ctx context.Context, nodeIDs []ids.NodeID, requestID uint32, msg []byte) error + SendAppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error + SendCrossChainAppRequest func(ctx context.Context, chainID ids.ID, requestID uint32, msg []byte) error + SendCrossChainAppResponse func(ctx context.Context, chainID ids.ID, requestID uint32, msg []byte) error + type BootstrapTracker interface + Bootstrapped func() + IsBootstrapped func() bool + OnValidatorAdded func(nodeID ids.NodeID, weight uint64) + OnValidatorRemoved func(nodeID ids.NodeID, weight uint64) + OnValidatorWeightChanged func(nodeID ids.NodeID, oldWeight, newWeight uint64) + type ChainVM interface + Connected func(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error + CreateHandlers func(context.Context) (map[string]interface{}, error) + Disconnected func(ctx context.Context, nodeID ids.NodeID) error + HealthCheck func(context.Context) (interface{}, error) + Initialize func(ctx context.Context, chainCtx *Context, db interface{}, genesisBytes []byte, ...) error + SetState func(ctx context.Context, state State) error + Shutdown func(context.Context) error + Version func(context.Context) (string, error) + type Context struct + Bootstrappers []ids.NodeID + ChainID ids.ID + Lock sync.Locker + Log Logger + NodeID ids.NodeID + Registerer Registerer + RequestID *RequestID + Sender Sender + StartTime time.Time + SubnetID ids.ID + ValidatorSet validators.Set + ValidatorState ValidatorState + type Engine interface + GetVM func() interface{} + type Fx struct + Fx interface{} + ID ids.ID + type Handler interface + Accepted func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + AcceptedFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + AcceptedStateSummary func(ctx context.Context, nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) error + Ancestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte) error + AppGossip func(ctx context.Context, nodeID ids.NodeID, msg []byte) error + AppRequest func(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + AppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error + Chits func(ctx context.Context, nodeID ids.NodeID, requestID uint32, preferredID ids.ID, ...) error + Connected func(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error + Context func() *Context + CrossChainAppRequest func(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error + CrossChainAppResponse func(ctx context.Context, chainID ids.ID, requestID uint32, msg []byte) error + Disconnected func(ctx context.Context, nodeID ids.NodeID) error + Get func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + GetAccepted func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + GetAcceptedFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetAcceptedStateSummary func(ctx context.Context, nodeID ids.NodeID, requestID uint32, heights []uint64) error + GetAncestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + GetStateSummaryFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + HealthCheck func(context.Context) (interface{}, error) + Notify func(context.Context, Message) error + PullQuery func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID, ...) error + PushQuery func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte, ...) error + Put func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte) error + QueryFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + Shutdown func(context.Context) error + Start func(ctx context.Context, startReqID uint32) error + StateSummaryFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32, summary []byte) error + Stop func(ctx context.Context) error + type Logger interface + type Message struct + Body interface{} + NodeID ids.NodeID + Type message.Op + type PendingTxs struct + Txs [][]byte + type PreemptionSignal struct + func NewPreemptionSignal() *PreemptionSignal + func (p *PreemptionSignal) Listen() <-chan struct{} + func (p *PreemptionSignal) Preempt() + type Registerer interface + type Request struct + Deadline time.Time + Handler Handler + NodeID ids.NodeID + RequestID uint32 + type RequestID struct + type SendConfig struct + NodeIDs []ids.NodeID + Peers int + Validators []ids.NodeID + type Sender interface + type State uint8 + const StateBootstrapping + const StateConsensus + type VM interface + AppGossip func(ctx context.Context, nodeID ids.NodeID, msg []byte) error + AppRequest func(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + AppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error + Connected func(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error + CreateHandlers func(context.Context) (map[string]interface{}, error) + CreateStaticHandlers func(context.Context) (map[string]interface{}, error) + CrossChainAppRequest func(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error + CrossChainAppResponse func(ctx context.Context, chainID ids.ID, requestID uint32, msg []byte) error + Disconnected func(ctx context.Context, nodeID ids.NodeID) error + HealthCheck func(context.Context) (interface{}, error) + Initialize func(ctx context.Context, chainCtx *Context, dbManager interface{}, ...) error + SetState func(ctx context.Context, state State) error + Shutdown func(context.Context) error + Version func(context.Context) (string, error) + type ValidatorState interface + GetSubnetID func(ctx context.Context, chainID ids.ID) (ids.ID, error) Other modules containing this package github.com/luxfi/node/v2