// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.6.0
// - protoc             (unknown)
// source: orlysync/cluster/v1/service.proto

package clusterv1

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	v1 "next.orly.dev/pkg/proto/orlysync/common/v1"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.64.0 or later.
const _ = grpc.SupportPackageIsVersion9

const (
	ClusterSyncService_Ready_FullMethodName                 = "/orlysync.cluster.v1.ClusterSyncService/Ready"
	ClusterSyncService_Start_FullMethodName                 = "/orlysync.cluster.v1.ClusterSyncService/Start"
	ClusterSyncService_Stop_FullMethodName                  = "/orlysync.cluster.v1.ClusterSyncService/Stop"
	ClusterSyncService_HandleLatestSerial_FullMethodName    = "/orlysync.cluster.v1.ClusterSyncService/HandleLatestSerial"
	ClusterSyncService_HandleEventsRange_FullMethodName     = "/orlysync.cluster.v1.ClusterSyncService/HandleEventsRange"
	ClusterSyncService_GetMembers_FullMethodName            = "/orlysync.cluster.v1.ClusterSyncService/GetMembers"
	ClusterSyncService_UpdateMembership_FullMethodName      = "/orlysync.cluster.v1.ClusterSyncService/UpdateMembership"
	ClusterSyncService_HandleMembershipEvent_FullMethodName = "/orlysync.cluster.v1.ClusterSyncService/HandleMembershipEvent"
	ClusterSyncService_GetClusterStatus_FullMethodName      = "/orlysync.cluster.v1.ClusterSyncService/GetClusterStatus"
	ClusterSyncService_GetMemberStatus_FullMethodName       = "/orlysync.cluster.v1.ClusterSyncService/GetMemberStatus"
	ClusterSyncService_GetLatestSerial_FullMethodName       = "/orlysync.cluster.v1.ClusterSyncService/GetLatestSerial"
	ClusterSyncService_GetEventsInRange_FullMethodName      = "/orlysync.cluster.v1.ClusterSyncService/GetEventsInRange"
)

// ClusterSyncServiceClient is the client API for ClusterSyncService service.
//
// 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.
//
// ClusterSyncService provides cluster replication with persistent state
// for multi-member relay clusters
type ClusterSyncServiceClient interface {
	// Ready returns whether the service is ready to serve requests
	Ready(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.ReadyResponse, error)
	// Start starts the cluster polling loop
	Start(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error)
	// Stop stops the cluster polling loop
	Stop(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error)
	// HandleLatestSerial proxies GET /cluster/latest HTTP requests
	HandleLatestSerial(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error)
	// HandleEventsRange proxies GET /cluster/events HTTP requests
	HandleEventsRange(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error)
	// GetMembers returns the current cluster members
	GetMembers(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*MembersResponse, error)
	// UpdateMembership updates cluster membership
	UpdateMembership(ctx context.Context, in *UpdateMembershipRequest, opts ...grpc.CallOption) (*v1.Empty, error)
	// HandleMembershipEvent processes a cluster membership event (Kind 39108)
	HandleMembershipEvent(ctx context.Context, in *MembershipEventRequest, opts ...grpc.CallOption) (*v1.Empty, error)
	// GetClusterStatus returns overall cluster status
	GetClusterStatus(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*ClusterStatusResponse, error)
	// GetMemberStatus returns status for a specific member
	GetMemberStatus(ctx context.Context, in *MemberStatusRequest, opts ...grpc.CallOption) (*MemberStatusResponse, error)
	// GetLatestSerial returns the latest serial from this relay's database
	GetLatestSerial(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*LatestSerialResponse, error)
	// GetEventsInRange returns event info for a serial range
	GetEventsInRange(ctx context.Context, in *EventsRangeRequest, opts ...grpc.CallOption) (*EventsRangeResponse, error)
}

type clusterSyncServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewClusterSyncServiceClient(cc grpc.ClientConnInterface) ClusterSyncServiceClient {
	return &clusterSyncServiceClient{cc}
}

func (c *clusterSyncServiceClient) Ready(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.ReadyResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(v1.ReadyResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_Ready_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) Start(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(v1.Empty)
	err := c.cc.Invoke(ctx, ClusterSyncService_Start_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) Stop(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*v1.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(v1.Empty)
	err := c.cc.Invoke(ctx, ClusterSyncService_Stop_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) HandleLatestSerial(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(v1.HTTPResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_HandleLatestSerial_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) HandleEventsRange(ctx context.Context, in *v1.HTTPRequest, opts ...grpc.CallOption) (*v1.HTTPResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(v1.HTTPResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_HandleEventsRange_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) GetMembers(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*MembersResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MembersResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_GetMembers_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) UpdateMembership(ctx context.Context, in *UpdateMembershipRequest, opts ...grpc.CallOption) (*v1.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(v1.Empty)
	err := c.cc.Invoke(ctx, ClusterSyncService_UpdateMembership_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) HandleMembershipEvent(ctx context.Context, in *MembershipEventRequest, opts ...grpc.CallOption) (*v1.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(v1.Empty)
	err := c.cc.Invoke(ctx, ClusterSyncService_HandleMembershipEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) GetClusterStatus(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*ClusterStatusResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ClusterStatusResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_GetClusterStatus_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) GetMemberStatus(ctx context.Context, in *MemberStatusRequest, opts ...grpc.CallOption) (*MemberStatusResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MemberStatusResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_GetMemberStatus_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) GetLatestSerial(ctx context.Context, in *v1.Empty, opts ...grpc.CallOption) (*LatestSerialResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(LatestSerialResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_GetLatestSerial_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *clusterSyncServiceClient) GetEventsInRange(ctx context.Context, in *EventsRangeRequest, opts ...grpc.CallOption) (*EventsRangeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(EventsRangeResponse)
	err := c.cc.Invoke(ctx, ClusterSyncService_GetEventsInRange_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// ClusterSyncServiceServer is the server API for ClusterSyncService service.
// All implementations must embed UnimplementedClusterSyncServiceServer
// for forward compatibility.
//
// ClusterSyncService provides cluster replication with persistent state
// for multi-member relay clusters
type ClusterSyncServiceServer interface {
	// Ready returns whether the service is ready to serve requests
	Ready(context.Context, *v1.Empty) (*v1.ReadyResponse, error)
	// Start starts the cluster polling loop
	Start(context.Context, *v1.Empty) (*v1.Empty, error)
	// Stop stops the cluster polling loop
	Stop(context.Context, *v1.Empty) (*v1.Empty, error)
	// HandleLatestSerial proxies GET /cluster/latest HTTP requests
	HandleLatestSerial(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error)
	// HandleEventsRange proxies GET /cluster/events HTTP requests
	HandleEventsRange(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error)
	// GetMembers returns the current cluster members
	GetMembers(context.Context, *v1.Empty) (*MembersResponse, error)
	// UpdateMembership updates cluster membership
	UpdateMembership(context.Context, *UpdateMembershipRequest) (*v1.Empty, error)
	// HandleMembershipEvent processes a cluster membership event (Kind 39108)
	HandleMembershipEvent(context.Context, *MembershipEventRequest) (*v1.Empty, error)
	// GetClusterStatus returns overall cluster status
	GetClusterStatus(context.Context, *v1.Empty) (*ClusterStatusResponse, error)
	// GetMemberStatus returns status for a specific member
	GetMemberStatus(context.Context, *MemberStatusRequest) (*MemberStatusResponse, error)
	// GetLatestSerial returns the latest serial from this relay's database
	GetLatestSerial(context.Context, *v1.Empty) (*LatestSerialResponse, error)
	// GetEventsInRange returns event info for a serial range
	GetEventsInRange(context.Context, *EventsRangeRequest) (*EventsRangeResponse, error)
	mustEmbedUnimplementedClusterSyncServiceServer()
}

// UnimplementedClusterSyncServiceServer must be embedded to have
// forward compatible implementations.
//
// NOTE: this should be embedded by value instead of pointer to avoid a nil
// pointer dereference when methods are called.
type UnimplementedClusterSyncServiceServer struct{}

func (UnimplementedClusterSyncServiceServer) Ready(context.Context, *v1.Empty) (*v1.ReadyResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method Ready not implemented")
}
func (UnimplementedClusterSyncServiceServer) Start(context.Context, *v1.Empty) (*v1.Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method Start not implemented")
}
func (UnimplementedClusterSyncServiceServer) Stop(context.Context, *v1.Empty) (*v1.Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method Stop not implemented")
}
func (UnimplementedClusterSyncServiceServer) HandleLatestSerial(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HandleLatestSerial not implemented")
}
func (UnimplementedClusterSyncServiceServer) HandleEventsRange(context.Context, *v1.HTTPRequest) (*v1.HTTPResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HandleEventsRange not implemented")
}
func (UnimplementedClusterSyncServiceServer) GetMembers(context.Context, *v1.Empty) (*MembersResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetMembers not implemented")
}
func (UnimplementedClusterSyncServiceServer) UpdateMembership(context.Context, *UpdateMembershipRequest) (*v1.Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method UpdateMembership not implemented")
}
func (UnimplementedClusterSyncServiceServer) HandleMembershipEvent(context.Context, *MembershipEventRequest) (*v1.Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method HandleMembershipEvent not implemented")
}
func (UnimplementedClusterSyncServiceServer) GetClusterStatus(context.Context, *v1.Empty) (*ClusterStatusResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetClusterStatus not implemented")
}
func (UnimplementedClusterSyncServiceServer) GetMemberStatus(context.Context, *MemberStatusRequest) (*MemberStatusResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetMemberStatus not implemented")
}
func (UnimplementedClusterSyncServiceServer) GetLatestSerial(context.Context, *v1.Empty) (*LatestSerialResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetLatestSerial not implemented")
}
func (UnimplementedClusterSyncServiceServer) GetEventsInRange(context.Context, *EventsRangeRequest) (*EventsRangeResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetEventsInRange not implemented")
}
func (UnimplementedClusterSyncServiceServer) mustEmbedUnimplementedClusterSyncServiceServer() {}
func (UnimplementedClusterSyncServiceServer) testEmbeddedByValue()                            {}

// UnsafeClusterSyncServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ClusterSyncServiceServer will
// result in compilation errors.
type UnsafeClusterSyncServiceServer interface {
	mustEmbedUnimplementedClusterSyncServiceServer()
}

func RegisterClusterSyncServiceServer(s grpc.ServiceRegistrar, srv ClusterSyncServiceServer) {
	// If the following call panics, it indicates UnimplementedClusterSyncServiceServer was
	// embedded by pointer and is nil.  This will cause panics if an
	// unimplemented method is ever invoked, so we test this at initialization
	// time to prevent it from happening at runtime later due to I/O.
	if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
		t.testEmbeddedByValue()
	}
	s.RegisterService(&ClusterSyncService_ServiceDesc, srv)
}

func _ClusterSyncService_Ready_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).Ready(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_Ready_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).Ready(ctx, req.(*v1.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_Start_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).Start(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_Start_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).Start(ctx, req.(*v1.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_Stop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).Stop(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_Stop_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).Stop(ctx, req.(*v1.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_HandleLatestSerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.HTTPRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).HandleLatestSerial(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_HandleLatestSerial_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).HandleLatestSerial(ctx, req.(*v1.HTTPRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_HandleEventsRange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.HTTPRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).HandleEventsRange(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_HandleEventsRange_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).HandleEventsRange(ctx, req.(*v1.HTTPRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_GetMembers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).GetMembers(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_GetMembers_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).GetMembers(ctx, req.(*v1.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_UpdateMembership_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateMembershipRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).UpdateMembership(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_UpdateMembership_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).UpdateMembership(ctx, req.(*UpdateMembershipRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_HandleMembershipEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MembershipEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).HandleMembershipEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_HandleMembershipEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).HandleMembershipEvent(ctx, req.(*MembershipEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_GetClusterStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).GetClusterStatus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_GetClusterStatus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).GetClusterStatus(ctx, req.(*v1.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_GetMemberStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MemberStatusRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).GetMemberStatus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_GetMemberStatus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).GetMemberStatus(ctx, req.(*MemberStatusRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_GetLatestSerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(v1.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).GetLatestSerial(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_GetLatestSerial_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).GetLatestSerial(ctx, req.(*v1.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _ClusterSyncService_GetEventsInRange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EventsRangeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ClusterSyncServiceServer).GetEventsInRange(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ClusterSyncService_GetEventsInRange_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ClusterSyncServiceServer).GetEventsInRange(ctx, req.(*EventsRangeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// ClusterSyncService_ServiceDesc is the grpc.ServiceDesc for ClusterSyncService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ClusterSyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "orlysync.cluster.v1.ClusterSyncService",
	HandlerType: (*ClusterSyncServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ready",
			Handler:    _ClusterSyncService_Ready_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _ClusterSyncService_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ClusterSyncService_Stop_Handler,
		},
		{
			MethodName: "HandleLatestSerial",
			Handler:    _ClusterSyncService_HandleLatestSerial_Handler,
		},
		{
			MethodName: "HandleEventsRange",
			Handler:    _ClusterSyncService_HandleEventsRange_Handler,
		},
		{
			MethodName: "GetMembers",
			Handler:    _ClusterSyncService_GetMembers_Handler,
		},
		{
			MethodName: "UpdateMembership",
			Handler:    _ClusterSyncService_UpdateMembership_Handler,
		},
		{
			MethodName: "HandleMembershipEvent",
			Handler:    _ClusterSyncService_HandleMembershipEvent_Handler,
		},
		{
			MethodName: "GetClusterStatus",
			Handler:    _ClusterSyncService_GetClusterStatus_Handler,
		},
		{
			MethodName: "GetMemberStatus",
			Handler:    _ClusterSyncService_GetMemberStatus_Handler,
		},
		{
			MethodName: "GetLatestSerial",
			Handler:    _ClusterSyncService_GetLatestSerial_Handler,
		},
		{
			MethodName: "GetEventsInRange",
			Handler:    _ClusterSyncService_GetEventsInRange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "orlysync/cluster/v1/service.proto",
}