go-libp2p-kad-dht/messages.pb.go

161 lines
4.1 KiB
Go
Raw Normal View History

// Code generated by protoc-gen-go.
// source: messages.proto
// DO NOT EDIT!
/*
Package dht is a generated protocol buffer package.
It is generated from these files:
messages.proto
It has these top-level messages:
2014-09-16 00:52:57 -07:00
Message
*/
package dht
import proto "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/goprotobuf/proto"
import math "math"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = math.Inf
2014-09-16 00:52:57 -07:00
type Message_MessageType int32
const (
2014-09-16 00:52:57 -07:00
Message_PUT_VALUE Message_MessageType = 0
Message_GET_VALUE Message_MessageType = 1
Message_ADD_PROVIDER Message_MessageType = 2
Message_GET_PROVIDERS Message_MessageType = 3
Message_FIND_NODE Message_MessageType = 4
Message_PING Message_MessageType = 5
)
2014-09-16 00:52:57 -07:00
var Message_MessageType_name = map[int32]string{
0: "PUT_VALUE",
1: "GET_VALUE",
2: "ADD_PROVIDER",
3: "GET_PROVIDERS",
4: "FIND_NODE",
5: "PING",
}
2014-09-16 00:52:57 -07:00
var Message_MessageType_value = map[string]int32{
"PUT_VALUE": 0,
"GET_VALUE": 1,
"ADD_PROVIDER": 2,
"GET_PROVIDERS": 3,
"FIND_NODE": 4,
"PING": 5,
}
2014-09-16 00:52:57 -07:00
func (x Message_MessageType) Enum() *Message_MessageType {
p := new(Message_MessageType)
*p = x
return p
}
2014-09-16 00:52:57 -07:00
func (x Message_MessageType) String() string {
return proto.EnumName(Message_MessageType_name, int32(x))
}
2014-09-16 00:52:57 -07:00
func (x *Message_MessageType) UnmarshalJSON(data []byte) error {
value, err := proto.UnmarshalJSONEnum(Message_MessageType_value, data, "Message_MessageType")
if err != nil {
return err
}
2014-09-16 00:52:57 -07:00
*x = Message_MessageType(value)
return nil
}
2014-09-16 00:52:57 -07:00
type Message struct {
// defines what type of message it is.
Type *Message_MessageType `protobuf:"varint,1,opt,name=type,enum=dht.Message_MessageType" json:"type,omitempty"`
2014-09-16 00:52:57 -07:00
// defines what coral cluster level this query/response belongs to.
ClusterLevelRaw *int32 `protobuf:"varint,10,opt,name=clusterLevelRaw" json:"clusterLevelRaw,omitempty"`
// Used to specify the key associated with this message.
// PUT_VALUE, GET_VALUE, ADD_PROVIDER, GET_PROVIDERS
Key *string `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
// Used to return a value
// PUT_VALUE, GET_VALUE
Value []byte `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
// Used to return peers closer to a key in a query
// GET_VALUE, GET_PROVIDERS, FIND_NODE
CloserPeers []*Message_Peer `protobuf:"bytes,8,rep,name=closerPeers" json:"closerPeers,omitempty"`
// Used to return Providers
// GET_VALUE, ADD_PROVIDER, GET_PROVIDERS
ProviderPeers []*Message_Peer `protobuf:"bytes,9,rep,name=providerPeers" json:"providerPeers,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *Message) Reset() { *m = Message{} }
func (m *Message) String() string { return proto.CompactTextString(m) }
func (*Message) ProtoMessage() {}
func (m *Message) GetType() Message_MessageType {
if m != nil && m.Type != nil {
return *m.Type
}
2014-09-16 00:52:57 -07:00
return Message_PUT_VALUE
}
2014-09-16 00:52:57 -07:00
func (m *Message) GetClusterLevelRaw() int32 {
if m != nil && m.ClusterLevelRaw != nil {
return *m.ClusterLevelRaw
}
return 0
}
func (m *Message) GetKey() string {
if m != nil && m.Key != nil {
return *m.Key
}
return ""
}
2014-09-16 00:52:57 -07:00
func (m *Message) GetValue() []byte {
if m != nil {
return m.Value
}
return nil
}
2014-09-16 00:52:57 -07:00
func (m *Message) GetCloserPeers() []*Message_Peer {
if m != nil {
return m.CloserPeers
}
2014-09-16 00:52:57 -07:00
return nil
}
2014-09-16 00:52:57 -07:00
func (m *Message) GetProviderPeers() []*Message_Peer {
if m != nil {
2014-09-16 00:52:57 -07:00
return m.ProviderPeers
}
return nil
}
2014-09-16 00:52:57 -07:00
type Message_Peer struct {
Id *string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Addr *string `protobuf:"bytes,2,opt,name=addr" json:"addr,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
2014-09-16 00:52:57 -07:00
func (m *Message_Peer) Reset() { *m = Message_Peer{} }
func (m *Message_Peer) String() string { return proto.CompactTextString(m) }
func (*Message_Peer) ProtoMessage() {}
2014-09-16 00:52:57 -07:00
func (m *Message_Peer) GetId() string {
if m != nil && m.Id != nil {
return *m.Id
}
return ""
}
2014-09-16 00:52:57 -07:00
func (m *Message_Peer) GetAddr() string {
if m != nil && m.Addr != nil {
return *m.Addr
}
return ""
}
func init() {
2014-09-16 00:52:57 -07:00
proto.RegisterEnum("dht.Message_MessageType", Message_MessageType_name, Message_MessageType_value)
}