protobuf

package
v0.0.0-...-b22b80b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 21, 2022 License: Apache-2.0 Imports: 9 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNode   = fmt.Errorf("proto: integer overflow")
)
View Source 
var MessageType_name = map[int32]string{
	0: "PING",
	1: "EXCHANGE_NODE",
	2: "STOP",
	3: "GET_SUCC_AND_PRED",
	4: "FIND_SUCC_AND_PRED",
	5: "BYTES",
}
View Source 
var MessageType_value = map[string]int32{
	"PING":               0,
	"EXCHANGE_NODE":      1,
	"STOP":               2,
	"GET_SUCC_AND_PRED":  3,
	"FIND_SUCC_AND_PRED": 4,
	"BYTES":              5,
}
View Source 
var RoutingType_name = map[int32]string{
	0: "DIRECT",
	1: "RELAY",
	2: "BROADCAST_PUSH",
	3: "BROADCAST_PULL",
	4: "BROADCAST_TREE",
}
View Source 
var RoutingType_value = map[string]int32{
	"DIRECT":         0,
	"RELAY":          1,
	"BROADCAST_PUSH": 2,
	"BROADCAST_PULL": 3,
	"BROADCAST_TREE": 4,
}

Functions

This section is empty.

Types

type Bytes 

type Bytes struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func NewPopulatedBytes 

func NewPopulatedBytes(r randyMessage, easy bool) *Bytes

func (*Bytes) Descriptor 

func (*Bytes) Descriptor() ([]byte, []int)

func (*Bytes) Equal 

func (this *Bytes) Equal(that interface{}) bool

func (*Bytes) GetData 

func (m *Bytes) GetData() []byte

func (*Bytes) GoString 

func (this *Bytes) GoString() string

func (*Bytes) Marshal 

func (m *Bytes) Marshal() (dAtA []byte, err error)

func (*Bytes) MarshalTo 

func (m *Bytes) MarshalTo(dAtA []byte) (int, error)

func (*Bytes) ProtoMessage 

func (*Bytes) ProtoMessage()

func (*Bytes) Reset 

func (m *Bytes) Reset()

func (*Bytes) Size 

func (m *Bytes) Size() (n int)

func (*Bytes) String 

func (this *Bytes) String() string

func (*Bytes) Unmarshal 

func (m *Bytes) Unmarshal(dAtA []byte) error

func (*Bytes) XXX_DiscardUnknown 

func (m *Bytes) XXX_DiscardUnknown()

func (*Bytes) XXX_Marshal 

func (m *Bytes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Bytes) XXX_Merge 

func (dst *Bytes) XXX_Merge(src proto.Message)

func (*Bytes) XXX_Size 

func (m *Bytes) XXX_Size() int

func (*Bytes) XXX_Unmarshal 

func (m *Bytes) XXX_Unmarshal(b []byte) error

type ExchangeNode 

type ExchangeNode struct {
	Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}

func NewPopulatedExchangeNode 

func NewPopulatedExchangeNode(r randyMessage, easy bool) *ExchangeNode

func (*ExchangeNode) Descriptor 

func (*ExchangeNode) Descriptor() ([]byte, []int)

func (*ExchangeNode) Equal 

func (this *ExchangeNode) Equal(that interface{}) bool

func (*ExchangeNode) GetNode 

func (m *ExchangeNode) GetNode() *Node

func (*ExchangeNode) GoString 

func (this *ExchangeNode) GoString() string

func (*ExchangeNode) Marshal 

func (m *ExchangeNode) Marshal() (dAtA []byte, err error)

func (*ExchangeNode) MarshalTo 

func (m *ExchangeNode) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeNode) ProtoMessage 

func (*ExchangeNode) ProtoMessage()

func (*ExchangeNode) Reset 

func (m *ExchangeNode) Reset()

func (*ExchangeNode) Size 

func (m *ExchangeNode) Size() (n int)

func (*ExchangeNode) String 

func (this *ExchangeNode) String() string

func (*ExchangeNode) Unmarshal 

func (m *ExchangeNode) Unmarshal(dAtA []byte) error

func (*ExchangeNode) XXX_DiscardUnknown 

func (m *ExchangeNode) XXX_DiscardUnknown()

func (*ExchangeNode) XXX_Marshal 

func (m *ExchangeNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeNode) XXX_Merge 

func (dst *ExchangeNode) XXX_Merge(src proto.Message)

func (*ExchangeNode) XXX_Size 

func (m *ExchangeNode) XXX_Size() int

func (*ExchangeNode) XXX_Unmarshal 

func (m *ExchangeNode) XXX_Unmarshal(b []byte) error

type ExchangeNodeReply 

type ExchangeNodeReply struct {
	Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}

func NewPopulatedExchangeNodeReply 

func NewPopulatedExchangeNodeReply(r randyMessage, easy bool) *ExchangeNodeReply

func (*ExchangeNodeReply) Descriptor 

func (*ExchangeNodeReply) Descriptor() ([]byte, []int)

func (*ExchangeNodeReply) Equal 

func (this *ExchangeNodeReply) Equal(that interface{}) bool

func (*ExchangeNodeReply) GetNode 

func (m *ExchangeNodeReply) GetNode() *Node

func (*ExchangeNodeReply) GoString 

func (this *ExchangeNodeReply) GoString() string

func (*ExchangeNodeReply) Marshal 

func (m *ExchangeNodeReply) Marshal() (dAtA []byte, err error)

func (*ExchangeNodeReply) MarshalTo 

func (m *ExchangeNodeReply) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeNodeReply) ProtoMessage 

func (*ExchangeNodeReply) ProtoMessage()

func (*ExchangeNodeReply) Reset 

func (m *ExchangeNodeReply) Reset()

func (*ExchangeNodeReply) Size 

func (m *ExchangeNodeReply) Size() (n int)

func (*ExchangeNodeReply) String 

func (this *ExchangeNodeReply) String() string

func (*ExchangeNodeReply) Unmarshal 

func (m *ExchangeNodeReply) Unmarshal(dAtA []byte) error

func (*ExchangeNodeReply) XXX_DiscardUnknown 

func (m *ExchangeNodeReply) XXX_DiscardUnknown()

func (*ExchangeNodeReply) XXX_Marshal 

func (m *ExchangeNodeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeNodeReply) XXX_Merge 

func (dst *ExchangeNodeReply) XXX_Merge(src proto.Message)

func (*ExchangeNodeReply) XXX_Size 

func (m *ExchangeNodeReply) XXX_Size() int

func (*ExchangeNodeReply) XXX_Unmarshal 

func (m *ExchangeNodeReply) XXX_Unmarshal(b []byte) error

type FindSuccAndPred 

type FindSuccAndPred struct {
	Key     []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	NumSucc uint32 `protobuf:"varint,2,opt,name=num_succ,json=numSucc,proto3" json:"num_succ,omitempty"`
	NumPred uint32 `protobuf:"varint,3,opt,name=num_pred,json=numPred,proto3" json:"num_pred,omitempty"`
}

func NewPopulatedFindSuccAndPred 

func NewPopulatedFindSuccAndPred(r randyMessage, easy bool) *FindSuccAndPred

func (*FindSuccAndPred) Descriptor 

func (*FindSuccAndPred) Descriptor() ([]byte, []int)

func (*FindSuccAndPred) Equal 

func (this *FindSuccAndPred) Equal(that interface{}) bool

func (*FindSuccAndPred) GetKey 

func (m *FindSuccAndPred) GetKey() []byte

func (*FindSuccAndPred) GetNumPred 

func (m *FindSuccAndPred) GetNumPred() uint32

func (*FindSuccAndPred) GetNumSucc 

func (m *FindSuccAndPred) GetNumSucc() uint32

func (*FindSuccAndPred) GoString 

func (this *FindSuccAndPred) GoString() string

func (*FindSuccAndPred) Marshal 

func (m *FindSuccAndPred) Marshal() (dAtA []byte, err error)

func (*FindSuccAndPred) MarshalTo 

func (m *FindSuccAndPred) MarshalTo(dAtA []byte) (int, error)

func (*FindSuccAndPred) ProtoMessage 

func (*FindSuccAndPred) ProtoMessage()

func (*FindSuccAndPred) Reset 

func (m *FindSuccAndPred) Reset()

func (*FindSuccAndPred) Size 

func (m *FindSuccAndPred) Size() (n int)

func (*FindSuccAndPred) String 

func (this *FindSuccAndPred) String() string

func (*FindSuccAndPred) Unmarshal 

func (m *FindSuccAndPred) Unmarshal(dAtA []byte) error

func (*FindSuccAndPred) XXX_DiscardUnknown 

func (m *FindSuccAndPred) XXX_DiscardUnknown()

func (*FindSuccAndPred) XXX_Marshal 

func (m *FindSuccAndPred) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindSuccAndPred) XXX_Merge 

func (dst *FindSuccAndPred) XXX_Merge(src proto.Message)

func (*FindSuccAndPred) XXX_Size 

func (m *FindSuccAndPred) XXX_Size() int

func (*FindSuccAndPred) XXX_Unmarshal 

func (m *FindSuccAndPred) XXX_Unmarshal(b []byte) error

type FindSuccAndPredReply 

type FindSuccAndPredReply struct {
	Successors   []*Node `protobuf:"bytes,1,rep,name=successors" json:"successors,omitempty"`
	Predecessors []*Node `protobuf:"bytes,2,rep,name=predecessors" json:"predecessors,omitempty"`
}

func NewPopulatedFindSuccAndPredReply 

func NewPopulatedFindSuccAndPredReply(r randyMessage, easy bool) *FindSuccAndPredReply

func (*FindSuccAndPredReply) Descriptor 

func (*FindSuccAndPredReply) Descriptor() ([]byte, []int)

func (*FindSuccAndPredReply) Equal 

func (this *FindSuccAndPredReply) Equal(that interface{}) bool

func (*FindSuccAndPredReply) GetPredecessors 

func (m *FindSuccAndPredReply) GetPredecessors() []*Node

func (*FindSuccAndPredReply) GetSuccessors 

func (m *FindSuccAndPredReply) GetSuccessors() []*Node

func (*FindSuccAndPredReply) GoString 

func (this *FindSuccAndPredReply) GoString() string

func (*FindSuccAndPredReply) Marshal 

func (m *FindSuccAndPredReply) Marshal() (dAtA []byte, err error)

func (*FindSuccAndPredReply) MarshalTo 

func (m *FindSuccAndPredReply) MarshalTo(dAtA []byte) (int, error)

func (*FindSuccAndPredReply) ProtoMessage 

func (*FindSuccAndPredReply) ProtoMessage()

func (*FindSuccAndPredReply) Reset 

func (m *FindSuccAndPredReply) Reset()

func (*FindSuccAndPredReply) Size 

func (m *FindSuccAndPredReply) Size() (n int)

func (*FindSuccAndPredReply) String 

func (this *FindSuccAndPredReply) String() string

func (*FindSuccAndPredReply) Unmarshal 

func (m *FindSuccAndPredReply) Unmarshal(dAtA []byte) error

func (*FindSuccAndPredReply) XXX_DiscardUnknown 

func (m *FindSuccAndPredReply) XXX_DiscardUnknown()

func (*FindSuccAndPredReply) XXX_Marshal 

func (m *FindSuccAndPredReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindSuccAndPredReply) XXX_Merge 

func (dst *FindSuccAndPredReply) XXX_Merge(src proto.Message)

func (*FindSuccAndPredReply) XXX_Size 

func (m *FindSuccAndPredReply) XXX_Size() int

func (*FindSuccAndPredReply) XXX_Unmarshal 

func (m *FindSuccAndPredReply) XXX_Unmarshal(b []byte) error

type GetSuccAndPred 

type GetSuccAndPred struct {
	NumSucc uint32 `protobuf:"varint,1,opt,name=num_succ,json=numSucc,proto3" json:"num_succ,omitempty"`
	NumPred uint32 `protobuf:"varint,2,opt,name=num_pred,json=numPred,proto3" json:"num_pred,omitempty"`
}

func NewPopulatedGetSuccAndPred 

func NewPopulatedGetSuccAndPred(r randyMessage, easy bool) *GetSuccAndPred

func (*GetSuccAndPred) Descriptor 

func (*GetSuccAndPred) Descriptor() ([]byte, []int)

func (*GetSuccAndPred) Equal 

func (this *GetSuccAndPred) Equal(that interface{}) bool

func (*GetSuccAndPred) GetNumPred 

func (m *GetSuccAndPred) GetNumPred() uint32

func (*GetSuccAndPred) GetNumSucc 

func (m *GetSuccAndPred) GetNumSucc() uint32

func (*GetSuccAndPred) GoString 

func (this *GetSuccAndPred) GoString() string

func (*GetSuccAndPred) Marshal 

func (m *GetSuccAndPred) Marshal() (dAtA []byte, err error)

func (*GetSuccAndPred) MarshalTo 

func (m *GetSuccAndPred) MarshalTo(dAtA []byte) (int, error)

func (*GetSuccAndPred) ProtoMessage 

func (*GetSuccAndPred) ProtoMessage()

func (*GetSuccAndPred) Reset 

func (m *GetSuccAndPred) Reset()

func (*GetSuccAndPred) Size 

func (m *GetSuccAndPred) Size() (n int)

func (*GetSuccAndPred) String 

func (this *GetSuccAndPred) String() string

func (*GetSuccAndPred) Unmarshal 

func (m *GetSuccAndPred) Unmarshal(dAtA []byte) error

func (*GetSuccAndPred) XXX_DiscardUnknown 

func (m *GetSuccAndPred) XXX_DiscardUnknown()

func (*GetSuccAndPred) XXX_Marshal 

func (m *GetSuccAndPred) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSuccAndPred) XXX_Merge 

func (dst *GetSuccAndPred) XXX_Merge(src proto.Message)

func (*GetSuccAndPred) XXX_Size 

func (m *GetSuccAndPred) XXX_Size() int

func (*GetSuccAndPred) XXX_Unmarshal 

func (m *GetSuccAndPred) XXX_Unmarshal(b []byte) error

type GetSuccAndPredReply 

type GetSuccAndPredReply struct {
	Successors   []*Node `protobuf:"bytes,1,rep,name=successors" json:"successors,omitempty"`
	Predecessors []*Node `protobuf:"bytes,2,rep,name=predecessors" json:"predecessors,omitempty"`
}

func NewPopulatedGetSuccAndPredReply 

func NewPopulatedGetSuccAndPredReply(r randyMessage, easy bool) *GetSuccAndPredReply

func (*GetSuccAndPredReply) Descriptor 

func (*GetSuccAndPredReply) Descriptor() ([]byte, []int)

func (*GetSuccAndPredReply) Equal 

func (this *GetSuccAndPredReply) Equal(that interface{}) bool

func (*GetSuccAndPredReply) GetPredecessors 

func (m *GetSuccAndPredReply) GetPredecessors() []*Node

func (*GetSuccAndPredReply) GetSuccessors 

func (m *GetSuccAndPredReply) GetSuccessors() []*Node

func (*GetSuccAndPredReply) GoString 

func (this *GetSuccAndPredReply) GoString() string

func (*GetSuccAndPredReply) Marshal 

func (m *GetSuccAndPredReply) Marshal() (dAtA []byte, err error)

func (*GetSuccAndPredReply) MarshalTo 

func (m *GetSuccAndPredReply) MarshalTo(dAtA []byte) (int, error)

func (*GetSuccAndPredReply) ProtoMessage 

func (*GetSuccAndPredReply) ProtoMessage()

func (*GetSuccAndPredReply) Reset 

func (m *GetSuccAndPredReply) Reset()

func (*GetSuccAndPredReply) Size 

func (m *GetSuccAndPredReply) Size() (n int)

func (*GetSuccAndPredReply) String 

func (this *GetSuccAndPredReply) String() string

func (*GetSuccAndPredReply) Unmarshal 

func (m *GetSuccAndPredReply) Unmarshal(dAtA []byte) error

func (*GetSuccAndPredReply) XXX_DiscardUnknown 

func (m *GetSuccAndPredReply) XXX_DiscardUnknown()

func (*GetSuccAndPredReply) XXX_Marshal 

func (m *GetSuccAndPredReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSuccAndPredReply) XXX_Merge 

func (dst *GetSuccAndPredReply) XXX_Merge(src proto.Message)

func (*GetSuccAndPredReply) XXX_Size 

func (m *GetSuccAndPredReply) XXX_Size() int

func (*GetSuccAndPredReply) XXX_Unmarshal 

func (m *GetSuccAndPredReply) XXX_Unmarshal(b []byte) error

type Message 

type Message struct {
	RoutingType RoutingType `protobuf:"varint,1,opt,name=routing_type,json=routingType,proto3,enum=protobuf.RoutingType" json:"routing_type,omitempty"`
	MessageType MessageType `protobuf:"varint,2,opt,name=message_type,json=messageType,proto3,enum=protobuf.MessageType" json:"message_type,omitempty"`
	Message     []byte      `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	MessageId   []byte      `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	ReplyToId   []byte      `protobuf:"bytes,5,opt,name=reply_to_id,json=replyToId,proto3" json:"reply_to_id,omitempty"`
	SrcId       []byte      `protobuf:"bytes,6,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"`
	DestId      []byte      `protobuf:"bytes,7,opt,name=dest_id,json=destId,proto3" json:"dest_id,omitempty"`
}

func NewPopulatedMessage 

func NewPopulatedMessage(r randyMessage, easy bool) *Message

func (*Message) Descriptor 

func (*Message) Descriptor() ([]byte, []int)

func (*Message) Equal 

func (this *Message) Equal(that interface{}) bool

func (*Message) GetDestId 

func (m *Message) GetDestId() []byte

func (*Message) GetMessage 

func (m *Message) GetMessage() []byte

func (*Message) GetMessageId 

func (m *Message) GetMessageId() []byte

func (*Message) GetMessageType 

func (m *Message) GetMessageType() MessageType

func (*Message) GetReplyToId 

func (m *Message) GetReplyToId() []byte

func (*Message) GetRoutingType 

func (m *Message) GetRoutingType() RoutingType

func (*Message) GetSrcId 

func (m *Message) GetSrcId() []byte

func (*Message) GoString 

func (this *Message) GoString() string

func (*Message) Marshal 

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo 

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

func (m *Message) Size() (n int)

func (*Message) String 

func (this *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []byte) error

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (dst *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

type MessageType 

type MessageType int32
const (
	// Node message
	PING          MessageType = 0
	EXCHANGE_NODE MessageType = 1
	STOP          MessageType = 2
	// Chord message
	GET_SUCC_AND_PRED  MessageType = 3
	FIND_SUCC_AND_PRED MessageType = 4
	// Message that contains any bytes
	BYTES MessageType = 5
)

func (MessageType) EnumDescriptor 

func (MessageType) EnumDescriptor() ([]byte, []int)

func (MessageType) String 

func (x MessageType) String() string

type Node 

type Node struct {
	Id   []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func NewPopulatedNode 

func NewPopulatedNode(r randyNode, easy bool) *Node

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) Equal 

func (this *Node) Equal(that interface{}) bool

func (*Node) GetAddr 

func (m *Node) GetAddr() string

func (*Node) GetData 

func (m *Node) GetData() []byte

func (*Node) GetId 

func (m *Node) GetId() []byte

func (*Node) GoString 

func (this *Node) GoString() string

func (*Node) Marshal 

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo 

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (this *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (dst *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) error

type Ping 

type Ping struct {
}

func NewPopulatedPing 

func NewPopulatedPing(r randyMessage, easy bool) *Ping

func (*Ping) Descriptor 

func (*Ping) Descriptor() ([]byte, []int)

func (*Ping) Equal 

func (this *Ping) Equal(that interface{}) bool

func (*Ping) GoString 

func (this *Ping) GoString() string

func (*Ping) Marshal 

func (m *Ping) Marshal() (dAtA []byte, err error)

func (*Ping) MarshalTo 

func (m *Ping) MarshalTo(dAtA []byte) (int, error)

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) Size 

func (m *Ping) Size() (n int)

func (*Ping) String 

func (this *Ping) String() string

func (*Ping) Unmarshal 

func (m *Ping) Unmarshal(dAtA []byte) error

func (*Ping) XXX_DiscardUnknown 

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal 

func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping) XXX_Merge 

func (dst *Ping) XXX_Merge(src proto.Message)

func (*Ping) XXX_Size 

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal 

func (m *Ping) XXX_Unmarshal(b []byte) error

type PingReply 

type PingReply struct {
}

func NewPopulatedPingReply 

func NewPopulatedPingReply(r randyMessage, easy bool) *PingReply

func (*PingReply) Descriptor 

func (*PingReply) Descriptor() ([]byte, []int)

func (*PingReply) Equal 

func (this *PingReply) Equal(that interface{}) bool

func (*PingReply) GoString 

func (this *PingReply) GoString() string

func (*PingReply) Marshal 

func (m *PingReply) Marshal() (dAtA []byte, err error)

func (*PingReply) MarshalTo 

func (m *PingReply) MarshalTo(dAtA []byte) (int, error)

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) Reset 

func (m *PingReply) Reset()

func (*PingReply) Size 

func (m *PingReply) Size() (n int)

func (*PingReply) String 

func (this *PingReply) String() string

func (*PingReply) Unmarshal 

func (m *PingReply) Unmarshal(dAtA []byte) error

func (*PingReply) XXX_DiscardUnknown 

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal 

func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReply) XXX_Merge 

func (dst *PingReply) XXX_Merge(src proto.Message)

func (*PingReply) XXX_Size 

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal 

func (m *PingReply) XXX_Unmarshal(b []byte) error

type RoutingType 

type RoutingType int32
const (
	DIRECT         RoutingType = 0
	RELAY          RoutingType = 1
	BROADCAST_PUSH RoutingType = 2
	BROADCAST_PULL RoutingType = 3
	BROADCAST_TREE RoutingType = 4
)

func (RoutingType) EnumDescriptor 

func (RoutingType) EnumDescriptor() ([]byte, []int)

func (RoutingType) String 

func (x RoutingType) String() string

type Stop 

type Stop struct {
}

func NewPopulatedStop 

func NewPopulatedStop(r randyMessage, easy bool) *Stop

func (*Stop) Descriptor 

func (*Stop) Descriptor() ([]byte, []int)

func (*Stop) Equal 

func (this *Stop) Equal(that interface{}) bool

func (*Stop) GoString 

func (this *Stop) GoString() string

func (*Stop) Marshal 

func (m *Stop) Marshal() (dAtA []byte, err error)

func (*Stop) MarshalTo 

func (m *Stop) MarshalTo(dAtA []byte) (int, error)

func (*Stop) ProtoMessage 

func (*Stop) ProtoMessage()

func (*Stop) Reset 

func (m *Stop) Reset()

func (*Stop) Size 

func (m *Stop) Size() (n int)

func (*Stop) String 

func (this *Stop) String() string

func (*Stop) Unmarshal 

func (m *Stop) Unmarshal(dAtA []byte) error

func (*Stop) XXX_DiscardUnknown 

func (m *Stop) XXX_DiscardUnknown()

func (*Stop) XXX_Marshal 

func (m *Stop) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stop) XXX_Merge 

func (dst *Stop) XXX_Merge(src proto.Message)

func (*Stop) XXX_Size 

func (m *Stop) XXX_Size() int

func (*Stop) XXX_Unmarshal 

func (m *Stop) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.