v1sync

type AuthenticateRequest struct {
	InstanceId *v1.SignedMessage `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // The ID of the peer instance.
	// contains filtered or unexported fields
}

type AuthorizationToken struct {
	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.
	// contains filtered or unexported fields
}

type BackrestSyncServiceClient interface {
	Sync(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SyncStreamItem, SyncStreamItem], error)
}

type BackrestSyncServiceServer interface {
	Sync(grpc.BidiStreamingServer[SyncStreamItem, SyncStreamItem]) error
	// contains filtered or unexported methods
}

type BackrestSyncService_SyncClient = grpc.BidiStreamingClient[SyncStreamItem, SyncStreamItem]

type BackrestSyncService_SyncServer = grpc.BidiStreamingServer[SyncStreamItem, SyncStreamItem]

type BackrestSyncStateServiceClient interface {
	GetPeerSyncStatesStream(ctx context.Context, in *SyncStateStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[PeerState], error)
	// SetRemoteClientConfig pushes a config change to a connected authorized client peer.
	SetRemoteClientConfig(ctx context.Context, in *SetRemoteClientConfigRequest, opts ...grpc.CallOption) (*SetRemoteClientConfigResponse, error)
}

type BackrestSyncStateServiceServer interface {
	GetPeerSyncStatesStream(*SyncStateStreamRequest, grpc.ServerStreamingServer[PeerState]) error
	// SetRemoteClientConfig pushes a config change to a connected authorized client peer.
	SetRemoteClientConfig(context.Context, *SetRemoteClientConfigRequest) (*SetRemoteClientConfigResponse, error)
	// contains filtered or unexported methods
}

type BackrestSyncStateService_GetPeerSyncStatesStreamClient = grpc.ServerStreamingClient[PeerState]

type BackrestSyncStateService_GetPeerSyncStatesStreamServer = grpc.ServerStreamingServer[PeerState]

type ConnectionState int32

type GetOperationMetadataResponse struct {
	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.
	// contains filtered or unexported fields
}

type LogDataEntry struct {
	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.
	// contains filtered or unexported fields
}

type PeerState struct {
	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.
	// contains filtered or unexported fields
}

type PlanMetadata struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type RemoteConfig struct {
	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"`
	// contains filtered or unexported fields
}

type RepoMetadata struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Guid string `protobuf:"bytes,2,opt,name=guid,proto3" json:"guid,omitempty"`
	// contains filtered or unexported fields
}

type SetAvailableResourcesRequest struct {
	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.
	// contains filtered or unexported fields
}

type SetConfigRequest struct {
	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.
	// contains filtered or unexported fields
}

type SetRemoteClientConfigRequest struct {
	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.
	// contains filtered or unexported fields
}

type SetRemoteClientConfigResponse struct {
	// contains filtered or unexported fields
}

type SyncStateStreamRequest struct {
	Subscribe bool `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"` // If true, the stream will continue to send updates until cancelled.
	// contains filtered or unexported fields
}

type SyncStreamItem struct {

	// 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"`
	// contains filtered or unexported fields
}

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

type SyncStreamItem_EstablishSharedSecret struct {
	EstablishSharedSecret *SyncStreamItem_SyncEstablishSharedSecret `protobuf:"bytes,2,opt,name=establish_shared_secret,json=establishSharedSecret,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_ReceiveConfig struct {
	ReceiveConfig *SyncStreamItem_SyncActionReceiveConfig `protobuf:"bytes,23,opt,name=receive_config,json=receiveConfig,proto3,oneof"`
}

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

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

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_RepoConnectionState int32

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

type SyncStreamItem_RequestOperationData struct {
	RequestOperationData *SyncStreamItem_SyncActionRequestOperationData `protobuf:"bytes,22,opt,name=request_operation_data,json=requestOperationData,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_SetConfig struct {
	SetConfig *SyncStreamItem_SyncActionSetConfig `protobuf:"bytes,24,opt,name=set_config,json=setConfig,proto3,oneof"`
}

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

type SyncStreamItem_SyncActionConnectRepo struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionEncrypted struct {
	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)
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionHandshake struct {
	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))
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionHeartbeat struct {
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionOperationManifest struct {
	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"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionReceiveConfig struct {
	Config *RemoteConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionReceiveLogData struct {
	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"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionReceiveOperations struct {
	Event *v1.OperationEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionReceiveResources struct {
	Repos []*RepoMetadata `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
	Plans []*PlanMetadata `protobuf:"bytes,2,rep,name=plans,proto3" json:"plans,omitempty"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionRequestLog struct {
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionRequestOperationData struct {
	OpIds []int64 `protobuf:"varint,1,rep,packed,name=op_ids,json=opIds,proto3" json:"op_ids,omitempty"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionRequestResources struct {
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionSetConfig struct {
	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"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncActionThrottle struct {
	DelayMs int64 `protobuf:"varint,1,opt,name=delay_ms,json=delayMs,proto3" json:"delay_ms,omitempty"`
	// contains filtered or unexported fields
}

type SyncStreamItem_SyncEstablishSharedSecret struct {
	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
	// contains filtered or unexported fields
}

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

type UnimplementedBackrestSyncServiceServer struct{}

type UnimplementedBackrestSyncStateServiceServer struct{}

type UnsafeBackrestSyncServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeBackrestSyncStateServiceServer interface {
	// contains filtered or unexported methods
}