dht.pb.go 5.3 KB
Newer Older
1 2
// Code generated by protoc-gen-gogo.
// source: dht.proto
3 4 5
// DO NOT EDIT!

/*
6
Package dht_pb is a generated protocol buffer package.
7 8

It is generated from these files:
9
	dht.proto
10 11

It has these top-level messages:
12
	Message
13
	Record
14
*/
15
package dht_pb
16

Jeromy's avatar
Jeromy committed
17
import proto "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/gogoprotobuf/proto"
18 19
import math "math"

20
// Reference imports to suppress errors if they are not otherwise used.
21 22 23
var _ = proto.Marshal
var _ = math.Inf

24
type Message_MessageType int32
25 26

const (
27 28 29 30 31 32
	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
33 34
)

35
var Message_MessageType_name = map[int32]string{
36 37
	0: "PUT_VALUE",
	1: "GET_VALUE",
38 39 40 41
	2: "ADD_PROVIDER",
	3: "GET_PROVIDERS",
	4: "FIND_NODE",
	5: "PING",
42
}
43
var Message_MessageType_value = map[string]int32{
44 45 46 47 48 49
	"PUT_VALUE":     0,
	"GET_VALUE":     1,
	"ADD_PROVIDER":  2,
	"GET_PROVIDERS": 3,
	"FIND_NODE":     4,
	"PING":          5,
50 51
}

52 53
func (x Message_MessageType) Enum() *Message_MessageType {
	p := new(Message_MessageType)
54 55 56
	*p = x
	return p
}
57 58
func (x Message_MessageType) String() string {
	return proto.EnumName(Message_MessageType_name, int32(x))
59
}
60 61
func (x *Message_MessageType) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(Message_MessageType_value, data, "Message_MessageType")
62 63 64
	if err != nil {
		return err
	}
65
	*x = Message_MessageType(value)
66 67 68
	return nil
}

69 70
type Message struct {
	// defines what type of message it is.
71
	Type *Message_MessageType `protobuf:"varint,1,opt,name=type,enum=dht.pb.Message_MessageType" json:"type,omitempty"`
72 73 74 75 76 77 78
	// 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
79
	Record *Record `protobuf:"bytes,3,opt,name=record" json:"record,omitempty"`
80 81 82 83 84 85 86 87 88 89 90 91 92 93
	// 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 {
94 95 96
	if m != nil && m.Type != nil {
		return *m.Type
	}
97
	return Message_PUT_VALUE
98 99
}

100 101 102 103 104 105 106 107
func (m *Message) GetClusterLevelRaw() int32 {
	if m != nil && m.ClusterLevelRaw != nil {
		return *m.ClusterLevelRaw
	}
	return 0
}

func (m *Message) GetKey() string {
108 109 110 111 112 113
	if m != nil && m.Key != nil {
		return *m.Key
	}
	return ""
}

114
func (m *Message) GetRecord() *Record {
115
	if m != nil {
116
		return m.Record
117 118 119 120
	}
	return nil
}

121 122 123
func (m *Message) GetCloserPeers() []*Message_Peer {
	if m != nil {
		return m.CloserPeers
124
	}
125
	return nil
126 127
}

128
func (m *Message) GetProviderPeers() []*Message_Peer {
129
	if m != nil {
130
		return m.ProviderPeers
131 132 133 134
	}
	return nil
}

135
type Message_Peer struct {
136 137
	Id               *string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Addr             *string `protobuf:"bytes,2,opt,name=addr" json:"addr,omitempty"`
138 139 140
	XXX_unrecognized []byte  `json:"-"`
}

141 142 143
func (m *Message_Peer) Reset()         { *m = Message_Peer{} }
func (m *Message_Peer) String() string { return proto.CompactTextString(m) }
func (*Message_Peer) ProtoMessage()    {}
144

145
func (m *Message_Peer) GetId() string {
146 147 148 149 150 151
	if m != nil && m.Id != nil {
		return *m.Id
	}
	return ""
}

152
func (m *Message_Peer) GetAddr() string {
153 154 155 156 157 158
	if m != nil && m.Addr != nil {
		return *m.Addr
	}
	return ""
}

159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204
// Record represents a dht record that contains a value
// for a key value pair
type Record struct {
	// The key that references this record
	Key *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	// The actual value this record is storing
	Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// hash of the authors public key
	Author *string `protobuf:"bytes,3,opt,name=author" json:"author,omitempty"`
	// A PKI signature for the key+value+author
	Signature        []byte `protobuf:"bytes,4,opt,name=signature" json:"signature,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (m *Record) Reset()         { *m = Record{} }
func (m *Record) String() string { return proto.CompactTextString(m) }
func (*Record) ProtoMessage()    {}

func (m *Record) GetKey() string {
	if m != nil && m.Key != nil {
		return *m.Key
	}
	return ""
}

func (m *Record) GetValue() []byte {
	if m != nil {
		return m.Value
	}
	return nil
}

func (m *Record) GetAuthor() string {
	if m != nil && m.Author != nil {
		return *m.Author
	}
	return ""
}

func (m *Record) GetSignature() []byte {
	if m != nil {
		return m.Signature
	}
	return nil
}

205
func init() {
206
	proto.RegisterEnum("dht.pb.Message_MessageType", Message_MessageType_name, Message_MessageType_value)
207
}