// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.10
// 	protoc        (unknown)
// source: v1sync/syncservice.proto

package v1sync

import (
	_ "github.com/garethgeorge/backrest/gen/go/types"
	v1 "github.com/garethgeorge/backrest/gen/go/v1"
	_ "google.golang.org/genproto/googleapis/api/annotations"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	_ "google.golang.org/protobuf/types/known/anypb"
	_ "google.golang.org/protobuf/types/known/emptypb"
	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)
)

type ConnectionState int32

const (
	ConnectionState_CONNECTION_STATE_UNKNOWN        ConnectionState = 0
	ConnectionState_CONNECTION_STATE_PENDING        ConnectionState = 1
	ConnectionState_CONNECTION_STATE_CONNECTED      ConnectionState = 2
	ConnectionState_CONNECTION_STATE_DISCONNECTED   ConnectionState = 3
	ConnectionState_CONNECTION_STATE_RETRY_WAIT     ConnectionState = 4
	ConnectionState_CONNECTION_STATE_ERROR_AUTH     ConnectionState = 10
	ConnectionState_CONNECTION_STATE_ERROR_PROTOCOL ConnectionState = 11
	ConnectionState_CONNECTION_STATE_ERROR_INTERNAL ConnectionState = 12
)

// Enum value maps for ConnectionState.
var (
	ConnectionState_name = map[int32]string{
		0:  "CONNECTION_STATE_UNKNOWN",
		1:  "CONNECTION_STATE_PENDING",
		2:  "CONNECTION_STATE_CONNECTED",
		3:  "CONNECTION_STATE_DISCONNECTED",
		4:  "CONNECTION_STATE_RETRY_WAIT",
		10: "CONNECTION_STATE_ERROR_AUTH",
		11: "CONNECTION_STATE_ERROR_PROTOCOL",
		12: "CONNECTION_STATE_ERROR_INTERNAL",
	}
	ConnectionState_value = map[string]int32{
		"CONNECTION_STATE_UNKNOWN":        0,
		"CONNECTION_STATE_PENDING":        1,
		"CONNECTION_STATE_CONNECTED":      2,
		"CONNECTION_STATE_DISCONNECTED":   3,
		"CONNECTION_STATE_RETRY_WAIT":     4,
		"CONNECTION_STATE_ERROR_AUTH":     10,
		"CONNECTION_STATE_ERROR_PROTOCOL": 11,
		"CONNECTION_STATE_ERROR_INTERNAL": 12,
	}
)

func (x ConnectionState) Enum() *ConnectionState {
	p := new(ConnectionState)
	*p = x
	return p
}

func (x ConnectionState) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (ConnectionState) Descriptor() protoreflect.EnumDescriptor {
	return file_v1sync_syncservice_proto_enumTypes[0].Descriptor()
}

func (ConnectionState) Type() protoreflect.EnumType {
	return &file_v1sync_syncservice_proto_enumTypes[0]
}

func (x ConnectionState) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use ConnectionState.Descriptor instead.
func (ConnectionState) EnumDescriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{0}
}

type SyncStreamItem_RepoConnectionState int32

const (
	SyncStreamItem_CONNECTION_STATE_UNKNOWN      SyncStreamItem_RepoConnectionState = 0
	SyncStreamItem_CONNECTION_STATE_PENDING      SyncStreamItem_RepoConnectionState = 1 // queried, response not yet received.
	SyncStreamItem_CONNECTION_STATE_CONNECTED    SyncStreamItem_RepoConnectionState = 2
	SyncStreamItem_CONNECTION_STATE_UNAUTHORIZED SyncStreamItem_RepoConnectionState = 3
	SyncStreamItem_CONNECTION_STATE_NOT_FOUND    SyncStreamItem_RepoConnectionState = 4
)

// Enum value maps for SyncStreamItem_RepoConnectionState.
var (
	SyncStreamItem_RepoConnectionState_name = map[int32]string{
		0: "CONNECTION_STATE_UNKNOWN",
		1: "CONNECTION_STATE_PENDING",
		2: "CONNECTION_STATE_CONNECTED",
		3: "CONNECTION_STATE_UNAUTHORIZED",
		4: "CONNECTION_STATE_NOT_FOUND",
	}
	SyncStreamItem_RepoConnectionState_value = map[string]int32{
		"CONNECTION_STATE_UNKNOWN":      0,
		"CONNECTION_STATE_PENDING":      1,
		"CONNECTION_STATE_CONNECTED":    2,
		"CONNECTION_STATE_UNAUTHORIZED": 3,
		"CONNECTION_STATE_NOT_FOUND":    4,
	}
)

func (x SyncStreamItem_RepoConnectionState) Enum() *SyncStreamItem_RepoConnectionState {
	p := new(SyncStreamItem_RepoConnectionState)
	*p = x
	return p
}

func (x SyncStreamItem_RepoConnectionState) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (SyncStreamItem_RepoConnectionState) Descriptor() protoreflect.EnumDescriptor {
	return file_v1sync_syncservice_proto_enumTypes[1].Descriptor()
}

func (SyncStreamItem_RepoConnectionState) Type() protoreflect.EnumType {
	return &file_v1sync_syncservice_proto_enumTypes[1]
}

func (x SyncStreamItem_RepoConnectionState) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use SyncStreamItem_RepoConnectionState.Descriptor instead.
func (SyncStreamItem_RepoConnectionState) EnumDescriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 0}
}

type SyncStateStreamRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Subscribe     bool                   `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"` // If true, the stream will continue to send updates until cancelled.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*SyncStateStreamRequest) ProtoMessage() {}

func (x *SyncStateStreamRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 SyncStateStreamRequest.ProtoReflect.Descriptor instead.
func (*SyncStateStreamRequest) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{0}
}

func (x *SyncStateStreamRequest) GetSubscribe() bool {
	if x != nil {
		return x.Subscribe
	}
	return false
}

type PeerState struct {
	state               protoimpl.MessageState `protogen:"open.v1"`
	PeerInstanceId      string                 `protobuf:"bytes,1,opt,name=peer_instance_id,json=peerInstanceId,proto3" json:"peer_instance_id,omitempty"`
	PeerKeyid           string                 `protobuf:"bytes,2,opt,name=peer_keyid,json=peerKeyid,proto3" json:"peer_keyid,omitempty"`
	State               ConnectionState        `protobuf:"varint,3,opt,name=state,proto3,enum=v1sync.ConnectionState" json:"state,omitempty"`
	StatusMessage       string                 `protobuf:"bytes,4,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	KnownPlans          []*PlanMetadata        `protobuf:"bytes,5,rep,name=known_plans,json=knownPlans,proto3" json:"known_plans,omitempty"`                               // List of plan IDs that the peer has.
	KnownRepos          []*RepoMetadata        `protobuf:"bytes,6,rep,name=known_repos,json=knownRepos,proto3" json:"known_repos,omitempty"`                               // List of repo IDs that the peer has.
	RemoteConfig        *RemoteConfig          `protobuf:"bytes,7,opt,name=remote_config,json=remoteConfig,proto3" json:"remote_config,omitempty"`                         // The remote config of the peer, if available.
	LastHeartbeatMillis int64                  `protobuf:"varint,8,opt,name=last_heartbeat_millis,json=lastHeartbeatMillis,proto3" json:"last_heartbeat_millis,omitempty"` // The last time the peer sent a heartbeat, in milliseconds since epoch.
	unknownFields       protoimpl.UnknownFields
	sizeCache           protoimpl.SizeCache
}

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

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

func (*PeerState) ProtoMessage() {}

func (x *PeerState) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 PeerState.ProtoReflect.Descriptor instead.
func (*PeerState) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{1}
}

func (x *PeerState) GetPeerInstanceId() string {
	if x != nil {
		return x.PeerInstanceId
	}
	return ""
}

func (x *PeerState) GetPeerKeyid() string {
	if x != nil {
		return x.PeerKeyid
	}
	return ""
}

func (x *PeerState) GetState() ConnectionState {
	if x != nil {
		return x.State
	}
	return ConnectionState_CONNECTION_STATE_UNKNOWN
}

func (x *PeerState) GetStatusMessage() string {
	if x != nil {
		return x.StatusMessage
	}
	return ""
}

func (x *PeerState) GetKnownPlans() []*PlanMetadata {
	if x != nil {
		return x.KnownPlans
	}
	return nil
}

func (x *PeerState) GetKnownRepos() []*RepoMetadata {
	if x != nil {
		return x.KnownRepos
	}
	return nil
}

func (x *PeerState) GetRemoteConfig() *RemoteConfig {
	if x != nil {
		return x.RemoteConfig
	}
	return nil
}

func (x *PeerState) GetLastHeartbeatMillis() int64 {
	if x != nil {
		return x.LastHeartbeatMillis
	}
	return 0
}

type AuthenticateRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	InstanceId    *v1.SignedMessage      `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // The ID of the peer instance.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AuthenticateRequest) ProtoMessage() {}

func (x *AuthenticateRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 AuthenticateRequest.ProtoReflect.Descriptor instead.
func (*AuthenticateRequest) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{2}
}

func (x *AuthenticateRequest) GetInstanceId() *v1.SignedMessage {
	if x != nil {
		return x.InstanceId
	}
	return nil
}

type GetOperationMetadataResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	OpIds         []int64                `protobuf:"varint,1,rep,packed,name=op_ids,json=opIds,proto3" json:"op_ids,omitempty"` // The IDs of the operations.
	Modnos        []int64                `protobuf:"varint,2,rep,packed,name=modnos,proto3" json:"modnos,omitempty"`            // The modnos of the operations.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetOperationMetadataResponse) ProtoMessage() {}

func (x *GetOperationMetadataResponse) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 GetOperationMetadataResponse.ProtoReflect.Descriptor instead.
func (*GetOperationMetadataResponse) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{3}
}

func (x *GetOperationMetadataResponse) GetOpIds() []int64 {
	if x != nil {
		return x.OpIds
	}
	return nil
}

func (x *GetOperationMetadataResponse) GetModnos() []int64 {
	if x != nil {
		return x.Modnos
	}
	return nil
}

type LogDataEntry struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	LogId            string                 `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`                                     // The ID of the log, only used for the first message in a log data stream.
	OwnerOpid        int64                  `protobuf:"varint,2,opt,name=owner_opid,json=ownerOpid,proto3" json:"owner_opid,omitempty"`                        // The operation ID of the operation that owns this log data.
	ExpirationTsUnix int64                  `protobuf:"varint,3,opt,name=expiration_ts_unix,json=expirationTsUnix,proto3" json:"expiration_ts_unix,omitempty"` // Unix timestamp in seconds when the log data expires.
	Chunk            []byte                 `protobuf:"bytes,4,opt,name=chunk,proto3" json:"chunk,omitempty"`                                                  // The log data chunk, can be sent repeatedly, must be terminated by a packet with size = 0.
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*LogDataEntry) ProtoMessage() {}

func (x *LogDataEntry) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 LogDataEntry.ProtoReflect.Descriptor instead.
func (*LogDataEntry) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{4}
}

func (x *LogDataEntry) GetLogId() string {
	if x != nil {
		return x.LogId
	}
	return ""
}

func (x *LogDataEntry) GetOwnerOpid() int64 {
	if x != nil {
		return x.OwnerOpid
	}
	return 0
}

func (x *LogDataEntry) GetExpirationTsUnix() int64 {
	if x != nil {
		return x.ExpirationTsUnix
	}
	return 0
}

func (x *LogDataEntry) GetChunk() []byte {
	if x != nil {
		return x.Chunk
	}
	return nil
}

type SetAvailableResourcesRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Repos         []*PlanMetadata        `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"` // The repos that are available.
	Plans         []*RepoMetadata        `protobuf:"bytes,2,rep,name=plans,proto3" json:"plans,omitempty"` // The plans that are available.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*SetAvailableResourcesRequest) ProtoMessage() {}

func (x *SetAvailableResourcesRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 SetAvailableResourcesRequest.ProtoReflect.Descriptor instead.
func (*SetAvailableResourcesRequest) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{5}
}

func (x *SetAvailableResourcesRequest) GetRepos() []*PlanMetadata {
	if x != nil {
		return x.Repos
	}
	return nil
}

func (x *SetAvailableResourcesRequest) GetPlans() []*RepoMetadata {
	if x != nil {
		return x.Plans
	}
	return nil
}

type RepoMetadata struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Guid          string                 `protobuf:"bytes,2,opt,name=guid,proto3" json:"guid,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*RepoMetadata) ProtoMessage() {}

func (x *RepoMetadata) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 RepoMetadata.ProtoReflect.Descriptor instead.
func (*RepoMetadata) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{6}
}

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

func (x *RepoMetadata) GetGuid() string {
	if x != nil {
		return x.Guid
	}
	return ""
}

type PlanMetadata struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*PlanMetadata) ProtoMessage() {}

func (x *PlanMetadata) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 PlanMetadata.ProtoReflect.Descriptor instead.
func (*PlanMetadata) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{7}
}

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

type SetConfigRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Plans         []*v1.Plan             `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans,omitempty"`                                        // The plans to set.
	Repos         []*v1.Repo             `protobuf:"bytes,2,rep,name=repos,proto3" json:"repos,omitempty"`                                        // The repos to set.
	ReposToDelete []string               `protobuf:"bytes,3,rep,name=repos_to_delete,json=reposToDelete,proto3" json:"repos_to_delete,omitempty"` // The repo IDs to delete.
	PlansToDelete []string               `protobuf:"bytes,4,rep,name=plans_to_delete,json=plansToDelete,proto3" json:"plans_to_delete,omitempty"` // The plan IDs to delete.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*SetConfigRequest) ProtoMessage() {}

func (x *SetConfigRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 SetConfigRequest.ProtoReflect.Descriptor instead.
func (*SetConfigRequest) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{8}
}

func (x *SetConfigRequest) GetPlans() []*v1.Plan {
	if x != nil {
		return x.Plans
	}
	return nil
}

func (x *SetConfigRequest) GetRepos() []*v1.Repo {
	if x != nil {
		return x.Repos
	}
	return nil
}

func (x *SetConfigRequest) GetReposToDelete() []string {
	if x != nil {
		return x.ReposToDelete
	}
	return nil
}

func (x *SetConfigRequest) GetPlansToDelete() []string {
	if x != nil {
		return x.PlansToDelete
	}
	return nil
}

type SetRemoteClientConfigRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	PeerKeyid     string                 `protobuf:"bytes,1,opt,name=peer_keyid,json=peerKeyid,proto3" json:"peer_keyid,omitempty"`               // The key ID of the connected peer to push config to.
	Repos         []*v1.Repo             `protobuf:"bytes,2,rep,name=repos,proto3" json:"repos,omitempty"`                                        // Repos to create or update on the peer.
	Plans         []*v1.Plan             `protobuf:"bytes,3,rep,name=plans,proto3" json:"plans,omitempty"`                                        // Plans to create or update on the peer.
	ReposToDelete []string               `protobuf:"bytes,4,rep,name=repos_to_delete,json=reposToDelete,proto3" json:"repos_to_delete,omitempty"` // Repo IDs to delete on the peer.
	PlansToDelete []string               `protobuf:"bytes,5,rep,name=plans_to_delete,json=plansToDelete,proto3" json:"plans_to_delete,omitempty"` // Plan IDs to delete on the peer.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*SetRemoteClientConfigRequest) ProtoMessage() {}

func (x *SetRemoteClientConfigRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 SetRemoteClientConfigRequest.ProtoReflect.Descriptor instead.
func (*SetRemoteClientConfigRequest) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{9}
}

func (x *SetRemoteClientConfigRequest) GetPeerKeyid() string {
	if x != nil {
		return x.PeerKeyid
	}
	return ""
}

func (x *SetRemoteClientConfigRequest) GetRepos() []*v1.Repo {
	if x != nil {
		return x.Repos
	}
	return nil
}

func (x *SetRemoteClientConfigRequest) GetPlans() []*v1.Plan {
	if x != nil {
		return x.Plans
	}
	return nil
}

func (x *SetRemoteClientConfigRequest) GetReposToDelete() []string {
	if x != nil {
		return x.ReposToDelete
	}
	return nil
}

func (x *SetRemoteClientConfigRequest) GetPlansToDelete() []string {
	if x != nil {
		return x.PlansToDelete
	}
	return nil
}

type SetRemoteClientConfigResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*SetRemoteClientConfigResponse) ProtoMessage() {}

func (x *SetRemoteClientConfigResponse) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_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 SetRemoteClientConfigResponse.ProtoReflect.Descriptor instead.
func (*SetRemoteClientConfigResponse) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{10}
}

type RemoteConfig struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Modno         int32                  `protobuf:"varint,1,opt,name=modno,proto3" json:"modno,omitempty"`     // The modno of the config.
	Version       int32                  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // The storage version of the config.
	Repos         []*v1.Repo             `protobuf:"bytes,3,rep,name=repos,proto3" json:"repos,omitempty"`
	Plans         []*v1.Plan             `protobuf:"bytes,4,rep,name=plans,proto3" json:"plans,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RemoteConfig) Reset() {
	*x = RemoteConfig{}
	mi := &file_v1sync_syncservice_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*RemoteConfig) ProtoMessage() {}

func (x *RemoteConfig) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[11]
	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 RemoteConfig.ProtoReflect.Descriptor instead.
func (*RemoteConfig) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{11}
}

func (x *RemoteConfig) GetModno() int32 {
	if x != nil {
		return x.Modno
	}
	return 0
}

func (x *RemoteConfig) GetVersion() int32 {
	if x != nil {
		return x.Version
	}
	return 0
}

func (x *RemoteConfig) GetRepos() []*v1.Repo {
	if x != nil {
		return x.Repos
	}
	return nil
}

func (x *RemoteConfig) GetPlans() []*v1.Plan {
	if x != nil {
		return x.Plans
	}
	return nil
}

type AuthorizationToken struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	PublicKey     *v1.PublicKey          `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	InstanceId    *v1.SignedMessage      `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // The ID of the peer instance.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AuthorizationToken) Reset() {
	*x = AuthorizationToken{}
	mi := &file_v1sync_syncservice_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*AuthorizationToken) ProtoMessage() {}

func (x *AuthorizationToken) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[12]
	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 AuthorizationToken.ProtoReflect.Descriptor instead.
func (*AuthorizationToken) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{12}
}

func (x *AuthorizationToken) GetPublicKey() *v1.PublicKey {
	if x != nil {
		return x.PublicKey
	}
	return nil
}

func (x *AuthorizationToken) GetInstanceId() *v1.SignedMessage {
	if x != nil {
		return x.InstanceId
	}
	return nil
}

type SyncStreamItem struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Action:
	//
	//	*SyncStreamItem_SignedMessage
	//	*SyncStreamItem_Handshake
	//	*SyncStreamItem_Heartbeat
	//	*SyncStreamItem_OperationManifest
	//	*SyncStreamItem_ReceiveOperations
	//	*SyncStreamItem_RequestOperationData
	//	*SyncStreamItem_ReceiveConfig
	//	*SyncStreamItem_SetConfig
	//	*SyncStreamItem_RequestResources
	//	*SyncStreamItem_ReceiveResources
	//	*SyncStreamItem_RequestLog
	//	*SyncStreamItem_ReceiveLogData
	//	*SyncStreamItem_Throttle
	//	*SyncStreamItem_EstablishSharedSecret
	//	*SyncStreamItem_Encrypted
	Action        isSyncStreamItem_Action `protobuf_oneof:"action"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem) Reset() {
	*x = SyncStreamItem{}
	mi := &file_v1sync_syncservice_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem) ProtoMessage() {}

func (x *SyncStreamItem) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[13]
	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 SyncStreamItem.ProtoReflect.Descriptor instead.
func (*SyncStreamItem) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13}
}

func (x *SyncStreamItem) GetAction() isSyncStreamItem_Action {
	if x != nil {
		return x.Action
	}
	return nil
}

func (x *SyncStreamItem) GetSignedMessage() *v1.SignedMessage {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_SignedMessage); ok {
			return x.SignedMessage
		}
	}
	return nil
}

func (x *SyncStreamItem) GetHandshake() *SyncStreamItem_SyncActionHandshake {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_Handshake); ok {
			return x.Handshake
		}
	}
	return nil
}

func (x *SyncStreamItem) GetHeartbeat() *SyncStreamItem_SyncActionHeartbeat {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_Heartbeat); ok {
			return x.Heartbeat
		}
	}
	return nil
}

func (x *SyncStreamItem) GetOperationManifest() *SyncStreamItem_SyncActionOperationManifest {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_OperationManifest); ok {
			return x.OperationManifest
		}
	}
	return nil
}

func (x *SyncStreamItem) GetReceiveOperations() *SyncStreamItem_SyncActionReceiveOperations {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_ReceiveOperations); ok {
			return x.ReceiveOperations
		}
	}
	return nil
}

func (x *SyncStreamItem) GetRequestOperationData() *SyncStreamItem_SyncActionRequestOperationData {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_RequestOperationData); ok {
			return x.RequestOperationData
		}
	}
	return nil
}

func (x *SyncStreamItem) GetReceiveConfig() *SyncStreamItem_SyncActionReceiveConfig {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_ReceiveConfig); ok {
			return x.ReceiveConfig
		}
	}
	return nil
}

func (x *SyncStreamItem) GetSetConfig() *SyncStreamItem_SyncActionSetConfig {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_SetConfig); ok {
			return x.SetConfig
		}
	}
	return nil
}

func (x *SyncStreamItem) GetRequestResources() *SyncStreamItem_SyncActionRequestResources {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_RequestResources); ok {
			return x.RequestResources
		}
	}
	return nil
}

func (x *SyncStreamItem) GetReceiveResources() *SyncStreamItem_SyncActionReceiveResources {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_ReceiveResources); ok {
			return x.ReceiveResources
		}
	}
	return nil
}

func (x *SyncStreamItem) GetRequestLog() *SyncStreamItem_SyncActionRequestLog {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_RequestLog); ok {
			return x.RequestLog
		}
	}
	return nil
}

func (x *SyncStreamItem) GetReceiveLogData() *SyncStreamItem_SyncActionReceiveLogData {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_ReceiveLogData); ok {
			return x.ReceiveLogData
		}
	}
	return nil
}

func (x *SyncStreamItem) GetThrottle() *SyncStreamItem_SyncActionThrottle {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_Throttle); ok {
			return x.Throttle
		}
	}
	return nil
}

func (x *SyncStreamItem) GetEstablishSharedSecret() *SyncStreamItem_SyncEstablishSharedSecret {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_EstablishSharedSecret); ok {
			return x.EstablishSharedSecret
		}
	}
	return nil
}

func (x *SyncStreamItem) GetEncrypted() *SyncStreamItem_SyncActionEncrypted {
	if x != nil {
		if x, ok := x.Action.(*SyncStreamItem_Encrypted); ok {
			return x.Encrypted
		}
	}
	return nil
}

type isSyncStreamItem_Action interface {
	isSyncStreamItem_Action()
}

type SyncStreamItem_SignedMessage struct {
	SignedMessage *v1.SignedMessage `protobuf:"bytes,1,opt,name=signed_message,json=signedMessage,proto3,oneof"`
}

type SyncStreamItem_Handshake struct {
	Handshake *SyncStreamItem_SyncActionHandshake `protobuf:"bytes,3,opt,name=handshake,proto3,oneof"` // note: mostly deprecated, sent through headers rather than stream.
}

type SyncStreamItem_Heartbeat struct {
	Heartbeat *SyncStreamItem_SyncActionHeartbeat `protobuf:"bytes,4,opt,name=heartbeat,proto3,oneof"`
}

type SyncStreamItem_OperationManifest struct {
	OperationManifest *SyncStreamItem_SyncActionOperationManifest `protobuf:"bytes,20,opt,name=operation_manifest,json=operationManifest,proto3,oneof"`
}

type SyncStreamItem_ReceiveOperations struct {
	ReceiveOperations *SyncStreamItem_SyncActionReceiveOperations `protobuf:"bytes,21,opt,name=receive_operations,json=receiveOperations,proto3,oneof"`
}

type SyncStreamItem_RequestOperationData struct {
	RequestOperationData *SyncStreamItem_SyncActionRequestOperationData `protobuf:"bytes,22,opt,name=request_operation_data,json=requestOperationData,proto3,oneof"`
}

type SyncStreamItem_ReceiveConfig struct {
	ReceiveConfig *SyncStreamItem_SyncActionReceiveConfig `protobuf:"bytes,23,opt,name=receive_config,json=receiveConfig,proto3,oneof"`
}

type SyncStreamItem_SetConfig struct {
	SetConfig *SyncStreamItem_SyncActionSetConfig `protobuf:"bytes,24,opt,name=set_config,json=setConfig,proto3,oneof"`
}

type SyncStreamItem_RequestResources struct {
	RequestResources *SyncStreamItem_SyncActionRequestResources `protobuf:"bytes,25,opt,name=request_resources,json=requestResources,proto3,oneof"` // request a list of available resources. Only used by the server.
}

type SyncStreamItem_ReceiveResources struct {
	ReceiveResources *SyncStreamItem_SyncActionReceiveResources `protobuf:"bytes,26,opt,name=receive_resources,json=receiveResources,proto3,oneof"` // receiving a list of available resources.
}

type SyncStreamItem_RequestLog struct {
	RequestLog *SyncStreamItem_SyncActionRequestLog `protobuf:"bytes,30,opt,name=request_log,json=requestLog,proto3,oneof"`
}

type SyncStreamItem_ReceiveLogData struct {
	ReceiveLogData *SyncStreamItem_SyncActionReceiveLogData `protobuf:"bytes,31,opt,name=receive_log_data,json=receiveLogData,proto3,oneof"`
}

type SyncStreamItem_Throttle struct {
	Throttle *SyncStreamItem_SyncActionThrottle `protobuf:"bytes,1000,opt,name=throttle,proto3,oneof"`
}

type SyncStreamItem_EstablishSharedSecret struct {
	EstablishSharedSecret *SyncStreamItem_SyncEstablishSharedSecret `protobuf:"bytes,2,opt,name=establish_shared_secret,json=establishSharedSecret,proto3,oneof"`
}

type SyncStreamItem_Encrypted struct {
	Encrypted *SyncStreamItem_SyncActionEncrypted `protobuf:"bytes,5,opt,name=encrypted,proto3,oneof"`
}

func (*SyncStreamItem_SignedMessage) isSyncStreamItem_Action() {}

func (*SyncStreamItem_Handshake) isSyncStreamItem_Action() {}

func (*SyncStreamItem_Heartbeat) isSyncStreamItem_Action() {}

func (*SyncStreamItem_OperationManifest) isSyncStreamItem_Action() {}

func (*SyncStreamItem_ReceiveOperations) isSyncStreamItem_Action() {}

func (*SyncStreamItem_RequestOperationData) isSyncStreamItem_Action() {}

func (*SyncStreamItem_ReceiveConfig) isSyncStreamItem_Action() {}

func (*SyncStreamItem_SetConfig) isSyncStreamItem_Action() {}

func (*SyncStreamItem_RequestResources) isSyncStreamItem_Action() {}

func (*SyncStreamItem_ReceiveResources) isSyncStreamItem_Action() {}

func (*SyncStreamItem_RequestLog) isSyncStreamItem_Action() {}

func (*SyncStreamItem_ReceiveLogData) isSyncStreamItem_Action() {}

func (*SyncStreamItem_Throttle) isSyncStreamItem_Action() {}

func (*SyncStreamItem_EstablishSharedSecret) isSyncStreamItem_Action() {}

func (*SyncStreamItem_Encrypted) isSyncStreamItem_Action() {}

// SyncActionHandshake is the first message sent by each peer over the
// post-quantum encrypted channel. It carries the sender's long-term
// ed25519 identity, its instance ID, and a single signature that binds
// the identity to *this* transport session.
//
// The signature covers a domain-separated hash of:
//
//	"backrest-sync-handshake/v1\x00"
//	|| protocol_version (8 bytes BE)
//	|| LP(instance_id)
//	|| LP(pairing_secret)
//	|| LP(transport transcript)
//
// where LP(x) = 4-byte BE length prefix || x, and the transport transcript
// is cryptoutil.TransportSession.Transcript() — a hash that commits to
// the ephemeral KEM messages of this connection.
//
// The transcript binding is what defeats a MITM that completes a separate
// KEM with each side: each leg has a different transcript, and the
// legitimate peer's signature only commits to its own transcript, so the
// attacker cannot forward a usable signature to either side.
//
// Receivers MUST recompute the transcript locally from their TransportSession
// and reject the handshake if the signature does not verify against
// public_key. There is no timestamp because freshness is provided by the
// ephemeral KEM, not by clock comparison.
type SyncStreamItem_SyncActionHandshake struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	ProtocolVersion int64                  `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	PublicKey       *v1.PublicKey          `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`             // sender's long-term ed25519 identity
	InstanceId      string                 `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`          // covered by signature below
	PairingSecret   string                 `protobuf:"bytes,4,opt,name=pairing_secret,json=pairingSecret,proto3" json:"pairing_secret,omitempty"` // optional pairing token; covered by signature below
	Signature       []byte                 `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`                              // ed25519(public_key, H(handshake bind input))
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionHandshake) Reset() {
	*x = SyncStreamItem_SyncActionHandshake{}
	mi := &file_v1sync_syncservice_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionHandshake) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionHandshake) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[14]
	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 SyncStreamItem_SyncActionHandshake.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionHandshake) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 0}
}

func (x *SyncStreamItem_SyncActionHandshake) GetProtocolVersion() int64 {
	if x != nil {
		return x.ProtocolVersion
	}
	return 0
}

func (x *SyncStreamItem_SyncActionHandshake) GetPublicKey() *v1.PublicKey {
	if x != nil {
		return x.PublicKey
	}
	return nil
}

func (x *SyncStreamItem_SyncActionHandshake) GetInstanceId() string {
	if x != nil {
		return x.InstanceId
	}
	return ""
}

func (x *SyncStreamItem_SyncActionHandshake) GetPairingSecret() string {
	if x != nil {
		return x.PairingSecret
	}
	return ""
}

func (x *SyncStreamItem_SyncActionHandshake) GetSignature() []byte {
	if x != nil {
		return x.Signature
	}
	return nil
}

// SyncActionEncrypted wraps an encrypted SyncStreamItem.
// After the post-quantum KEM handshake, all subsequent messages are sent
// inside this envelope.
type SyncStreamItem_SyncActionEncrypted struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Nonce         []byte                 `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`           // 12-byte GCM nonce
	Ciphertext    []byte                 `protobuf:"bytes,2,opt,name=ciphertext,proto3" json:"ciphertext,omitempty"` // AES-256-GCM(serialized SyncStreamItem)
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionEncrypted) Reset() {
	*x = SyncStreamItem_SyncActionEncrypted{}
	mi := &file_v1sync_syncservice_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionEncrypted) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionEncrypted) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[15]
	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 SyncStreamItem_SyncActionEncrypted.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionEncrypted) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 1}
}

func (x *SyncStreamItem_SyncActionEncrypted) GetNonce() []byte {
	if x != nil {
		return x.Nonce
	}
	return nil
}

func (x *SyncStreamItem_SyncActionEncrypted) GetCiphertext() []byte {
	if x != nil {
		return x.Ciphertext
	}
	return nil
}

// SyncActionHeartbeat is sent periodically to keep the connection alive.
type SyncStreamItem_SyncActionHeartbeat struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionHeartbeat) Reset() {
	*x = SyncStreamItem_SyncActionHeartbeat{}
	mi := &file_v1sync_syncservice_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionHeartbeat) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionHeartbeat) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[16]
	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 SyncStreamItem_SyncActionHeartbeat.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionHeartbeat) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 2}
}

type SyncStreamItem_SyncActionReceiveConfig struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Config        *RemoteConfig          `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionReceiveConfig) Reset() {
	*x = SyncStreamItem_SyncActionReceiveConfig{}
	mi := &file_v1sync_syncservice_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionReceiveConfig) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionReceiveConfig) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[17]
	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 SyncStreamItem_SyncActionReceiveConfig.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionReceiveConfig) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 3}
}

func (x *SyncStreamItem_SyncActionReceiveConfig) GetConfig() *RemoteConfig {
	if x != nil {
		return x.Config
	}
	return nil
}

type SyncStreamItem_SyncActionSetConfig struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Repos         []*v1.Repo             `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
	Plans         []*v1.Plan             `protobuf:"bytes,2,rep,name=plans,proto3" json:"plans,omitempty"`
	ReposToDelete []string               `protobuf:"bytes,3,rep,name=repos_to_delete,json=reposToDelete,proto3" json:"repos_to_delete,omitempty"`
	PlansToDelete []string               `protobuf:"bytes,4,rep,name=plans_to_delete,json=plansToDelete,proto3" json:"plans_to_delete,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionSetConfig) Reset() {
	*x = SyncStreamItem_SyncActionSetConfig{}
	mi := &file_v1sync_syncservice_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionSetConfig) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionSetConfig) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[18]
	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 SyncStreamItem_SyncActionSetConfig.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionSetConfig) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 4}
}

func (x *SyncStreamItem_SyncActionSetConfig) GetRepos() []*v1.Repo {
	if x != nil {
		return x.Repos
	}
	return nil
}

func (x *SyncStreamItem_SyncActionSetConfig) GetPlans() []*v1.Plan {
	if x != nil {
		return x.Plans
	}
	return nil
}

func (x *SyncStreamItem_SyncActionSetConfig) GetReposToDelete() []string {
	if x != nil {
		return x.ReposToDelete
	}
	return nil
}

func (x *SyncStreamItem_SyncActionSetConfig) GetPlansToDelete() []string {
	if x != nil {
		return x.PlansToDelete
	}
	return nil
}

type SyncStreamItem_SyncActionRequestResources struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionRequestResources) Reset() {
	*x = SyncStreamItem_SyncActionRequestResources{}
	mi := &file_v1sync_syncservice_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionRequestResources) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionRequestResources) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[19]
	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 SyncStreamItem_SyncActionRequestResources.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionRequestResources) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 5}
}

type SyncStreamItem_SyncActionReceiveResources struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Repos         []*RepoMetadata        `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
	Plans         []*PlanMetadata        `protobuf:"bytes,2,rep,name=plans,proto3" json:"plans,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionReceiveResources) Reset() {
	*x = SyncStreamItem_SyncActionReceiveResources{}
	mi := &file_v1sync_syncservice_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionReceiveResources) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionReceiveResources) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[20]
	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 SyncStreamItem_SyncActionReceiveResources.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionReceiveResources) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 6}
}

func (x *SyncStreamItem_SyncActionReceiveResources) GetRepos() []*RepoMetadata {
	if x != nil {
		return x.Repos
	}
	return nil
}

func (x *SyncStreamItem_SyncActionReceiveResources) GetPlans() []*PlanMetadata {
	if x != nil {
		return x.Plans
	}
	return nil
}

type SyncStreamItem_SyncActionConnectRepo struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RepoId        string                 `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionConnectRepo) Reset() {
	*x = SyncStreamItem_SyncActionConnectRepo{}
	mi := &file_v1sync_syncservice_proto_msgTypes[21]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionConnectRepo) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionConnectRepo) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[21]
	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 SyncStreamItem_SyncActionConnectRepo.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionConnectRepo) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 7}
}

func (x *SyncStreamItem_SyncActionConnectRepo) GetRepoId() string {
	if x != nil {
		return x.RepoId
	}
	return ""
}

type SyncStreamItem_SyncActionOperationManifest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	OpIds         []int64                `protobuf:"varint,1,rep,packed,name=op_ids,json=opIds,proto3" json:"op_ids,omitempty"`
	Modnos        []int64                `protobuf:"varint,2,rep,packed,name=modnos,proto3" json:"modnos,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionOperationManifest) Reset() {
	*x = SyncStreamItem_SyncActionOperationManifest{}
	mi := &file_v1sync_syncservice_proto_msgTypes[22]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionOperationManifest) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionOperationManifest) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[22]
	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 SyncStreamItem_SyncActionOperationManifest.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionOperationManifest) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 8}
}

func (x *SyncStreamItem_SyncActionOperationManifest) GetOpIds() []int64 {
	if x != nil {
		return x.OpIds
	}
	return nil
}

func (x *SyncStreamItem_SyncActionOperationManifest) GetModnos() []int64 {
	if x != nil {
		return x.Modnos
	}
	return nil
}

type SyncStreamItem_SyncActionRequestOperationData struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	OpIds         []int64                `protobuf:"varint,1,rep,packed,name=op_ids,json=opIds,proto3" json:"op_ids,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionRequestOperationData) Reset() {
	*x = SyncStreamItem_SyncActionRequestOperationData{}
	mi := &file_v1sync_syncservice_proto_msgTypes[23]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionRequestOperationData) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionRequestOperationData) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[23]
	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 SyncStreamItem_SyncActionRequestOperationData.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionRequestOperationData) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 9}
}

func (x *SyncStreamItem_SyncActionRequestOperationData) GetOpIds() []int64 {
	if x != nil {
		return x.OpIds
	}
	return nil
}

type SyncStreamItem_SyncActionReceiveOperations struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Event         *v1.OperationEvent     `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionReceiveOperations) Reset() {
	*x = SyncStreamItem_SyncActionReceiveOperations{}
	mi := &file_v1sync_syncservice_proto_msgTypes[24]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionReceiveOperations) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionReceiveOperations) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[24]
	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 SyncStreamItem_SyncActionReceiveOperations.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionReceiveOperations) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 10}
}

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

type SyncStreamItem_SyncActionRequestLog struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	LogId         string                 `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionRequestLog) Reset() {
	*x = SyncStreamItem_SyncActionRequestLog{}
	mi := &file_v1sync_syncservice_proto_msgTypes[25]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionRequestLog) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionRequestLog) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[25]
	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 SyncStreamItem_SyncActionRequestLog.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionRequestLog) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 11}
}

func (x *SyncStreamItem_SyncActionRequestLog) GetLogId() string {
	if x != nil {
		return x.LogId
	}
	return ""
}

type SyncStreamItem_SyncActionReceiveLogData struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	LogId string                 `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// Required only for first message in a log data stream.
	OwnerOpid        int64 `protobuf:"varint,2,opt,name=owner_opid,json=ownerOpid,proto3" json:"owner_opid,omitempty"`                        // The operation ID of the operation that owns this log data.
	ExpirationTsUnix int64 `protobuf:"varint,3,opt,name=expiration_ts_unix,json=expirationTsUnix,proto3" json:"expiration_ts_unix,omitempty"` // Unix timestamp in seconds when the log data expires.
	// Can be sent repeatedly, must be terminated by a packet with size = 0.
	Chunk []byte `protobuf:"bytes,4,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// If set, indicates an error occurred while fetching the log data.
	ErrorMessage  string `protobuf:"bytes,5,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionReceiveLogData) Reset() {
	*x = SyncStreamItem_SyncActionReceiveLogData{}
	mi := &file_v1sync_syncservice_proto_msgTypes[26]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionReceiveLogData) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionReceiveLogData) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[26]
	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 SyncStreamItem_SyncActionReceiveLogData.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionReceiveLogData) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 12}
}

func (x *SyncStreamItem_SyncActionReceiveLogData) GetLogId() string {
	if x != nil {
		return x.LogId
	}
	return ""
}

func (x *SyncStreamItem_SyncActionReceiveLogData) GetOwnerOpid() int64 {
	if x != nil {
		return x.OwnerOpid
	}
	return 0
}

func (x *SyncStreamItem_SyncActionReceiveLogData) GetExpirationTsUnix() int64 {
	if x != nil {
		return x.ExpirationTsUnix
	}
	return 0
}

func (x *SyncStreamItem_SyncActionReceiveLogData) GetChunk() []byte {
	if x != nil {
		return x.Chunk
	}
	return nil
}

func (x *SyncStreamItem_SyncActionReceiveLogData) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

type SyncStreamItem_SyncActionThrottle struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	DelayMs       int64                  `protobuf:"varint,1,opt,name=delay_ms,json=delayMs,proto3" json:"delay_ms,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncActionThrottle) Reset() {
	*x = SyncStreamItem_SyncActionThrottle{}
	mi := &file_v1sync_syncservice_proto_msgTypes[27]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncActionThrottle) ProtoMessage() {}

func (x *SyncStreamItem_SyncActionThrottle) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[27]
	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 SyncStreamItem_SyncActionThrottle.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncActionThrottle) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 13}
}

func (x *SyncStreamItem_SyncActionThrottle) GetDelayMs() int64 {
	if x != nil {
		return x.DelayMs
	}
	return 0
}

// SyncEstablishSharedSecret is exchanged immediately after the connection
// is opened. The initiator (client) sends kem_public_key. The responder
// (server) replies with kem_encapsulation. Both sides then derive a shared
// AES-256-GCM session key via the HPKE Export interface. All subsequent
// messages must be wrapped in SyncActionEncrypted.
//
// The KEM is the post-quantum hybrid ML-KEM-1024 + ECDH-P384 (HPKE
// ciphersuite ML-KEM-1024-P384 / KEM ID 0x0050, RFC 9180 + the IETF hybrid
// KEM drafts). KDF is HKDF-SHA256, AEAD is AES-256-GCM. Peers must use
// protocol_version=1; mismatched versions abort the connection.
type SyncStreamItem_SyncEstablishSharedSecret struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	ProtocolVersion  uint32                 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`   // current: 1
	KemPublicKey     []byte                 `protobuf:"bytes,2,opt,name=kem_public_key,json=kemPublicKey,proto3" json:"kem_public_key,omitempty"`           // set by initiator
	KemEncapsulation []byte                 `protobuf:"bytes,3,opt,name=kem_encapsulation,json=kemEncapsulation,proto3" json:"kem_encapsulation,omitempty"` // set by responder
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *SyncStreamItem_SyncEstablishSharedSecret) Reset() {
	*x = SyncStreamItem_SyncEstablishSharedSecret{}
	mi := &file_v1sync_syncservice_proto_msgTypes[28]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SyncStreamItem_SyncEstablishSharedSecret) ProtoMessage() {}

func (x *SyncStreamItem_SyncEstablishSharedSecret) ProtoReflect() protoreflect.Message {
	mi := &file_v1sync_syncservice_proto_msgTypes[28]
	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 SyncStreamItem_SyncEstablishSharedSecret.ProtoReflect.Descriptor instead.
func (*SyncStreamItem_SyncEstablishSharedSecret) Descriptor() ([]byte, []int) {
	return file_v1sync_syncservice_proto_rawDescGZIP(), []int{13, 14}
}

func (x *SyncStreamItem_SyncEstablishSharedSecret) GetProtocolVersion() uint32 {
	if x != nil {
		return x.ProtocolVersion
	}
	return 0
}

func (x *SyncStreamItem_SyncEstablishSharedSecret) GetKemPublicKey() []byte {
	if x != nil {
		return x.KemPublicKey
	}
	return nil
}

func (x *SyncStreamItem_SyncEstablishSharedSecret) GetKemEncapsulation() []byte {
	if x != nil {
		return x.KemEncapsulation
	}
	return nil
}

var File_v1sync_syncservice_proto protoreflect.FileDescriptor

const file_v1sync_syncservice_proto_rawDesc = "" +
	"\n" +
	"\x18v1sync/syncservice.proto\x12\x06v1sync\x1a\x0fv1/config.proto\x1a\x0fv1/crypto.proto\x1a\x0fv1/restic.proto\x1a\x10v1/service.proto\x1a\x13v1/operations.proto\x1a\x11types/value.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a\x1cgoogle/api/annotations.proto\x1a\x19google/protobuf/any.proto\"6\n" +
	"\x16SyncStateStreamRequest\x12\x1c\n" +
	"\tsubscribe\x18\x01 \x01(\bR\tsubscribe\"\x87\x03\n" +
	"\tPeerState\x12(\n" +
	"\x10peer_instance_id\x18\x01 \x01(\tR\x0epeerInstanceId\x12\x1d\n" +
	"\n" +
	"peer_keyid\x18\x02 \x01(\tR\tpeerKeyid\x12-\n" +
	"\x05state\x18\x03 \x01(\x0e2\x17.v1sync.ConnectionStateR\x05state\x12%\n" +
	"\x0estatus_message\x18\x04 \x01(\tR\rstatusMessage\x125\n" +
	"\vknown_plans\x18\x05 \x03(\v2\x14.v1sync.PlanMetadataR\n" +
	"knownPlans\x125\n" +
	"\vknown_repos\x18\x06 \x03(\v2\x14.v1sync.RepoMetadataR\n" +
	"knownRepos\x129\n" +
	"\rremote_config\x18\a \x01(\v2\x14.v1sync.RemoteConfigR\fremoteConfig\x122\n" +
	"\x15last_heartbeat_millis\x18\b \x01(\x03R\x13lastHeartbeatMillis\"I\n" +
	"\x13AuthenticateRequest\x122\n" +
	"\vinstance_id\x18\x01 \x01(\v2\x11.v1.SignedMessageR\n" +
	"instanceId\"M\n" +
	"\x1cGetOperationMetadataResponse\x12\x15\n" +
	"\x06op_ids\x18\x01 \x03(\x03R\x05opIds\x12\x16\n" +
	"\x06modnos\x18\x02 \x03(\x03R\x06modnos\"\x88\x01\n" +
	"\fLogDataEntry\x12\x15\n" +
	"\x06log_id\x18\x01 \x01(\tR\x05logId\x12\x1d\n" +
	"\n" +
	"owner_opid\x18\x02 \x01(\x03R\townerOpid\x12,\n" +
	"\x12expiration_ts_unix\x18\x03 \x01(\x03R\x10expirationTsUnix\x12\x14\n" +
	"\x05chunk\x18\x04 \x01(\fR\x05chunk\"v\n" +
	"\x1cSetAvailableResourcesRequest\x12*\n" +
	"\x05repos\x18\x01 \x03(\v2\x14.v1sync.PlanMetadataR\x05repos\x12*\n" +
	"\x05plans\x18\x02 \x03(\v2\x14.v1sync.RepoMetadataR\x05plans\"2\n" +
	"\fRepoMetadata\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\x12\x12\n" +
	"\x04guid\x18\x02 \x01(\tR\x04guid\"\x1e\n" +
	"\fPlanMetadata\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\"\xa2\x01\n" +
	"\x10SetConfigRequest\x12\x1e\n" +
	"\x05plans\x18\x01 \x03(\v2\b.v1.PlanR\x05plans\x12\x1e\n" +
	"\x05repos\x18\x02 \x03(\v2\b.v1.RepoR\x05repos\x12&\n" +
	"\x0frepos_to_delete\x18\x03 \x03(\tR\rreposToDelete\x12&\n" +
	"\x0fplans_to_delete\x18\x04 \x03(\tR\rplansToDelete\"\xcd\x01\n" +
	"\x1cSetRemoteClientConfigRequest\x12\x1d\n" +
	"\n" +
	"peer_keyid\x18\x01 \x01(\tR\tpeerKeyid\x12\x1e\n" +
	"\x05repos\x18\x02 \x03(\v2\b.v1.RepoR\x05repos\x12\x1e\n" +
	"\x05plans\x18\x03 \x03(\v2\b.v1.PlanR\x05plans\x12&\n" +
	"\x0frepos_to_delete\x18\x04 \x03(\tR\rreposToDelete\x12&\n" +
	"\x0fplans_to_delete\x18\x05 \x03(\tR\rplansToDelete\"\x1f\n" +
	"\x1dSetRemoteClientConfigResponse\"~\n" +
	"\fRemoteConfig\x12\x14\n" +
	"\x05modno\x18\x01 \x01(\x05R\x05modno\x12\x18\n" +
	"\aversion\x18\x02 \x01(\x05R\aversion\x12\x1e\n" +
	"\x05repos\x18\x03 \x03(\v2\b.v1.RepoR\x05repos\x12\x1e\n" +
	"\x05plans\x18\x04 \x03(\v2\b.v1.PlanR\x05plans\"v\n" +
	"\x12AuthorizationToken\x12,\n" +
	"\n" +
	"public_key\x18\x01 \x01(\v2\r.v1.PublicKeyR\tpublicKey\x122\n" +
	"\vinstance_id\x18\x02 \x01(\v2\x11.v1.SignedMessageR\n" +
	"instanceId\"\xf1\x16\n" +
	"\x0eSyncStreamItem\x12:\n" +
	"\x0esigned_message\x18\x01 \x01(\v2\x11.v1.SignedMessageH\x00R\rsignedMessage\x12J\n" +
	"\thandshake\x18\x03 \x01(\v2*.v1sync.SyncStreamItem.SyncActionHandshakeH\x00R\thandshake\x12J\n" +
	"\theartbeat\x18\x04 \x01(\v2*.v1sync.SyncStreamItem.SyncActionHeartbeatH\x00R\theartbeat\x12c\n" +
	"\x12operation_manifest\x18\x14 \x01(\v22.v1sync.SyncStreamItem.SyncActionOperationManifestH\x00R\x11operationManifest\x12c\n" +
	"\x12receive_operations\x18\x15 \x01(\v22.v1sync.SyncStreamItem.SyncActionReceiveOperationsH\x00R\x11receiveOperations\x12m\n" +
	"\x16request_operation_data\x18\x16 \x01(\v25.v1sync.SyncStreamItem.SyncActionRequestOperationDataH\x00R\x14requestOperationData\x12W\n" +
	"\x0ereceive_config\x18\x17 \x01(\v2..v1sync.SyncStreamItem.SyncActionReceiveConfigH\x00R\rreceiveConfig\x12K\n" +
	"\n" +
	"set_config\x18\x18 \x01(\v2*.v1sync.SyncStreamItem.SyncActionSetConfigH\x00R\tsetConfig\x12`\n" +
	"\x11request_resources\x18\x19 \x01(\v21.v1sync.SyncStreamItem.SyncActionRequestResourcesH\x00R\x10requestResources\x12`\n" +
	"\x11receive_resources\x18\x1a \x01(\v21.v1sync.SyncStreamItem.SyncActionReceiveResourcesH\x00R\x10receiveResources\x12N\n" +
	"\vrequest_log\x18\x1e \x01(\v2+.v1sync.SyncStreamItem.SyncActionRequestLogH\x00R\n" +
	"requestLog\x12[\n" +
	"\x10receive_log_data\x18\x1f \x01(\v2/.v1sync.SyncStreamItem.SyncActionReceiveLogDataH\x00R\x0ereceiveLogData\x12H\n" +
	"\bthrottle\x18\xe8\a \x01(\v2).v1sync.SyncStreamItem.SyncActionThrottleH\x00R\bthrottle\x12j\n" +
	"\x17establish_shared_secret\x18\x02 \x01(\v20.v1sync.SyncStreamItem.SyncEstablishSharedSecretH\x00R\x15establishSharedSecret\x12J\n" +
	"\tencrypted\x18\x05 \x01(\v2*.v1sync.SyncStreamItem.SyncActionEncryptedH\x00R\tencrypted\x1a\xd4\x01\n" +
	"\x13SyncActionHandshake\x12)\n" +
	"\x10protocol_version\x18\x01 \x01(\x03R\x0fprotocolVersion\x12,\n" +
	"\n" +
	"public_key\x18\x02 \x01(\v2\r.v1.PublicKeyR\tpublicKey\x12\x1f\n" +
	"\vinstance_id\x18\x03 \x01(\tR\n" +
	"instanceId\x12%\n" +
	"\x0epairing_secret\x18\x04 \x01(\tR\rpairingSecret\x12\x1c\n" +
	"\tsignature\x18\x05 \x01(\fR\tsignature\x1aK\n" +
	"\x13SyncActionEncrypted\x12\x14\n" +
	"\x05nonce\x18\x01 \x01(\fR\x05nonce\x12\x1e\n" +
	"\n" +
	"ciphertext\x18\x02 \x01(\fR\n" +
	"ciphertext\x1a\x15\n" +
	"\x13SyncActionHeartbeat\x1aG\n" +
	"\x17SyncActionReceiveConfig\x12,\n" +
	"\x06config\x18\x01 \x01(\v2\x14.v1sync.RemoteConfigR\x06config\x1a\xa5\x01\n" +
	"\x13SyncActionSetConfig\x12\x1e\n" +
	"\x05repos\x18\x01 \x03(\v2\b.v1.RepoR\x05repos\x12\x1e\n" +
	"\x05plans\x18\x02 \x03(\v2\b.v1.PlanR\x05plans\x12&\n" +
	"\x0frepos_to_delete\x18\x03 \x03(\tR\rreposToDelete\x12&\n" +
	"\x0fplans_to_delete\x18\x04 \x03(\tR\rplansToDelete\x1a\x1c\n" +
	"\x1aSyncActionRequestResources\x1at\n" +
	"\x1aSyncActionReceiveResources\x12*\n" +
	"\x05repos\x18\x01 \x03(\v2\x14.v1sync.RepoMetadataR\x05repos\x12*\n" +
	"\x05plans\x18\x02 \x03(\v2\x14.v1sync.PlanMetadataR\x05plans\x1a0\n" +
	"\x15SyncActionConnectRepo\x12\x17\n" +
	"\arepo_id\x18\x01 \x01(\tR\x06repoId\x1aL\n" +
	"\x1bSyncActionOperationManifest\x12\x15\n" +
	"\x06op_ids\x18\x01 \x03(\x03R\x05opIds\x12\x16\n" +
	"\x06modnos\x18\x02 \x03(\x03R\x06modnos\x1a7\n" +
	"\x1eSyncActionRequestOperationData\x12\x15\n" +
	"\x06op_ids\x18\x01 \x03(\x03R\x05opIds\x1aG\n" +
	"\x1bSyncActionReceiveOperations\x12(\n" +
	"\x05event\x18\x01 \x01(\v2\x12.v1.OperationEventR\x05event\x1a-\n" +
	"\x14SyncActionRequestLog\x12\x15\n" +
	"\x06log_id\x18\x01 \x01(\tR\x05logId\x1a\xb9\x01\n" +
	"\x18SyncActionReceiveLogData\x12\x15\n" +
	"\x06log_id\x18\x01 \x01(\tR\x05logId\x12\x1d\n" +
	"\n" +
	"owner_opid\x18\x02 \x01(\x03R\townerOpid\x12,\n" +
	"\x12expiration_ts_unix\x18\x03 \x01(\x03R\x10expirationTsUnix\x12\x14\n" +
	"\x05chunk\x18\x04 \x01(\fR\x05chunk\x12#\n" +
	"\rerror_message\x18\x05 \x01(\tR\ferrorMessage\x1a/\n" +
	"\x12SyncActionThrottle\x12\x19\n" +
	"\bdelay_ms\x18\x01 \x01(\x03R\adelayMs\x1a\x99\x01\n" +
	"\x19SyncEstablishSharedSecret\x12)\n" +
	"\x10protocol_version\x18\x01 \x01(\rR\x0fprotocolVersion\x12$\n" +
	"\x0ekem_public_key\x18\x02 \x01(\fR\fkemPublicKey\x12+\n" +
	"\x11kem_encapsulation\x18\x03 \x01(\fR\x10kemEncapsulation\"\xb4\x01\n" +
	"\x13RepoConnectionState\x12\x1c\n" +
	"\x18CONNECTION_STATE_UNKNOWN\x10\x00\x12\x1c\n" +
	"\x18CONNECTION_STATE_PENDING\x10\x01\x12\x1e\n" +
	"\x1aCONNECTION_STATE_CONNECTED\x10\x02\x12!\n" +
	"\x1dCONNECTION_STATE_UNAUTHORIZED\x10\x03\x12\x1e\n" +
	"\x1aCONNECTION_STATE_NOT_FOUND\x10\x04B\b\n" +
	"\x06action*\x9c\x02\n" +
	"\x0fConnectionState\x12\x1c\n" +
	"\x18CONNECTION_STATE_UNKNOWN\x10\x00\x12\x1c\n" +
	"\x18CONNECTION_STATE_PENDING\x10\x01\x12\x1e\n" +
	"\x1aCONNECTION_STATE_CONNECTED\x10\x02\x12!\n" +
	"\x1dCONNECTION_STATE_DISCONNECTED\x10\x03\x12\x1f\n" +
	"\x1bCONNECTION_STATE_RETRY_WAIT\x10\x04\x12\x1f\n" +
	"\x1bCONNECTION_STATE_ERROR_AUTH\x10\n" +
	"\x12#\n" +
	"\x1fCONNECTION_STATE_ERROR_PROTOCOL\x10\v\x12#\n" +
	"\x1fCONNECTION_STATE_ERROR_INTERNAL\x10\f2S\n" +
	"\x13BackrestSyncService\x12<\n" +
	"\x04Sync\x12\x16.v1sync.SyncStreamItem\x1a\x16.v1sync.SyncStreamItem\"\x00(\x010\x012\xd4\x01\n" +
	"\x18BackrestSyncStateService\x12P\n" +
	"\x17GetPeerSyncStatesStream\x12\x1e.v1sync.SyncStateStreamRequest\x1a\x11.v1sync.PeerState\"\x000\x01\x12f\n" +
	"\x15SetRemoteClientConfig\x12$.v1sync.SetRemoteClientConfigRequest\x1a%.v1sync.SetRemoteClientConfigResponse\"\x00B0Z.github.com/garethgeorge/backrest/gen/go/v1syncb\x06proto3"

var (
	file_v1sync_syncservice_proto_rawDescOnce sync.Once
	file_v1sync_syncservice_proto_rawDescData []byte
)

func file_v1sync_syncservice_proto_rawDescGZIP() []byte {
	file_v1sync_syncservice_proto_rawDescOnce.Do(func() {
		file_v1sync_syncservice_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_v1sync_syncservice_proto_rawDesc), len(file_v1sync_syncservice_proto_rawDesc)))
	})
	return file_v1sync_syncservice_proto_rawDescData
}

var file_v1sync_syncservice_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
var file_v1sync_syncservice_proto_msgTypes = make([]protoimpl.MessageInfo, 29)
var file_v1sync_syncservice_proto_goTypes = []any{
	(ConnectionState)(0),                                  // 0: v1sync.ConnectionState
	(SyncStreamItem_RepoConnectionState)(0),               // 1: v1sync.SyncStreamItem.RepoConnectionState
	(*SyncStateStreamRequest)(nil),                        // 2: v1sync.SyncStateStreamRequest
	(*PeerState)(nil),                                     // 3: v1sync.PeerState
	(*AuthenticateRequest)(nil),                           // 4: v1sync.AuthenticateRequest
	(*GetOperationMetadataResponse)(nil),                  // 5: v1sync.GetOperationMetadataResponse
	(*LogDataEntry)(nil),                                  // 6: v1sync.LogDataEntry
	(*SetAvailableResourcesRequest)(nil),                  // 7: v1sync.SetAvailableResourcesRequest
	(*RepoMetadata)(nil),                                  // 8: v1sync.RepoMetadata
	(*PlanMetadata)(nil),                                  // 9: v1sync.PlanMetadata
	(*SetConfigRequest)(nil),                              // 10: v1sync.SetConfigRequest
	(*SetRemoteClientConfigRequest)(nil),                  // 11: v1sync.SetRemoteClientConfigRequest
	(*SetRemoteClientConfigResponse)(nil),                 // 12: v1sync.SetRemoteClientConfigResponse
	(*RemoteConfig)(nil),                                  // 13: v1sync.RemoteConfig
	(*AuthorizationToken)(nil),                            // 14: v1sync.AuthorizationToken
	(*SyncStreamItem)(nil),                                // 15: v1sync.SyncStreamItem
	(*SyncStreamItem_SyncActionHandshake)(nil),            // 16: v1sync.SyncStreamItem.SyncActionHandshake
	(*SyncStreamItem_SyncActionEncrypted)(nil),            // 17: v1sync.SyncStreamItem.SyncActionEncrypted
	(*SyncStreamItem_SyncActionHeartbeat)(nil),            // 18: v1sync.SyncStreamItem.SyncActionHeartbeat
	(*SyncStreamItem_SyncActionReceiveConfig)(nil),        // 19: v1sync.SyncStreamItem.SyncActionReceiveConfig
	(*SyncStreamItem_SyncActionSetConfig)(nil),            // 20: v1sync.SyncStreamItem.SyncActionSetConfig
	(*SyncStreamItem_SyncActionRequestResources)(nil),     // 21: v1sync.SyncStreamItem.SyncActionRequestResources
	(*SyncStreamItem_SyncActionReceiveResources)(nil),     // 22: v1sync.SyncStreamItem.SyncActionReceiveResources
	(*SyncStreamItem_SyncActionConnectRepo)(nil),          // 23: v1sync.SyncStreamItem.SyncActionConnectRepo
	(*SyncStreamItem_SyncActionOperationManifest)(nil),    // 24: v1sync.SyncStreamItem.SyncActionOperationManifest
	(*SyncStreamItem_SyncActionRequestOperationData)(nil), // 25: v1sync.SyncStreamItem.SyncActionRequestOperationData
	(*SyncStreamItem_SyncActionReceiveOperations)(nil),    // 26: v1sync.SyncStreamItem.SyncActionReceiveOperations
	(*SyncStreamItem_SyncActionRequestLog)(nil),           // 27: v1sync.SyncStreamItem.SyncActionRequestLog
	(*SyncStreamItem_SyncActionReceiveLogData)(nil),       // 28: v1sync.SyncStreamItem.SyncActionReceiveLogData
	(*SyncStreamItem_SyncActionThrottle)(nil),             // 29: v1sync.SyncStreamItem.SyncActionThrottle
	(*SyncStreamItem_SyncEstablishSharedSecret)(nil),      // 30: v1sync.SyncStreamItem.SyncEstablishSharedSecret
	(*v1.SignedMessage)(nil),                              // 31: v1.SignedMessage
	(*v1.Plan)(nil),                                       // 32: v1.Plan
	(*v1.Repo)(nil),                                       // 33: v1.Repo
	(*v1.PublicKey)(nil),                                  // 34: v1.PublicKey
	(*v1.OperationEvent)(nil),                             // 35: v1.OperationEvent
}
var file_v1sync_syncservice_proto_depIdxs = []int32{
	0,  // 0: v1sync.PeerState.state:type_name -> v1sync.ConnectionState
	9,  // 1: v1sync.PeerState.known_plans:type_name -> v1sync.PlanMetadata
	8,  // 2: v1sync.PeerState.known_repos:type_name -> v1sync.RepoMetadata
	13, // 3: v1sync.PeerState.remote_config:type_name -> v1sync.RemoteConfig
	31, // 4: v1sync.AuthenticateRequest.instance_id:type_name -> v1.SignedMessage
	9,  // 5: v1sync.SetAvailableResourcesRequest.repos:type_name -> v1sync.PlanMetadata
	8,  // 6: v1sync.SetAvailableResourcesRequest.plans:type_name -> v1sync.RepoMetadata
	32, // 7: v1sync.SetConfigRequest.plans:type_name -> v1.Plan
	33, // 8: v1sync.SetConfigRequest.repos:type_name -> v1.Repo
	33, // 9: v1sync.SetRemoteClientConfigRequest.repos:type_name -> v1.Repo
	32, // 10: v1sync.SetRemoteClientConfigRequest.plans:type_name -> v1.Plan
	33, // 11: v1sync.RemoteConfig.repos:type_name -> v1.Repo
	32, // 12: v1sync.RemoteConfig.plans:type_name -> v1.Plan
	34, // 13: v1sync.AuthorizationToken.public_key:type_name -> v1.PublicKey
	31, // 14: v1sync.AuthorizationToken.instance_id:type_name -> v1.SignedMessage
	31, // 15: v1sync.SyncStreamItem.signed_message:type_name -> v1.SignedMessage
	16, // 16: v1sync.SyncStreamItem.handshake:type_name -> v1sync.SyncStreamItem.SyncActionHandshake
	18, // 17: v1sync.SyncStreamItem.heartbeat:type_name -> v1sync.SyncStreamItem.SyncActionHeartbeat
	24, // 18: v1sync.SyncStreamItem.operation_manifest:type_name -> v1sync.SyncStreamItem.SyncActionOperationManifest
	26, // 19: v1sync.SyncStreamItem.receive_operations:type_name -> v1sync.SyncStreamItem.SyncActionReceiveOperations
	25, // 20: v1sync.SyncStreamItem.request_operation_data:type_name -> v1sync.SyncStreamItem.SyncActionRequestOperationData
	19, // 21: v1sync.SyncStreamItem.receive_config:type_name -> v1sync.SyncStreamItem.SyncActionReceiveConfig
	20, // 22: v1sync.SyncStreamItem.set_config:type_name -> v1sync.SyncStreamItem.SyncActionSetConfig
	21, // 23: v1sync.SyncStreamItem.request_resources:type_name -> v1sync.SyncStreamItem.SyncActionRequestResources
	22, // 24: v1sync.SyncStreamItem.receive_resources:type_name -> v1sync.SyncStreamItem.SyncActionReceiveResources
	27, // 25: v1sync.SyncStreamItem.request_log:type_name -> v1sync.SyncStreamItem.SyncActionRequestLog
	28, // 26: v1sync.SyncStreamItem.receive_log_data:type_name -> v1sync.SyncStreamItem.SyncActionReceiveLogData
	29, // 27: v1sync.SyncStreamItem.throttle:type_name -> v1sync.SyncStreamItem.SyncActionThrottle
	30, // 28: v1sync.SyncStreamItem.establish_shared_secret:type_name -> v1sync.SyncStreamItem.SyncEstablishSharedSecret
	17, // 29: v1sync.SyncStreamItem.encrypted:type_name -> v1sync.SyncStreamItem.SyncActionEncrypted
	34, // 30: v1sync.SyncStreamItem.SyncActionHandshake.public_key:type_name -> v1.PublicKey
	13, // 31: v1sync.SyncStreamItem.SyncActionReceiveConfig.config:type_name -> v1sync.RemoteConfig
	33, // 32: v1sync.SyncStreamItem.SyncActionSetConfig.repos:type_name -> v1.Repo
	32, // 33: v1sync.SyncStreamItem.SyncActionSetConfig.plans:type_name -> v1.Plan
	8,  // 34: v1sync.SyncStreamItem.SyncActionReceiveResources.repos:type_name -> v1sync.RepoMetadata
	9,  // 35: v1sync.SyncStreamItem.SyncActionReceiveResources.plans:type_name -> v1sync.PlanMetadata
	35, // 36: v1sync.SyncStreamItem.SyncActionReceiveOperations.event:type_name -> v1.OperationEvent
	15, // 37: v1sync.BackrestSyncService.Sync:input_type -> v1sync.SyncStreamItem
	2,  // 38: v1sync.BackrestSyncStateService.GetPeerSyncStatesStream:input_type -> v1sync.SyncStateStreamRequest
	11, // 39: v1sync.BackrestSyncStateService.SetRemoteClientConfig:input_type -> v1sync.SetRemoteClientConfigRequest
	15, // 40: v1sync.BackrestSyncService.Sync:output_type -> v1sync.SyncStreamItem
	3,  // 41: v1sync.BackrestSyncStateService.GetPeerSyncStatesStream:output_type -> v1sync.PeerState
	12, // 42: v1sync.BackrestSyncStateService.SetRemoteClientConfig:output_type -> v1sync.SetRemoteClientConfigResponse
	40, // [40:43] is the sub-list for method output_type
	37, // [37:40] is the sub-list for method input_type
	37, // [37:37] is the sub-list for extension type_name
	37, // [37:37] is the sub-list for extension extendee
	0,  // [0:37] is the sub-list for field type_name
}

func init() { file_v1sync_syncservice_proto_init() }
func file_v1sync_syncservice_proto_init() {
	if File_v1sync_syncservice_proto != nil {
		return
	}
	file_v1sync_syncservice_proto_msgTypes[13].OneofWrappers = []any{
		(*SyncStreamItem_SignedMessage)(nil),
		(*SyncStreamItem_Handshake)(nil),
		(*SyncStreamItem_Heartbeat)(nil),
		(*SyncStreamItem_OperationManifest)(nil),
		(*SyncStreamItem_ReceiveOperations)(nil),
		(*SyncStreamItem_RequestOperationData)(nil),
		(*SyncStreamItem_ReceiveConfig)(nil),
		(*SyncStreamItem_SetConfig)(nil),
		(*SyncStreamItem_RequestResources)(nil),
		(*SyncStreamItem_ReceiveResources)(nil),
		(*SyncStreamItem_RequestLog)(nil),
		(*SyncStreamItem_ReceiveLogData)(nil),
		(*SyncStreamItem_Throttle)(nil),
		(*SyncStreamItem_EstablishSharedSecret)(nil),
		(*SyncStreamItem_Encrypted)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_v1sync_syncservice_proto_rawDesc), len(file_v1sync_syncservice_proto_rawDesc)),
			NumEnums:      2,
			NumMessages:   29,
			NumExtensions: 0,
			NumServices:   2,
		},
		GoTypes:           file_v1sync_syncservice_proto_goTypes,
		DependencyIndexes: file_v1sync_syncservice_proto_depIdxs,
		EnumInfos:         file_v1sync_syncservice_proto_enumTypes,
		MessageInfos:      file_v1sync_syncservice_proto_msgTypes,
	}.Build()
	File_v1sync_syncservice_proto = out.File
	file_v1sync_syncservice_proto_goTypes = nil
	file_v1sync_syncservice_proto_depIdxs = nil
}