Versions in this module Expand all Collapse all v1 v1.10.1 Apr 13, 2022 v1.7.11 Apr 13, 2022 v1.6.11 Apr 13, 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, compressionEnabled bool, parentNamespace string, ...) (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 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{} + NodeID func() ids.ShortID + OnFinishedHandling func() + Op func() Op + type InboundMsgBuilder interface + InboundAccepted func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.ShortID) InboundMessage + InboundAcceptedFrontier func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.ShortID) InboundMessage + InboundAncestors func(chainID ids.ID, requestID uint32, containers [][]byte, nodeID ids.ShortID) 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.ShortID) InboundMessage + InboundChits func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.ShortID) 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.ShortID) 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, containerID ids.ID, ...) InboundMessage + InboundPut func(chainID ids.ID, requestID uint32, containerID ids.ID, container []byte, ...) InboundMessage + func NewInboundBuilder(c Codec) InboundMsgBuilder + type InternalMsgBuilder interface + InternalConnected func(nodeID ids.ShortID, nodeVersion version.Application) InboundMessage + InternalDisconnected func(nodeID ids.ShortID) InboundMessage + InternalFailedRequest func(op Op, nodeID ids.ShortID, chainID ids.ID, requestID uint32) InboundMessage + InternalGossipRequest func(nodeID ids.ShortID) InboundMessage + InternalTimeout func(nodeID ids.ShortID) InboundMessage + InternalVMMessage func(nodeID ids.ShortID, notification uint32) InboundMessage + func NewInternalBuilder() InternalMsgBuilder + type Op byte + const Accepted + const AcceptedFrontier + 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 GetAncestors + const GetAncestorsFailed + const GetFailed + const GossipRequest + const Notify + const PeerList + const Ping + const Pong + const PullQuery + const PushQuery + const Put + const QueryFailed + 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() + 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) + 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) + GetAncestors func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID) (OutboundMessage, error) + PeerList func(peers []utils.IPCertDesc, 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, containerID ids.ID, ...) (OutboundMessage, error) + Put func(chainID ids.ID, requestID uint32, containerID ids.ID, container []byte) (OutboundMessage, error) + Version func(networkID uint32, myTime uint64, ip utils.IPDesc, myVersion string, ...) (OutboundMessage, error) + func NewOutboundBuilder(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.ShortID, 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 (m *TestMsg) BypassThrottling() bool + func (m *TestMsg) Bytes() []byte + func (m *TestMsg) Op() Op
Go to main page