1
// Code generated by protoc-gen-go. DO NOT EDIT.
2
// versions:
3
// 	protoc-gen-go v1.36.11
4
// 	protoc        v7.34.0
5
// source: spec/proto/chord.proto
6
 
7
package protocol
8
 
9
import (
10
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
11
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
12
	reflect "reflect"
13
	sync "sync"
14
	unsafe "unsafe"
15
)
16
 
17
const (
18
	// Verify that this generated code is sufficiently up-to-date.
19
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
20
	// Verify that runtime/protoimpl is sufficiently up-to-date.
21
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
22
)
23
 
24
type Empty struct {
25
	state         protoimpl.MessageState `protogen:"open.v1"`
26
	unknownFields protoimpl.UnknownFields
27
	sizeCache     protoimpl.SizeCache
28
}
29
 
30
func (x *Empty) Reset() {
31
	*x = Empty{}
32
	mi := &file_spec_proto_chord_proto_msgTypes[0]
33
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
34
	ms.StoreMessageInfo(mi)
35
}
36
 
37
func (x *Empty) String() string {
38
	return protoimpl.X.MessageStringOf(x)
39
}
40
 
41
func (*Empty) ProtoMessage() {}
42
 
43
func (x *Empty) ProtoReflect() protoreflect.Message {
44
	mi := &file_spec_proto_chord_proto_msgTypes[0]
45
	if x != nil {
46
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
47
		if ms.LoadMessageInfo() == nil {
48
			ms.StoreMessageInfo(mi)
49
		}
50
		return ms
51
	}
52
	return mi.MessageOf(x)
53
}
54
 
55
// Deprecated: Use Empty.ProtoReflect.Descriptor instead.
56
func (*Empty) Descriptor() ([]byte, []int) {
57
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{0}
58
}
59
 
60
type IdentityRequest struct {
61
	state         protoimpl.MessageState `protogen:"open.v1"`
62
	unknownFields protoimpl.UnknownFields
63
	sizeCache     protoimpl.SizeCache
64
}
65
 
66
func (x *IdentityRequest) Reset() {
67
	*x = IdentityRequest{}
68
	mi := &file_spec_proto_chord_proto_msgTypes[1]
69
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
70
	ms.StoreMessageInfo(mi)
71
}
72
 
73
func (x *IdentityRequest) String() string {
74
	return protoimpl.X.MessageStringOf(x)
75
}
76
 
77
func (*IdentityRequest) ProtoMessage() {}
78
 
79
func (x *IdentityRequest) ProtoReflect() protoreflect.Message {
80
	mi := &file_spec_proto_chord_proto_msgTypes[1]
81
	if x != nil {
82
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
83
		if ms.LoadMessageInfo() == nil {
84
			ms.StoreMessageInfo(mi)
85
		}
86
		return ms
87
	}
88
	return mi.MessageOf(x)
89
}
90
 
91
// Deprecated: Use IdentityRequest.ProtoReflect.Descriptor instead.
92
func (*IdentityRequest) Descriptor() ([]byte, []int) {
93
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{1}
94
}
95
 
96
type IdentityResponse struct {
97
	state         protoimpl.MessageState `protogen:"open.v1"`
98
	Identity      *Node                  `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
99
	unknownFields protoimpl.UnknownFields
100
	sizeCache     protoimpl.SizeCache
101
}
102
 
103
func (x *IdentityResponse) Reset() {
104
	*x = IdentityResponse{}
105
	mi := &file_spec_proto_chord_proto_msgTypes[2]
106
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
107
	ms.StoreMessageInfo(mi)
108
}
109
 
110
func (x *IdentityResponse) String() string {
111
	return protoimpl.X.MessageStringOf(x)
112
}
113
 
114
func (*IdentityResponse) ProtoMessage() {}
115
 
116
func (x *IdentityResponse) ProtoReflect() protoreflect.Message {
117
	mi := &file_spec_proto_chord_proto_msgTypes[2]
118
	if x != nil {
119
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
120
		if ms.LoadMessageInfo() == nil {
121
			ms.StoreMessageInfo(mi)
122
		}
123
		return ms
124
	}
125
	return mi.MessageOf(x)
126
}
127
 
128
// Deprecated: Use IdentityResponse.ProtoReflect.Descriptor instead.
129
func (*IdentityResponse) Descriptor() ([]byte, []int) {
130
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{2}
131
}
132
 
133
func (x *IdentityResponse) GetIdentity() *Node {
134
	if x != nil {
135
		return x.Identity
136
	}
137
	return nil
138
}
139
 
140
type PingRequest struct {
141
	state         protoimpl.MessageState `protogen:"open.v1"`
142
	unknownFields protoimpl.UnknownFields
143
	sizeCache     protoimpl.SizeCache
144
}
145
 
146
func (x *PingRequest) Reset() {
147
	*x = PingRequest{}
148
	mi := &file_spec_proto_chord_proto_msgTypes[3]
149
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
150
	ms.StoreMessageInfo(mi)
151
}
152
 
153
func (x *PingRequest) String() string {
154
	return protoimpl.X.MessageStringOf(x)
155
}
156
 
157
func (*PingRequest) ProtoMessage() {}
158
 
159
func (x *PingRequest) ProtoReflect() protoreflect.Message {
160
	mi := &file_spec_proto_chord_proto_msgTypes[3]
161
	if x != nil {
162
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
163
		if ms.LoadMessageInfo() == nil {
164
			ms.StoreMessageInfo(mi)
165
		}
166
		return ms
167
	}
168
	return mi.MessageOf(x)
169
}
170
 
171
// Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
172
func (*PingRequest) Descriptor() ([]byte, []int) {
173
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{3}
174
}
175
 
176
type PingResponse struct {
177
	state         protoimpl.MessageState `protogen:"open.v1"`
178
	unknownFields protoimpl.UnknownFields
179
	sizeCache     protoimpl.SizeCache
180
}
181
 
182
func (x *PingResponse) Reset() {
183
	*x = PingResponse{}
184
	mi := &file_spec_proto_chord_proto_msgTypes[4]
185
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
186
	ms.StoreMessageInfo(mi)
187
}
188
 
189
func (x *PingResponse) String() string {
190
	return protoimpl.X.MessageStringOf(x)
191
}
192
 
193
func (*PingResponse) ProtoMessage() {}
194
 
195
func (x *PingResponse) ProtoReflect() protoreflect.Message {
196
	mi := &file_spec_proto_chord_proto_msgTypes[4]
197
	if x != nil {
198
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
199
		if ms.LoadMessageInfo() == nil {
200
			ms.StoreMessageInfo(mi)
201
		}
202
		return ms
203
	}
204
	return mi.MessageOf(x)
205
}
206
 
207
// Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
208
func (*PingResponse) Descriptor() ([]byte, []int) {
209
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{4}
210
}
211
 
212
type NotifyRequest struct {
213
	state         protoimpl.MessageState `protogen:"open.v1"`
214
	Predecessor   *Node                  `protobuf:"bytes,1,opt,name=predecessor,proto3" json:"predecessor,omitempty"`
215
	unknownFields protoimpl.UnknownFields
216
	sizeCache     protoimpl.SizeCache
217
}
218
 
219
func (x *NotifyRequest) Reset() {
220
	*x = NotifyRequest{}
221
	mi := &file_spec_proto_chord_proto_msgTypes[5]
222
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
223
	ms.StoreMessageInfo(mi)
224
}
225
 
226
func (x *NotifyRequest) String() string {
227
	return protoimpl.X.MessageStringOf(x)
228
}
229
 
230
func (*NotifyRequest) ProtoMessage() {}
231
 
232
func (x *NotifyRequest) ProtoReflect() protoreflect.Message {
233
	mi := &file_spec_proto_chord_proto_msgTypes[5]
234
	if x != nil {
235
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
236
		if ms.LoadMessageInfo() == nil {
237
			ms.StoreMessageInfo(mi)
238
		}
239
		return ms
240
	}
241
	return mi.MessageOf(x)
242
}
243
 
244
// Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.
245
func (*NotifyRequest) Descriptor() ([]byte, []int) {
246
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{5}
247
}
248
 
249
func (x *NotifyRequest) GetPredecessor() *Node {
250
	if x != nil {
251
		return x.Predecessor
252
	}
253
	return nil
254
}
255
 
256
type NotifyResponse struct {
257
	state         protoimpl.MessageState `protogen:"open.v1"`
258
	unknownFields protoimpl.UnknownFields
259
	sizeCache     protoimpl.SizeCache
260
}
261
 
262
func (x *NotifyResponse) Reset() {
263
	*x = NotifyResponse{}
264
	mi := &file_spec_proto_chord_proto_msgTypes[6]
265
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
266
	ms.StoreMessageInfo(mi)
267
}
268
 
269
func (x *NotifyResponse) String() string {
270
	return protoimpl.X.MessageStringOf(x)
271
}
272
 
273
func (*NotifyResponse) ProtoMessage() {}
274
 
275
func (x *NotifyResponse) ProtoReflect() protoreflect.Message {
276
	mi := &file_spec_proto_chord_proto_msgTypes[6]
277
	if x != nil {
278
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
279
		if ms.LoadMessageInfo() == nil {
280
			ms.StoreMessageInfo(mi)
281
		}
282
		return ms
283
	}
284
	return mi.MessageOf(x)
285
}
286
 
287
// Deprecated: Use NotifyResponse.ProtoReflect.Descriptor instead.
288
func (*NotifyResponse) Descriptor() ([]byte, []int) {
289
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{6}
290
}
291
 
292
type FindSuccessorRequest struct {
293
	state         protoimpl.MessageState `protogen:"open.v1"`
294
	Key           uint64                 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
295
	unknownFields protoimpl.UnknownFields
296
	sizeCache     protoimpl.SizeCache
297
}
298
 
299
func (x *FindSuccessorRequest) Reset() {
300
	*x = FindSuccessorRequest{}
301
	mi := &file_spec_proto_chord_proto_msgTypes[7]
302
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
303
	ms.StoreMessageInfo(mi)
304
}
305
 
306
func (x *FindSuccessorRequest) String() string {
307
	return protoimpl.X.MessageStringOf(x)
308
}
309
 
310
func (*FindSuccessorRequest) ProtoMessage() {}
311
 
312
func (x *FindSuccessorRequest) ProtoReflect() protoreflect.Message {
313
	mi := &file_spec_proto_chord_proto_msgTypes[7]
314
	if x != nil {
315
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
316
		if ms.LoadMessageInfo() == nil {
317
			ms.StoreMessageInfo(mi)
318
		}
319
		return ms
320
	}
321
	return mi.MessageOf(x)
322
}
323
 
324
// Deprecated: Use FindSuccessorRequest.ProtoReflect.Descriptor instead.
325
func (*FindSuccessorRequest) Descriptor() ([]byte, []int) {
326
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{7}
327
}
328
 
329
func (x *FindSuccessorRequest) GetKey() uint64 {
330
	if x != nil {
331
		return x.Key
332
	}
333
	return 0
334
}
335
 
336
type FindSuccessorResponse struct {
337
	state         protoimpl.MessageState `protogen:"open.v1"`
338
	Successor     *Node                  `protobuf:"bytes,1,opt,name=successor,proto3" json:"successor,omitempty"`
339
	unknownFields protoimpl.UnknownFields
340
	sizeCache     protoimpl.SizeCache
341
}
342
 
343
func (x *FindSuccessorResponse) Reset() {
344
	*x = FindSuccessorResponse{}
345
	mi := &file_spec_proto_chord_proto_msgTypes[8]
346
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
347
	ms.StoreMessageInfo(mi)
348
}
349
 
350
func (x *FindSuccessorResponse) String() string {
351
	return protoimpl.X.MessageStringOf(x)
352
}
353
 
354
func (*FindSuccessorResponse) ProtoMessage() {}
355
 
356
func (x *FindSuccessorResponse) ProtoReflect() protoreflect.Message {
357
	mi := &file_spec_proto_chord_proto_msgTypes[8]
358
	if x != nil {
359
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
360
		if ms.LoadMessageInfo() == nil {
361
			ms.StoreMessageInfo(mi)
362
		}
363
		return ms
364
	}
365
	return mi.MessageOf(x)
366
}
367
 
368
// Deprecated: Use FindSuccessorResponse.ProtoReflect.Descriptor instead.
369
func (*FindSuccessorResponse) Descriptor() ([]byte, []int) {
370
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{8}
371
}
372
 
373
func (x *FindSuccessorResponse) GetSuccessor() *Node {
374
	if x != nil {
375
		return x.Successor
376
	}
377
	return nil
378
}
379
 
380
type GetPredecessorRequest struct {
381
	state         protoimpl.MessageState `protogen:"open.v1"`
382
	unknownFields protoimpl.UnknownFields
383
	sizeCache     protoimpl.SizeCache
384
}
385
 
386
func (x *GetPredecessorRequest) Reset() {
387
	*x = GetPredecessorRequest{}
388
	mi := &file_spec_proto_chord_proto_msgTypes[9]
389
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
390
	ms.StoreMessageInfo(mi)
391
}
392
 
393
func (x *GetPredecessorRequest) String() string {
394
	return protoimpl.X.MessageStringOf(x)
395
}
396
 
397
func (*GetPredecessorRequest) ProtoMessage() {}
398
 
399
func (x *GetPredecessorRequest) ProtoReflect() protoreflect.Message {
400
	mi := &file_spec_proto_chord_proto_msgTypes[9]
401
	if x != nil {
402
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
403
		if ms.LoadMessageInfo() == nil {
404
			ms.StoreMessageInfo(mi)
405
		}
406
		return ms
407
	}
408
	return mi.MessageOf(x)
409
}
410
 
411
// Deprecated: Use GetPredecessorRequest.ProtoReflect.Descriptor instead.
412
func (*GetPredecessorRequest) Descriptor() ([]byte, []int) {
413
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{9}
414
}
415
 
416
type GetPredecessorResponse struct {
417
	state         protoimpl.MessageState `protogen:"open.v1"`
418
	Predecessor   *Node                  `protobuf:"bytes,1,opt,name=predecessor,proto3" json:"predecessor,omitempty"`
419
	unknownFields protoimpl.UnknownFields
420
	sizeCache     protoimpl.SizeCache
421
}
422
 
423
func (x *GetPredecessorResponse) Reset() {
424
	*x = GetPredecessorResponse{}
425
	mi := &file_spec_proto_chord_proto_msgTypes[10]
426
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
427
	ms.StoreMessageInfo(mi)
428
}
429
 
430
func (x *GetPredecessorResponse) String() string {
431
	return protoimpl.X.MessageStringOf(x)
432
}
433
 
434
func (*GetPredecessorResponse) ProtoMessage() {}
435
 
436
func (x *GetPredecessorResponse) ProtoReflect() protoreflect.Message {
437
	mi := &file_spec_proto_chord_proto_msgTypes[10]
438
	if x != nil {
439
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
440
		if ms.LoadMessageInfo() == nil {
441
			ms.StoreMessageInfo(mi)
442
		}
443
		return ms
444
	}
445
	return mi.MessageOf(x)
446
}
447
 
448
// Deprecated: Use GetPredecessorResponse.ProtoReflect.Descriptor instead.
449
func (*GetPredecessorResponse) Descriptor() ([]byte, []int) {
450
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{10}
451
}
452
 
453
func (x *GetPredecessorResponse) GetPredecessor() *Node {
454
	if x != nil {
455
		return x.Predecessor
456
	}
457
	return nil
458
}
459
 
460
type GetSuccessorsRequest struct {
461
	state         protoimpl.MessageState `protogen:"open.v1"`
462
	unknownFields protoimpl.UnknownFields
463
	sizeCache     protoimpl.SizeCache
464
}
465
 
466
func (x *GetSuccessorsRequest) Reset() {
467
	*x = GetSuccessorsRequest{}
468
	mi := &file_spec_proto_chord_proto_msgTypes[11]
469
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
470
	ms.StoreMessageInfo(mi)
471
}
472
 
473
func (x *GetSuccessorsRequest) String() string {
474
	return protoimpl.X.MessageStringOf(x)
475
}
476
 
477
func (*GetSuccessorsRequest) ProtoMessage() {}
478
 
479
func (x *GetSuccessorsRequest) ProtoReflect() protoreflect.Message {
480
	mi := &file_spec_proto_chord_proto_msgTypes[11]
481
	if x != nil {
482
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
483
		if ms.LoadMessageInfo() == nil {
484
			ms.StoreMessageInfo(mi)
485
		}
486
		return ms
487
	}
488
	return mi.MessageOf(x)
489
}
490
 
491
// Deprecated: Use GetSuccessorsRequest.ProtoReflect.Descriptor instead.
492
func (*GetSuccessorsRequest) Descriptor() ([]byte, []int) {
493
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{11}
494
}
495
 
496
type GetSuccessorsResponse struct {
497
	state         protoimpl.MessageState `protogen:"open.v1"`
498
	Successors    []*Node                `protobuf:"bytes,1,rep,name=successors,proto3" json:"successors,omitempty"`
499
	unknownFields protoimpl.UnknownFields
500
	sizeCache     protoimpl.SizeCache
501
}
502
 
503
func (x *GetSuccessorsResponse) Reset() {
504
	*x = GetSuccessorsResponse{}
505
	mi := &file_spec_proto_chord_proto_msgTypes[12]
506
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
507
	ms.StoreMessageInfo(mi)
508
}
509
 
510
func (x *GetSuccessorsResponse) String() string {
511
	return protoimpl.X.MessageStringOf(x)
512
}
513
 
514
func (*GetSuccessorsResponse) ProtoMessage() {}
515
 
516
func (x *GetSuccessorsResponse) ProtoReflect() protoreflect.Message {
517
	mi := &file_spec_proto_chord_proto_msgTypes[12]
518
	if x != nil {
519
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
520
		if ms.LoadMessageInfo() == nil {
521
			ms.StoreMessageInfo(mi)
522
		}
523
		return ms
524
	}
525
	return mi.MessageOf(x)
526
}
527
 
528
// Deprecated: Use GetSuccessorsResponse.ProtoReflect.Descriptor instead.
529
func (*GetSuccessorsResponse) Descriptor() ([]byte, []int) {
530
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{12}
531
}
532
 
533
func (x *GetSuccessorsResponse) GetSuccessors() []*Node {
534
	if x != nil {
535
		return x.Successors
536
	}
537
	return nil
538
}
539
 
540
type RequestToJoinRequest struct {
541
	state         protoimpl.MessageState `protogen:"open.v1"`
542
	Joiner        *Node                  `protobuf:"bytes,1,opt,name=joiner,proto3" json:"joiner,omitempty"`
543
	unknownFields protoimpl.UnknownFields
544
	sizeCache     protoimpl.SizeCache
545
}
546
 
547
func (x *RequestToJoinRequest) Reset() {
548
	*x = RequestToJoinRequest{}
549
	mi := &file_spec_proto_chord_proto_msgTypes[13]
550
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
551
	ms.StoreMessageInfo(mi)
552
}
553
 
554
func (x *RequestToJoinRequest) String() string {
555
	return protoimpl.X.MessageStringOf(x)
556
}
557
 
558
func (*RequestToJoinRequest) ProtoMessage() {}
559
 
560
func (x *RequestToJoinRequest) ProtoReflect() protoreflect.Message {
561
	mi := &file_spec_proto_chord_proto_msgTypes[13]
562
	if x != nil {
563
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
564
		if ms.LoadMessageInfo() == nil {
565
			ms.StoreMessageInfo(mi)
566
		}
567
		return ms
568
	}
569
	return mi.MessageOf(x)
570
}
571
 
572
// Deprecated: Use RequestToJoinRequest.ProtoReflect.Descriptor instead.
573
func (*RequestToJoinRequest) Descriptor() ([]byte, []int) {
574
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{13}
575
}
576
 
577
func (x *RequestToJoinRequest) GetJoiner() *Node {
578
	if x != nil {
579
		return x.Joiner
580
	}
581
	return nil
582
}
583
 
584
type RequestToJoinResponse struct {
585
	state         protoimpl.MessageState `protogen:"open.v1"`
586
	Predecessor   *Node                  `protobuf:"bytes,1,opt,name=predecessor,proto3" json:"predecessor,omitempty"`
587
	Successors    []*Node                `protobuf:"bytes,2,rep,name=successors,proto3" json:"successors,omitempty"`
588
	unknownFields protoimpl.UnknownFields
589
	sizeCache     protoimpl.SizeCache
590
}
591
 
592
func (x *RequestToJoinResponse) Reset() {
593
	*x = RequestToJoinResponse{}
594
	mi := &file_spec_proto_chord_proto_msgTypes[14]
595
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
596
	ms.StoreMessageInfo(mi)
597
}
598
 
599
func (x *RequestToJoinResponse) String() string {
600
	return protoimpl.X.MessageStringOf(x)
601
}
602
 
603
func (*RequestToJoinResponse) ProtoMessage() {}
604
 
605
func (x *RequestToJoinResponse) ProtoReflect() protoreflect.Message {
606
	mi := &file_spec_proto_chord_proto_msgTypes[14]
607
	if x != nil {
608
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
609
		if ms.LoadMessageInfo() == nil {
610
			ms.StoreMessageInfo(mi)
611
		}
612
		return ms
613
	}
614
	return mi.MessageOf(x)
615
}
616
 
617
// Deprecated: Use RequestToJoinResponse.ProtoReflect.Descriptor instead.
618
func (*RequestToJoinResponse) Descriptor() ([]byte, []int) {
619
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{14}
620
}
621
 
622
func (x *RequestToJoinResponse) GetPredecessor() *Node {
623
	if x != nil {
624
		return x.Predecessor
625
	}
626
	return nil
627
}
628
 
629
func (x *RequestToJoinResponse) GetSuccessors() []*Node {
630
	if x != nil {
631
		return x.Successors
632
	}
633
	return nil
634
}
635
 
636
type RequestToLeaveRequest struct {
637
	state         protoimpl.MessageState `protogen:"open.v1"`
638
	Leaver        *Node                  `protobuf:"bytes,1,opt,name=leaver,proto3" json:"leaver,omitempty"`
639
	unknownFields protoimpl.UnknownFields
640
	sizeCache     protoimpl.SizeCache
641
}
642
 
643
func (x *RequestToLeaveRequest) Reset() {
644
	*x = RequestToLeaveRequest{}
645
	mi := &file_spec_proto_chord_proto_msgTypes[15]
646
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
647
	ms.StoreMessageInfo(mi)
648
}
649
 
650
func (x *RequestToLeaveRequest) String() string {
651
	return protoimpl.X.MessageStringOf(x)
652
}
653
 
654
func (*RequestToLeaveRequest) ProtoMessage() {}
655
 
656
func (x *RequestToLeaveRequest) ProtoReflect() protoreflect.Message {
657
	mi := &file_spec_proto_chord_proto_msgTypes[15]
658
	if x != nil {
659
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
660
		if ms.LoadMessageInfo() == nil {
661
			ms.StoreMessageInfo(mi)
662
		}
663
		return ms
664
	}
665
	return mi.MessageOf(x)
666
}
667
 
668
// Deprecated: Use RequestToLeaveRequest.ProtoReflect.Descriptor instead.
669
func (*RequestToLeaveRequest) Descriptor() ([]byte, []int) {
670
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{15}
671
}
672
 
673
func (x *RequestToLeaveRequest) GetLeaver() *Node {
674
	if x != nil {
675
		return x.Leaver
676
	}
677
	return nil
678
}
679
 
680
type RequestToLeaveResponse struct {
681
	state         protoimpl.MessageState `protogen:"open.v1"`
682
	unknownFields protoimpl.UnknownFields
683
	sizeCache     protoimpl.SizeCache
684
}
685
 
686
func (x *RequestToLeaveResponse) Reset() {
687
	*x = RequestToLeaveResponse{}
688
	mi := &file_spec_proto_chord_proto_msgTypes[16]
689
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
690
	ms.StoreMessageInfo(mi)
691
}
692
 
693
func (x *RequestToLeaveResponse) String() string {
694
	return protoimpl.X.MessageStringOf(x)
695
}
696
 
697
func (*RequestToLeaveResponse) ProtoMessage() {}
698
 
699
func (x *RequestToLeaveResponse) ProtoReflect() protoreflect.Message {
700
	mi := &file_spec_proto_chord_proto_msgTypes[16]
701
	if x != nil {
702
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
703
		if ms.LoadMessageInfo() == nil {
704
			ms.StoreMessageInfo(mi)
705
		}
706
		return ms
707
	}
708
	return mi.MessageOf(x)
709
}
710
 
711
// Deprecated: Use RequestToLeaveResponse.ProtoReflect.Descriptor instead.
712
func (*RequestToLeaveResponse) Descriptor() ([]byte, []int) {
713
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{16}
714
}
715
 
716
type MembershipConclusionRequest struct {
717
	state         protoimpl.MessageState `protogen:"open.v1"`
718
	Stabilize     bool                   `protobuf:"varint,1,opt,name=stabilize,proto3" json:"stabilize,omitempty"`
719
	Release       bool                   `protobuf:"varint,2,opt,name=release,proto3" json:"release,omitempty"`
720
	unknownFields protoimpl.UnknownFields
721
	sizeCache     protoimpl.SizeCache
722
}
723
 
724
func (x *MembershipConclusionRequest) Reset() {
725
	*x = MembershipConclusionRequest{}
726
	mi := &file_spec_proto_chord_proto_msgTypes[17]
727
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
728
	ms.StoreMessageInfo(mi)
729
}
730
 
731
func (x *MembershipConclusionRequest) String() string {
732
	return protoimpl.X.MessageStringOf(x)
733
}
734
 
735
func (*MembershipConclusionRequest) ProtoMessage() {}
736
 
737
func (x *MembershipConclusionRequest) ProtoReflect() protoreflect.Message {
738
	mi := &file_spec_proto_chord_proto_msgTypes[17]
739
	if x != nil {
740
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
741
		if ms.LoadMessageInfo() == nil {
742
			ms.StoreMessageInfo(mi)
743
		}
744
		return ms
745
	}
746
	return mi.MessageOf(x)
747
}
748
 
749
// Deprecated: Use MembershipConclusionRequest.ProtoReflect.Descriptor instead.
750
func (*MembershipConclusionRequest) Descriptor() ([]byte, []int) {
751
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{17}
752
}
753
 
754
func (x *MembershipConclusionRequest) GetStabilize() bool {
755
	if x != nil {
756
		return x.Stabilize
757
	}
758
	return false
759
}
760
 
761
func (x *MembershipConclusionRequest) GetRelease() bool {
762
	if x != nil {
763
		return x.Release
764
	}
765
	return false
766
}
767
 
768
type MembershipConclusionResponse struct {
769
	state         protoimpl.MessageState `protogen:"open.v1"`
770
	unknownFields protoimpl.UnknownFields
771
	sizeCache     protoimpl.SizeCache
772
}
773
 
774
func (x *MembershipConclusionResponse) Reset() {
775
	*x = MembershipConclusionResponse{}
776
	mi := &file_spec_proto_chord_proto_msgTypes[18]
777
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
778
	ms.StoreMessageInfo(mi)
779
}
780
 
781
func (x *MembershipConclusionResponse) String() string {
782
	return protoimpl.X.MessageStringOf(x)
783
}
784
 
785
func (*MembershipConclusionResponse) ProtoMessage() {}
786
 
787
func (x *MembershipConclusionResponse) ProtoReflect() protoreflect.Message {
788
	mi := &file_spec_proto_chord_proto_msgTypes[18]
789
	if x != nil {
790
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
791
		if ms.LoadMessageInfo() == nil {
792
			ms.StoreMessageInfo(mi)
793
		}
794
		return ms
795
	}
796
	return mi.MessageOf(x)
797
}
798
 
799
// Deprecated: Use MembershipConclusionResponse.ProtoReflect.Descriptor instead.
800
func (*MembershipConclusionResponse) Descriptor() ([]byte, []int) {
801
	return file_spec_proto_chord_proto_rawDescGZIP(), []int{18}
802
}
803
 
804
var File_spec_proto_chord_proto protoreflect.FileDescriptor
805
 
806
const file_spec_proto_chord_proto_rawDesc = "" +
807
	"\n" +
808
	"\x16spec/proto/chord.proto\x12\bprotocol\x1a\x15spec/proto/node.proto\"\a\n" +
809
	"\x05Empty\"\x11\n" +
810
	"\x0fIdentityRequest\">\n" +
811
	"\x10IdentityResponse\x12*\n" +
812
	"\bidentity\x18\x01 \x01(\v2\x0e.protocol.NodeR\bidentity\"\r\n" +
813
	"\vPingRequest\"\x0e\n" +
814
	"\fPingResponse\"A\n" +
815
	"\rNotifyRequest\x120\n" +
816
	"\vpredecessor\x18\x01 \x01(\v2\x0e.protocol.NodeR\vpredecessor\"\x10\n" +
817
	"\x0eNotifyResponse\"(\n" +
818
	"\x14FindSuccessorRequest\x12\x10\n" +
819
	"\x03key\x18\x01 \x01(\x04R\x03key\"E\n" +
820
	"\x15FindSuccessorResponse\x12,\n" +
821
	"\tsuccessor\x18\x01 \x01(\v2\x0e.protocol.NodeR\tsuccessor\"\x17\n" +
822
	"\x15GetPredecessorRequest\"J\n" +
823
	"\x16GetPredecessorResponse\x120\n" +
824
	"\vpredecessor\x18\x01 \x01(\v2\x0e.protocol.NodeR\vpredecessor\"\x16\n" +
825
	"\x14GetSuccessorsRequest\"G\n" +
826
	"\x15GetSuccessorsResponse\x12.\n" +
827
	"\n" +
828
	"successors\x18\x01 \x03(\v2\x0e.protocol.NodeR\n" +
829
	"successors\">\n" +
830
	"\x14RequestToJoinRequest\x12&\n" +
831
	"\x06joiner\x18\x01 \x01(\v2\x0e.protocol.NodeR\x06joiner\"y\n" +
832
	"\x15RequestToJoinResponse\x120\n" +
833
	"\vpredecessor\x18\x01 \x01(\v2\x0e.protocol.NodeR\vpredecessor\x12.\n" +
834
	"\n" +
835
	"successors\x18\x02 \x03(\v2\x0e.protocol.NodeR\n" +
836
	"successors\"?\n" +
837
	"\x15RequestToLeaveRequest\x12&\n" +
838
	"\x06leaver\x18\x01 \x01(\v2\x0e.protocol.NodeR\x06leaver\"\x18\n" +
839
	"\x16RequestToLeaveResponse\"U\n" +
840
	"\x1bMembershipConclusionRequest\x12\x1c\n" +
841
	"\tstabilize\x18\x01 \x01(\bR\tstabilize\x12\x18\n" +
842
	"\arelease\x18\x02 \x01(\bR\arelease\"\x1e\n" +
843
	"\x1cMembershipConclusionResponse2\xa0\x06\n" +
844
	"\fVNodeService\x12A\n" +
845
	"\bIdentity\x12\x19.protocol.IdentityRequest\x1a\x1a.protocol.IdentityResponse\x125\n" +
846
	"\x04Ping\x12\x15.protocol.PingRequest\x1a\x16.protocol.PingResponse\x12;\n" +
847
	"\x06Notify\x12\x17.protocol.NotifyRequest\x1a\x18.protocol.NotifyResponse\x12P\n" +
848
	"\rFindSuccessor\x12\x1e.protocol.FindSuccessorRequest\x1a\x1f.protocol.FindSuccessorResponse\x12P\n" +
849
	"\rGetSuccessors\x12\x1e.protocol.GetSuccessorsRequest\x1a\x1f.protocol.GetSuccessorsResponse\x12S\n" +
850
	"\x0eGetPredecessor\x12\x1f.protocol.GetPredecessorRequest\x1a .protocol.GetPredecessorResponse\x12P\n" +
851
	"\rRequestToJoin\x12\x1e.protocol.RequestToJoinRequest\x1a\x1f.protocol.RequestToJoinResponse\x12[\n" +
852
	"\n" +
853
	"FinishJoin\x12%.protocol.MembershipConclusionRequest\x1a&.protocol.MembershipConclusionResponse\x12S\n" +
854
	"\x0eRequestToLeave\x12\x1f.protocol.RequestToLeaveRequest\x1a .protocol.RequestToLeaveResponse\x12\\\n" +
855
	"\vFinishLeave\x12%.protocol.MembershipConclusionRequest\x1a&.protocol.MembershipConclusionResponseB+H\x01Z'go.miragespace.co/specter/spec/protocolb\x06proto3"
856
 
857
var (
858
	file_spec_proto_chord_proto_rawDescOnce sync.Once
859
	file_spec_proto_chord_proto_rawDescData []byte
860
)
861
 
862
func file_spec_proto_chord_proto_rawDescGZIP() []byte {
863
	file_spec_proto_chord_proto_rawDescOnce.Do(func() {
864
		file_spec_proto_chord_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_spec_proto_chord_proto_rawDesc), len(file_spec_proto_chord_proto_rawDesc)))
865
	})
866
	return file_spec_proto_chord_proto_rawDescData
867
}
868
 
869
var file_spec_proto_chord_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
870
var file_spec_proto_chord_proto_goTypes = []any{
871
	(*Empty)(nil),                        // 0: protocol.Empty
872
	(*IdentityRequest)(nil),              // 1: protocol.IdentityRequest
873
	(*IdentityResponse)(nil),             // 2: protocol.IdentityResponse
874
	(*PingRequest)(nil),                  // 3: protocol.PingRequest
875
	(*PingResponse)(nil),                 // 4: protocol.PingResponse
876
	(*NotifyRequest)(nil),                // 5: protocol.NotifyRequest
877
	(*NotifyResponse)(nil),               // 6: protocol.NotifyResponse
878
	(*FindSuccessorRequest)(nil),         // 7: protocol.FindSuccessorRequest
879
	(*FindSuccessorResponse)(nil),        // 8: protocol.FindSuccessorResponse
880
	(*GetPredecessorRequest)(nil),        // 9: protocol.GetPredecessorRequest
881
	(*GetPredecessorResponse)(nil),       // 10: protocol.GetPredecessorResponse
882
	(*GetSuccessorsRequest)(nil),         // 11: protocol.GetSuccessorsRequest
883
	(*GetSuccessorsResponse)(nil),        // 12: protocol.GetSuccessorsResponse
884
	(*RequestToJoinRequest)(nil),         // 13: protocol.RequestToJoinRequest
885
	(*RequestToJoinResponse)(nil),        // 14: protocol.RequestToJoinResponse
886
	(*RequestToLeaveRequest)(nil),        // 15: protocol.RequestToLeaveRequest
887
	(*RequestToLeaveResponse)(nil),       // 16: protocol.RequestToLeaveResponse
888
	(*MembershipConclusionRequest)(nil),  // 17: protocol.MembershipConclusionRequest
889
	(*MembershipConclusionResponse)(nil), // 18: protocol.MembershipConclusionResponse
890
	(*Node)(nil),                         // 19: protocol.Node
891
}
892
var file_spec_proto_chord_proto_depIdxs = []int32{
893
	19, // 0: protocol.IdentityResponse.identity:type_name -> protocol.Node
894
	19, // 1: protocol.NotifyRequest.predecessor:type_name -> protocol.Node
895
	19, // 2: protocol.FindSuccessorResponse.successor:type_name -> protocol.Node
896
	19, // 3: protocol.GetPredecessorResponse.predecessor:type_name -> protocol.Node
897
	19, // 4: protocol.GetSuccessorsResponse.successors:type_name -> protocol.Node
898
	19, // 5: protocol.RequestToJoinRequest.joiner:type_name -> protocol.Node
899
	19, // 6: protocol.RequestToJoinResponse.predecessor:type_name -> protocol.Node
900
	19, // 7: protocol.RequestToJoinResponse.successors:type_name -> protocol.Node
901
	19, // 8: protocol.RequestToLeaveRequest.leaver:type_name -> protocol.Node
902
	1,  // 9: protocol.VNodeService.Identity:input_type -> protocol.IdentityRequest
903
	3,  // 10: protocol.VNodeService.Ping:input_type -> protocol.PingRequest
904
	5,  // 11: protocol.VNodeService.Notify:input_type -> protocol.NotifyRequest
905
	7,  // 12: protocol.VNodeService.FindSuccessor:input_type -> protocol.FindSuccessorRequest
906
	11, // 13: protocol.VNodeService.GetSuccessors:input_type -> protocol.GetSuccessorsRequest
907
	9,  // 14: protocol.VNodeService.GetPredecessor:input_type -> protocol.GetPredecessorRequest
908
	13, // 15: protocol.VNodeService.RequestToJoin:input_type -> protocol.RequestToJoinRequest
909
	17, // 16: protocol.VNodeService.FinishJoin:input_type -> protocol.MembershipConclusionRequest
910
	15, // 17: protocol.VNodeService.RequestToLeave:input_type -> protocol.RequestToLeaveRequest
911
	17, // 18: protocol.VNodeService.FinishLeave:input_type -> protocol.MembershipConclusionRequest
912
	2,  // 19: protocol.VNodeService.Identity:output_type -> protocol.IdentityResponse
913
	4,  // 20: protocol.VNodeService.Ping:output_type -> protocol.PingResponse
914
	6,  // 21: protocol.VNodeService.Notify:output_type -> protocol.NotifyResponse
915
	8,  // 22: protocol.VNodeService.FindSuccessor:output_type -> protocol.FindSuccessorResponse
916
	12, // 23: protocol.VNodeService.GetSuccessors:output_type -> protocol.GetSuccessorsResponse
917
	10, // 24: protocol.VNodeService.GetPredecessor:output_type -> protocol.GetPredecessorResponse
918
	14, // 25: protocol.VNodeService.RequestToJoin:output_type -> protocol.RequestToJoinResponse
919
	18, // 26: protocol.VNodeService.FinishJoin:output_type -> protocol.MembershipConclusionResponse
920
	16, // 27: protocol.VNodeService.RequestToLeave:output_type -> protocol.RequestToLeaveResponse
921
	18, // 28: protocol.VNodeService.FinishLeave:output_type -> protocol.MembershipConclusionResponse
922
	19, // [19:29] is the sub-list for method output_type
923
	9,  // [9:19] is the sub-list for method input_type
924
	9,  // [9:9] is the sub-list for extension type_name
925
	9,  // [9:9] is the sub-list for extension extendee
926
	0,  // [0:9] is the sub-list for field type_name
927
}
928
 
929
func init() { file_spec_proto_chord_proto_init() }
930
func file_spec_proto_chord_proto_init() {
931
	if File_spec_proto_chord_proto != nil {
932
		return
933
	}
934
	file_spec_proto_node_proto_init()
935
	type x struct{}
936
	out := protoimpl.TypeBuilder{
937
		File: protoimpl.DescBuilder{
938
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
939
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_spec_proto_chord_proto_rawDesc), len(file_spec_proto_chord_proto_rawDesc)),
940
			NumEnums:      0,
941
			NumMessages:   19,
942
			NumExtensions: 0,
943
			NumServices:   1,
944
		},
945
		GoTypes:           file_spec_proto_chord_proto_goTypes,
946
		DependencyIndexes: file_spec_proto_chord_proto_depIdxs,
947
		MessageInfos:      file_spec_proto_chord_proto_msgTypes,
948
	}.Build()
949
	File_spec_proto_chord_proto = out.File
950
	file_spec_proto_chord_proto_goTypes = nil
951
	file_spec_proto_chord_proto_depIdxs = nil
952
}