storagepb

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 26, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package storagepb is a generated protocol buffer package.

It is generated from these files: 

storage/storagepb/storage.proto

It has these top-level messages: 

GetLatestToLSNRequest
GetLatestToLSNResponse
GetKeysAtPointRequest
GetKeysAtPointResponse
BackupFileInfo
GetFileByKeyRequest
FileStream
PurgePrevBackupRequest
PurgePrevBackupResponse
BackupStream
InitializeRequest
BackupRequest
CheckpointRequest
ClientErrorRequest
BackupReply

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStorage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStorage   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterStorageServiceServer 

func RegisterStorageServiceServer(s *grpc.Server, srv StorageServiceServer)

Types

type BackupFileInfo 

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"`
}

func (*BackupFileInfo) Descriptor 

func (*BackupFileInfo) Descriptor() ([]byte, []int)

func (*BackupFileInfo) GetBackupType 

func (m *BackupFileInfo) GetBackupType() polypb.BackupType

func (*BackupFileInfo) GetFileSize added in v0.4.9 

func (m *BackupFileInfo) GetFileSize() int64

func (*BackupFileInfo) GetKey 

func (m *BackupFileInfo) GetKey() github_com_taku_k_polymerase_pkg_polypb.Key

func (*BackupFileInfo) GetStorageType 

func (m *BackupFileInfo) GetStorageType() polypb.StorageType

func (*BackupFileInfo) Marshal added in v0.4.9 

func (m *BackupFileInfo) Marshal() (dAtA []byte, err error)

func (*BackupFileInfo) MarshalTo added in v0.4.9 

func (m *BackupFileInfo) MarshalTo(dAtA []byte) (int, error)

func (*BackupFileInfo) ProtoMessage 

func (*BackupFileInfo) ProtoMessage()

func (*BackupFileInfo) Reset 

func (m *BackupFileInfo) Reset()

func (*BackupFileInfo) Size 

func (m *BackupFileInfo) Size() (n int)

func (*BackupFileInfo) String 

func (m *BackupFileInfo) String() string

func (*BackupFileInfo) Unmarshal added in v0.4.9 

func (m *BackupFileInfo) Unmarshal(dAtA []byte) error

type BackupReply added in v0.4.7 

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"`
}

func (*BackupReply) Descriptor added in v0.4.7 

func (*BackupReply) Descriptor() ([]byte, []int)

func (*BackupReply) GetKey added in v0.4.7 

func (m *BackupReply) GetKey() github_com_taku_k_polymerase_pkg_polypb.Key

func (*BackupReply) GetMessage added in v0.4.7 

func (m *BackupReply) GetMessage() string

func (*BackupReply) Marshal added in v0.4.9 

func (m *BackupReply) Marshal() (dAtA []byte, err error)

func (*BackupReply) MarshalTo added in v0.4.9 

func (m *BackupReply) MarshalTo(dAtA []byte) (int, error)

func (*BackupReply) ProtoMessage added in v0.4.7 

func (*BackupReply) ProtoMessage()

func (*BackupReply) Reset added in v0.4.7 

func (m *BackupReply) Reset()

func (*BackupReply) Size added in v0.4.9 

func (m *BackupReply) Size() (n int)

func (*BackupReply) String added in v0.4.7 

func (m *BackupReply) String() string

func (*BackupReply) Unmarshal added in v0.4.9 

func (m *BackupReply) Unmarshal(dAtA []byte) error

type BackupRequest added in v0.6.0 

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

func (*BackupRequest) Descriptor added in v0.6.0 

func (*BackupRequest) Descriptor() ([]byte, []int)

func (*BackupRequest) GetContent added in v0.6.0 

func (m *BackupRequest) GetContent() []byte

func (*BackupRequest) Marshal added in v0.6.0 

func (m *BackupRequest) Marshal() (dAtA []byte, err error)

func (*BackupRequest) MarshalTo added in v0.6.0 

func (m *BackupRequest) MarshalTo(dAtA []byte) (int, error)

func (*BackupRequest) ProtoMessage added in v0.6.0 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) Reset added in v0.6.0 

func (m *BackupRequest) Reset()

func (*BackupRequest) Size added in v0.6.0 

func (m *BackupRequest) Size() (n int)

func (*BackupRequest) String added in v0.6.0 

func (m *BackupRequest) String() string

func (*BackupRequest) Unmarshal added in v0.6.0 

func (m *BackupRequest) Unmarshal(dAtA []byte) error

type BackupStream added in v0.6.0 

type BackupStream struct {
	// Types that are valid to be assigned to Request:
	//	*BackupStream_InitializeRequest
	//	*BackupStream_BackupRequest
	//	*BackupStream_CheckpointRequest
	//	*BackupStream_ClientErrorRequest
	Request isBackupStream_Request `protobuf_oneof:"request"`
}

func (*BackupStream) Descriptor added in v0.6.0 

func (*BackupStream) Descriptor() ([]byte, []int)

func (*BackupStream) GetBackupRequest added in v0.6.0 

func (m *BackupStream) GetBackupRequest() *BackupRequest

func (*BackupStream) GetCheckpointRequest added in v0.6.0 

func (m *BackupStream) GetCheckpointRequest() *CheckpointRequest

func (*BackupStream) GetClientErrorRequest added in v0.6.0 

func (m *BackupStream) GetClientErrorRequest() *ClientErrorRequest

func (*BackupStream) GetInitializeRequest added in v0.6.0 

func (m *BackupStream) GetInitializeRequest() *InitializeRequest

func (*BackupStream) GetRequest added in v0.6.0 

func (m *BackupStream) GetRequest() isBackupStream_Request

func (*BackupStream) Marshal added in v0.6.0 

func (m *BackupStream) Marshal() (dAtA []byte, err error)

func (*BackupStream) MarshalTo added in v0.6.0 

func (m *BackupStream) MarshalTo(dAtA []byte) (int, error)

func (*BackupStream) ProtoMessage added in v0.6.0 

func (*BackupStream) ProtoMessage()

func (*BackupStream) Reset added in v0.6.0 

func (m *BackupStream) Reset()

func (*BackupStream) Size added in v0.6.0 

func (m *BackupStream) Size() (n int)

func (*BackupStream) String added in v0.6.0 

func (m *BackupStream) String() string

func (*BackupStream) Unmarshal added in v0.6.0 

func (m *BackupStream) Unmarshal(dAtA []byte) error

func (*BackupStream) XXX_OneofFuncs added in v0.6.0 

func (*BackupStream) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type BackupStream_BackupRequest added in v0.6.0 

type BackupStream_BackupRequest struct {
	BackupRequest *BackupRequest `protobuf:"bytes,2,opt,name=backup_request,json=backupRequest,oneof"`
}

func (*BackupStream_BackupRequest) MarshalTo added in v0.6.0 

func (m *BackupStream_BackupRequest) MarshalTo(dAtA []byte) (int, error)

func (*BackupStream_BackupRequest) Size added in v0.6.0 

func (m *BackupStream_BackupRequest) Size() (n int)

type BackupStream_CheckpointRequest added in v0.6.0 

type BackupStream_CheckpointRequest struct {
	CheckpointRequest *CheckpointRequest `protobuf:"bytes,3,opt,name=checkpoint_request,json=checkpointRequest,oneof"`
}

func (*BackupStream_CheckpointRequest) MarshalTo added in v0.6.0 

func (m *BackupStream_CheckpointRequest) MarshalTo(dAtA []byte) (int, error)

func (*BackupStream_CheckpointRequest) Size added in v0.6.0 

func (m *BackupStream_CheckpointRequest) Size() (n int)

type BackupStream_ClientErrorRequest added in v0.6.0 

type BackupStream_ClientErrorRequest struct {
	ClientErrorRequest *ClientErrorRequest `protobuf:"bytes,4,opt,name=client_error_request,json=clientErrorRequest,oneof"`
}

func (*BackupStream_ClientErrorRequest) MarshalTo added in v0.6.0 

func (m *BackupStream_ClientErrorRequest) MarshalTo(dAtA []byte) (int, error)

func (*BackupStream_ClientErrorRequest) Size added in v0.6.0 

func (m *BackupStream_ClientErrorRequest) Size() (n int)

type BackupStream_InitializeRequest added in v0.6.0 

type BackupStream_InitializeRequest struct {
	InitializeRequest *InitializeRequest `protobuf:"bytes,1,opt,name=initialize_request,json=initializeRequest,oneof"`
}

func (*BackupStream_InitializeRequest) MarshalTo added in v0.6.0 

func (m *BackupStream_InitializeRequest) MarshalTo(dAtA []byte) (int, error)

func (*BackupStream_InitializeRequest) Size added in v0.6.0 

func (m *BackupStream_InitializeRequest) Size() (n int)

type CheckpointRequest added in v0.6.0 

type CheckpointRequest struct {
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
}

func (*CheckpointRequest) Descriptor added in v0.6.0 

func (*CheckpointRequest) Descriptor() ([]byte, []int)

func (*CheckpointRequest) GetBody added in v0.6.0 

func (m *CheckpointRequest) GetBody() []byte

func (*CheckpointRequest) Marshal added in v0.6.0 

func (m *CheckpointRequest) Marshal() (dAtA []byte, err error)

func (*CheckpointRequest) MarshalTo added in v0.6.0 

func (m *CheckpointRequest) MarshalTo(dAtA []byte) (int, error)

func (*CheckpointRequest) ProtoMessage added in v0.6.0 

func (*CheckpointRequest) ProtoMessage()

func (*CheckpointRequest) Reset added in v0.6.0 

func (m *CheckpointRequest) Reset()

func (*CheckpointRequest) Size added in v0.6.0 

func (m *CheckpointRequest) Size() (n int)

func (*CheckpointRequest) String added in v0.6.0 

func (m *CheckpointRequest) String() string

func (*CheckpointRequest) Unmarshal added in v0.6.0 

func (m *CheckpointRequest) Unmarshal(dAtA []byte) error

type ClientErrorRequest added in v0.6.0 

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

func (*ClientErrorRequest) Descriptor added in v0.6.0 

func (*ClientErrorRequest) Descriptor() ([]byte, []int)

func (*ClientErrorRequest) GetMessage added in v0.6.0 

func (m *ClientErrorRequest) GetMessage() string

func (*ClientErrorRequest) Marshal added in v0.6.0 

func (m *ClientErrorRequest) Marshal() (dAtA []byte, err error)

func (*ClientErrorRequest) MarshalTo added in v0.6.0 

func (m *ClientErrorRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClientErrorRequest) ProtoMessage added in v0.6.0 

func (*ClientErrorRequest) ProtoMessage()

func (*ClientErrorRequest) Reset added in v0.6.0 

func (m *ClientErrorRequest) Reset()

func (*ClientErrorRequest) Size added in v0.6.0 

func (m *ClientErrorRequest) Size() (n int)

func (*ClientErrorRequest) String added in v0.6.0 

func (m *ClientErrorRequest) String() string

func (*ClientErrorRequest) Unmarshal added in v0.6.0 

func (m *ClientErrorRequest) Unmarshal(dAtA []byte) error

type FileStream 

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

func (*FileStream) Descriptor 

func (*FileStream) Descriptor() ([]byte, []int)

func (*FileStream) GetContent 

func (m *FileStream) GetContent() []byte

func (*FileStream) Marshal added in v0.4.9 

func (m *FileStream) Marshal() (dAtA []byte, err error)

func (*FileStream) MarshalTo added in v0.4.9 

func (m *FileStream) MarshalTo(dAtA []byte) (int, error)

func (*FileStream) ProtoMessage 

func (*FileStream) ProtoMessage()

func (*FileStream) Reset 

func (m *FileStream) Reset()

func (*FileStream) Size added in v0.4.9 

func (m *FileStream) Size() (n int)

func (*FileStream) String 

func (m *FileStream) String() string

func (*FileStream) Unmarshal added in v0.4.9 

func (m *FileStream) Unmarshal(dAtA []byte) error

type GetFileByKeyRequest 

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"`
}

func (*GetFileByKeyRequest) Descriptor 

func (*GetFileByKeyRequest) Descriptor() ([]byte, []int)

func (*GetFileByKeyRequest) GetKey 

func (m *GetFileByKeyRequest) GetKey() github_com_taku_k_polymerase_pkg_polypb.Key

func (*GetFileByKeyRequest) GetStorageType 

func (m *GetFileByKeyRequest) GetStorageType() polypb.StorageType

func (*GetFileByKeyRequest) Marshal added in v0.4.9 

func (m *GetFileByKeyRequest) Marshal() (dAtA []byte, err error)

func (*GetFileByKeyRequest) MarshalTo added in v0.4.9 

func (m *GetFileByKeyRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetFileByKeyRequest) ProtoMessage 

func (*GetFileByKeyRequest) ProtoMessage()

func (*GetFileByKeyRequest) Reset 

func (m *GetFileByKeyRequest) Reset()

func (*GetFileByKeyRequest) Size added in v0.4.9 

func (m *GetFileByKeyRequest) Size() (n int)

func (*GetFileByKeyRequest) String 

func (m *GetFileByKeyRequest) String() string

func (*GetFileByKeyRequest) Unmarshal added in v0.4.9 

func (m *GetFileByKeyRequest) Unmarshal(dAtA []byte) error

type GetKeysAtPointRequest 

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 time.Time                                          `protobuf:"bytes,2,opt,name=from,stdtime" json:"from"`
}

func (*GetKeysAtPointRequest) Descriptor 

func (*GetKeysAtPointRequest) Descriptor() ([]byte, []int)

func (*GetKeysAtPointRequest) GetDb 

func (m *GetKeysAtPointRequest) GetDb() github_com_taku_k_polymerase_pkg_polypb.DatabaseID

func (*GetKeysAtPointRequest) GetFrom 

func (m *GetKeysAtPointRequest) GetFrom() time.Time

func (*GetKeysAtPointRequest) Marshal added in v0.4.9 

func (m *GetKeysAtPointRequest) Marshal() (dAtA []byte, err error)

func (*GetKeysAtPointRequest) MarshalTo added in v0.4.9 

func (m *GetKeysAtPointRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetKeysAtPointRequest) ProtoMessage 

func (*GetKeysAtPointRequest) ProtoMessage()

func (*GetKeysAtPointRequest) Reset 

func (m *GetKeysAtPointRequest) Reset()

func (*GetKeysAtPointRequest) Size added in v0.4.9 

func (m *GetKeysAtPointRequest) Size() (n int)

func (*GetKeysAtPointRequest) String 

func (m *GetKeysAtPointRequest) String() string

func (*GetKeysAtPointRequest) Unmarshal added in v0.4.9 

func (m *GetKeysAtPointRequest) Unmarshal(dAtA []byte) error

type GetKeysAtPointResponse 

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

func (*GetKeysAtPointResponse) Descriptor 

func (*GetKeysAtPointResponse) Descriptor() ([]byte, []int)

func (*GetKeysAtPointResponse) GetKeys 

func (m *GetKeysAtPointResponse) GetKeys() []*BackupFileInfo

func (*GetKeysAtPointResponse) Marshal added in v0.4.9 

func (m *GetKeysAtPointResponse) Marshal() (dAtA []byte, err error)

func (*GetKeysAtPointResponse) MarshalTo added in v0.4.9 

func (m *GetKeysAtPointResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetKeysAtPointResponse) ProtoMessage 

func (*GetKeysAtPointResponse) ProtoMessage()

func (*GetKeysAtPointResponse) Reset 

func (m *GetKeysAtPointResponse) Reset()

func (*GetKeysAtPointResponse) Size added in v0.4.9 

func (m *GetKeysAtPointResponse) Size() (n int)

func (*GetKeysAtPointResponse) String 

func (m *GetKeysAtPointResponse) String() string

func (*GetKeysAtPointResponse) Unmarshal added in v0.4.9 

func (m *GetKeysAtPointResponse) Unmarshal(dAtA []byte) error

type GetLatestToLSNRequest 

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"`
}

func (*GetLatestToLSNRequest) Descriptor 

func (*GetLatestToLSNRequest) Descriptor() ([]byte, []int)

func (*GetLatestToLSNRequest) GetDb 

func (m *GetLatestToLSNRequest) GetDb() github_com_taku_k_polymerase_pkg_polypb.DatabaseID

func (*GetLatestToLSNRequest) Marshal added in v0.4.9 

func (m *GetLatestToLSNRequest) Marshal() (dAtA []byte, err error)

func (*GetLatestToLSNRequest) MarshalTo added in v0.4.9 

func (m *GetLatestToLSNRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetLatestToLSNRequest) ProtoMessage 

func (*GetLatestToLSNRequest) ProtoMessage()

func (*GetLatestToLSNRequest) Reset 

func (m *GetLatestToLSNRequest) Reset()

func (*GetLatestToLSNRequest) Size added in v0.4.9 

func (m *GetLatestToLSNRequest) Size() (n int)

func (*GetLatestToLSNRequest) String 

func (m *GetLatestToLSNRequest) String() string

func (*GetLatestToLSNRequest) Unmarshal added in v0.4.9 

func (m *GetLatestToLSNRequest) Unmarshal(dAtA []byte) error

type GetLatestToLSNResponse 

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

func (*GetLatestToLSNResponse) Descriptor 

func (*GetLatestToLSNResponse) Descriptor() ([]byte, []int)

func (*GetLatestToLSNResponse) GetLsn 

func (m *GetLatestToLSNResponse) GetLsn() string

func (*GetLatestToLSNResponse) Marshal added in v0.4.9 

func (m *GetLatestToLSNResponse) Marshal() (dAtA []byte, err error)

func (*GetLatestToLSNResponse) MarshalTo added in v0.4.9 

func (m *GetLatestToLSNResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetLatestToLSNResponse) ProtoMessage 

func (*GetLatestToLSNResponse) ProtoMessage()

func (*GetLatestToLSNResponse) Reset 

func (m *GetLatestToLSNResponse) Reset()

func (*GetLatestToLSNResponse) Size added in v0.4.9 

func (m *GetLatestToLSNResponse) Size() (n int)

func (*GetLatestToLSNResponse) String 

func (m *GetLatestToLSNResponse) String() string

func (*GetLatestToLSNResponse) Unmarshal added in v0.4.9 

func (m *GetLatestToLSNResponse) Unmarshal(dAtA []byte) error

type InitializeRequest added in v0.6.0 

type InitializeRequest struct {
	BackupType polypb.BackupType                                  `protobuf:"varint,1,opt,name=backup_type,json=backupType,proto3,enum=polypb.BackupType" json:"backup_type,omitempty"`
	Db         github_com_taku_k_polymerase_pkg_polypb.DatabaseID `protobuf:"bytes,2,opt,name=db,proto3,casttype=github.com/taku-k/polymerase/pkg/polypb.DatabaseID" json:"db,omitempty"`
	Lsn        string                                             `protobuf:"bytes,3,opt,name=lsn,proto3" json:"lsn,omitempty"`
}

func (*InitializeRequest) Descriptor added in v0.6.0 

func (*InitializeRequest) Descriptor() ([]byte, []int)

func (*InitializeRequest) GetBackupType added in v0.6.0 

func (m *InitializeRequest) GetBackupType() polypb.BackupType

func (*InitializeRequest) GetDb added in v0.6.0 

func (m *InitializeRequest) GetDb() github_com_taku_k_polymerase_pkg_polypb.DatabaseID

func (*InitializeRequest) GetLsn added in v0.6.0 

func (m *InitializeRequest) GetLsn() string

func (*InitializeRequest) Marshal added in v0.6.0 

func (m *InitializeRequest) Marshal() (dAtA []byte, err error)

func (*InitializeRequest) MarshalTo added in v0.6.0 

func (m *InitializeRequest) MarshalTo(dAtA []byte) (int, error)

func (*InitializeRequest) ProtoMessage added in v0.6.0 

func (*InitializeRequest) ProtoMessage()

func (*InitializeRequest) Reset added in v0.6.0 

func (m *InitializeRequest) Reset()

func (*InitializeRequest) Size added in v0.6.0 

func (m *InitializeRequest) Size() (n int)

func (*InitializeRequest) String added in v0.6.0 

func (m *InitializeRequest) String() string

func (*InitializeRequest) Unmarshal added in v0.6.0 

func (m *InitializeRequest) Unmarshal(dAtA []byte) error

type PurgePrevBackupRequest 

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"`
}

func (*PurgePrevBackupRequest) Descriptor 

func (*PurgePrevBackupRequest) Descriptor() ([]byte, []int)

func (*PurgePrevBackupRequest) GetDb 

func (m *PurgePrevBackupRequest) GetDb() github_com_taku_k_polymerase_pkg_polypb.DatabaseID

func (*PurgePrevBackupRequest) Marshal added in v0.4.9 

func (m *PurgePrevBackupRequest) Marshal() (dAtA []byte, err error)

func (*PurgePrevBackupRequest) MarshalTo added in v0.4.9 

func (m *PurgePrevBackupRequest) MarshalTo(dAtA []byte) (int, error)

func (*PurgePrevBackupRequest) ProtoMessage 

func (*PurgePrevBackupRequest) ProtoMessage()

func (*PurgePrevBackupRequest) Reset 

func (m *PurgePrevBackupRequest) Reset()

func (*PurgePrevBackupRequest) Size added in v0.4.9 

func (m *PurgePrevBackupRequest) Size() (n int)

func (*PurgePrevBackupRequest) String 

func (m *PurgePrevBackupRequest) String() string

func (*PurgePrevBackupRequest) Unmarshal added in v0.4.9 

func (m *PurgePrevBackupRequest) Unmarshal(dAtA []byte) error

type PurgePrevBackupResponse 

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

func (*PurgePrevBackupResponse) Descriptor 

func (*PurgePrevBackupResponse) Descriptor() ([]byte, []int)

func (*PurgePrevBackupResponse) GetMessage 

func (m *PurgePrevBackupResponse) GetMessage() string

func (*PurgePrevBackupResponse) Marshal added in v0.4.9 

func (m *PurgePrevBackupResponse) Marshal() (dAtA []byte, err error)

func (*PurgePrevBackupResponse) MarshalTo added in v0.4.9 

func (m *PurgePrevBackupResponse) MarshalTo(dAtA []byte) (int, error)

func (*PurgePrevBackupResponse) ProtoMessage 

func (*PurgePrevBackupResponse) ProtoMessage()

func (*PurgePrevBackupResponse) Reset 

func (m *PurgePrevBackupResponse) Reset()

func (*PurgePrevBackupResponse) Size added in v0.4.9 

func (m *PurgePrevBackupResponse) Size() (n int)

func (*PurgePrevBackupResponse) String 

func (m *PurgePrevBackupResponse) String() string

func (*PurgePrevBackupResponse) Unmarshal added in v0.4.9 

func (m *PurgePrevBackupResponse) Unmarshal(dAtA []byte) error

type StorageServiceClient 

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)
	TransferBackup(ctx context.Context, opts ...grpc.CallOption) (StorageService_TransferBackupClient, error)
}

func NewStorageServiceClient 

func NewStorageServiceClient(cc *grpc.ClientConn) StorageServiceClient

type StorageServiceServer 

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)
	TransferBackup(StorageService_TransferBackupServer) error
}

type StorageService_GetFileByKeyClient 

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

type StorageService_GetFileByKeyServer 

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

type StorageService_TransferBackupClient added in v0.6.0 

type StorageService_TransferBackupClient interface {
	Send(*BackupStream) error
	CloseAndRecv() (*BackupReply, error)
	grpc.ClientStream
}

type StorageService_TransferBackupServer added in v0.6.0 

type StorageService_TransferBackupServer interface {
	SendAndClose(*BackupReply) error
	Recv() (*BackupStream, error)
	grpc.ServerStream
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.