storagepb

type BackupFileInfo struct {
	StorageType polypb.StorageType                          `protobuf:"varint,1,opt,name=storage_type,json=storageType,proto3,enum=polypb.StorageType" json:"storage_type,omitempty"`
	BackupType  polypb.BackupType                           `protobuf:"varint,2,opt,name=backup_type,json=backupType,proto3,enum=polypb.BackupType" json:"backup_type,omitempty"`
	Key         github_com_taku_k_polymerase_pkg_polypb.Key `protobuf:"bytes,3,opt,name=key,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.Key" json:"key,omitempty"`
	FileSize    int64                                       `protobuf:"varint,4,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
}

type BackupReply struct {
	Message string                                      `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Key     github_com_taku_k_polymerase_pkg_polypb.Key `protobuf:"bytes,2,opt,name=key,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.Key" json:"key,omitempty"`
}

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

type FullBackupContentStream struct {
	Db      github_com_taku_k_polymerase_pkg_polypb.DatabaseID `protobuf:"bytes,1,opt,name=db,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.DatabaseID" json:"db,omitempty"`
	Content []byte                                             `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
}

type GetFileByKeyRequest struct {
	Key         github_com_taku_k_polymerase_pkg_polypb.Key `protobuf:"bytes,1,opt,name=key,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.Key" json:"key,omitempty"`
	StorageType polypb.StorageType                          `protobuf:"varint,2,opt,name=storage_type,json=storageType,proto3,enum=polypb.StorageType" json:"storage_type,omitempty"`
}

type GetKeysAtPointRequest struct {
	Db   github_com_taku_k_polymerase_pkg_polypb.DatabaseID `protobuf:"bytes,1,opt,name=db,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.DatabaseID" json:"db,omitempty"`
	From string                                             `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
}

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

type GetLatestToLSNRequest struct {
	Db github_com_taku_k_polymerase_pkg_polypb.DatabaseID `protobuf:"bytes,1,opt,name=db,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.DatabaseID" json:"db,omitempty"`
}

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

type IncBackupContentStream struct {
	Db      github_com_taku_k_polymerase_pkg_polypb.DatabaseID `protobuf:"bytes,1,opt,name=db,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.DatabaseID" json:"db,omitempty"`
	Lsn     string                                             `protobuf:"bytes,2,opt,name=lsn,proto3" json:"lsn,omitempty"`
	Content []byte                                             `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
}

type PostCheckpointsRequest struct {
	Key     github_com_taku_k_polymerase_pkg_polypb.Key `protobuf:"bytes,1,opt,name=key,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.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,proto3" json:"message,omitempty"`
}

type PurgePrevBackupRequest struct {
	Db github_com_taku_k_polymerase_pkg_polypb.DatabaseID `protobuf:"bytes,1,opt,name=db,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.DatabaseID" json:"db,omitempty"`
}

type PurgePrevBackupResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" 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)
	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)
	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
}