Versions in this module Expand all Collapse all v1 v1.9.0 Oct 3, 2022 Changes in this version + var AsynchronousOps = []Op + var ConsensusExternalOps = append(ConsensusRequestOps, append(ConsensusResponseOps, AppGossip)) + var ConsensusInternalOps = []Op + var ConsensusOps = append(ConsensusExternalOps, ConsensusInternalOps) + var ConsensusRequestOps = []Op + var ConsensusResponseOps = []Op + var ExternalOps = append(ConsensusExternalOps, HandshakeOps) + var FailedToResponseOps = map[Op]Op + var HandshakeOps = []Op + var RequestToResponseOps = map[Op]Op + var ResponseToFailedOps = map[Op]Op + var SynchronousOps = []Op + var UnrequestedOps = map[Op]struct + type Codec interface + func NewCodecWithMemoryPool(namespace string, metrics prometheus.Registerer, maxMessageSize int64, ...) (Codec, error) + type Creator interface + func NewCreator(metrics prometheus.Registerer, parentNamespace string, compressionEnabled bool, ...) (Creator, error) + func NewCreatorWithProto(metrics prometheus.Registerer, parentNamespace string, compressionEnabled bool, ...) (Creator, error) + type Field uint32 + const AppBytes + const ChainID + const ContainerBytes + const ContainerID + const ContainerIDs + const Deadline + const IP + const MultiContainerBytes + const MyTime + const NetworkID + const NodeID + const Peers + const RequestID + const SigBytes + const SummaryBytes + const SummaryHeights + const SummaryIDs + const TrackedSubnets + const Uptime + const VMMessage + const VersionStr + const VersionStruct + const VersionTime + func (f Field) Packer() func(*wrappers.Packer, interface{}) + func (f Field) String() string + func (f Field) Unpacker() func(*wrappers.Packer) interface{} + type InboundMessage interface + BytesSavedCompression func() int + ExpirationTime func() time.Time + Get func(Field) (interface{}, error) + NodeID func() ids.NodeID + OnFinishedHandling func() + Op func() Op + type InboundMsgBuilder interface + InboundAccepted func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID) InboundMessage + InboundAcceptedFrontier func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID) InboundMessage + InboundAcceptedStateSummary func(chainID ids.ID, requestID uint32, summaryIDs []ids.ID, nodeID ids.NodeID) InboundMessage + InboundAncestors func(chainID ids.ID, requestID uint32, containers [][]byte, nodeID ids.NodeID) InboundMessage + InboundAppRequest func(chainID ids.ID, requestID uint32, deadline time.Duration, msg []byte, ...) InboundMessage + InboundAppResponse func(chainID ids.ID, requestID uint32, msg []byte, nodeID ids.NodeID) InboundMessage + InboundChits func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID) InboundMessage + InboundGet func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID, ...) InboundMessage + InboundGetAccepted func(chainID ids.ID, requestID uint32, deadline time.Duration, ...) InboundMessage + InboundGetAcceptedFrontier func(chainID ids.ID, requestID uint32, deadline time.Duration, nodeID ids.NodeID) InboundMessage + InboundGetAcceptedStateSummary func(chainID ids.ID, requestID uint32, heights []uint64, deadline time.Duration, ...) InboundMessage + InboundGetStateSummaryFrontier func(chainID ids.ID, requestID uint32, deadline time.Duration, nodeID ids.NodeID) InboundMessage + InboundPullQuery func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID, ...) InboundMessage + InboundPushQuery func(chainID ids.ID, requestID uint32, deadline time.Duration, container []byte, ...) InboundMessage + InboundPut func(chainID ids.ID, requestID uint32, container []byte, nodeID ids.NodeID) InboundMessage + InboundStateSummaryFrontier func(chainID ids.ID, requestID uint32, summary []byte, nodeID ids.NodeID) InboundMessage + func NewInboundBuilderWithPacker(c Codec) InboundMsgBuilder + type InternalMsgBuilder interface + InternalConnected func(nodeID ids.NodeID, nodeVersion *version.Application) InboundMessage + InternalDisconnected func(nodeID ids.NodeID) InboundMessage + InternalFailedRequest func(op Op, nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage + InternalGossipRequest func(nodeID ids.NodeID) InboundMessage + InternalTimeout func(nodeID ids.NodeID) InboundMessage + InternalVMMessage func(nodeID ids.NodeID, notification uint32) InboundMessage + func NewInternalBuilder() InternalMsgBuilder + type Op byte + const Accepted + const AcceptedFrontier + const AcceptedStateSummary + const Ancestors + const AppGossip + const AppRequest + const AppRequestFailed + const AppResponse + const Chits + const Connected + const Disconnected + const Get + const GetAccepted + const GetAcceptedFailed + const GetAcceptedFrontier + const GetAcceptedFrontierFailed + const GetAcceptedStateSummary + const GetAcceptedStateSummaryFailed + const GetAncestors + const GetAncestorsFailed + const GetFailed + const GetStateSummaryFrontier + const GetStateSummaryFrontierFailed + const GossipRequest + const Notify + const PeerList + const Ping + const Pong + const PullQuery + const PushQuery + const Put + const QueryFailed + const StateSummaryFrontier + const Timeout + const Version + func (op Op) Compressible() bool + func (op Op) String() string + type OutboundMessage interface + AddRef func() + BypassThrottling func() bool + Bytes func() []byte + BytesSavedCompression func() int + DecRef func() + IsProto func() bool + Op func() Op + type OutboundMsgBuilder interface + Accepted func(chainID ids.ID, requestID uint32, containerIDs []ids.ID) (OutboundMessage, error) + AcceptedFrontier func(chainID ids.ID, requestID uint32, containerIDs []ids.ID) (OutboundMessage, error) + AcceptedStateSummary func(chainID ids.ID, requestID uint32, summaryIDs []ids.ID) (OutboundMessage, error) + Ancestors func(chainID ids.ID, requestID uint32, containers [][]byte) (OutboundMessage, error) + AppGossip func(chainID ids.ID, msg []byte) (OutboundMessage, error) + AppRequest func(chainID ids.ID, requestID uint32, deadline time.Duration, msg []byte) (OutboundMessage, error) + AppResponse func(chainID ids.ID, requestID uint32, msg []byte) (OutboundMessage, error) + Chits func(chainID ids.ID, requestID uint32, containerIDs []ids.ID) (OutboundMessage, error) + Get func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID) (OutboundMessage, error) + GetAccepted func(chainID ids.ID, requestID uint32, deadline time.Duration, ...) (OutboundMessage, error) + GetAcceptedFrontier func(chainID ids.ID, requestID uint32, deadline time.Duration) (OutboundMessage, error) + GetAcceptedStateSummary func(chainID ids.ID, requestID uint32, deadline time.Duration, heights []uint64) (OutboundMessage, error) + GetAncestors func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID) (OutboundMessage, error) + GetStateSummaryFrontier func(chainID ids.ID, requestID uint32, deadline time.Duration) (OutboundMessage, error) + PeerList func(peers []ips.ClaimedIPPort, bypassThrottling bool) (OutboundMessage, error) + Ping func() (OutboundMessage, error) + Pong func(uptimePercentage uint8) (OutboundMessage, error) + PullQuery func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID) (OutboundMessage, error) + PushQuery func(chainID ids.ID, requestID uint32, deadline time.Duration, container []byte) (OutboundMessage, error) + Put func(chainID ids.ID, requestID uint32, container []byte) (OutboundMessage, error) + StateSummaryFrontier func(chainID ids.ID, requestID uint32, summary []byte) (OutboundMessage, error) + Version func(networkID uint32, myTime uint64, ip ips.IPPort, myVersion string, ...) (OutboundMessage, error) + func NewOutboundBuilderWithPacker(c Codec, enableCompression bool) OutboundMsgBuilder + type Packer interface + Pack func(op Op, fieldValues map[Field]interface{}, compress bool, bypassThrottling bool) (OutboundMessage, error) + type Parser interface + Parse func(bytes []byte, nodeID ids.NodeID, onFinishedHandling func()) (InboundMessage, error) + SetTime func(t time.Time) + type TestMsg struct + func NewTestMsg(op Op, bytes []byte, bypassThrottling bool) *TestMsg + func (*TestMsg) AddRef() + func (*TestMsg) BytesSavedCompression() int + func (*TestMsg) DecRef() + func (*TestMsg) Get(Field) interface{} + func (*TestMsg) IsProto() bool + func (m *TestMsg) BypassThrottling() bool + func (m *TestMsg) Bytes() []byte + func (m *TestMsg) Op() Op
Go to main page