message

package
v0.0.0-...-ecfc0d7 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RoutingType_name = map[int32]string{
		0: "DIRECT",
		1: "RELAY",
		2: "BROADCAST_PUSH",
		3: "BROADCAST_PULL",
		4: "BROADCAST_TREE",
	}
	RoutingType_value = map[string]int32{
		"DIRECT":         0,
		"RELAY":          1,
		"BROADCAST_PUSH": 2,
		"BROADCAST_PULL": 3,
		"BROADCAST_TREE": 4,
	}
)

Enum value maps for RoutingType.

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",
	}
	MessageType_value = map[string]int32{
		"PING":               0,
		"EXCHANGE_NODE":      1,
		"STOP":               2,
		"GET_SUCC_AND_PRED":  3,
		"FIND_SUCC_AND_PRED": 4,
		"BYTES":              5,
	}
)

Enum value maps for MessageType.

View Source 
var File_protobuf_message_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Bytes 

type Bytes struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Bytes) Descriptor deprecated 

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

Deprecated: Use Bytes.ProtoReflect.Descriptor instead.

func (*Bytes) GetData 

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

func (*Bytes) ProtoMessage 

func (*Bytes) ProtoMessage()

func (*Bytes) ProtoReflect 

func (x *Bytes) ProtoReflect() protoreflect.Message

func (*Bytes) Reset 

func (x *Bytes) Reset()

func (*Bytes) String 

func (x *Bytes) String() string

type ExchangeNode 

type ExchangeNode struct {
	Node *node.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeNode) Descriptor deprecated 

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

Deprecated: Use ExchangeNode.ProtoReflect.Descriptor instead.

func (*ExchangeNode) GetNode 

func (x *ExchangeNode) GetNode() *node.Node

func (*ExchangeNode) ProtoMessage 

func (*ExchangeNode) ProtoMessage()

func (*ExchangeNode) ProtoReflect 

func (x *ExchangeNode) ProtoReflect() protoreflect.Message

func (*ExchangeNode) Reset 

func (x *ExchangeNode) Reset()

func (*ExchangeNode) String 

func (x *ExchangeNode) String() string

type ExchangeNodeReply 

type ExchangeNodeReply struct {
	Node *node.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeNodeReply) Descriptor deprecated 

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

Deprecated: Use ExchangeNodeReply.ProtoReflect.Descriptor instead.

func (*ExchangeNodeReply) GetNode 

func (x *ExchangeNodeReply) GetNode() *node.Node

func (*ExchangeNodeReply) ProtoMessage 

func (*ExchangeNodeReply) ProtoMessage()

func (*ExchangeNodeReply) ProtoReflect 

func (x *ExchangeNodeReply) ProtoReflect() protoreflect.Message

func (*ExchangeNodeReply) Reset 

func (x *ExchangeNodeReply) Reset()

func (*ExchangeNodeReply) String 

func (x *ExchangeNodeReply) String() string

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"`
	// contains filtered or unexported fields
}

func (*FindSuccAndPred) Descriptor deprecated 

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

Deprecated: Use FindSuccAndPred.ProtoReflect.Descriptor instead.

func (*FindSuccAndPred) GetKey 

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

func (*FindSuccAndPred) GetNumPred 

func (x *FindSuccAndPred) GetNumPred() uint32

func (*FindSuccAndPred) GetNumSucc 

func (x *FindSuccAndPred) GetNumSucc() uint32

func (*FindSuccAndPred) ProtoMessage 

func (*FindSuccAndPred) ProtoMessage()

func (*FindSuccAndPred) ProtoReflect 

func (x *FindSuccAndPred) ProtoReflect() protoreflect.Message

func (*FindSuccAndPred) Reset 

func (x *FindSuccAndPred) Reset()

func (*FindSuccAndPred) String 

func (x *FindSuccAndPred) String() string

type FindSuccAndPredReply 

type FindSuccAndPredReply struct {
	Successors   []*node.Node `protobuf:"bytes,1,rep,name=successors,proto3" json:"successors,omitempty"`
	Predecessors []*node.Node `protobuf:"bytes,2,rep,name=predecessors,proto3" json:"predecessors,omitempty"`
	// contains filtered or unexported fields
}

func (*FindSuccAndPredReply) Descriptor deprecated 

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

Deprecated: Use FindSuccAndPredReply.ProtoReflect.Descriptor instead.

func (*FindSuccAndPredReply) GetPredecessors 

func (x *FindSuccAndPredReply) GetPredecessors() []*node.Node

func (*FindSuccAndPredReply) GetSuccessors 

func (x *FindSuccAndPredReply) GetSuccessors() []*node.Node

func (*FindSuccAndPredReply) ProtoMessage 

func (*FindSuccAndPredReply) ProtoMessage()

func (*FindSuccAndPredReply) ProtoReflect 

func (x *FindSuccAndPredReply) ProtoReflect() protoreflect.Message

func (*FindSuccAndPredReply) Reset 

func (x *FindSuccAndPredReply) Reset()

func (*FindSuccAndPredReply) String 

func (x *FindSuccAndPredReply) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetSuccAndPred) Descriptor deprecated 

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

Deprecated: Use GetSuccAndPred.ProtoReflect.Descriptor instead.

func (*GetSuccAndPred) GetNumPred 

func (x *GetSuccAndPred) GetNumPred() uint32

func (*GetSuccAndPred) GetNumSucc 

func (x *GetSuccAndPred) GetNumSucc() uint32

func (*GetSuccAndPred) ProtoMessage 

func (*GetSuccAndPred) ProtoMessage()

func (*GetSuccAndPred) ProtoReflect 

func (x *GetSuccAndPred) ProtoReflect() protoreflect.Message

func (*GetSuccAndPred) Reset 

func (x *GetSuccAndPred) Reset()

func (*GetSuccAndPred) String 

func (x *GetSuccAndPred) String() string

type GetSuccAndPredReply 

type GetSuccAndPredReply struct {
	Successors   []*node.Node `protobuf:"bytes,1,rep,name=successors,proto3" json:"successors,omitempty"`
	Predecessors []*node.Node `protobuf:"bytes,2,rep,name=predecessors,proto3" json:"predecessors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSuccAndPredReply) Descriptor deprecated 

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

Deprecated: Use GetSuccAndPredReply.ProtoReflect.Descriptor instead.

func (*GetSuccAndPredReply) GetPredecessors 

func (x *GetSuccAndPredReply) GetPredecessors() []*node.Node

func (*GetSuccAndPredReply) GetSuccessors 

func (x *GetSuccAndPredReply) GetSuccessors() []*node.Node

func (*GetSuccAndPredReply) ProtoMessage 

func (*GetSuccAndPredReply) ProtoMessage()

func (*GetSuccAndPredReply) ProtoReflect 

func (x *GetSuccAndPredReply) ProtoReflect() protoreflect.Message

func (*GetSuccAndPredReply) Reset 

func (x *GetSuccAndPredReply) Reset()

func (*GetSuccAndPredReply) String 

func (x *GetSuccAndPredReply) String() string

type Message 

type Message struct {
	RoutingType RoutingType `protobuf:"varint,1,opt,name=routing_type,json=routingType,proto3,enum=RoutingType" json:"routing_type,omitempty"`
	MessageType MessageType `protobuf:"varint,2,opt,name=message_type,json=messageType,proto3,enum=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"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetDestId 

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

func (*Message) GetMessage 

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

func (*Message) GetMessageId 

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

func (*Message) GetMessageType 

func (x *Message) GetMessageType() MessageType

func (*Message) GetReplyToId 

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

func (*Message) GetRoutingType 

func (x *Message) GetRoutingType() RoutingType

func (*Message) GetSrcId 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageType 

type MessageType int32
const (
	// Node message
	MessageType_PING          MessageType = 0
	MessageType_EXCHANGE_NODE MessageType = 1
	MessageType_STOP          MessageType = 2
	// Chord message
	MessageType_GET_SUCC_AND_PRED  MessageType = 3
	MessageType_FIND_SUCC_AND_PRED MessageType = 4
	// Message that contains any bytes
	MessageType_BYTES MessageType = 5
)

func (MessageType) Descriptor 

func (MessageType) Descriptor() protoreflect.EnumDescriptor

func (MessageType) Enum 

func (x MessageType) Enum() *MessageType

func (MessageType) EnumDescriptor deprecated 

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

Deprecated: Use MessageType.Descriptor instead.

func (MessageType) Number 

func (x MessageType) Number() protoreflect.EnumNumber

func (MessageType) String 

func (x MessageType) String() string

func (MessageType) Type 

func (MessageType) Type() protoreflect.EnumType

type Ping 

type Ping struct {
	// contains filtered or unexported fields
}

func (*Ping) Descriptor deprecated 

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect 

func (x *Ping) ProtoReflect() protoreflect.Message

func (*Ping) Reset 

func (x *Ping) Reset()

func (*Ping) String 

func (x *Ping) String() string

type PingReply 

type PingReply struct {
	// contains filtered or unexported fields
}

func (*PingReply) Descriptor deprecated 

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

Deprecated: Use PingReply.ProtoReflect.Descriptor instead.

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) ProtoReflect 

func (x *PingReply) ProtoReflect() protoreflect.Message

func (*PingReply) Reset 

func (x *PingReply) Reset()

func (*PingReply) String 

func (x *PingReply) String() string

type RoutingType 

type RoutingType int32
const (
	RoutingType_DIRECT         RoutingType = 0
	RoutingType_RELAY          RoutingType = 1
	RoutingType_BROADCAST_PUSH RoutingType = 2
	RoutingType_BROADCAST_PULL RoutingType = 3 // to be implemented
	RoutingType_BROADCAST_TREE RoutingType = 4
)

func (RoutingType) Descriptor 

func (RoutingType) Descriptor() protoreflect.EnumDescriptor

func (RoutingType) Enum 

func (x RoutingType) Enum() *RoutingType

func (RoutingType) EnumDescriptor deprecated 

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

Deprecated: Use RoutingType.Descriptor instead.

func (RoutingType) Number 

func (x RoutingType) Number() protoreflect.EnumNumber

func (RoutingType) String 

func (x RoutingType) String() string

func (RoutingType) Type 

func (RoutingType) Type() protoreflect.EnumType

type Stop 

type Stop struct {
	// contains filtered or unexported fields
}

func (*Stop) Descriptor deprecated 

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

Deprecated: Use Stop.ProtoReflect.Descriptor instead.

func (*Stop) ProtoMessage 

func (*Stop) ProtoMessage()

func (*Stop) ProtoReflect 

func (x *Stop) ProtoReflect() protoreflect.Message

func (*Stop) Reset 

func (x *Stop) Reset()

func (*Stop) String 

func (x *Stop) String() string

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.