storagepb

type BackupFileInfo struct {
	StorageType string `protobuf:"bytes,1,opt,name=storage_type,json=storageType" json:"storage_type,omitempty"`
	BackupType  string `protobuf:"bytes,2,opt,name=backup_type,json=backupType" json:"backup_type,omitempty"`
	Key         string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
	Size        int64  `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
}

type BackupReply struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	Key     string `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
}

type FileStream struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
}

type FullBackupContentStream struct {
	Db      string `protobuf:"bytes,1,opt,name=db" json:"db,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
}

type GetBestStartTimeRequest struct {
}

type GetBestStartTimeResponse struct {
	Minute int32 `protobuf:"varint,1,opt,name=minute" json:"minute,omitempty"`
	Hour   int32 `protobuf:"varint,2,opt,name=hour" json:"hour,omitempty"`
}

type GetFileByKeyRequest struct {
	Key         string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	StorageType string `protobuf:"bytes,2,opt,name=storage_type,json=storageType" json:"storage_type,omitempty"`
}

type GetKeysAtPointRequest struct {
	Db   string `protobuf:"bytes,1,opt,name=db" json:"db,omitempty"`
	From string `protobuf:"bytes,2,opt,name=from" json:"from,omitempty"`
}

type GetKeysAtPointResponse struct {
	Keys []*BackupFileInfo `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}

type GetLatestToLSNRequest struct {
	Db string `protobuf:"bytes,1,opt,name=db" json:"db,omitempty"`
}

type GetLatestToLSNResponse struct {
	Lsn string `protobuf:"bytes,1,opt,name=lsn" json:"lsn,omitempty"`
}

type IncBackupContentStream struct {
	Db      string `protobuf:"bytes,1,opt,name=db" json:"db,omitempty"`
	Lsn     string `protobuf:"bytes,2,opt,name=lsn" json:"lsn,omitempty"`
	Content []byte `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
}

type PostCheckpointsRequest struct {
	Key     string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
}

type PostCheckpointsResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

type PurgePrevBackupRequest struct {
	Db string `protobuf:"bytes,1,opt,name=db" json:"db,omitempty"`
}

type PurgePrevBackupResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

type StorageServiceClient interface {
	GetLatestToLSN(ctx context.Context, in *GetLatestToLSNRequest, opts ...grpc.CallOption) (*GetLatestToLSNResponse, error)
	GetKeysAtPoint(ctx context.Context, in *GetKeysAtPointRequest, opts ...grpc.CallOption) (*GetKeysAtPointResponse, error)
	GetFileByKey(ctx context.Context, in *GetFileByKeyRequest, opts ...grpc.CallOption) (StorageService_GetFileByKeyClient, error)
	PurgePrevBackup(ctx context.Context, in *PurgePrevBackupRequest, opts ...grpc.CallOption) (*PurgePrevBackupResponse, error)
	GetBestStartTime(ctx context.Context, in *GetBestStartTimeRequest, opts ...grpc.CallOption) (*GetBestStartTimeResponse, error)
	TransferFullBackup(ctx context.Context, opts ...grpc.CallOption) (StorageService_TransferFullBackupClient, error)
	TransferIncBackup(ctx context.Context, opts ...grpc.CallOption) (StorageService_TransferIncBackupClient, error)
	PostCheckpoints(ctx context.Context, in *PostCheckpointsRequest, opts ...grpc.CallOption) (*PostCheckpointsResponse, error)
}

type StorageServiceServer interface {
	GetLatestToLSN(context.Context, *GetLatestToLSNRequest) (*GetLatestToLSNResponse, error)
	GetKeysAtPoint(context.Context, *GetKeysAtPointRequest) (*GetKeysAtPointResponse, error)
	GetFileByKey(*GetFileByKeyRequest, StorageService_GetFileByKeyServer) error
	PurgePrevBackup(context.Context, *PurgePrevBackupRequest) (*PurgePrevBackupResponse, error)
	GetBestStartTime(context.Context, *GetBestStartTimeRequest) (*GetBestStartTimeResponse, error)
	TransferFullBackup(StorageService_TransferFullBackupServer) error
	TransferIncBackup(StorageService_TransferIncBackupServer) error
	PostCheckpoints(context.Context, *PostCheckpointsRequest) (*PostCheckpointsResponse, error)
}

type StorageService_GetFileByKeyClient interface {
	Recv() (*FileStream, error)
	grpc.ClientStream
}

type StorageService_GetFileByKeyServer interface {
	Send(*FileStream) error
	grpc.ServerStream
}

type StorageService_TransferFullBackupClient interface {
	Send(*FullBackupContentStream) error
	CloseAndRecv() (*BackupReply, error)
	grpc.ClientStream
}

type StorageService_TransferFullBackupServer interface {
	SendAndClose(*BackupReply) error
	Recv() (*FullBackupContentStream, error)
	grpc.ServerStream
}

type StorageService_TransferIncBackupClient interface {
	Send(*IncBackupContentStream) error
	CloseAndRecv() (*BackupReply, error)
	grpc.ClientStream
}

type StorageService_TransferIncBackupServer interface {
	SendAndClose(*BackupReply) error
	Recv() (*IncBackupContentStream, error)
	grpc.ServerStream
}