service.pb.go raw
1 // Code generated by protoc-gen-go. DO NOT EDIT.
2 // versions:
3 // protoc-gen-go v1.36.11
4 // protoc (unknown)
5 // source: orlysync/distributed/v1/service.proto
6
7 package distributedv1
8
9 import (
10 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
11 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
12 v1 "next.orly.dev/pkg/proto/orlysync/common/v1"
13 reflect "reflect"
14 sync "sync"
15 unsafe "unsafe"
16 )
17
18 const (
19 // Verify that this generated code is sufficiently up-to-date.
20 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
21 // Verify that runtime/protoimpl is sufficiently up-to-date.
22 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
23 )
24
25 // CurrentRequest is sent to request current serial number
26 type CurrentRequest struct {
27 state protoimpl.MessageState `protogen:"open.v1"`
28 NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Requesting node's identity
29 RelayUrl string `protobuf:"bytes,2,opt,name=relay_url,json=relayUrl,proto3" json:"relay_url,omitempty"` // Requesting relay's URL
30 unknownFields protoimpl.UnknownFields
31 sizeCache protoimpl.SizeCache
32 }
33
34 func (x *CurrentRequest) Reset() {
35 *x = CurrentRequest{}
36 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[0]
37 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
38 ms.StoreMessageInfo(mi)
39 }
40
41 func (x *CurrentRequest) String() string {
42 return protoimpl.X.MessageStringOf(x)
43 }
44
45 func (*CurrentRequest) ProtoMessage() {}
46
47 func (x *CurrentRequest) ProtoReflect() protoreflect.Message {
48 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[0]
49 if x != nil {
50 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
51 if ms.LoadMessageInfo() == nil {
52 ms.StoreMessageInfo(mi)
53 }
54 return ms
55 }
56 return mi.MessageOf(x)
57 }
58
59 // Deprecated: Use CurrentRequest.ProtoReflect.Descriptor instead.
60 func (*CurrentRequest) Descriptor() ([]byte, []int) {
61 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{0}
62 }
63
64 func (x *CurrentRequest) GetNodeId() string {
65 if x != nil {
66 return x.NodeId
67 }
68 return ""
69 }
70
71 func (x *CurrentRequest) GetRelayUrl() string {
72 if x != nil {
73 return x.RelayUrl
74 }
75 return ""
76 }
77
78 // CurrentResponse contains the current serial number
79 type CurrentResponse struct {
80 state protoimpl.MessageState `protogen:"open.v1"`
81 NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Responding node's identity
82 RelayUrl string `protobuf:"bytes,2,opt,name=relay_url,json=relayUrl,proto3" json:"relay_url,omitempty"` // Responding relay's URL
83 Serial uint64 `protobuf:"varint,3,opt,name=serial,proto3" json:"serial,omitempty"` // Current serial number
84 unknownFields protoimpl.UnknownFields
85 sizeCache protoimpl.SizeCache
86 }
87
88 func (x *CurrentResponse) Reset() {
89 *x = CurrentResponse{}
90 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[1]
91 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
92 ms.StoreMessageInfo(mi)
93 }
94
95 func (x *CurrentResponse) String() string {
96 return protoimpl.X.MessageStringOf(x)
97 }
98
99 func (*CurrentResponse) ProtoMessage() {}
100
101 func (x *CurrentResponse) ProtoReflect() protoreflect.Message {
102 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[1]
103 if x != nil {
104 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
105 if ms.LoadMessageInfo() == nil {
106 ms.StoreMessageInfo(mi)
107 }
108 return ms
109 }
110 return mi.MessageOf(x)
111 }
112
113 // Deprecated: Use CurrentResponse.ProtoReflect.Descriptor instead.
114 func (*CurrentResponse) Descriptor() ([]byte, []int) {
115 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{1}
116 }
117
118 func (x *CurrentResponse) GetNodeId() string {
119 if x != nil {
120 return x.NodeId
121 }
122 return ""
123 }
124
125 func (x *CurrentResponse) GetRelayUrl() string {
126 if x != nil {
127 return x.RelayUrl
128 }
129 return ""
130 }
131
132 func (x *CurrentResponse) GetSerial() uint64 {
133 if x != nil {
134 return x.Serial
135 }
136 return 0
137 }
138
139 // EventIDsRequest requests event IDs in a serial range
140 type EventIDsRequest struct {
141 state protoimpl.MessageState `protogen:"open.v1"`
142 NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Requesting node's identity
143 RelayUrl string `protobuf:"bytes,2,opt,name=relay_url,json=relayUrl,proto3" json:"relay_url,omitempty"` // Requesting relay's URL
144 From uint64 `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"` // Start serial (inclusive)
145 To uint64 `protobuf:"varint,4,opt,name=to,proto3" json:"to,omitempty"` // End serial (inclusive)
146 unknownFields protoimpl.UnknownFields
147 sizeCache protoimpl.SizeCache
148 }
149
150 func (x *EventIDsRequest) Reset() {
151 *x = EventIDsRequest{}
152 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[2]
153 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
154 ms.StoreMessageInfo(mi)
155 }
156
157 func (x *EventIDsRequest) String() string {
158 return protoimpl.X.MessageStringOf(x)
159 }
160
161 func (*EventIDsRequest) ProtoMessage() {}
162
163 func (x *EventIDsRequest) ProtoReflect() protoreflect.Message {
164 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[2]
165 if x != nil {
166 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
167 if ms.LoadMessageInfo() == nil {
168 ms.StoreMessageInfo(mi)
169 }
170 return ms
171 }
172 return mi.MessageOf(x)
173 }
174
175 // Deprecated: Use EventIDsRequest.ProtoReflect.Descriptor instead.
176 func (*EventIDsRequest) Descriptor() ([]byte, []int) {
177 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{2}
178 }
179
180 func (x *EventIDsRequest) GetNodeId() string {
181 if x != nil {
182 return x.NodeId
183 }
184 return ""
185 }
186
187 func (x *EventIDsRequest) GetRelayUrl() string {
188 if x != nil {
189 return x.RelayUrl
190 }
191 return ""
192 }
193
194 func (x *EventIDsRequest) GetFrom() uint64 {
195 if x != nil {
196 return x.From
197 }
198 return 0
199 }
200
201 func (x *EventIDsRequest) GetTo() uint64 {
202 if x != nil {
203 return x.To
204 }
205 return 0
206 }
207
208 // EventIDsResponse contains event IDs mapped to serial numbers
209 type EventIDsResponse struct {
210 state protoimpl.MessageState `protogen:"open.v1"`
211 EventMap map[string]uint64 `protobuf:"bytes,1,rep,name=event_map,json=eventMap,proto3" json:"event_map,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"` // event_id (hex) -> serial
212 unknownFields protoimpl.UnknownFields
213 sizeCache protoimpl.SizeCache
214 }
215
216 func (x *EventIDsResponse) Reset() {
217 *x = EventIDsResponse{}
218 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[3]
219 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
220 ms.StoreMessageInfo(mi)
221 }
222
223 func (x *EventIDsResponse) String() string {
224 return protoimpl.X.MessageStringOf(x)
225 }
226
227 func (*EventIDsResponse) ProtoMessage() {}
228
229 func (x *EventIDsResponse) ProtoReflect() protoreflect.Message {
230 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[3]
231 if x != nil {
232 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
233 if ms.LoadMessageInfo() == nil {
234 ms.StoreMessageInfo(mi)
235 }
236 return ms
237 }
238 return mi.MessageOf(x)
239 }
240
241 // Deprecated: Use EventIDsResponse.ProtoReflect.Descriptor instead.
242 func (*EventIDsResponse) Descriptor() ([]byte, []int) {
243 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{3}
244 }
245
246 func (x *EventIDsResponse) GetEventMap() map[string]uint64 {
247 if x != nil {
248 return x.EventMap
249 }
250 return nil
251 }
252
253 // PeersResponse contains the list of sync peers
254 type PeersResponse struct {
255 state protoimpl.MessageState `protogen:"open.v1"`
256 Peers []string `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"` // List of peer relay URLs
257 unknownFields protoimpl.UnknownFields
258 sizeCache protoimpl.SizeCache
259 }
260
261 func (x *PeersResponse) Reset() {
262 *x = PeersResponse{}
263 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[4]
264 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
265 ms.StoreMessageInfo(mi)
266 }
267
268 func (x *PeersResponse) String() string {
269 return protoimpl.X.MessageStringOf(x)
270 }
271
272 func (*PeersResponse) ProtoMessage() {}
273
274 func (x *PeersResponse) ProtoReflect() protoreflect.Message {
275 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[4]
276 if x != nil {
277 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
278 if ms.LoadMessageInfo() == nil {
279 ms.StoreMessageInfo(mi)
280 }
281 return ms
282 }
283 return mi.MessageOf(x)
284 }
285
286 // Deprecated: Use PeersResponse.ProtoReflect.Descriptor instead.
287 func (*PeersResponse) Descriptor() ([]byte, []int) {
288 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{4}
289 }
290
291 func (x *PeersResponse) GetPeers() []string {
292 if x != nil {
293 return x.Peers
294 }
295 return nil
296 }
297
298 // UpdatePeersRequest updates the peer list
299 type UpdatePeersRequest struct {
300 state protoimpl.MessageState `protogen:"open.v1"`
301 Peers []string `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"` // New list of peer relay URLs
302 unknownFields protoimpl.UnknownFields
303 sizeCache protoimpl.SizeCache
304 }
305
306 func (x *UpdatePeersRequest) Reset() {
307 *x = UpdatePeersRequest{}
308 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[5]
309 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
310 ms.StoreMessageInfo(mi)
311 }
312
313 func (x *UpdatePeersRequest) String() string {
314 return protoimpl.X.MessageStringOf(x)
315 }
316
317 func (*UpdatePeersRequest) ProtoMessage() {}
318
319 func (x *UpdatePeersRequest) ProtoReflect() protoreflect.Message {
320 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[5]
321 if x != nil {
322 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
323 if ms.LoadMessageInfo() == nil {
324 ms.StoreMessageInfo(mi)
325 }
326 return ms
327 }
328 return mi.MessageOf(x)
329 }
330
331 // Deprecated: Use UpdatePeersRequest.ProtoReflect.Descriptor instead.
332 func (*UpdatePeersRequest) Descriptor() ([]byte, []int) {
333 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{5}
334 }
335
336 func (x *UpdatePeersRequest) GetPeers() []string {
337 if x != nil {
338 return x.Peers
339 }
340 return nil
341 }
342
343 // AuthorizedPeerRequest checks if a peer is authorized
344 type AuthorizedPeerRequest struct {
345 state protoimpl.MessageState `protogen:"open.v1"`
346 PeerUrl string `protobuf:"bytes,1,opt,name=peer_url,json=peerUrl,proto3" json:"peer_url,omitempty"`
347 ExpectedPubkey string `protobuf:"bytes,2,opt,name=expected_pubkey,json=expectedPubkey,proto3" json:"expected_pubkey,omitempty"` // Expected NIP-11 pubkey
348 unknownFields protoimpl.UnknownFields
349 sizeCache protoimpl.SizeCache
350 }
351
352 func (x *AuthorizedPeerRequest) Reset() {
353 *x = AuthorizedPeerRequest{}
354 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[6]
355 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
356 ms.StoreMessageInfo(mi)
357 }
358
359 func (x *AuthorizedPeerRequest) String() string {
360 return protoimpl.X.MessageStringOf(x)
361 }
362
363 func (*AuthorizedPeerRequest) ProtoMessage() {}
364
365 func (x *AuthorizedPeerRequest) ProtoReflect() protoreflect.Message {
366 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[6]
367 if x != nil {
368 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
369 if ms.LoadMessageInfo() == nil {
370 ms.StoreMessageInfo(mi)
371 }
372 return ms
373 }
374 return mi.MessageOf(x)
375 }
376
377 // Deprecated: Use AuthorizedPeerRequest.ProtoReflect.Descriptor instead.
378 func (*AuthorizedPeerRequest) Descriptor() ([]byte, []int) {
379 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{6}
380 }
381
382 func (x *AuthorizedPeerRequest) GetPeerUrl() string {
383 if x != nil {
384 return x.PeerUrl
385 }
386 return ""
387 }
388
389 func (x *AuthorizedPeerRequest) GetExpectedPubkey() string {
390 if x != nil {
391 return x.ExpectedPubkey
392 }
393 return ""
394 }
395
396 // AuthorizedPeerResponse indicates if the peer is authorized
397 type AuthorizedPeerResponse struct {
398 state protoimpl.MessageState `protogen:"open.v1"`
399 Authorized bool `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"`
400 unknownFields protoimpl.UnknownFields
401 sizeCache protoimpl.SizeCache
402 }
403
404 func (x *AuthorizedPeerResponse) Reset() {
405 *x = AuthorizedPeerResponse{}
406 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[7]
407 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
408 ms.StoreMessageInfo(mi)
409 }
410
411 func (x *AuthorizedPeerResponse) String() string {
412 return protoimpl.X.MessageStringOf(x)
413 }
414
415 func (*AuthorizedPeerResponse) ProtoMessage() {}
416
417 func (x *AuthorizedPeerResponse) ProtoReflect() protoreflect.Message {
418 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[7]
419 if x != nil {
420 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
421 if ms.LoadMessageInfo() == nil {
422 ms.StoreMessageInfo(mi)
423 }
424 return ms
425 }
426 return mi.MessageOf(x)
427 }
428
429 // Deprecated: Use AuthorizedPeerResponse.ProtoReflect.Descriptor instead.
430 func (*AuthorizedPeerResponse) Descriptor() ([]byte, []int) {
431 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{7}
432 }
433
434 func (x *AuthorizedPeerResponse) GetAuthorized() bool {
435 if x != nil {
436 return x.Authorized
437 }
438 return false
439 }
440
441 // PeerPubkeyRequest requests the pubkey for a peer
442 type PeerPubkeyRequest struct {
443 state protoimpl.MessageState `protogen:"open.v1"`
444 PeerUrl string `protobuf:"bytes,1,opt,name=peer_url,json=peerUrl,proto3" json:"peer_url,omitempty"`
445 unknownFields protoimpl.UnknownFields
446 sizeCache protoimpl.SizeCache
447 }
448
449 func (x *PeerPubkeyRequest) Reset() {
450 *x = PeerPubkeyRequest{}
451 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[8]
452 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
453 ms.StoreMessageInfo(mi)
454 }
455
456 func (x *PeerPubkeyRequest) String() string {
457 return protoimpl.X.MessageStringOf(x)
458 }
459
460 func (*PeerPubkeyRequest) ProtoMessage() {}
461
462 func (x *PeerPubkeyRequest) ProtoReflect() protoreflect.Message {
463 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[8]
464 if x != nil {
465 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
466 if ms.LoadMessageInfo() == nil {
467 ms.StoreMessageInfo(mi)
468 }
469 return ms
470 }
471 return mi.MessageOf(x)
472 }
473
474 // Deprecated: Use PeerPubkeyRequest.ProtoReflect.Descriptor instead.
475 func (*PeerPubkeyRequest) Descriptor() ([]byte, []int) {
476 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{8}
477 }
478
479 func (x *PeerPubkeyRequest) GetPeerUrl() string {
480 if x != nil {
481 return x.PeerUrl
482 }
483 return ""
484 }
485
486 // PeerPubkeyResponse contains the peer's pubkey
487 type PeerPubkeyResponse struct {
488 state protoimpl.MessageState `protogen:"open.v1"`
489 Pubkey string `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"` // Peer's NIP-11 pubkey (hex or npub)
490 unknownFields protoimpl.UnknownFields
491 sizeCache protoimpl.SizeCache
492 }
493
494 func (x *PeerPubkeyResponse) Reset() {
495 *x = PeerPubkeyResponse{}
496 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[9]
497 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
498 ms.StoreMessageInfo(mi)
499 }
500
501 func (x *PeerPubkeyResponse) String() string {
502 return protoimpl.X.MessageStringOf(x)
503 }
504
505 func (*PeerPubkeyResponse) ProtoMessage() {}
506
507 func (x *PeerPubkeyResponse) ProtoReflect() protoreflect.Message {
508 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[9]
509 if x != nil {
510 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
511 if ms.LoadMessageInfo() == nil {
512 ms.StoreMessageInfo(mi)
513 }
514 return ms
515 }
516 return mi.MessageOf(x)
517 }
518
519 // Deprecated: Use PeerPubkeyResponse.ProtoReflect.Descriptor instead.
520 func (*PeerPubkeyResponse) Descriptor() ([]byte, []int) {
521 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{9}
522 }
523
524 func (x *PeerPubkeyResponse) GetPubkey() string {
525 if x != nil {
526 return x.Pubkey
527 }
528 return ""
529 }
530
531 // NewEventNotification notifies of a new event
532 type NewEventNotification struct {
533 state protoimpl.MessageState `protogen:"open.v1"`
534 EventId []byte `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` // 32 bytes event ID
535 Serial uint64 `protobuf:"varint,2,opt,name=serial,proto3" json:"serial,omitempty"` // Assigned serial number
536 unknownFields protoimpl.UnknownFields
537 sizeCache protoimpl.SizeCache
538 }
539
540 func (x *NewEventNotification) Reset() {
541 *x = NewEventNotification{}
542 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[10]
543 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
544 ms.StoreMessageInfo(mi)
545 }
546
547 func (x *NewEventNotification) String() string {
548 return protoimpl.X.MessageStringOf(x)
549 }
550
551 func (*NewEventNotification) ProtoMessage() {}
552
553 func (x *NewEventNotification) ProtoReflect() protoreflect.Message {
554 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[10]
555 if x != nil {
556 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
557 if ms.LoadMessageInfo() == nil {
558 ms.StoreMessageInfo(mi)
559 }
560 return ms
561 }
562 return mi.MessageOf(x)
563 }
564
565 // Deprecated: Use NewEventNotification.ProtoReflect.Descriptor instead.
566 func (*NewEventNotification) Descriptor() ([]byte, []int) {
567 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{10}
568 }
569
570 func (x *NewEventNotification) GetEventId() []byte {
571 if x != nil {
572 return x.EventId
573 }
574 return nil
575 }
576
577 func (x *NewEventNotification) GetSerial() uint64 {
578 if x != nil {
579 return x.Serial
580 }
581 return 0
582 }
583
584 // SyncStatusResponse contains sync status for all peers
585 type SyncStatusResponse struct {
586 state protoimpl.MessageState `protogen:"open.v1"`
587 CurrentSerial uint64 `protobuf:"varint,1,opt,name=current_serial,json=currentSerial,proto3" json:"current_serial,omitempty"`
588 Peers []*v1.PeerInfo `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
589 unknownFields protoimpl.UnknownFields
590 sizeCache protoimpl.SizeCache
591 }
592
593 func (x *SyncStatusResponse) Reset() {
594 *x = SyncStatusResponse{}
595 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[11]
596 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
597 ms.StoreMessageInfo(mi)
598 }
599
600 func (x *SyncStatusResponse) String() string {
601 return protoimpl.X.MessageStringOf(x)
602 }
603
604 func (*SyncStatusResponse) ProtoMessage() {}
605
606 func (x *SyncStatusResponse) ProtoReflect() protoreflect.Message {
607 mi := &file_orlysync_distributed_v1_service_proto_msgTypes[11]
608 if x != nil {
609 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
610 if ms.LoadMessageInfo() == nil {
611 ms.StoreMessageInfo(mi)
612 }
613 return ms
614 }
615 return mi.MessageOf(x)
616 }
617
618 // Deprecated: Use SyncStatusResponse.ProtoReflect.Descriptor instead.
619 func (*SyncStatusResponse) Descriptor() ([]byte, []int) {
620 return file_orlysync_distributed_v1_service_proto_rawDescGZIP(), []int{11}
621 }
622
623 func (x *SyncStatusResponse) GetCurrentSerial() uint64 {
624 if x != nil {
625 return x.CurrentSerial
626 }
627 return 0
628 }
629
630 func (x *SyncStatusResponse) GetPeers() []*v1.PeerInfo {
631 if x != nil {
632 return x.Peers
633 }
634 return nil
635 }
636
637 var File_orlysync_distributed_v1_service_proto protoreflect.FileDescriptor
638
639 const file_orlysync_distributed_v1_service_proto_rawDesc = "" +
640 "\n" +
641 "%orlysync/distributed/v1/service.proto\x12\x17orlysync.distributed.v1\x1a\x1eorlysync/common/v1/types.proto\"F\n" +
642 "\x0eCurrentRequest\x12\x17\n" +
643 "\anode_id\x18\x01 \x01(\tR\x06nodeId\x12\x1b\n" +
644 "\trelay_url\x18\x02 \x01(\tR\brelayUrl\"_\n" +
645 "\x0fCurrentResponse\x12\x17\n" +
646 "\anode_id\x18\x01 \x01(\tR\x06nodeId\x12\x1b\n" +
647 "\trelay_url\x18\x02 \x01(\tR\brelayUrl\x12\x16\n" +
648 "\x06serial\x18\x03 \x01(\x04R\x06serial\"k\n" +
649 "\x0fEventIDsRequest\x12\x17\n" +
650 "\anode_id\x18\x01 \x01(\tR\x06nodeId\x12\x1b\n" +
651 "\trelay_url\x18\x02 \x01(\tR\brelayUrl\x12\x12\n" +
652 "\x04from\x18\x03 \x01(\x04R\x04from\x12\x0e\n" +
653 "\x02to\x18\x04 \x01(\x04R\x02to\"\xa5\x01\n" +
654 "\x10EventIDsResponse\x12T\n" +
655 "\tevent_map\x18\x01 \x03(\v27.orlysync.distributed.v1.EventIDsResponse.EventMapEntryR\beventMap\x1a;\n" +
656 "\rEventMapEntry\x12\x10\n" +
657 "\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
658 "\x05value\x18\x02 \x01(\x04R\x05value:\x028\x01\"%\n" +
659 "\rPeersResponse\x12\x14\n" +
660 "\x05peers\x18\x01 \x03(\tR\x05peers\"*\n" +
661 "\x12UpdatePeersRequest\x12\x14\n" +
662 "\x05peers\x18\x01 \x03(\tR\x05peers\"[\n" +
663 "\x15AuthorizedPeerRequest\x12\x19\n" +
664 "\bpeer_url\x18\x01 \x01(\tR\apeerUrl\x12'\n" +
665 "\x0fexpected_pubkey\x18\x02 \x01(\tR\x0eexpectedPubkey\"8\n" +
666 "\x16AuthorizedPeerResponse\x12\x1e\n" +
667 "\n" +
668 "authorized\x18\x01 \x01(\bR\n" +
669 "authorized\".\n" +
670 "\x11PeerPubkeyRequest\x12\x19\n" +
671 "\bpeer_url\x18\x01 \x01(\tR\apeerUrl\",\n" +
672 "\x12PeerPubkeyResponse\x12\x16\n" +
673 "\x06pubkey\x18\x01 \x01(\tR\x06pubkey\"I\n" +
674 "\x14NewEventNotification\x12\x19\n" +
675 "\bevent_id\x18\x01 \x01(\fR\aeventId\x12\x16\n" +
676 "\x06serial\x18\x02 \x01(\x04R\x06serial\"o\n" +
677 "\x12SyncStatusResponse\x12%\n" +
678 "\x0ecurrent_serial\x18\x01 \x01(\x04R\rcurrentSerial\x122\n" +
679 "\x05peers\x18\x02 \x03(\v2\x1c.orlysync.common.v1.PeerInfoR\x05peers2\xea\t\n" +
680 "\x16DistributedSyncService\x12E\n" +
681 "\x05Ready\x12\x19.orlysync.common.v1.Empty\x1a!.orlysync.common.v1.ReadyResponse\x12B\n" +
682 "\aGetInfo\x12\x19.orlysync.common.v1.Empty\x1a\x1c.orlysync.common.v1.SyncInfo\x12e\n" +
683 "\x10GetCurrentSerial\x12'.orlysync.distributed.v1.CurrentRequest\x1a(.orlysync.distributed.v1.CurrentResponse\x12b\n" +
684 "\vGetEventIDs\x12(.orlysync.distributed.v1.EventIDsRequest\x1a).orlysync.distributed.v1.EventIDsResponse\x12Y\n" +
685 "\x14HandleCurrentRequest\x12\x1f.orlysync.common.v1.HTTPRequest\x1a .orlysync.common.v1.HTTPResponse\x12Z\n" +
686 "\x15HandleEventIDsRequest\x12\x1f.orlysync.common.v1.HTTPRequest\x1a .orlysync.common.v1.HTTPResponse\x12M\n" +
687 "\bGetPeers\x12\x19.orlysync.common.v1.Empty\x1a&.orlysync.distributed.v1.PeersResponse\x12U\n" +
688 "\vUpdatePeers\x12+.orlysync.distributed.v1.UpdatePeersRequest\x1a\x19.orlysync.common.v1.Empty\x12s\n" +
689 "\x10IsAuthorizedPeer\x12..orlysync.distributed.v1.AuthorizedPeerRequest\x1a/.orlysync.distributed.v1.AuthorizedPeerResponse\x12h\n" +
690 "\rGetPeerPubkey\x12*.orlysync.distributed.v1.PeerPubkeyRequest\x1a+.orlysync.distributed.v1.PeerPubkeyResponse\x12D\n" +
691 "\fUpdateSerial\x12\x19.orlysync.common.v1.Empty\x1a\x19.orlysync.common.v1.Empty\x12Z\n" +
692 "\x0eNotifyNewEvent\x12-.orlysync.distributed.v1.NewEventNotification\x1a\x19.orlysync.common.v1.Empty\x12C\n" +
693 "\vTriggerSync\x12\x19.orlysync.common.v1.Empty\x1a\x19.orlysync.common.v1.Empty\x12W\n" +
694 "\rGetSyncStatus\x12\x19.orlysync.common.v1.Empty\x1a+.orlysync.distributed.v1.SyncStatusResponseB?Z=next.orly.dev/pkg/proto/orlysync/distributed/v1;distributedv1b\x06proto3"
695
696 var (
697 file_orlysync_distributed_v1_service_proto_rawDescOnce sync.Once
698 file_orlysync_distributed_v1_service_proto_rawDescData []byte
699 )
700
701 func file_orlysync_distributed_v1_service_proto_rawDescGZIP() []byte {
702 file_orlysync_distributed_v1_service_proto_rawDescOnce.Do(func() {
703 file_orlysync_distributed_v1_service_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_orlysync_distributed_v1_service_proto_rawDesc), len(file_orlysync_distributed_v1_service_proto_rawDesc)))
704 })
705 return file_orlysync_distributed_v1_service_proto_rawDescData
706 }
707
708 var file_orlysync_distributed_v1_service_proto_msgTypes = make([]protoimpl.MessageInfo, 13)
709 var file_orlysync_distributed_v1_service_proto_goTypes = []any{
710 (*CurrentRequest)(nil), // 0: orlysync.distributed.v1.CurrentRequest
711 (*CurrentResponse)(nil), // 1: orlysync.distributed.v1.CurrentResponse
712 (*EventIDsRequest)(nil), // 2: orlysync.distributed.v1.EventIDsRequest
713 (*EventIDsResponse)(nil), // 3: orlysync.distributed.v1.EventIDsResponse
714 (*PeersResponse)(nil), // 4: orlysync.distributed.v1.PeersResponse
715 (*UpdatePeersRequest)(nil), // 5: orlysync.distributed.v1.UpdatePeersRequest
716 (*AuthorizedPeerRequest)(nil), // 6: orlysync.distributed.v1.AuthorizedPeerRequest
717 (*AuthorizedPeerResponse)(nil), // 7: orlysync.distributed.v1.AuthorizedPeerResponse
718 (*PeerPubkeyRequest)(nil), // 8: orlysync.distributed.v1.PeerPubkeyRequest
719 (*PeerPubkeyResponse)(nil), // 9: orlysync.distributed.v1.PeerPubkeyResponse
720 (*NewEventNotification)(nil), // 10: orlysync.distributed.v1.NewEventNotification
721 (*SyncStatusResponse)(nil), // 11: orlysync.distributed.v1.SyncStatusResponse
722 nil, // 12: orlysync.distributed.v1.EventIDsResponse.EventMapEntry
723 (*v1.PeerInfo)(nil), // 13: orlysync.common.v1.PeerInfo
724 (*v1.Empty)(nil), // 14: orlysync.common.v1.Empty
725 (*v1.HTTPRequest)(nil), // 15: orlysync.common.v1.HTTPRequest
726 (*v1.ReadyResponse)(nil), // 16: orlysync.common.v1.ReadyResponse
727 (*v1.SyncInfo)(nil), // 17: orlysync.common.v1.SyncInfo
728 (*v1.HTTPResponse)(nil), // 18: orlysync.common.v1.HTTPResponse
729 }
730 var file_orlysync_distributed_v1_service_proto_depIdxs = []int32{
731 12, // 0: orlysync.distributed.v1.EventIDsResponse.event_map:type_name -> orlysync.distributed.v1.EventIDsResponse.EventMapEntry
732 13, // 1: orlysync.distributed.v1.SyncStatusResponse.peers:type_name -> orlysync.common.v1.PeerInfo
733 14, // 2: orlysync.distributed.v1.DistributedSyncService.Ready:input_type -> orlysync.common.v1.Empty
734 14, // 3: orlysync.distributed.v1.DistributedSyncService.GetInfo:input_type -> orlysync.common.v1.Empty
735 0, // 4: orlysync.distributed.v1.DistributedSyncService.GetCurrentSerial:input_type -> orlysync.distributed.v1.CurrentRequest
736 2, // 5: orlysync.distributed.v1.DistributedSyncService.GetEventIDs:input_type -> orlysync.distributed.v1.EventIDsRequest
737 15, // 6: orlysync.distributed.v1.DistributedSyncService.HandleCurrentRequest:input_type -> orlysync.common.v1.HTTPRequest
738 15, // 7: orlysync.distributed.v1.DistributedSyncService.HandleEventIDsRequest:input_type -> orlysync.common.v1.HTTPRequest
739 14, // 8: orlysync.distributed.v1.DistributedSyncService.GetPeers:input_type -> orlysync.common.v1.Empty
740 5, // 9: orlysync.distributed.v1.DistributedSyncService.UpdatePeers:input_type -> orlysync.distributed.v1.UpdatePeersRequest
741 6, // 10: orlysync.distributed.v1.DistributedSyncService.IsAuthorizedPeer:input_type -> orlysync.distributed.v1.AuthorizedPeerRequest
742 8, // 11: orlysync.distributed.v1.DistributedSyncService.GetPeerPubkey:input_type -> orlysync.distributed.v1.PeerPubkeyRequest
743 14, // 12: orlysync.distributed.v1.DistributedSyncService.UpdateSerial:input_type -> orlysync.common.v1.Empty
744 10, // 13: orlysync.distributed.v1.DistributedSyncService.NotifyNewEvent:input_type -> orlysync.distributed.v1.NewEventNotification
745 14, // 14: orlysync.distributed.v1.DistributedSyncService.TriggerSync:input_type -> orlysync.common.v1.Empty
746 14, // 15: orlysync.distributed.v1.DistributedSyncService.GetSyncStatus:input_type -> orlysync.common.v1.Empty
747 16, // 16: orlysync.distributed.v1.DistributedSyncService.Ready:output_type -> orlysync.common.v1.ReadyResponse
748 17, // 17: orlysync.distributed.v1.DistributedSyncService.GetInfo:output_type -> orlysync.common.v1.SyncInfo
749 1, // 18: orlysync.distributed.v1.DistributedSyncService.GetCurrentSerial:output_type -> orlysync.distributed.v1.CurrentResponse
750 3, // 19: orlysync.distributed.v1.DistributedSyncService.GetEventIDs:output_type -> orlysync.distributed.v1.EventIDsResponse
751 18, // 20: orlysync.distributed.v1.DistributedSyncService.HandleCurrentRequest:output_type -> orlysync.common.v1.HTTPResponse
752 18, // 21: orlysync.distributed.v1.DistributedSyncService.HandleEventIDsRequest:output_type -> orlysync.common.v1.HTTPResponse
753 4, // 22: orlysync.distributed.v1.DistributedSyncService.GetPeers:output_type -> orlysync.distributed.v1.PeersResponse
754 14, // 23: orlysync.distributed.v1.DistributedSyncService.UpdatePeers:output_type -> orlysync.common.v1.Empty
755 7, // 24: orlysync.distributed.v1.DistributedSyncService.IsAuthorizedPeer:output_type -> orlysync.distributed.v1.AuthorizedPeerResponse
756 9, // 25: orlysync.distributed.v1.DistributedSyncService.GetPeerPubkey:output_type -> orlysync.distributed.v1.PeerPubkeyResponse
757 14, // 26: orlysync.distributed.v1.DistributedSyncService.UpdateSerial:output_type -> orlysync.common.v1.Empty
758 14, // 27: orlysync.distributed.v1.DistributedSyncService.NotifyNewEvent:output_type -> orlysync.common.v1.Empty
759 14, // 28: orlysync.distributed.v1.DistributedSyncService.TriggerSync:output_type -> orlysync.common.v1.Empty
760 11, // 29: orlysync.distributed.v1.DistributedSyncService.GetSyncStatus:output_type -> orlysync.distributed.v1.SyncStatusResponse
761 16, // [16:30] is the sub-list for method output_type
762 2, // [2:16] is the sub-list for method input_type
763 2, // [2:2] is the sub-list for extension type_name
764 2, // [2:2] is the sub-list for extension extendee
765 0, // [0:2] is the sub-list for field type_name
766 }
767
768 func init() { file_orlysync_distributed_v1_service_proto_init() }
769 func file_orlysync_distributed_v1_service_proto_init() {
770 if File_orlysync_distributed_v1_service_proto != nil {
771 return
772 }
773 type x struct{}
774 out := protoimpl.TypeBuilder{
775 File: protoimpl.DescBuilder{
776 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
777 RawDescriptor: unsafe.Slice(unsafe.StringData(file_orlysync_distributed_v1_service_proto_rawDesc), len(file_orlysync_distributed_v1_service_proto_rawDesc)),
778 NumEnums: 0,
779 NumMessages: 13,
780 NumExtensions: 0,
781 NumServices: 1,
782 },
783 GoTypes: file_orlysync_distributed_v1_service_proto_goTypes,
784 DependencyIndexes: file_orlysync_distributed_v1_service_proto_depIdxs,
785 MessageInfos: file_orlysync_distributed_v1_service_proto_msgTypes,
786 }.Build()
787 File_orlysync_distributed_v1_service_proto = out.File
788 file_orlysync_distributed_v1_service_proto_goTypes = nil
789 file_orlysync_distributed_v1_service_proto_depIdxs = nil
790 }
791