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

package clusterv1

import (
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	v1 "next.orly.dev/pkg/proto/orlysync/common/v1"
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

// LatestSerialResponse contains the latest serial and timestamp
type LatestSerialResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Serial        uint64                 `protobuf:"varint,1,opt,name=serial,proto3" json:"serial,omitempty"`
	Timestamp     int64                  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Unix timestamp
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *LatestSerialResponse) Reset() {
	*x = LatestSerialResponse{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *LatestSerialResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*LatestSerialResponse) ProtoMessage() {}

func (x *LatestSerialResponse) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use LatestSerialResponse.ProtoReflect.Descriptor instead.
func (*LatestSerialResponse) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{0}
}

func (x *LatestSerialResponse) GetSerial() uint64 {
	if x != nil {
		return x.Serial
	}
	return 0
}

func (x *LatestSerialResponse) GetTimestamp() int64 {
	if x != nil {
		return x.Timestamp
	}
	return 0
}

// EventsRangeRequest requests events in a serial range
type EventsRangeRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	From          uint64                 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`   // Start serial (inclusive)
	To            uint64                 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`       // End serial (inclusive)
	Limit         int32                  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` // Max events to return
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *EventsRangeRequest) Reset() {
	*x = EventsRangeRequest{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *EventsRangeRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*EventsRangeRequest) ProtoMessage() {}

func (x *EventsRangeRequest) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use EventsRangeRequest.ProtoReflect.Descriptor instead.
func (*EventsRangeRequest) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{1}
}

func (x *EventsRangeRequest) GetFrom() uint64 {
	if x != nil {
		return x.From
	}
	return 0
}

func (x *EventsRangeRequest) GetTo() uint64 {
	if x != nil {
		return x.To
	}
	return 0
}

func (x *EventsRangeRequest) GetLimit() int32 {
	if x != nil {
		return x.Limit
	}
	return 0
}

// EventsRangeResponse contains events in the requested range
type EventsRangeResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Events        []*EventInfo           `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	HasMore       bool                   `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	NextFrom      uint64                 `protobuf:"varint,3,opt,name=next_from,json=nextFrom,proto3" json:"next_from,omitempty"` // Next serial if has_more is true
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *EventsRangeResponse) Reset() {
	*x = EventsRangeResponse{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *EventsRangeResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*EventsRangeResponse) ProtoMessage() {}

func (x *EventsRangeResponse) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use EventsRangeResponse.ProtoReflect.Descriptor instead.
func (*EventsRangeResponse) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{2}
}

func (x *EventsRangeResponse) GetEvents() []*EventInfo {
	if x != nil {
		return x.Events
	}
	return nil
}

func (x *EventsRangeResponse) GetHasMore() bool {
	if x != nil {
		return x.HasMore
	}
	return false
}

func (x *EventsRangeResponse) GetNextFrom() uint64 {
	if x != nil {
		return x.NextFrom
	}
	return 0
}

// EventInfo contains metadata about an event
type EventInfo struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Serial        uint64                 `protobuf:"varint,1,opt,name=serial,proto3" json:"serial,omitempty"`
	Id            string                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                // Event ID (hex)
	Timestamp     int64                  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Created timestamp
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *EventInfo) Reset() {
	*x = EventInfo{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *EventInfo) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*EventInfo) ProtoMessage() {}

func (x *EventInfo) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use EventInfo.ProtoReflect.Descriptor instead.
func (*EventInfo) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{3}
}

func (x *EventInfo) GetSerial() uint64 {
	if x != nil {
		return x.Serial
	}
	return 0
}

func (x *EventInfo) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *EventInfo) GetTimestamp() int64 {
	if x != nil {
		return x.Timestamp
	}
	return 0
}

// ClusterMember represents a cluster member
type ClusterMember struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	HttpUrl       string                 `protobuf:"bytes,1,opt,name=http_url,json=httpUrl,proto3" json:"http_url,omitempty"`
	WebsocketUrl  string                 `protobuf:"bytes,2,opt,name=websocket_url,json=websocketUrl,proto3" json:"websocket_url,omitempty"`
	LastSerial    uint64                 `protobuf:"varint,3,opt,name=last_serial,json=lastSerial,proto3" json:"last_serial,omitempty"`
	LastPoll      int64                  `protobuf:"varint,4,opt,name=last_poll,json=lastPoll,proto3" json:"last_poll,omitempty"` // Unix timestamp
	Status        string                 `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`                      // "active", "error", "unknown"
	ErrorCount    int32                  `protobuf:"varint,6,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ClusterMember) Reset() {
	*x = ClusterMember{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ClusterMember) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ClusterMember) ProtoMessage() {}

func (x *ClusterMember) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ClusterMember.ProtoReflect.Descriptor instead.
func (*ClusterMember) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{4}
}

func (x *ClusterMember) GetHttpUrl() string {
	if x != nil {
		return x.HttpUrl
	}
	return ""
}

func (x *ClusterMember) GetWebsocketUrl() string {
	if x != nil {
		return x.WebsocketUrl
	}
	return ""
}

func (x *ClusterMember) GetLastSerial() uint64 {
	if x != nil {
		return x.LastSerial
	}
	return 0
}

func (x *ClusterMember) GetLastPoll() int64 {
	if x != nil {
		return x.LastPoll
	}
	return 0
}

func (x *ClusterMember) GetStatus() string {
	if x != nil {
		return x.Status
	}
	return ""
}

func (x *ClusterMember) GetErrorCount() int32 {
	if x != nil {
		return x.ErrorCount
	}
	return 0
}

// MembersResponse contains the list of cluster members
type MembersResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Members       []*ClusterMember       `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *MembersResponse) Reset() {
	*x = MembersResponse{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *MembersResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*MembersResponse) ProtoMessage() {}

func (x *MembersResponse) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use MembersResponse.ProtoReflect.Descriptor instead.
func (*MembersResponse) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{5}
}

func (x *MembersResponse) GetMembers() []*ClusterMember {
	if x != nil {
		return x.Members
	}
	return nil
}

// UpdateMembershipRequest updates cluster membership
type UpdateMembershipRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RelayUrls     []string               `protobuf:"bytes,1,rep,name=relay_urls,json=relayUrls,proto3" json:"relay_urls,omitempty"` // List of relay URLs to add
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *UpdateMembershipRequest) Reset() {
	*x = UpdateMembershipRequest{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *UpdateMembershipRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*UpdateMembershipRequest) ProtoMessage() {}

func (x *UpdateMembershipRequest) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use UpdateMembershipRequest.ProtoReflect.Descriptor instead.
func (*UpdateMembershipRequest) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{6}
}

func (x *UpdateMembershipRequest) GetRelayUrls() []string {
	if x != nil {
		return x.RelayUrls
	}
	return nil
}

// MembershipEventRequest contains a cluster membership event
type MembershipEventRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Event         *v1.Event              `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *MembershipEventRequest) Reset() {
	*x = MembershipEventRequest{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *MembershipEventRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*MembershipEventRequest) ProtoMessage() {}

func (x *MembershipEventRequest) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[7]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use MembershipEventRequest.ProtoReflect.Descriptor instead.
func (*MembershipEventRequest) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{7}
}

func (x *MembershipEventRequest) GetEvent() *v1.Event {
	if x != nil {
		return x.Event
	}
	return nil
}

// ClusterStatusResponse contains overall cluster status
type ClusterStatusResponse struct {
	state                     protoimpl.MessageState `protogen:"open.v1"`
	LatestSerial              uint64                 `protobuf:"varint,1,opt,name=latest_serial,json=latestSerial,proto3" json:"latest_serial,omitempty"`
	ActiveMembers             int32                  `protobuf:"varint,2,opt,name=active_members,json=activeMembers,proto3" json:"active_members,omitempty"`
	TotalMembers              int32                  `protobuf:"varint,3,opt,name=total_members,json=totalMembers,proto3" json:"total_members,omitempty"`
	PropagatePrivilegedEvents bool                   `protobuf:"varint,4,opt,name=propagate_privileged_events,json=propagatePrivilegedEvents,proto3" json:"propagate_privileged_events,omitempty"`
	Members                   []*ClusterMember       `protobuf:"bytes,5,rep,name=members,proto3" json:"members,omitempty"`
	unknownFields             protoimpl.UnknownFields
	sizeCache                 protoimpl.SizeCache
}

func (x *ClusterStatusResponse) Reset() {
	*x = ClusterStatusResponse{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ClusterStatusResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ClusterStatusResponse) ProtoMessage() {}

func (x *ClusterStatusResponse) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[8]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ClusterStatusResponse.ProtoReflect.Descriptor instead.
func (*ClusterStatusResponse) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{8}
}

func (x *ClusterStatusResponse) GetLatestSerial() uint64 {
	if x != nil {
		return x.LatestSerial
	}
	return 0
}

func (x *ClusterStatusResponse) GetActiveMembers() int32 {
	if x != nil {
		return x.ActiveMembers
	}
	return 0
}

func (x *ClusterStatusResponse) GetTotalMembers() int32 {
	if x != nil {
		return x.TotalMembers
	}
	return 0
}

func (x *ClusterStatusResponse) GetPropagatePrivilegedEvents() bool {
	if x != nil {
		return x.PropagatePrivilegedEvents
	}
	return false
}

func (x *ClusterStatusResponse) GetMembers() []*ClusterMember {
	if x != nil {
		return x.Members
	}
	return nil
}

// MemberStatusRequest requests status for a specific member
type MemberStatusRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	HttpUrl       string                 `protobuf:"bytes,1,opt,name=http_url,json=httpUrl,proto3" json:"http_url,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *MemberStatusRequest) Reset() {
	*x = MemberStatusRequest{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *MemberStatusRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*MemberStatusRequest) ProtoMessage() {}

func (x *MemberStatusRequest) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[9]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use MemberStatusRequest.ProtoReflect.Descriptor instead.
func (*MemberStatusRequest) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{9}
}

func (x *MemberStatusRequest) GetHttpUrl() string {
	if x != nil {
		return x.HttpUrl
	}
	return ""
}

// MemberStatusResponse contains status for a member
type MemberStatusResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Member        *ClusterMember         `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	Found         bool                   `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *MemberStatusResponse) Reset() {
	*x = MemberStatusResponse{}
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *MemberStatusResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*MemberStatusResponse) ProtoMessage() {}

func (x *MemberStatusResponse) ProtoReflect() protoreflect.Message {
	mi := &file_orlysync_cluster_v1_service_proto_msgTypes[10]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use MemberStatusResponse.ProtoReflect.Descriptor instead.
func (*MemberStatusResponse) Descriptor() ([]byte, []int) {
	return file_orlysync_cluster_v1_service_proto_rawDescGZIP(), []int{10}
}

func (x *MemberStatusResponse) GetMember() *ClusterMember {
	if x != nil {
		return x.Member
	}
	return nil
}

func (x *MemberStatusResponse) GetFound() bool {
	if x != nil {
		return x.Found
	}
	return false
}

var File_orlysync_cluster_v1_service_proto protoreflect.FileDescriptor

const file_orlysync_cluster_v1_service_proto_rawDesc = "" +
	"\n" +
	"!orlysync/cluster/v1/service.proto\x12\x13orlysync.cluster.v1\x1a\x1eorlysync/common/v1/types.proto\"L\n" +
	"\x14LatestSerialResponse\x12\x16\n" +
	"\x06serial\x18\x01 \x01(\x04R\x06serial\x12\x1c\n" +
	"\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\"N\n" +
	"\x12EventsRangeRequest\x12\x12\n" +
	"\x04from\x18\x01 \x01(\x04R\x04from\x12\x0e\n" +
	"\x02to\x18\x02 \x01(\x04R\x02to\x12\x14\n" +
	"\x05limit\x18\x03 \x01(\x05R\x05limit\"\x85\x01\n" +
	"\x13EventsRangeResponse\x126\n" +
	"\x06events\x18\x01 \x03(\v2\x1e.orlysync.cluster.v1.EventInfoR\x06events\x12\x19\n" +
	"\bhas_more\x18\x02 \x01(\bR\ahasMore\x12\x1b\n" +
	"\tnext_from\x18\x03 \x01(\x04R\bnextFrom\"Q\n" +
	"\tEventInfo\x12\x16\n" +
	"\x06serial\x18\x01 \x01(\x04R\x06serial\x12\x0e\n" +
	"\x02id\x18\x02 \x01(\tR\x02id\x12\x1c\n" +
	"\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"\xc6\x01\n" +
	"\rClusterMember\x12\x19\n" +
	"\bhttp_url\x18\x01 \x01(\tR\ahttpUrl\x12#\n" +
	"\rwebsocket_url\x18\x02 \x01(\tR\fwebsocketUrl\x12\x1f\n" +
	"\vlast_serial\x18\x03 \x01(\x04R\n" +
	"lastSerial\x12\x1b\n" +
	"\tlast_poll\x18\x04 \x01(\x03R\blastPoll\x12\x16\n" +
	"\x06status\x18\x05 \x01(\tR\x06status\x12\x1f\n" +
	"\verror_count\x18\x06 \x01(\x05R\n" +
	"errorCount\"O\n" +
	"\x0fMembersResponse\x12<\n" +
	"\amembers\x18\x01 \x03(\v2\".orlysync.cluster.v1.ClusterMemberR\amembers\"8\n" +
	"\x17UpdateMembershipRequest\x12\x1d\n" +
	"\n" +
	"relay_urls\x18\x01 \x03(\tR\trelayUrls\"I\n" +
	"\x16MembershipEventRequest\x12/\n" +
	"\x05event\x18\x01 \x01(\v2\x19.orlysync.common.v1.EventR\x05event\"\x86\x02\n" +
	"\x15ClusterStatusResponse\x12#\n" +
	"\rlatest_serial\x18\x01 \x01(\x04R\flatestSerial\x12%\n" +
	"\x0eactive_members\x18\x02 \x01(\x05R\ractiveMembers\x12#\n" +
	"\rtotal_members\x18\x03 \x01(\x05R\ftotalMembers\x12>\n" +
	"\x1bpropagate_privileged_events\x18\x04 \x01(\bR\x19propagatePrivilegedEvents\x12<\n" +
	"\amembers\x18\x05 \x03(\v2\".orlysync.cluster.v1.ClusterMemberR\amembers\"0\n" +
	"\x13MemberStatusRequest\x12\x19\n" +
	"\bhttp_url\x18\x01 \x01(\tR\ahttpUrl\"h\n" +
	"\x14MemberStatusResponse\x12:\n" +
	"\x06member\x18\x01 \x01(\v2\".orlysync.cluster.v1.ClusterMemberR\x06member\x12\x14\n" +
	"\x05found\x18\x02 \x01(\bR\x05found2\x99\b\n" +
	"\x12ClusterSyncService\x12E\n" +
	"\x05Ready\x12\x19.orlysync.common.v1.Empty\x1a!.orlysync.common.v1.ReadyResponse\x12=\n" +
	"\x05Start\x12\x19.orlysync.common.v1.Empty\x1a\x19.orlysync.common.v1.Empty\x12<\n" +
	"\x04Stop\x12\x19.orlysync.common.v1.Empty\x1a\x19.orlysync.common.v1.Empty\x12W\n" +
	"\x12HandleLatestSerial\x12\x1f.orlysync.common.v1.HTTPRequest\x1a .orlysync.common.v1.HTTPResponse\x12V\n" +
	"\x11HandleEventsRange\x12\x1f.orlysync.common.v1.HTTPRequest\x1a .orlysync.common.v1.HTTPResponse\x12M\n" +
	"\n" +
	"GetMembers\x12\x19.orlysync.common.v1.Empty\x1a$.orlysync.cluster.v1.MembersResponse\x12[\n" +
	"\x10UpdateMembership\x12,.orlysync.cluster.v1.UpdateMembershipRequest\x1a\x19.orlysync.common.v1.Empty\x12_\n" +
	"\x15HandleMembershipEvent\x12+.orlysync.cluster.v1.MembershipEventRequest\x1a\x19.orlysync.common.v1.Empty\x12Y\n" +
	"\x10GetClusterStatus\x12\x19.orlysync.common.v1.Empty\x1a*.orlysync.cluster.v1.ClusterStatusResponse\x12f\n" +
	"\x0fGetMemberStatus\x12(.orlysync.cluster.v1.MemberStatusRequest\x1a).orlysync.cluster.v1.MemberStatusResponse\x12W\n" +
	"\x0fGetLatestSerial\x12\x19.orlysync.common.v1.Empty\x1a).orlysync.cluster.v1.LatestSerialResponse\x12e\n" +
	"\x10GetEventsInRange\x12'.orlysync.cluster.v1.EventsRangeRequest\x1a(.orlysync.cluster.v1.EventsRangeResponseB7Z5next.orly.dev/pkg/proto/orlysync/cluster/v1;clusterv1b\x06proto3"

var (
	file_orlysync_cluster_v1_service_proto_rawDescOnce sync.Once
	file_orlysync_cluster_v1_service_proto_rawDescData []byte
)

func file_orlysync_cluster_v1_service_proto_rawDescGZIP() []byte {
	file_orlysync_cluster_v1_service_proto_rawDescOnce.Do(func() {
		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)))
	})
	return file_orlysync_cluster_v1_service_proto_rawDescData
}

var file_orlysync_cluster_v1_service_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
var file_orlysync_cluster_v1_service_proto_goTypes = []any{
	(*LatestSerialResponse)(nil),    // 0: orlysync.cluster.v1.LatestSerialResponse
	(*EventsRangeRequest)(nil),      // 1: orlysync.cluster.v1.EventsRangeRequest
	(*EventsRangeResponse)(nil),     // 2: orlysync.cluster.v1.EventsRangeResponse
	(*EventInfo)(nil),               // 3: orlysync.cluster.v1.EventInfo
	(*ClusterMember)(nil),           // 4: orlysync.cluster.v1.ClusterMember
	(*MembersResponse)(nil),         // 5: orlysync.cluster.v1.MembersResponse
	(*UpdateMembershipRequest)(nil), // 6: orlysync.cluster.v1.UpdateMembershipRequest
	(*MembershipEventRequest)(nil),  // 7: orlysync.cluster.v1.MembershipEventRequest
	(*ClusterStatusResponse)(nil),   // 8: orlysync.cluster.v1.ClusterStatusResponse
	(*MemberStatusRequest)(nil),     // 9: orlysync.cluster.v1.MemberStatusRequest
	(*MemberStatusResponse)(nil),    // 10: orlysync.cluster.v1.MemberStatusResponse
	(*v1.Event)(nil),                // 11: orlysync.common.v1.Event
	(*v1.Empty)(nil),                // 12: orlysync.common.v1.Empty
	(*v1.HTTPRequest)(nil),          // 13: orlysync.common.v1.HTTPRequest
	(*v1.ReadyResponse)(nil),        // 14: orlysync.common.v1.ReadyResponse
	(*v1.HTTPResponse)(nil),         // 15: orlysync.common.v1.HTTPResponse
}
var file_orlysync_cluster_v1_service_proto_depIdxs = []int32{
	3,  // 0: orlysync.cluster.v1.EventsRangeResponse.events:type_name -> orlysync.cluster.v1.EventInfo
	4,  // 1: orlysync.cluster.v1.MembersResponse.members:type_name -> orlysync.cluster.v1.ClusterMember
	11, // 2: orlysync.cluster.v1.MembershipEventRequest.event:type_name -> orlysync.common.v1.Event
	4,  // 3: orlysync.cluster.v1.ClusterStatusResponse.members:type_name -> orlysync.cluster.v1.ClusterMember
	4,  // 4: orlysync.cluster.v1.MemberStatusResponse.member:type_name -> orlysync.cluster.v1.ClusterMember
	12, // 5: orlysync.cluster.v1.ClusterSyncService.Ready:input_type -> orlysync.common.v1.Empty
	12, // 6: orlysync.cluster.v1.ClusterSyncService.Start:input_type -> orlysync.common.v1.Empty
	12, // 7: orlysync.cluster.v1.ClusterSyncService.Stop:input_type -> orlysync.common.v1.Empty
	13, // 8: orlysync.cluster.v1.ClusterSyncService.HandleLatestSerial:input_type -> orlysync.common.v1.HTTPRequest
	13, // 9: orlysync.cluster.v1.ClusterSyncService.HandleEventsRange:input_type -> orlysync.common.v1.HTTPRequest
	12, // 10: orlysync.cluster.v1.ClusterSyncService.GetMembers:input_type -> orlysync.common.v1.Empty
	6,  // 11: orlysync.cluster.v1.ClusterSyncService.UpdateMembership:input_type -> orlysync.cluster.v1.UpdateMembershipRequest
	7,  // 12: orlysync.cluster.v1.ClusterSyncService.HandleMembershipEvent:input_type -> orlysync.cluster.v1.MembershipEventRequest
	12, // 13: orlysync.cluster.v1.ClusterSyncService.GetClusterStatus:input_type -> orlysync.common.v1.Empty
	9,  // 14: orlysync.cluster.v1.ClusterSyncService.GetMemberStatus:input_type -> orlysync.cluster.v1.MemberStatusRequest
	12, // 15: orlysync.cluster.v1.ClusterSyncService.GetLatestSerial:input_type -> orlysync.common.v1.Empty
	1,  // 16: orlysync.cluster.v1.ClusterSyncService.GetEventsInRange:input_type -> orlysync.cluster.v1.EventsRangeRequest
	14, // 17: orlysync.cluster.v1.ClusterSyncService.Ready:output_type -> orlysync.common.v1.ReadyResponse
	12, // 18: orlysync.cluster.v1.ClusterSyncService.Start:output_type -> orlysync.common.v1.Empty
	12, // 19: orlysync.cluster.v1.ClusterSyncService.Stop:output_type -> orlysync.common.v1.Empty
	15, // 20: orlysync.cluster.v1.ClusterSyncService.HandleLatestSerial:output_type -> orlysync.common.v1.HTTPResponse
	15, // 21: orlysync.cluster.v1.ClusterSyncService.HandleEventsRange:output_type -> orlysync.common.v1.HTTPResponse
	5,  // 22: orlysync.cluster.v1.ClusterSyncService.GetMembers:output_type -> orlysync.cluster.v1.MembersResponse
	12, // 23: orlysync.cluster.v1.ClusterSyncService.UpdateMembership:output_type -> orlysync.common.v1.Empty
	12, // 24: orlysync.cluster.v1.ClusterSyncService.HandleMembershipEvent:output_type -> orlysync.common.v1.Empty
	8,  // 25: orlysync.cluster.v1.ClusterSyncService.GetClusterStatus:output_type -> orlysync.cluster.v1.ClusterStatusResponse
	10, // 26: orlysync.cluster.v1.ClusterSyncService.GetMemberStatus:output_type -> orlysync.cluster.v1.MemberStatusResponse
	0,  // 27: orlysync.cluster.v1.ClusterSyncService.GetLatestSerial:output_type -> orlysync.cluster.v1.LatestSerialResponse
	2,  // 28: orlysync.cluster.v1.ClusterSyncService.GetEventsInRange:output_type -> orlysync.cluster.v1.EventsRangeResponse
	17, // [17:29] is the sub-list for method output_type
	5,  // [5:17] is the sub-list for method input_type
	5,  // [5:5] is the sub-list for extension type_name
	5,  // [5:5] is the sub-list for extension extendee
	0,  // [0:5] is the sub-list for field type_name
}

func init() { file_orlysync_cluster_v1_service_proto_init() }
func file_orlysync_cluster_v1_service_proto_init() {
	if File_orlysync_cluster_v1_service_proto != nil {
		return
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_orlysync_cluster_v1_service_proto_rawDesc), len(file_orlysync_cluster_v1_service_proto_rawDesc)),
			NumEnums:      0,
			NumMessages:   11,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_orlysync_cluster_v1_service_proto_goTypes,
		DependencyIndexes: file_orlysync_cluster_v1_service_proto_depIdxs,
		MessageInfos:      file_orlysync_cluster_v1_service_proto_msgTypes,
	}.Build()
	File_orlysync_cluster_v1_service_proto = out.File
	file_orlysync_cluster_v1_service_proto_goTypes = nil
	file_orlysync_cluster_v1_service_proto_depIdxs = nil
}