message

package

Go to main page

Versions in this module

v1

v1.8.14

Dec 22, 2022

v1.8.13

Dec 22, 2022

v1.8.12

Dec 21, 2022

v1.8.11

Dec 21, 2022

v1.8.10

Dec 14, 2022

v1.8.9

Dec 13, 2022

v1.8.8

Dec 13, 2022

v1.8.7

Dec 13, 2022

Changes in this version

+ func GetChainID(m any) (ids.ID, error)

+ func GetDeadline(m any) (time.Duration, bool)

+ func GetRequestID(m any) (uint32, bool)

+ func GetSourceChainID(m any) (ids.ID, error)

+ func Unwrap(m *p2ppb.Message) (interface{}, error)

type AppRequestFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *AppRequestFailed) GetChainId() []byte

+ func (m *AppRequestFailed) GetRequestId() uint32

type Connected

+ NodeVersion *version.Application

+ type ConnectedSubnet struct

+ SubnetID ids.ID

+ type CrossChainAppRequest struct

+ DestinationChainID ids.ID

+ Message []byte

+ RequestID uint32

+ SourceChainID ids.ID

+ func (m *CrossChainAppRequest) GetChainId() []byte

+ func (m *CrossChainAppRequest) GetRequestId() uint32

+ func (m *CrossChainAppRequest) GetSourceChainID() ids.ID

+ type CrossChainAppRequestFailed struct

+ DestinationChainID ids.ID

+ RequestID uint32

+ SourceChainID ids.ID

+ func (m *CrossChainAppRequestFailed) GetChainId() []byte

+ func (m *CrossChainAppRequestFailed) GetRequestId() uint32

+ func (m *CrossChainAppRequestFailed) GetSourceChainID() ids.ID

+ type CrossChainAppResponse struct

+ DestinationChainID ids.ID

+ Message []byte

+ RequestID uint32

+ SourceChainID ids.ID

+ func (m *CrossChainAppResponse) GetChainId() []byte

+ func (m *CrossChainAppResponse) GetRequestId() uint32

+ func (m *CrossChainAppResponse) GetSourceChainID() ids.ID

type GetAcceptedFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *GetAcceptedFailed) GetChainId() []byte

+ func (m *GetAcceptedFailed) GetRequestId() uint32

type GetAcceptedFrontierFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *GetAcceptedFrontierFailed) GetChainId() []byte

+ func (m *GetAcceptedFrontierFailed) GetRequestId() uint32

type GetAcceptedStateSummaryFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *GetAcceptedStateSummaryFailed) GetChainId() []byte

+ func (m *GetAcceptedStateSummaryFailed) GetRequestId() uint32

type GetAncestorsFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *GetAncestorsFailed) GetChainId() []byte

+ func (m *GetAncestorsFailed) GetRequestId() uint32

type GetFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *GetFailed) GetChainId() []byte

+ func (m *GetFailed) GetRequestId() uint32

type GetStateSummaryFrontierFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *GetStateSummaryFrontierFailed) GetChainId() []byte

+ func (m *GetStateSummaryFrontierFailed) GetRequestId() uint32

type InboundMessage

+ func InboundAccepted(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID) InboundMessage

+ func InboundAcceptedFrontier(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID) InboundMessage

+ func InboundAcceptedStateSummary(chainID ids.ID, requestID uint32, summaryIDs []ids.ID, nodeID ids.NodeID) InboundMessage

+ func InboundAppRequest(chainID ids.ID, requestID uint32, deadline time.Duration, msg []byte, ...) InboundMessage

+ func InboundAppResponse(chainID ids.ID, requestID uint32, msg []byte, nodeID ids.NodeID) InboundMessage

+ func InboundChits(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID) InboundMessage

+ func InboundGetAccepted(chainID ids.ID, requestID uint32, deadline time.Duration, ...) InboundMessage

+ func InboundGetAcceptedFrontier(chainID ids.ID, requestID uint32, deadline time.Duration, nodeID ids.NodeID) InboundMessage

+ func InboundGetAcceptedStateSummary(chainID ids.ID, requestID uint32, heights []uint64, deadline time.Duration, ...) InboundMessage

+ func InboundGetStateSummaryFrontier(chainID ids.ID, requestID uint32, deadline time.Duration, nodeID ids.NodeID) InboundMessage

+ func InboundPullQuery(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID, ...) InboundMessage

+ func InboundPushQuery(chainID ids.ID, requestID uint32, deadline time.Duration, container []byte, ...) InboundMessage

+ func InboundStateSummaryFrontier(chainID ids.ID, requestID uint32, summary []byte, nodeID ids.NodeID) InboundMessage

+ func InternalAppRequestFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalConnected(nodeID ids.NodeID, nodeVersion *version.Application) InboundMessage

+ func InternalConnectedSubnet(nodeID ids.NodeID, subnetID ids.ID) InboundMessage

+ func InternalCrossChainAppRequest(nodeID ids.NodeID, sourceChainID ids.ID, destinationChainID ids.ID, ...) InboundMessage

+ func InternalCrossChainAppRequestFailed(nodeID ids.NodeID, sourceChainID ids.ID, destinationChainID ids.ID, ...) InboundMessage

+ func InternalCrossChainAppResponse(nodeID ids.NodeID, sourceChainID ids.ID, destinationChainID ids.ID, ...) InboundMessage

+ func InternalDisconnected(nodeID ids.NodeID) InboundMessage

+ func InternalGetAcceptedFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalGetAcceptedFrontierFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalGetAcceptedStateSummaryFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalGetAncestorsFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalGetFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalGetStateSummaryFrontierFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalGossipRequest(nodeID ids.NodeID) InboundMessage

+ func InternalQueryFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage

+ func InternalTimeout(nodeID ids.NodeID) InboundMessage

+ func InternalVMMessage(nodeID ids.NodeID, notification uint32) InboundMessage

+ Expiration func() time.Time

+ Message func() any

type InboundMsgBuilder

+ Parse func(bytes []byte, nodeID ids.NodeID, onFinishedHandling func()) (InboundMessage, error)

+ type MockOutboundMessage struct

+ func NewMockOutboundMessage(ctrl *gomock.Controller) *MockOutboundMessage

+ func (m *MockOutboundMessage) BypassThrottling() bool

+ func (m *MockOutboundMessage) Bytes() []byte

+ func (m *MockOutboundMessage) BytesSavedCompression() int

+ func (m *MockOutboundMessage) EXPECT() *MockOutboundMessageMockRecorder

+ func (m *MockOutboundMessage) Op() Op

+ type MockOutboundMessageMockRecorder struct

+ func (mr *MockOutboundMessageMockRecorder) BypassThrottling() *gomock.Call

+ func (mr *MockOutboundMessageMockRecorder) Bytes() *gomock.Call

+ func (mr *MockOutboundMessageMockRecorder) BytesSavedCompression() *gomock.Call

+ func (mr *MockOutboundMessageMockRecorder) Op() *gomock.Call

+ type MockOutboundMsgBuilder struct

+ func NewMockOutboundMsgBuilder(ctrl *gomock.Controller) *MockOutboundMsgBuilder

+ func (m *MockOutboundMsgBuilder) Accepted(arg0 ids.ID, arg1 uint32, arg2 []ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) AcceptedFrontier(arg0 ids.ID, arg1 uint32, arg2 []ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) AcceptedStateSummary(arg0 ids.ID, arg1 uint32, arg2 []ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) Ancestors(arg0 ids.ID, arg1 uint32, arg2 [][]byte) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) AppGossip(arg0 ids.ID, arg1 []byte) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) AppRequest(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []byte) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) AppResponse(arg0 ids.ID, arg1 uint32, arg2 []byte) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) Chits(arg0 ids.ID, arg1 uint32, arg2 []ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) EXPECT() *MockOutboundMsgBuilderMockRecorder

+ func (m *MockOutboundMsgBuilder) Get(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) GetAccepted(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) GetAcceptedFrontier(arg0 ids.ID, arg1 uint32, arg2 time.Duration) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) GetAcceptedStateSummary(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []uint64) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) GetAncestors(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) GetStateSummaryFrontier(arg0 ids.ID, arg1 uint32, arg2 time.Duration) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) PeerList(arg0 []ips.ClaimedIPPort, arg1 bool) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) PeerListAck(arg0 []ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) Ping() (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) Pong(arg0 uint32, arg1 []*p2p.SubnetUptime) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) PullQuery(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) PushQuery(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []byte) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) Put(arg0 ids.ID, arg1 uint32, arg2 []byte) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) StateSummaryFrontier(arg0 ids.ID, arg1 uint32, arg2 []byte) (OutboundMessage, error)

+ func (m *MockOutboundMsgBuilder) Version(arg0 uint32, arg1 uint64, arg2 ips.IPPort, arg3 string, arg4 uint64, ...) (OutboundMessage, error)

+ type MockOutboundMsgBuilderMockRecorder struct

+ func (mr *MockOutboundMsgBuilderMockRecorder) Accepted(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) AcceptedFrontier(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) AcceptedStateSummary(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) Ancestors(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) AppGossip(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) AppRequest(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) AppResponse(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) Chits(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) Get(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) GetAccepted(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) GetAcceptedFrontier(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) GetAcceptedStateSummary(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) GetAncestors(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) GetStateSummaryFrontier(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) PeerList(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) PeerListAck(arg0 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) Ping() *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) Pong(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) PullQuery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) PushQuery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) Put(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) StateSummaryFrontier(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockOutboundMsgBuilderMockRecorder) Version(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

type Op

+ const AcceptedFrontierOp

+ const AcceptedOp

+ const AcceptedStateSummaryOp

+ const AncestorsOp

+ const AppGossipOp

+ const AppRequestFailedOp

+ const AppRequestOp

+ const AppResponseOp

+ const ChitsOp

+ const ConnectedOp

+ const ConnectedSubnetOp

+ const CrossChainAppRequestFailedOp

+ const CrossChainAppRequestOp

+ const CrossChainAppResponseOp

+ const DisconnectedOp

+ const GetAcceptedFailedOp

+ const GetAcceptedFrontierFailedOp

+ const GetAcceptedFrontierOp

+ const GetAcceptedOp

+ const GetAcceptedStateSummaryFailedOp

+ const GetAcceptedStateSummaryOp

+ const GetAncestorsFailedOp

+ const GetAncestorsOp

+ const GetFailedOp

+ const GetOp

+ const GetStateSummaryFrontierFailedOp

+ const GetStateSummaryFrontierOp

+ const GossipRequestOp

+ const NotifyOp

+ const PeerListAckOp

+ const PeerListOp

+ const PingOp

+ const PongOp

+ const PullQueryOp

+ const PushQueryOp

+ const PutOp

+ const QueryFailedOp

+ const StateSummaryFrontierOp

+ const TimeoutOp

+ const VersionOp

+ func ToOp(m *p2ppb.Message) (Op, error)

type OutboundMsgBuilder

+ PeerListAck func(txIDs []ids.ID) (OutboundMessage, error)

type QueryFailed

+ ChainID ids.ID

+ RequestID uint32

+ func (m *QueryFailed) GetChainId() []byte

+ func (m *QueryFailed) GetRequestId() uint32

type VMMessage

+ Notification uint32

v1.8.6

Dec 6, 2022

v0

v0.1.0

Dec 4, 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL