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/cluster/v1/service.proto
6
7 package clusterv1
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 // LatestSerialResponse contains the latest serial and timestamp
26 type LatestSerialResponse struct {
27 state protoimpl.MessageState `protogen:"open.v1"`
28 Serial uint64 `protobuf:"varint,1,opt,name=serial,proto3" json:"serial,omitempty"`
29 Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Unix timestamp
30 unknownFields protoimpl.UnknownFields
31 sizeCache protoimpl.SizeCache
32 }
33
34 func (x *LatestSerialResponse) Reset() {
35 *x = LatestSerialResponse{}
36 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[0]
37 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
38 ms.StoreMessageInfo(mi)
39 }
40
41 func (x *LatestSerialResponse) String() string {
42 return protoimpl.X.MessageStringOf(x)
43 }
44
45 func (*LatestSerialResponse) ProtoMessage() {}
46
47 func (x *LatestSerialResponse) ProtoReflect() protoreflect.Message {
48 mi := &file_orlysync_cluster_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 LatestSerialResponse.ProtoReflect.Descriptor instead.
60 func (*LatestSerialResponse) Descriptor() ([]byte, []int) {
61 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{0}
62 }
63
64 func (x *LatestSerialResponse) GetSerial() uint64 {
65 if x != nil {
66 return x.Serial
67 }
68 return 0
69 }
70
71 func (x *LatestSerialResponse) GetTimestamp() int64 {
72 if x != nil {
73 return x.Timestamp
74 }
75 return 0
76 }
77
78 // EventsRangeRequest requests events in a serial range
79 type EventsRangeRequest struct {
80 state protoimpl.MessageState `protogen:"open.v1"`
81 From uint64 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"` // Start serial (inclusive)
82 To uint64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"` // End serial (inclusive)
83 Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` // Max events to return
84 unknownFields protoimpl.UnknownFields
85 sizeCache protoimpl.SizeCache
86 }
87
88 func (x *EventsRangeRequest) Reset() {
89 *x = EventsRangeRequest{}
90 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[1]
91 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
92 ms.StoreMessageInfo(mi)
93 }
94
95 func (x *EventsRangeRequest) String() string {
96 return protoimpl.X.MessageStringOf(x)
97 }
98
99 func (*EventsRangeRequest) ProtoMessage() {}
100
101 func (x *EventsRangeRequest) ProtoReflect() protoreflect.Message {
102 mi := &file_orlysync_cluster_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 EventsRangeRequest.ProtoReflect.Descriptor instead.
114 func (*EventsRangeRequest) Descriptor() ([]byte, []int) {
115 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{1}
116 }
117
118 func (x *EventsRangeRequest) GetFrom() uint64 {
119 if x != nil {
120 return x.From
121 }
122 return 0
123 }
124
125 func (x *EventsRangeRequest) GetTo() uint64 {
126 if x != nil {
127 return x.To
128 }
129 return 0
130 }
131
132 func (x *EventsRangeRequest) GetLimit() int32 {
133 if x != nil {
134 return x.Limit
135 }
136 return 0
137 }
138
139 // EventsRangeResponse contains events in the requested range
140 type EventsRangeResponse struct {
141 state protoimpl.MessageState `protogen:"open.v1"`
142 Events []*EventInfo `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
143 HasMore bool `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
144 NextFrom uint64 `protobuf:"varint,3,opt,name=next_from,json=nextFrom,proto3" json:"next_from,omitempty"` // Next serial if has_more is true
145 unknownFields protoimpl.UnknownFields
146 sizeCache protoimpl.SizeCache
147 }
148
149 func (x *EventsRangeResponse) Reset() {
150 *x = EventsRangeResponse{}
151 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[2]
152 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
153 ms.StoreMessageInfo(mi)
154 }
155
156 func (x *EventsRangeResponse) String() string {
157 return protoimpl.X.MessageStringOf(x)
158 }
159
160 func (*EventsRangeResponse) ProtoMessage() {}
161
162 func (x *EventsRangeResponse) ProtoReflect() protoreflect.Message {
163 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[2]
164 if x != nil {
165 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
166 if ms.LoadMessageInfo() == nil {
167 ms.StoreMessageInfo(mi)
168 }
169 return ms
170 }
171 return mi.MessageOf(x)
172 }
173
174 // Deprecated: Use EventsRangeResponse.ProtoReflect.Descriptor instead.
175 func (*EventsRangeResponse) Descriptor() ([]byte, []int) {
176 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{2}
177 }
178
179 func (x *EventsRangeResponse) GetEvents() []*EventInfo {
180 if x != nil {
181 return x.Events
182 }
183 return nil
184 }
185
186 func (x *EventsRangeResponse) GetHasMore() bool {
187 if x != nil {
188 return x.HasMore
189 }
190 return false
191 }
192
193 func (x *EventsRangeResponse) GetNextFrom() uint64 {
194 if x != nil {
195 return x.NextFrom
196 }
197 return 0
198 }
199
200 // EventInfo contains metadata about an event
201 type EventInfo struct {
202 state protoimpl.MessageState `protogen:"open.v1"`
203 Serial uint64 `protobuf:"varint,1,opt,name=serial,proto3" json:"serial,omitempty"`
204 Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // Event ID (hex)
205 Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Created timestamp
206 unknownFields protoimpl.UnknownFields
207 sizeCache protoimpl.SizeCache
208 }
209
210 func (x *EventInfo) Reset() {
211 *x = EventInfo{}
212 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[3]
213 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
214 ms.StoreMessageInfo(mi)
215 }
216
217 func (x *EventInfo) String() string {
218 return protoimpl.X.MessageStringOf(x)
219 }
220
221 func (*EventInfo) ProtoMessage() {}
222
223 func (x *EventInfo) ProtoReflect() protoreflect.Message {
224 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[3]
225 if x != nil {
226 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
227 if ms.LoadMessageInfo() == nil {
228 ms.StoreMessageInfo(mi)
229 }
230 return ms
231 }
232 return mi.MessageOf(x)
233 }
234
235 // Deprecated: Use EventInfo.ProtoReflect.Descriptor instead.
236 func (*EventInfo) Descriptor() ([]byte, []int) {
237 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{3}
238 }
239
240 func (x *EventInfo) GetSerial() uint64 {
241 if x != nil {
242 return x.Serial
243 }
244 return 0
245 }
246
247 func (x *EventInfo) GetId() string {
248 if x != nil {
249 return x.Id
250 }
251 return ""
252 }
253
254 func (x *EventInfo) GetTimestamp() int64 {
255 if x != nil {
256 return x.Timestamp
257 }
258 return 0
259 }
260
261 // ClusterMember represents a cluster member
262 type ClusterMember struct {
263 state protoimpl.MessageState `protogen:"open.v1"`
264 HttpUrl string `protobuf:"bytes,1,opt,name=http_url,json=httpUrl,proto3" json:"http_url,omitempty"`
265 WebsocketUrl string `protobuf:"bytes,2,opt,name=websocket_url,json=websocketUrl,proto3" json:"websocket_url,omitempty"`
266 LastSerial uint64 `protobuf:"varint,3,opt,name=last_serial,json=lastSerial,proto3" json:"last_serial,omitempty"`
267 LastPoll int64 `protobuf:"varint,4,opt,name=last_poll,json=lastPoll,proto3" json:"last_poll,omitempty"` // Unix timestamp
268 Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` // "active", "error", "unknown"
269 ErrorCount int32 `protobuf:"varint,6,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
270 unknownFields protoimpl.UnknownFields
271 sizeCache protoimpl.SizeCache
272 }
273
274 func (x *ClusterMember) Reset() {
275 *x = ClusterMember{}
276 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[4]
277 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
278 ms.StoreMessageInfo(mi)
279 }
280
281 func (x *ClusterMember) String() string {
282 return protoimpl.X.MessageStringOf(x)
283 }
284
285 func (*ClusterMember) ProtoMessage() {}
286
287 func (x *ClusterMember) ProtoReflect() protoreflect.Message {
288 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[4]
289 if x != nil {
290 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
291 if ms.LoadMessageInfo() == nil {
292 ms.StoreMessageInfo(mi)
293 }
294 return ms
295 }
296 return mi.MessageOf(x)
297 }
298
299 // Deprecated: Use ClusterMember.ProtoReflect.Descriptor instead.
300 func (*ClusterMember) Descriptor() ([]byte, []int) {
301 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{4}
302 }
303
304 func (x *ClusterMember) GetHttpUrl() string {
305 if x != nil {
306 return x.HttpUrl
307 }
308 return ""
309 }
310
311 func (x *ClusterMember) GetWebsocketUrl() string {
312 if x != nil {
313 return x.WebsocketUrl
314 }
315 return ""
316 }
317
318 func (x *ClusterMember) GetLastSerial() uint64 {
319 if x != nil {
320 return x.LastSerial
321 }
322 return 0
323 }
324
325 func (x *ClusterMember) GetLastPoll() int64 {
326 if x != nil {
327 return x.LastPoll
328 }
329 return 0
330 }
331
332 func (x *ClusterMember) GetStatus() string {
333 if x != nil {
334 return x.Status
335 }
336 return ""
337 }
338
339 func (x *ClusterMember) GetErrorCount() int32 {
340 if x != nil {
341 return x.ErrorCount
342 }
343 return 0
344 }
345
346 // MembersResponse contains the list of cluster members
347 type MembersResponse struct {
348 state protoimpl.MessageState `protogen:"open.v1"`
349 Members []*ClusterMember `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
350 unknownFields protoimpl.UnknownFields
351 sizeCache protoimpl.SizeCache
352 }
353
354 func (x *MembersResponse) Reset() {
355 *x = MembersResponse{}
356 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[5]
357 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
358 ms.StoreMessageInfo(mi)
359 }
360
361 func (x *MembersResponse) String() string {
362 return protoimpl.X.MessageStringOf(x)
363 }
364
365 func (*MembersResponse) ProtoMessage() {}
366
367 func (x *MembersResponse) ProtoReflect() protoreflect.Message {
368 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[5]
369 if x != nil {
370 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
371 if ms.LoadMessageInfo() == nil {
372 ms.StoreMessageInfo(mi)
373 }
374 return ms
375 }
376 return mi.MessageOf(x)
377 }
378
379 // Deprecated: Use MembersResponse.ProtoReflect.Descriptor instead.
380 func (*MembersResponse) Descriptor() ([]byte, []int) {
381 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{5}
382 }
383
384 func (x *MembersResponse) GetMembers() []*ClusterMember {
385 if x != nil {
386 return x.Members
387 }
388 return nil
389 }
390
391 // UpdateMembershipRequest updates cluster membership
392 type UpdateMembershipRequest struct {
393 state protoimpl.MessageState `protogen:"open.v1"`
394 RelayUrls []string `protobuf:"bytes,1,rep,name=relay_urls,json=relayUrls,proto3" json:"relay_urls,omitempty"` // List of relay URLs to add
395 unknownFields protoimpl.UnknownFields
396 sizeCache protoimpl.SizeCache
397 }
398
399 func (x *UpdateMembershipRequest) Reset() {
400 *x = UpdateMembershipRequest{}
401 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[6]
402 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
403 ms.StoreMessageInfo(mi)
404 }
405
406 func (x *UpdateMembershipRequest) String() string {
407 return protoimpl.X.MessageStringOf(x)
408 }
409
410 func (*UpdateMembershipRequest) ProtoMessage() {}
411
412 func (x *UpdateMembershipRequest) ProtoReflect() protoreflect.Message {
413 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[6]
414 if x != nil {
415 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
416 if ms.LoadMessageInfo() == nil {
417 ms.StoreMessageInfo(mi)
418 }
419 return ms
420 }
421 return mi.MessageOf(x)
422 }
423
424 // Deprecated: Use UpdateMembershipRequest.ProtoReflect.Descriptor instead.
425 func (*UpdateMembershipRequest) Descriptor() ([]byte, []int) {
426 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{6}
427 }
428
429 func (x *UpdateMembershipRequest) GetRelayUrls() []string {
430 if x != nil {
431 return x.RelayUrls
432 }
433 return nil
434 }
435
436 // MembershipEventRequest contains a cluster membership event
437 type MembershipEventRequest struct {
438 state protoimpl.MessageState `protogen:"open.v1"`
439 Event *v1.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
440 unknownFields protoimpl.UnknownFields
441 sizeCache protoimpl.SizeCache
442 }
443
444 func (x *MembershipEventRequest) Reset() {
445 *x = MembershipEventRequest{}
446 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[7]
447 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
448 ms.StoreMessageInfo(mi)
449 }
450
451 func (x *MembershipEventRequest) String() string {
452 return protoimpl.X.MessageStringOf(x)
453 }
454
455 func (*MembershipEventRequest) ProtoMessage() {}
456
457 func (x *MembershipEventRequest) ProtoReflect() protoreflect.Message {
458 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[7]
459 if x != nil {
460 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
461 if ms.LoadMessageInfo() == nil {
462 ms.StoreMessageInfo(mi)
463 }
464 return ms
465 }
466 return mi.MessageOf(x)
467 }
468
469 // Deprecated: Use MembershipEventRequest.ProtoReflect.Descriptor instead.
470 func (*MembershipEventRequest) Descriptor() ([]byte, []int) {
471 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{7}
472 }
473
474 func (x *MembershipEventRequest) GetEvent() *v1.Event {
475 if x != nil {
476 return x.Event
477 }
478 return nil
479 }
480
481 // ClusterStatusResponse contains overall cluster status
482 type ClusterStatusResponse struct {
483 state protoimpl.MessageState `protogen:"open.v1"`
484 LatestSerial uint64 `protobuf:"varint,1,opt,name=latest_serial,json=latestSerial,proto3" json:"latest_serial,omitempty"`
485 ActiveMembers int32 `protobuf:"varint,2,opt,name=active_members,json=activeMembers,proto3" json:"active_members,omitempty"`
486 TotalMembers int32 `protobuf:"varint,3,opt,name=total_members,json=totalMembers,proto3" json:"total_members,omitempty"`
487 PropagatePrivilegedEvents bool `protobuf:"varint,4,opt,name=propagate_privileged_events,json=propagatePrivilegedEvents,proto3" json:"propagate_privileged_events,omitempty"`
488 Members []*ClusterMember `protobuf:"bytes,5,rep,name=members,proto3" json:"members,omitempty"`
489 unknownFields protoimpl.UnknownFields
490 sizeCache protoimpl.SizeCache
491 }
492
493 func (x *ClusterStatusResponse) Reset() {
494 *x = ClusterStatusResponse{}
495 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[8]
496 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
497 ms.StoreMessageInfo(mi)
498 }
499
500 func (x *ClusterStatusResponse) String() string {
501 return protoimpl.X.MessageStringOf(x)
502 }
503
504 func (*ClusterStatusResponse) ProtoMessage() {}
505
506 func (x *ClusterStatusResponse) ProtoReflect() protoreflect.Message {
507 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[8]
508 if x != nil {
509 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
510 if ms.LoadMessageInfo() == nil {
511 ms.StoreMessageInfo(mi)
512 }
513 return ms
514 }
515 return mi.MessageOf(x)
516 }
517
518 // Deprecated: Use ClusterStatusResponse.ProtoReflect.Descriptor instead.
519 func (*ClusterStatusResponse) Descriptor() ([]byte, []int) {
520 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{8}
521 }
522
523 func (x *ClusterStatusResponse) GetLatestSerial() uint64 {
524 if x != nil {
525 return x.LatestSerial
526 }
527 return 0
528 }
529
530 func (x *ClusterStatusResponse) GetActiveMembers() int32 {
531 if x != nil {
532 return x.ActiveMembers
533 }
534 return 0
535 }
536
537 func (x *ClusterStatusResponse) GetTotalMembers() int32 {
538 if x != nil {
539 return x.TotalMembers
540 }
541 return 0
542 }
543
544 func (x *ClusterStatusResponse) GetPropagatePrivilegedEvents() bool {
545 if x != nil {
546 return x.PropagatePrivilegedEvents
547 }
548 return false
549 }
550
551 func (x *ClusterStatusResponse) GetMembers() []*ClusterMember {
552 if x != nil {
553 return x.Members
554 }
555 return nil
556 }
557
558 // MemberStatusRequest requests status for a specific member
559 type MemberStatusRequest struct {
560 state protoimpl.MessageState `protogen:"open.v1"`
561 HttpUrl string `protobuf:"bytes,1,opt,name=http_url,json=httpUrl,proto3" json:"http_url,omitempty"`
562 unknownFields protoimpl.UnknownFields
563 sizeCache protoimpl.SizeCache
564 }
565
566 func (x *MemberStatusRequest) Reset() {
567 *x = MemberStatusRequest{}
568 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[9]
569 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
570 ms.StoreMessageInfo(mi)
571 }
572
573 func (x *MemberStatusRequest) String() string {
574 return protoimpl.X.MessageStringOf(x)
575 }
576
577 func (*MemberStatusRequest) ProtoMessage() {}
578
579 func (x *MemberStatusRequest) ProtoReflect() protoreflect.Message {
580 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[9]
581 if x != nil {
582 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
583 if ms.LoadMessageInfo() == nil {
584 ms.StoreMessageInfo(mi)
585 }
586 return ms
587 }
588 return mi.MessageOf(x)
589 }
590
591 // Deprecated: Use MemberStatusRequest.ProtoReflect.Descriptor instead.
592 func (*MemberStatusRequest) Descriptor() ([]byte, []int) {
593 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{9}
594 }
595
596 func (x *MemberStatusRequest) GetHttpUrl() string {
597 if x != nil {
598 return x.HttpUrl
599 }
600 return ""
601 }
602
603 // MemberStatusResponse contains status for a member
604 type MemberStatusResponse struct {
605 state protoimpl.MessageState `protogen:"open.v1"`
606 Member *ClusterMember `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
607 Found bool `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
608 unknownFields protoimpl.UnknownFields
609 sizeCache protoimpl.SizeCache
610 }
611
612 func (x *MemberStatusResponse) Reset() {
613 *x = MemberStatusResponse{}
614 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[10]
615 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
616 ms.StoreMessageInfo(mi)
617 }
618
619 func (x *MemberStatusResponse) String() string {
620 return protoimpl.X.MessageStringOf(x)
621 }
622
623 func (*MemberStatusResponse) ProtoMessage() {}
624
625 func (x *MemberStatusResponse) ProtoReflect() protoreflect.Message {
626 mi := &file_orlysync_cluster_v1_service_proto_msgTypes[10]
627 if x != nil {
628 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
629 if ms.LoadMessageInfo() == nil {
630 ms.StoreMessageInfo(mi)
631 }
632 return ms
633 }
634 return mi.MessageOf(x)
635 }
636
637 // Deprecated: Use MemberStatusResponse.ProtoReflect.Descriptor instead.
638 func (*MemberStatusResponse) Descriptor() ([]byte, []int) {
639 return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{10}
640 }
641
642 func (x *MemberStatusResponse) GetMember() *ClusterMember {
643 if x != nil {
644 return x.Member
645 }
646 return nil
647 }
648
649 func (x *MemberStatusResponse) GetFound() bool {
650 if x != nil {
651 return x.Found
652 }
653 return false
654 }
655
656 var File_orlysync_cluster_v1_service_proto protoreflect.FileDescriptor
657
658 const file_orlysync_cluster_v1_service_proto_rawDesc = "" +
659 "\n" +
660 "!orlysync/cluster/v1/service.proto\x12\x13orlysync.cluster.v1\x1a\x1eorlysync/common/v1/types.proto\"L\n" +
661 "\x14LatestSerialResponse\x12\x16\n" +
662 "\x06serial\x18\x01 \x01(\x04R\x06serial\x12\x1c\n" +
663 "\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\"N\n" +
664 "\x12EventsRangeRequest\x12\x12\n" +
665 "\x04from\x18\x01 \x01(\x04R\x04from\x12\x0e\n" +
666 "\x02to\x18\x02 \x01(\x04R\x02to\x12\x14\n" +
667 "\x05limit\x18\x03 \x01(\x05R\x05limit\"\x85\x01\n" +
668 "\x13EventsRangeResponse\x126\n" +
669 "\x06events\x18\x01 \x03(\v2\x1e.orlysync.cluster.v1.EventInfoR\x06events\x12\x19\n" +
670 "\bhas_more\x18\x02 \x01(\bR\ahasMore\x12\x1b\n" +
671 "\tnext_from\x18\x03 \x01(\x04R\bnextFrom\"Q\n" +
672 "\tEventInfo\x12\x16\n" +
673 "\x06serial\x18\x01 \x01(\x04R\x06serial\x12\x0e\n" +
674 "\x02id\x18\x02 \x01(\tR\x02id\x12\x1c\n" +
675 "\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"\xc6\x01\n" +
676 "\rClusterMember\x12\x19\n" +
677 "\bhttp_url\x18\x01 \x01(\tR\ahttpUrl\x12#\n" +
678 "\rwebsocket_url\x18\x02 \x01(\tR\fwebsocketUrl\x12\x1f\n" +
679 "\vlast_serial\x18\x03 \x01(\x04R\n" +
680 "lastSerial\x12\x1b\n" +
681 "\tlast_poll\x18\x04 \x01(\x03R\blastPoll\x12\x16\n" +
682 "\x06status\x18\x05 \x01(\tR\x06status\x12\x1f\n" +
683 "\verror_count\x18\x06 \x01(\x05R\n" +
684 "errorCount\"O\n" +
685 "\x0fMembersResponse\x12<\n" +
686 "\amembers\x18\x01 \x03(\v2\".orlysync.cluster.v1.ClusterMemberR\amembers\"8\n" +
687 "\x17UpdateMembershipRequest\x12\x1d\n" +
688 "\n" +
689 "relay_urls\x18\x01 \x03(\tR\trelayUrls\"I\n" +
690 "\x16MembershipEventRequest\x12/\n" +
691 "\x05event\x18\x01 \x01(\v2\x19.orlysync.common.v1.EventR\x05event\"\x86\x02\n" +
692 "\x15ClusterStatusResponse\x12#\n" +
693 "\rlatest_serial\x18\x01 \x01(\x04R\flatestSerial\x12%\n" +
694 "\x0eactive_members\x18\x02 \x01(\x05R\ractiveMembers\x12#\n" +
695 "\rtotal_members\x18\x03 \x01(\x05R\ftotalMembers\x12>\n" +
696 "\x1bpropagate_privileged_events\x18\x04 \x01(\bR\x19propagatePrivilegedEvents\x12<\n" +
697 "\amembers\x18\x05 \x03(\v2\".orlysync.cluster.v1.ClusterMemberR\amembers\"0\n" +
698 "\x13MemberStatusRequest\x12\x19\n" +
699 "\bhttp_url\x18\x01 \x01(\tR\ahttpUrl\"h\n" +
700 "\x14MemberStatusResponse\x12:\n" +
701 "\x06member\x18\x01 \x01(\v2\".orlysync.cluster.v1.ClusterMemberR\x06member\x12\x14\n" +
702 "\x05found\x18\x02 \x01(\bR\x05found2\x99\b\n" +
703 "\x12ClusterSyncService\x12E\n" +
704 "\x05Ready\x12\x19.orlysync.common.v1.Empty\x1a!.orlysync.common.v1.ReadyResponse\x12=\n" +
705 "\x05Start\x12\x19.orlysync.common.v1.Empty\x1a\x19.orlysync.common.v1.Empty\x12<\n" +
706 "\x04Stop\x12\x19.orlysync.common.v1.Empty\x1a\x19.orlysync.common.v1.Empty\x12W\n" +
707 "\x12HandleLatestSerial\x12\x1f.orlysync.common.v1.HTTPRequest\x1a .orlysync.common.v1.HTTPResponse\x12V\n" +
708 "\x11HandleEventsRange\x12\x1f.orlysync.common.v1.HTTPRequest\x1a .orlysync.common.v1.HTTPResponse\x12M\n" +
709 "\n" +
710 "GetMembers\x12\x19.orlysync.common.v1.Empty\x1a$.orlysync.cluster.v1.MembersResponse\x12[\n" +
711 "\x10UpdateMembership\x12,.orlysync.cluster.v1.UpdateMembershipRequest\x1a\x19.orlysync.common.v1.Empty\x12_\n" +
712 "\x15HandleMembershipEvent\x12+.orlysync.cluster.v1.MembershipEventRequest\x1a\x19.orlysync.common.v1.Empty\x12Y\n" +
713 "\x10GetClusterStatus\x12\x19.orlysync.common.v1.Empty\x1a*.orlysync.cluster.v1.ClusterStatusResponse\x12f\n" +
714 "\x0fGetMemberStatus\x12(.orlysync.cluster.v1.MemberStatusRequest\x1a).orlysync.cluster.v1.MemberStatusResponse\x12W\n" +
715 "\x0fGetLatestSerial\x12\x19.orlysync.common.v1.Empty\x1a).orlysync.cluster.v1.LatestSerialResponse\x12e\n" +
716 "\x10GetEventsInRange\x12'.orlysync.cluster.v1.EventsRangeRequest\x1a(.orlysync.cluster.v1.EventsRangeResponseB7Z5next.orly.dev/pkg/proto/orlysync/cluster/v1;clusterv1b\x06proto3"
717
718 var (
719 file_orlysync_cluster_v1_service_proto_rawDescOnce sync.Once
720 file_orlysync_cluster_v1_service_proto_rawDescData []byte
721 )
722
723 func file_orlysync_cluster_v1_service_proto_rawDescGZIP() []byte {
724 file_orlysync_cluster_v1_service_proto_rawDescOnce.Do(func() {
725 file_orlysync_cluster_v1_service_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_orlysync_cluster_v1_service_proto_rawDesc), len(file_orlysync_cluster_v1_service_proto_rawDesc)))
726 })
727 return file_orlysync_cluster_v1_service_proto_rawDescData
728 }
729
730 var file_orlysync_cluster_v1_service_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
731 var file_orlysync_cluster_v1_service_proto_goTypes = []any{
732 (*LatestSerialResponse)(nil), // 0: orlysync.cluster.v1.LatestSerialResponse
733 (*EventsRangeRequest)(nil), // 1: orlysync.cluster.v1.EventsRangeRequest
734 (*EventsRangeResponse)(nil), // 2: orlysync.cluster.v1.EventsRangeResponse
735 (*EventInfo)(nil), // 3: orlysync.cluster.v1.EventInfo
736 (*ClusterMember)(nil), // 4: orlysync.cluster.v1.ClusterMember
737 (*MembersResponse)(nil), // 5: orlysync.cluster.v1.MembersResponse
738 (*UpdateMembershipRequest)(nil), // 6: orlysync.cluster.v1.UpdateMembershipRequest
739 (*MembershipEventRequest)(nil), // 7: orlysync.cluster.v1.MembershipEventRequest
740 (*ClusterStatusResponse)(nil), // 8: orlysync.cluster.v1.ClusterStatusResponse
741 (*MemberStatusRequest)(nil), // 9: orlysync.cluster.v1.MemberStatusRequest
742 (*MemberStatusResponse)(nil), // 10: orlysync.cluster.v1.MemberStatusResponse
743 (*v1.Event)(nil), // 11: orlysync.common.v1.Event
744 (*v1.Empty)(nil), // 12: orlysync.common.v1.Empty
745 (*v1.HTTPRequest)(nil), // 13: orlysync.common.v1.HTTPRequest
746 (*v1.ReadyResponse)(nil), // 14: orlysync.common.v1.ReadyResponse
747 (*v1.HTTPResponse)(nil), // 15: orlysync.common.v1.HTTPResponse
748 }
749 var file_orlysync_cluster_v1_service_proto_depIdxs = []int32{
750 3, // 0: orlysync.cluster.v1.EventsRangeResponse.events:type_name -> orlysync.cluster.v1.EventInfo
751 4, // 1: orlysync.cluster.v1.MembersResponse.members:type_name -> orlysync.cluster.v1.ClusterMember
752 11, // 2: orlysync.cluster.v1.MembershipEventRequest.event:type_name -> orlysync.common.v1.Event
753 4, // 3: orlysync.cluster.v1.ClusterStatusResponse.members:type_name -> orlysync.cluster.v1.ClusterMember
754 4, // 4: orlysync.cluster.v1.MemberStatusResponse.member:type_name -> orlysync.cluster.v1.ClusterMember
755 12, // 5: orlysync.cluster.v1.ClusterSyncService.Ready:input_type -> orlysync.common.v1.Empty
756 12, // 6: orlysync.cluster.v1.ClusterSyncService.Start:input_type -> orlysync.common.v1.Empty
757 12, // 7: orlysync.cluster.v1.ClusterSyncService.Stop:input_type -> orlysync.common.v1.Empty
758 13, // 8: orlysync.cluster.v1.ClusterSyncService.HandleLatestSerial:input_type -> orlysync.common.v1.HTTPRequest
759 13, // 9: orlysync.cluster.v1.ClusterSyncService.HandleEventsRange:input_type -> orlysync.common.v1.HTTPRequest
760 12, // 10: orlysync.cluster.v1.ClusterSyncService.GetMembers:input_type -> orlysync.common.v1.Empty
761 6, // 11: orlysync.cluster.v1.ClusterSyncService.UpdateMembership:input_type -> orlysync.cluster.v1.UpdateMembershipRequest
762 7, // 12: orlysync.cluster.v1.ClusterSyncService.HandleMembershipEvent:input_type -> orlysync.cluster.v1.MembershipEventRequest
763 12, // 13: orlysync.cluster.v1.ClusterSyncService.GetClusterStatus:input_type -> orlysync.common.v1.Empty
764 9, // 14: orlysync.cluster.v1.ClusterSyncService.GetMemberStatus:input_type -> orlysync.cluster.v1.MemberStatusRequest
765 12, // 15: orlysync.cluster.v1.ClusterSyncService.GetLatestSerial:input_type -> orlysync.common.v1.Empty
766 1, // 16: orlysync.cluster.v1.ClusterSyncService.GetEventsInRange:input_type -> orlysync.cluster.v1.EventsRangeRequest
767 14, // 17: orlysync.cluster.v1.ClusterSyncService.Ready:output_type -> orlysync.common.v1.ReadyResponse
768 12, // 18: orlysync.cluster.v1.ClusterSyncService.Start:output_type -> orlysync.common.v1.Empty
769 12, // 19: orlysync.cluster.v1.ClusterSyncService.Stop:output_type -> orlysync.common.v1.Empty
770 15, // 20: orlysync.cluster.v1.ClusterSyncService.HandleLatestSerial:output_type -> orlysync.common.v1.HTTPResponse
771 15, // 21: orlysync.cluster.v1.ClusterSyncService.HandleEventsRange:output_type -> orlysync.common.v1.HTTPResponse
772 5, // 22: orlysync.cluster.v1.ClusterSyncService.GetMembers:output_type -> orlysync.cluster.v1.MembersResponse
773 12, // 23: orlysync.cluster.v1.ClusterSyncService.UpdateMembership:output_type -> orlysync.common.v1.Empty
774 12, // 24: orlysync.cluster.v1.ClusterSyncService.HandleMembershipEvent:output_type -> orlysync.common.v1.Empty
775 8, // 25: orlysync.cluster.v1.ClusterSyncService.GetClusterStatus:output_type -> orlysync.cluster.v1.ClusterStatusResponse
776 10, // 26: orlysync.cluster.v1.ClusterSyncService.GetMemberStatus:output_type -> orlysync.cluster.v1.MemberStatusResponse
777 0, // 27: orlysync.cluster.v1.ClusterSyncService.GetLatestSerial:output_type -> orlysync.cluster.v1.LatestSerialResponse
778 2, // 28: orlysync.cluster.v1.ClusterSyncService.GetEventsInRange:output_type -> orlysync.cluster.v1.EventsRangeResponse
779 17, // [17:29] is the sub-list for method output_type
780 5, // [5:17] is the sub-list for method input_type
781 5, // [5:5] is the sub-list for extension type_name
782 5, // [5:5] is the sub-list for extension extendee
783 0, // [0:5] is the sub-list for field type_name
784 }
785
786 func init() { file_orlysync_cluster_v1_service_proto_init() }
787 func file_orlysync_cluster_v1_service_proto_init() {
788 if File_orlysync_cluster_v1_service_proto != nil {
789 return
790 }
791 type x struct{}
792 out := protoimpl.TypeBuilder{
793 File: protoimpl.DescBuilder{
794 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
795 RawDescriptor: unsafe.Slice(unsafe.StringData(file_orlysync_cluster_v1_service_proto_rawDesc), len(file_orlysync_cluster_v1_service_proto_rawDesc)),
796 NumEnums: 0,
797 NumMessages: 11,
798 NumExtensions: 0,
799 NumServices: 1,
800 },
801 GoTypes: file_orlysync_cluster_v1_service_proto_goTypes,
802 DependencyIndexes: file_orlysync_cluster_v1_service_proto_depIdxs,
803 MessageInfos: file_orlysync_cluster_v1_service_proto_msgTypes,
804 }.Build()
805 File_orlysync_cluster_v1_service_proto = out.File
806 file_orlysync_cluster_v1_service_proto_goTypes = nil
807 file_orlysync_cluster_v1_service_proto_depIdxs = nil
808 }
809