core

Dec 13, 2025

Changes in this version

+ func CgoAvailable() bool

type MessageType

+ const StateSyncDone

Dec 12, 2025

Changes in this version

+ type Message struct

+ Content []byte

+ NodeID ids.NodeID

+ Type MessageType

type MessageType

+ const Accepted

+ const AcceptedFrontier

+ const Chits

+ const ChitsV2

+ const GetAccepted

+ const GetAcceptedFrontier

+ const GetAcceptedFrontierFailed

+ const GetAncestors

+ const GetBlock

+ const GetFailed

+ const MultiPut

+ const PutBlock

+ const QueryFailed

+ const WarpGossip

+ const WarpRequest

+ const WarpResponse

+ func (m MessageType) String() string

Dec 12, 2025

Changes in this version

+ type Error = warp.Error

+ type Handler = warp.Handler

Dec 12, 2025

Changes in this version

+ type Sender = warp.Sender

Dec 12, 2025

Changes in this version

+ type WarpSender = consensus_core.WarpSender

Sep 27, 2025

Changes in this version

+ const PendingTxs

+ type AppError = consensus_core.AppError

+ type AppHandler = consensus_core.AppHandler

+ type AppSender = consensus_core.AppSender

+ type AppSenderOriginal interface

+ SendAppError func(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error

+ SendAppGossip func(ctx context.Context, nodeIDs set.Set[ids.NodeID], message []byte) error

+ SendAppRequest func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) error

+ SendAppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error

+ SendCrossChainAppError func(ctx context.Context, chainID ids.ID, requestID uint32, errorCode int32, ...) error

+ SendCrossChainAppRequest func(ctx context.Context, chainID ids.ID, requestID uint32, request []byte) error

+ SendCrossChainAppResponse func(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error

+ type Block interface

+ Accept func(context.Context) error

+ Bytes func() []byte

+ Height func() uint64

+ ID func() ids.ID

+ ParentID func() ids.ID

+ Reject func(context.Context) error

+ Timestamp func() int64

+ Verify func(context.Context) error

+ type BlockStatus uint8

+ const StatusAccepted

+ const StatusProcessing

+ const StatusRejected

+ const StatusUnknown

+ type CGOConsensus struct

+ func NewCGOConsensus(params ConsensusParams) (*CGOConsensus, error)

+ func (c *CGOConsensus) Add(block Block) error

+ func (c *CGOConsensus) Finalized() bool

+ func (c *CGOConsensus) GetPreference() ids.ID

+ func (c *CGOConsensus) HealthCheck() error

+ func (c *CGOConsensus) IsAccepted(blockID ids.ID) bool

+ func (c *CGOConsensus) Parameters() ConsensusParams

+ func (c *CGOConsensus) RecordPoll(blockID ids.ID, accept bool) error

+ type Consensus interface

+ Add func(Block) error

+ Finalized func() bool

+ GetPreference func() ids.ID

+ HealthCheck func() error

+ IsAccepted func(ids.ID) bool

+ Parameters func() ConsensusParams

+ RecordPoll func(ids.ID, bool) error

+ type ConsensusFactory struct

+ func NewConsensusFactory() *ConsensusFactory

+ func (f *ConsensusFactory) CreateConsensus(params ConsensusParams) (Consensus, error)

+ type ConsensusParams struct

+ AlphaConfidence int

+ AlphaPreference int

+ Beta int

+ ConcurrentPolls int

+ K int

+ MaxItemProcessingTime time.Duration

+ MaxOutstandingItems int

+ OptimalProcessing int

+ type FakeSender = consensus_core.FakeSender

+ type Fx struct

+ Fx interface{}

+ ID ids.ID

+ type MessageType = common.MessageType

+ type SendConfig = consensus_core.SendConfig

+ type SenderTest struct

+ type Stats struct

+ AverageDecisionTimeMs float64

+ BlocksAccepted uint64

+ BlocksRejected uint64

+ PollsCompleted uint64

+ VotesProcessed uint64