service_grpc.pb.go raw
1 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
2 // versions:
3 // - protoc-gen-go-grpc v1.6.0
4 // - protoc (unknown)
5 // source: orlysync/cluster/v1/service.proto
6
7 package clusterv1
8
9 import (
10 context "context"
11 grpc "google.golang.org/grpc"
12 codes "google.golang.org/grpc/codes"
13 status "google.golang.org/grpc/status"
14 v1 "next.orly.dev/pkg/proto/orlysync/common/v1"
15 )
16
17 // This is a compile-time assertion to ensure that this generated file
18 // is compatible with the grpc package it is being compiled against.
19 // Requires gRPC-Go v1.64.0 or later.
20 const _ = grpc.SupportPackageIsVersion9
21
22 const (
23 ClusterSyncService_Ready_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/Ready"
24 ClusterSyncService_Start_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/Start"
25 ClusterSyncService_Stop_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/Stop"
26 ClusterSyncService_HandleLatestSerial_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/HandleLatestSerial"
27 ClusterSyncService_HandleEventsRange_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/HandleEventsRange"
28 ClusterSyncService_GetMembers_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/GetMembers"
29 ClusterSyncService_UpdateMembership_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/UpdateMembership"
30 ClusterSyncService_HandleMembershipEvent_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/HandleMembershipEvent"
31 ClusterSyncService_GetClusterStatus_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/GetClusterStatus"
32 ClusterSyncService_GetMemberStatus_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/GetMemberStatus"
33 ClusterSyncService_GetLatestSerial_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/GetLatestSerial"
34 ClusterSyncService_GetEventsInRange_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/GetEventsInRange"
35 )
36
37 // ClusterSyncServiceClient is the client API for ClusterSyncService service.
38 //
39 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
40 //
41 // ClusterSyncService provides cluster replication with persistent state
42 // for multi-member relay clusters
43 type ClusterSyncServiceClient interface {
44 // Ready returns whether the service is ready to serve requests
45 Ready(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.ReadyResponse, error)
46 // Start starts the cluster polling loop
47 Start(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error)
48 // Stop stops the cluster polling loop
49 Stop(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error)
50 // HandleLatestSerial proxies GET /cluster/latest HTTP requests
51 HandleLatestSerial(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error)
52 // HandleEventsRange proxies GET /cluster/events HTTP requests
53 HandleEventsRange(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error)
54 // GetMembers returns the current cluster members
55 GetMembers(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*MembersResponse, error)
56 // UpdateMembership updates cluster membership
57 UpdateMembership(ctx context.Context, in *UpdateMembershipRequest, opts ...grpc.CallOption) (*v1.Empty, error)
58 // HandleMembershipEvent processes a cluster membership event (Kind 39108)
59 HandleMembershipEvent(ctx context.Context, in *MembershipEventRequest, opts ...grpc.CallOption) (*v1.Empty, error)
60 // GetClusterStatus returns overall cluster status
61 GetClusterStatus(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*ClusterStatusResponse, error)
62 // GetMemberStatus returns status for a specific member
63 GetMemberStatus(ctx context.Context, in *MemberStatusRequest, opts ...grpc.CallOption) (*MemberStatusResponse, error)
64 // GetLatestSerial returns the latest serial from this relay's database
65 GetLatestSerial(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*LatestSerialResponse, error)
66 // GetEventsInRange returns event info for a serial range
67 GetEventsInRange(ctx context.Context, in *EventsRangeRequest, opts ...grpc.CallOption) (*EventsRangeResponse, error)
68 }
69
70 type clusterSyncServiceClient struct {
71 cc grpc.ClientConnInterface
72 }
73
74 func NewClusterSyncServiceClient(cc grpc.ClientConnInterface) ClusterSyncServiceClient {
75 return &clusterSyncServiceClient{cc}
76 }
77
78 func (c *clusterSyncServiceClient) Ready(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.ReadyResponse, error) {
79 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
80 out := new(v1.ReadyResponse)
81 err := c.cc.Invoke(ctx, ClusterSyncService_Ready_FullMethodName, in, out, cOpts...)
82 if err != nil {
83 return nil, err
84 }
85 return out, nil
86 }
87
88 func (c *clusterSyncServiceClient) Start(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error) {
89 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
90 out := new(v1.Empty)
91 err := c.cc.Invoke(ctx, ClusterSyncService_Start_FullMethodName, in, out, cOpts...)
92 if err != nil {
93 return nil, err
94 }
95 return out, nil
96 }
97
98 func (c *clusterSyncServiceClient) Stop(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error) {
99 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
100 out := new(v1.Empty)
101 err := c.cc.Invoke(ctx, ClusterSyncService_Stop_FullMethodName, in, out, cOpts...)
102 if err != nil {
103 return nil, err
104 }
105 return out, nil
106 }
107
108 func (c *clusterSyncServiceClient) HandleLatestSerial(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error) {
109 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
110 out := new(v1.HTTPResponse)
111 err := c.cc.Invoke(ctx, ClusterSyncService_HandleLatestSerial_FullMethodName, in, out, cOpts...)
112 if err != nil {
113 return nil, err
114 }
115 return out, nil
116 }
117
118 func (c *clusterSyncServiceClient) HandleEventsRange(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error) {
119 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
120 out := new(v1.HTTPResponse)
121 err := c.cc.Invoke(ctx, ClusterSyncService_HandleEventsRange_FullMethodName, in, out, cOpts...)
122 if err != nil {
123 return nil, err
124 }
125 return out, nil
126 }
127
128 func (c *clusterSyncServiceClient) GetMembers(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*MembersResponse, error) {
129 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
130 out := new(MembersResponse)
131 err := c.cc.Invoke(ctx, ClusterSyncService_GetMembers_FullMethodName, in, out, cOpts...)
132 if err != nil {
133 return nil, err
134 }
135 return out, nil
136 }
137
138 func (c *clusterSyncServiceClient) UpdateMembership(ctx context.Context, in *UpdateMembershipRequest, opts ...grpc.CallOption) (*v1.Empty, error) {
139 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
140 out := new(v1.Empty)
141 err := c.cc.Invoke(ctx, ClusterSyncService_UpdateMembership_FullMethodName, in, out, cOpts...)
142 if err != nil {
143 return nil, err
144 }
145 return out, nil
146 }
147
148 func (c *clusterSyncServiceClient) HandleMembershipEvent(ctx context.Context, in *MembershipEventRequest, opts ...grpc.CallOption) (*v1.Empty, error) {
149 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
150 out := new(v1.Empty)
151 err := c.cc.Invoke(ctx, ClusterSyncService_HandleMembershipEvent_FullMethodName, in, out, cOpts...)
152 if err != nil {
153 return nil, err
154 }
155 return out, nil
156 }
157
158 func (c *clusterSyncServiceClient) GetClusterStatus(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*ClusterStatusResponse, error) {
159 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
160 out := new(ClusterStatusResponse)
161 err := c.cc.Invoke(ctx, ClusterSyncService_GetClusterStatus_FullMethodName, in, out, cOpts...)
162 if err != nil {
163 return nil, err
164 }
165 return out, nil
166 }
167
168 func (c *clusterSyncServiceClient) GetMemberStatus(ctx context.Context, in *MemberStatusRequest, opts ...grpc.CallOption) (*MemberStatusResponse, error) {
169 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
170 out := new(MemberStatusResponse)
171 err := c.cc.Invoke(ctx, ClusterSyncService_GetMemberStatus_FullMethodName, in, out, cOpts...)
172 if err != nil {
173 return nil, err
174 }
175 return out, nil
176 }
177
178 func (c *clusterSyncServiceClient) GetLatestSerial(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*LatestSerialResponse, error) {
179 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
180 out := new(LatestSerialResponse)
181 err := c.cc.Invoke(ctx, ClusterSyncService_GetLatestSerial_FullMethodName, in, out, cOpts...)
182 if err != nil {
183 return nil, err
184 }
185 return out, nil
186 }
187
188 func (c *clusterSyncServiceClient) GetEventsInRange(ctx context.Context, in *EventsRangeRequest, opts ...grpc.CallOption) (*EventsRangeResponse, error) {
189 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
190 out := new(EventsRangeResponse)
191 err := c.cc.Invoke(ctx, ClusterSyncService_GetEventsInRange_FullMethodName, in, out, cOpts...)
192 if err != nil {
193 return nil, err
194 }
195 return out, nil
196 }
197
198 // ClusterSyncServiceServer is the server API for ClusterSyncService service.
199 // All implementations must embed UnimplementedClusterSyncServiceServer
200 // for forward compatibility.
201 //
202 // ClusterSyncService provides cluster replication with persistent state
203 // for multi-member relay clusters
204 type ClusterSyncServiceServer interface {
205 // Ready returns whether the service is ready to serve requests
206 Ready(context.Context, *v1.Empty) (*v1.ReadyResponse, error)
207 // Start starts the cluster polling loop
208 Start(context.Context, *v1.Empty) (*v1.Empty, error)
209 // Stop stops the cluster polling loop
210 Stop(context.Context, *v1.Empty) (*v1.Empty, error)
211 // HandleLatestSerial proxies GET /cluster/latest HTTP requests
212 HandleLatestSerial(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error)
213 // HandleEventsRange proxies GET /cluster/events HTTP requests
214 HandleEventsRange(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error)
215 // GetMembers returns the current cluster members
216 GetMembers(context.Context, *v1.Empty) (*MembersResponse, error)
217 // UpdateMembership updates cluster membership
218 UpdateMembership(context.Context, *UpdateMembershipRequest) (*v1.Empty, error)
219 // HandleMembershipEvent processes a cluster membership event (Kind 39108)
220 HandleMembershipEvent(context.Context, *MembershipEventRequest) (*v1.Empty, error)
221 // GetClusterStatus returns overall cluster status
222 GetClusterStatus(context.Context, *v1.Empty) (*ClusterStatusResponse, error)
223 // GetMemberStatus returns status for a specific member
224 GetMemberStatus(context.Context, *MemberStatusRequest) (*MemberStatusResponse, error)
225 // GetLatestSerial returns the latest serial from this relay's database
226 GetLatestSerial(context.Context, *v1.Empty) (*LatestSerialResponse, error)
227 // GetEventsInRange returns event info for a serial range
228 GetEventsInRange(context.Context, *EventsRangeRequest) (*EventsRangeResponse, error)
229 mustEmbedUnimplementedClusterSyncServiceServer()
230 }
231
232 // UnimplementedClusterSyncServiceServer must be embedded to have
233 // forward compatible implementations.
234 //
235 // NOTE: this should be embedded by value instead of pointer to avoid a nil
236 // pointer dereference when methods are called.
237 type UnimplementedClusterSyncServiceServer struct{}
238
239 func (UnimplementedClusterSyncServiceServer) Ready(context.Context, *v1.Empty) (*v1.ReadyResponse, error) {
240 return nil, status.Error(codes.Unimplemented, "method Ready not implemented")
241 }
242 func (UnimplementedClusterSyncServiceServer) Start(context.Context, *v1.Empty) (*v1.Empty, error) {
243 return nil, status.Error(codes.Unimplemented, "method Start not implemented")
244 }
245 func (UnimplementedClusterSyncServiceServer) Stop(context.Context, *v1.Empty) (*v1.Empty, error) {
246 return nil, status.Error(codes.Unimplemented, "method Stop not implemented")
247 }
248 func (UnimplementedClusterSyncServiceServer) HandleLatestSerial(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error) {
249 return nil, status.Error(codes.Unimplemented, "method HandleLatestSerial not implemented")
250 }
251 func (UnimplementedClusterSyncServiceServer) HandleEventsRange(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error) {
252 return nil, status.Error(codes.Unimplemented, "method HandleEventsRange not implemented")
253 }
254 func (UnimplementedClusterSyncServiceServer) GetMembers(context.Context, *v1.Empty) (*MembersResponse, error) {
255 return nil, status.Error(codes.Unimplemented, "method GetMembers not implemented")
256 }
257 func (UnimplementedClusterSyncServiceServer) UpdateMembership(context.Context, *UpdateMembershipRequest) (*v1.Empty, error) {
258 return nil, status.Error(codes.Unimplemented, "method UpdateMembership not implemented")
259 }
260 func (UnimplementedClusterSyncServiceServer) HandleMembershipEvent(context.Context, *MembershipEventRequest) (*v1.Empty, error) {
261 return nil, status.Error(codes.Unimplemented, "method HandleMembershipEvent not implemented")
262 }
263 func (UnimplementedClusterSyncServiceServer) GetClusterStatus(context.Context, *v1.Empty) (*ClusterStatusResponse, error) {
264 return nil, status.Error(codes.Unimplemented, "method GetClusterStatus not implemented")
265 }
266 func (UnimplementedClusterSyncServiceServer) GetMemberStatus(context.Context, *MemberStatusRequest) (*MemberStatusResponse, error) {
267 return nil, status.Error(codes.Unimplemented, "method GetMemberStatus not implemented")
268 }
269 func (UnimplementedClusterSyncServiceServer) GetLatestSerial(context.Context, *v1.Empty) (*LatestSerialResponse, error) {
270 return nil, status.Error(codes.Unimplemented, "method GetLatestSerial not implemented")
271 }
272 func (UnimplementedClusterSyncServiceServer) GetEventsInRange(context.Context, *EventsRangeRequest) (*EventsRangeResponse, error) {
273 return nil, status.Error(codes.Unimplemented, "method GetEventsInRange not implemented")
274 }
275 func (UnimplementedClusterSyncServiceServer) mustEmbedUnimplementedClusterSyncServiceServer() {}
276 func (UnimplementedClusterSyncServiceServer) testEmbeddedByValue() {}
277
278 // UnsafeClusterSyncServiceServer may be embedded to opt out of forward compatibility for this service.
279 // Use of this interface is not recommended, as added methods to ClusterSyncServiceServer will
280 // result in compilation errors.
281 type UnsafeClusterSyncServiceServer interface {
282 mustEmbedUnimplementedClusterSyncServiceServer()
283 }
284
285 func RegisterClusterSyncServiceServer(s grpc.ServiceRegistrar, srv ClusterSyncServiceServer) {
286 // If the following call panics, it indicates UnimplementedClusterSyncServiceServer was
287 // embedded by pointer and is nil. This will cause panics if an
288 // unimplemented method is ever invoked, so we test this at initialization
289 // time to prevent it from happening at runtime later due to I/O.
290 if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
291 t.testEmbeddedByValue()
292 }
293 s.RegisterService(&ClusterSyncService_ServiceDesc, srv)
294 }
295
296 func _ClusterSyncService_Ready_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
297 in := new(v1.Empty)
298 if err := dec(in); err != nil {
299 return nil, err
300 }
301 if interceptor == nil {
302 return srv.(ClusterSyncServiceServer).Ready(ctx, in)
303 }
304 info := &grpc.UnaryServerInfo{
305 Server: srv,
306 FullMethod: ClusterSyncService_Ready_FullMethodName,
307 }
308 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
309 return srv.(ClusterSyncServiceServer).Ready(ctx, req.(*v1.Empty))
310 }
311 return interceptor(ctx, in, info, handler)
312 }
313
314 func _ClusterSyncService_Start_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
315 in := new(v1.Empty)
316 if err := dec(in); err != nil {
317 return nil, err
318 }
319 if interceptor == nil {
320 return srv.(ClusterSyncServiceServer).Start(ctx, in)
321 }
322 info := &grpc.UnaryServerInfo{
323 Server: srv,
324 FullMethod: ClusterSyncService_Start_FullMethodName,
325 }
326 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
327 return srv.(ClusterSyncServiceServer).Start(ctx, req.(*v1.Empty))
328 }
329 return interceptor(ctx, in, info, handler)
330 }
331
332 func _ClusterSyncService_Stop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
333 in := new(v1.Empty)
334 if err := dec(in); err != nil {
335 return nil, err
336 }
337 if interceptor == nil {
338 return srv.(ClusterSyncServiceServer).Stop(ctx, in)
339 }
340 info := &grpc.UnaryServerInfo{
341 Server: srv,
342 FullMethod: ClusterSyncService_Stop_FullMethodName,
343 }
344 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
345 return srv.(ClusterSyncServiceServer).Stop(ctx, req.(*v1.Empty))
346 }
347 return interceptor(ctx, in, info, handler)
348 }
349
350 func _ClusterSyncService_HandleLatestSerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
351 in := new(v1.HTTPRequest)
352 if err := dec(in); err != nil {
353 return nil, err
354 }
355 if interceptor == nil {
356 return srv.(ClusterSyncServiceServer).HandleLatestSerial(ctx, in)
357 }
358 info := &grpc.UnaryServerInfo{
359 Server: srv,
360 FullMethod: ClusterSyncService_HandleLatestSerial_FullMethodName,
361 }
362 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
363 return srv.(ClusterSyncServiceServer).HandleLatestSerial(ctx, req.(*v1.HTTPRequest))
364 }
365 return interceptor(ctx, in, info, handler)
366 }
367
368 func _ClusterSyncService_HandleEventsRange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
369 in := new(v1.HTTPRequest)
370 if err := dec(in); err != nil {
371 return nil, err
372 }
373 if interceptor == nil {
374 return srv.(ClusterSyncServiceServer).HandleEventsRange(ctx, in)
375 }
376 info := &grpc.UnaryServerInfo{
377 Server: srv,
378 FullMethod: ClusterSyncService_HandleEventsRange_FullMethodName,
379 }
380 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
381 return srv.(ClusterSyncServiceServer).HandleEventsRange(ctx, req.(*v1.HTTPRequest))
382 }
383 return interceptor(ctx, in, info, handler)
384 }
385
386 func _ClusterSyncService_GetMembers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
387 in := new(v1.Empty)
388 if err := dec(in); err != nil {
389 return nil, err
390 }
391 if interceptor == nil {
392 return srv.(ClusterSyncServiceServer).GetMembers(ctx, in)
393 }
394 info := &grpc.UnaryServerInfo{
395 Server: srv,
396 FullMethod: ClusterSyncService_GetMembers_FullMethodName,
397 }
398 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
399 return srv.(ClusterSyncServiceServer).GetMembers(ctx, req.(*v1.Empty))
400 }
401 return interceptor(ctx, in, info, handler)
402 }
403
404 func _ClusterSyncService_UpdateMembership_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
405 in := new(UpdateMembershipRequest)
406 if err := dec(in); err != nil {
407 return nil, err
408 }
409 if interceptor == nil {
410 return srv.(ClusterSyncServiceServer).UpdateMembership(ctx, in)
411 }
412 info := &grpc.UnaryServerInfo{
413 Server: srv,
414 FullMethod: ClusterSyncService_UpdateMembership_FullMethodName,
415 }
416 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
417 return srv.(ClusterSyncServiceServer).UpdateMembership(ctx, req.(*UpdateMembershipRequest))
418 }
419 return interceptor(ctx, in, info, handler)
420 }
421
422 func _ClusterSyncService_HandleMembershipEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
423 in := new(MembershipEventRequest)
424 if err := dec(in); err != nil {
425 return nil, err
426 }
427 if interceptor == nil {
428 return srv.(ClusterSyncServiceServer).HandleMembershipEvent(ctx, in)
429 }
430 info := &grpc.UnaryServerInfo{
431 Server: srv,
432 FullMethod: ClusterSyncService_HandleMembershipEvent_FullMethodName,
433 }
434 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
435 return srv.(ClusterSyncServiceServer).HandleMembershipEvent(ctx, req.(*MembershipEventRequest))
436 }
437 return interceptor(ctx, in, info, handler)
438 }
439
440 func _ClusterSyncService_GetClusterStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
441 in := new(v1.Empty)
442 if err := dec(in); err != nil {
443 return nil, err
444 }
445 if interceptor == nil {
446 return srv.(ClusterSyncServiceServer).GetClusterStatus(ctx, in)
447 }
448 info := &grpc.UnaryServerInfo{
449 Server: srv,
450 FullMethod: ClusterSyncService_GetClusterStatus_FullMethodName,
451 }
452 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
453 return srv.(ClusterSyncServiceServer).GetClusterStatus(ctx, req.(*v1.Empty))
454 }
455 return interceptor(ctx, in, info, handler)
456 }
457
458 func _ClusterSyncService_GetMemberStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
459 in := new(MemberStatusRequest)
460 if err := dec(in); err != nil {
461 return nil, err
462 }
463 if interceptor == nil {
464 return srv.(ClusterSyncServiceServer).GetMemberStatus(ctx, in)
465 }
466 info := &grpc.UnaryServerInfo{
467 Server: srv,
468 FullMethod: ClusterSyncService_GetMemberStatus_FullMethodName,
469 }
470 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
471 return srv.(ClusterSyncServiceServer).GetMemberStatus(ctx, req.(*MemberStatusRequest))
472 }
473 return interceptor(ctx, in, info, handler)
474 }
475
476 func _ClusterSyncService_GetLatestSerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
477 in := new(v1.Empty)
478 if err := dec(in); err != nil {
479 return nil, err
480 }
481 if interceptor == nil {
482 return srv.(ClusterSyncServiceServer).GetLatestSerial(ctx, in)
483 }
484 info := &grpc.UnaryServerInfo{
485 Server: srv,
486 FullMethod: ClusterSyncService_GetLatestSerial_FullMethodName,
487 }
488 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
489 return srv.(ClusterSyncServiceServer).GetLatestSerial(ctx, req.(*v1.Empty))
490 }
491 return interceptor(ctx, in, info, handler)
492 }
493
494 func _ClusterSyncService_GetEventsInRange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
495 in := new(EventsRangeRequest)
496 if err := dec(in); err != nil {
497 return nil, err
498 }
499 if interceptor == nil {
500 return srv.(ClusterSyncServiceServer).GetEventsInRange(ctx, in)
501 }
502 info := &grpc.UnaryServerInfo{
503 Server: srv,
504 FullMethod: ClusterSyncService_GetEventsInRange_FullMethodName,
505 }
506 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
507 return srv.(ClusterSyncServiceServer).GetEventsInRange(ctx, req.(*EventsRangeRequest))
508 }
509 return interceptor(ctx, in, info, handler)
510 }
511
512 // ClusterSyncService_ServiceDesc is the grpc.ServiceDesc for ClusterSyncService service.
513 // It's only intended for direct use with grpc.RegisterService,
514 // and not to be introspected or modified (even as a copy)
515 var ClusterSyncService_ServiceDesc = grpc.ServiceDesc{
516 ServiceName: "orlysync.cluster.v1.ClusterSyncService",
517 HandlerType: (*ClusterSyncServiceServer)(nil),
518 Methods: []grpc.MethodDesc{
519 {
520 MethodName: "Ready",
521 Handler: _ClusterSyncService_Ready_Handler,
522 },
523 {
524 MethodName: "Start",
525 Handler: _ClusterSyncService_Start_Handler,
526 },
527 {
528 MethodName: "Stop",
529 Handler: _ClusterSyncService_Stop_Handler,
530 },
531 {
532 MethodName: "HandleLatestSerial",
533 Handler: _ClusterSyncService_HandleLatestSerial_Handler,
534 },
535 {
536 MethodName: "HandleEventsRange",
537 Handler: _ClusterSyncService_HandleEventsRange_Handler,
538 },
539 {
540 MethodName: "GetMembers",
541 Handler: _ClusterSyncService_GetMembers_Handler,
542 },
543 {
544 MethodName: "UpdateMembership",
545 Handler: _ClusterSyncService_UpdateMembership_Handler,
546 },
547 {
548 MethodName: "HandleMembershipEvent",
549 Handler: _ClusterSyncService_HandleMembershipEvent_Handler,
550 },
551 {
552 MethodName: "GetClusterStatus",
553 Handler: _ClusterSyncService_GetClusterStatus_Handler,
554 },
555 {
556 MethodName: "GetMemberStatus",
557 Handler: _ClusterSyncService_GetMemberStatus_Handler,
558 },
559 {
560 MethodName: "GetLatestSerial",
561 Handler: _ClusterSyncService_GetLatestSerial_Handler,
562 },
563 {
564 MethodName: "GetEventsInRange",
565 Handler: _ClusterSyncService_GetEventsInRange_Handler,
566 },
567 },
568 Streams: []grpc.StreamDesc{},
569 Metadata: "orlysync/cluster/v1/service.proto",
570 }
571