ptypes

package
v1.0.0-rc3 Latest Latest
Warning

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

 Go to latest Published: May 28, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ReplicaMode_name = map[int32]string{
	0: "WO",
	1: "RW",
	2: "ERR",
}
View Source 
var ReplicaMode_value = map[string]int32{
	"WO":  0,
	"RW":  1,
	"ERR": 2,
}

Functions

func RegisterControllerServiceServer 

func RegisterControllerServiceServer(s *grpc.Server, srv ControllerServiceServer)

func RegisterReplicaServiceServer 

func RegisterReplicaServiceServer(s *grpc.Server, srv ReplicaServiceServer)

func RegisterSyncAgentServiceServer 

func RegisterSyncAgentServiceServer(s *grpc.Server, srv SyncAgentServiceServer)

Types

type BackupCreateReply 

type BackupCreateReply struct {
	Backup               string   `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	IsIncremental        bool     `protobuf:"varint,2,opt,name=isIncremental,proto3" json:"isIncremental,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupCreateReply) Descriptor 

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

func (*BackupCreateReply) GetBackup 

func (m *BackupCreateReply) GetBackup() string

func (*BackupCreateReply) GetIsIncremental 

func (m *BackupCreateReply) GetIsIncremental() bool

func (*BackupCreateReply) ProtoMessage 

func (*BackupCreateReply) ProtoMessage()

func (*BackupCreateReply) Reset 

func (m *BackupCreateReply) Reset()

func (*BackupCreateReply) String 

func (m *BackupCreateReply) String() string

func (*BackupCreateReply) XXX_DiscardUnknown 

func (m *BackupCreateReply) XXX_DiscardUnknown()

func (*BackupCreateReply) XXX_Marshal 

func (m *BackupCreateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupCreateReply) XXX_Merge 

func (m *BackupCreateReply) XXX_Merge(src proto.Message)

func (*BackupCreateReply) XXX_Size 

func (m *BackupCreateReply) XXX_Size() int

func (*BackupCreateReply) XXX_Unmarshal 

func (m *BackupCreateReply) XXX_Unmarshal(b []byte) error

type BackupCreateRequest 

type BackupCreateRequest struct {
	SnapshotFileName     string            `protobuf:"bytes,1,opt,name=snapshotFileName,proto3" json:"snapshotFileName,omitempty"`
	BackupTarget         string            `protobuf:"bytes,2,opt,name=backupTarget,proto3" json:"backupTarget,omitempty"`
	VolumeName           string            `protobuf:"bytes,3,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	Labels               []string          `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
	Credential           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BackupCreateRequest) Descriptor 

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

func (*BackupCreateRequest) GetBackupTarget 

func (m *BackupCreateRequest) GetBackupTarget() string

func (*BackupCreateRequest) GetCredential 

func (m *BackupCreateRequest) GetCredential() map[string]string

func (*BackupCreateRequest) GetLabels 

func (m *BackupCreateRequest) GetLabels() []string

func (*BackupCreateRequest) GetSnapshotFileName 

func (m *BackupCreateRequest) GetSnapshotFileName() string

func (*BackupCreateRequest) GetVolumeName 

func (m *BackupCreateRequest) GetVolumeName() string

func (*BackupCreateRequest) ProtoMessage 

func (*BackupCreateRequest) ProtoMessage()

func (*BackupCreateRequest) Reset 

func (m *BackupCreateRequest) Reset()

func (*BackupCreateRequest) String 

func (m *BackupCreateRequest) String() string

func (*BackupCreateRequest) XXX_DiscardUnknown 

func (m *BackupCreateRequest) XXX_DiscardUnknown()

func (*BackupCreateRequest) XXX_Marshal 

func (m *BackupCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupCreateRequest) XXX_Merge 

func (m *BackupCreateRequest) XXX_Merge(src proto.Message)

func (*BackupCreateRequest) XXX_Size 

func (m *BackupCreateRequest) XXX_Size() int

func (*BackupCreateRequest) XXX_Unmarshal 

func (m *BackupCreateRequest) XXX_Unmarshal(b []byte) error

type BackupProgressRequest 

type BackupProgressRequest struct {
	Backup               string   `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupProgressRequest) Descriptor 

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

func (*BackupProgressRequest) GetBackup 

func (m *BackupProgressRequest) GetBackup() string

func (*BackupProgressRequest) ProtoMessage 

func (*BackupProgressRequest) ProtoMessage()

func (*BackupProgressRequest) Reset 

func (m *BackupProgressRequest) Reset()

func (*BackupProgressRequest) String 

func (m *BackupProgressRequest) String() string

func (*BackupProgressRequest) XXX_DiscardUnknown 

func (m *BackupProgressRequest) XXX_DiscardUnknown()

func (*BackupProgressRequest) XXX_Marshal 

func (m *BackupProgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupProgressRequest) XXX_Merge 

func (m *BackupProgressRequest) XXX_Merge(src proto.Message)

func (*BackupProgressRequest) XXX_Size 

func (m *BackupProgressRequest) XXX_Size() int

func (*BackupProgressRequest) XXX_Unmarshal 

func (m *BackupProgressRequest) XXX_Unmarshal(b []byte) error

type BackupRemoveRequest 

type BackupRemoveRequest struct {
	Backup               string   `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupRemoveRequest) Descriptor 

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

func (*BackupRemoveRequest) GetBackup 

func (m *BackupRemoveRequest) GetBackup() string

func (*BackupRemoveRequest) ProtoMessage 

func (*BackupRemoveRequest) ProtoMessage()

func (*BackupRemoveRequest) Reset 

func (m *BackupRemoveRequest) Reset()

func (*BackupRemoveRequest) String 

func (m *BackupRemoveRequest) String() string

func (*BackupRemoveRequest) XXX_DiscardUnknown 

func (m *BackupRemoveRequest) XXX_DiscardUnknown()

func (*BackupRemoveRequest) XXX_Marshal 

func (m *BackupRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupRemoveRequest) XXX_Merge 

func (m *BackupRemoveRequest) XXX_Merge(src proto.Message)

func (*BackupRemoveRequest) XXX_Size 

func (m *BackupRemoveRequest) XXX_Size() int

func (*BackupRemoveRequest) XXX_Unmarshal 

func (m *BackupRemoveRequest) XXX_Unmarshal(b []byte) error

type BackupReplicaMap 

type BackupReplicaMap struct {
	BackupReplicaMap     map[string]string `` /* 173-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BackupReplicaMap) Descriptor 

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

func (*BackupReplicaMap) GetBackupReplicaMap 

func (m *BackupReplicaMap) GetBackupReplicaMap() map[string]string

func (*BackupReplicaMap) ProtoMessage 

func (*BackupReplicaMap) ProtoMessage()

func (*BackupReplicaMap) Reset 

func (m *BackupReplicaMap) Reset()

func (*BackupReplicaMap) String 

func (m *BackupReplicaMap) String() string

func (*BackupReplicaMap) XXX_DiscardUnknown 

func (m *BackupReplicaMap) XXX_DiscardUnknown()

func (*BackupReplicaMap) XXX_Marshal 

func (m *BackupReplicaMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupReplicaMap) XXX_Merge 

func (m *BackupReplicaMap) XXX_Merge(src proto.Message)

func (*BackupReplicaMap) XXX_Size 

func (m *BackupReplicaMap) XXX_Size() int

func (*BackupReplicaMap) XXX_Unmarshal 

func (m *BackupReplicaMap) XXX_Unmarshal(b []byte) error

type BackupReplicaMapping 

type BackupReplicaMapping struct {
	Backup               string   `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	ReplicaAddress       string   `protobuf:"bytes,2,opt,name=replicaAddress,proto3" json:"replicaAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupReplicaMapping) Descriptor 

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

func (*BackupReplicaMapping) GetBackup 

func (m *BackupReplicaMapping) GetBackup() string

func (*BackupReplicaMapping) GetReplicaAddress 

func (m *BackupReplicaMapping) GetReplicaAddress() string

func (*BackupReplicaMapping) ProtoMessage 

func (*BackupReplicaMapping) ProtoMessage()

func (*BackupReplicaMapping) Reset 

func (m *BackupReplicaMapping) Reset()

func (*BackupReplicaMapping) String 

func (m *BackupReplicaMapping) String() string

func (*BackupReplicaMapping) XXX_DiscardUnknown 

func (m *BackupReplicaMapping) XXX_DiscardUnknown()

func (*BackupReplicaMapping) XXX_Marshal 

func (m *BackupReplicaMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupReplicaMapping) XXX_Merge 

func (m *BackupReplicaMapping) XXX_Merge(src proto.Message)

func (*BackupReplicaMapping) XXX_Size 

func (m *BackupReplicaMapping) XXX_Size() int

func (*BackupReplicaMapping) XXX_Unmarshal 

func (m *BackupReplicaMapping) XXX_Unmarshal(b []byte) error

type BackupReplicaMappingDeleteRequest 

type BackupReplicaMappingDeleteRequest struct {
	Backup               string   `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupReplicaMappingDeleteRequest) Descriptor 

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

func (*BackupReplicaMappingDeleteRequest) GetBackup 

func (m *BackupReplicaMappingDeleteRequest) GetBackup() string

func (*BackupReplicaMappingDeleteRequest) ProtoMessage 

func (*BackupReplicaMappingDeleteRequest) ProtoMessage()

func (*BackupReplicaMappingDeleteRequest) Reset 

func (m *BackupReplicaMappingDeleteRequest) Reset()

func (*BackupReplicaMappingDeleteRequest) String 

func (m *BackupReplicaMappingDeleteRequest) String() string

func (*BackupReplicaMappingDeleteRequest) XXX_DiscardUnknown 

func (m *BackupReplicaMappingDeleteRequest) XXX_DiscardUnknown()

func (*BackupReplicaMappingDeleteRequest) XXX_Marshal 

func (m *BackupReplicaMappingDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupReplicaMappingDeleteRequest) XXX_Merge 

func (m *BackupReplicaMappingDeleteRequest) XXX_Merge(src proto.Message)

func (*BackupReplicaMappingDeleteRequest) XXX_Size 

func (m *BackupReplicaMappingDeleteRequest) XXX_Size() int

func (*BackupReplicaMappingDeleteRequest) XXX_Unmarshal 

func (m *BackupReplicaMappingDeleteRequest) XXX_Unmarshal(b []byte) error

type BackupRestoreIncrementallyRequest 

type BackupRestoreIncrementallyRequest struct {
	Backup                 string            `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	DeltaFileName          string            `protobuf:"bytes,2,opt,name=deltaFileName,proto3" json:"deltaFileName,omitempty"`
	LastRestoredBackupName string            `protobuf:"bytes,3,opt,name=lastRestoredBackupName,proto3" json:"lastRestoredBackupName,omitempty"`
	SnapshotDiskName       string            `protobuf:"bytes,4,opt,name=snapshotDiskName,proto3" json:"snapshotDiskName,omitempty"`
	Credential             map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}          `json:"-"`
	XXX_unrecognized       []byte            `json:"-"`
	XXX_sizecache          int32             `json:"-"`
}

func (*BackupRestoreIncrementallyRequest) Descriptor 

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

func (*BackupRestoreIncrementallyRequest) GetBackup 

func (m *BackupRestoreIncrementallyRequest) GetBackup() string

func (*BackupRestoreIncrementallyRequest) GetCredential 

func (m *BackupRestoreIncrementallyRequest) GetCredential() map[string]string

func (*BackupRestoreIncrementallyRequest) GetDeltaFileName 

func (m *BackupRestoreIncrementallyRequest) GetDeltaFileName() string

func (*BackupRestoreIncrementallyRequest) GetLastRestoredBackupName 

func (m *BackupRestoreIncrementallyRequest) GetLastRestoredBackupName() string

func (*BackupRestoreIncrementallyRequest) GetSnapshotDiskName 

func (m *BackupRestoreIncrementallyRequest) GetSnapshotDiskName() string

func (*BackupRestoreIncrementallyRequest) ProtoMessage 

func (*BackupRestoreIncrementallyRequest) ProtoMessage()

func (*BackupRestoreIncrementallyRequest) Reset 

func (m *BackupRestoreIncrementallyRequest) Reset()

func (*BackupRestoreIncrementallyRequest) String 

func (m *BackupRestoreIncrementallyRequest) String() string

func (*BackupRestoreIncrementallyRequest) XXX_DiscardUnknown 

func (m *BackupRestoreIncrementallyRequest) XXX_DiscardUnknown()

func (*BackupRestoreIncrementallyRequest) XXX_Marshal 

func (m *BackupRestoreIncrementallyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupRestoreIncrementallyRequest) XXX_Merge 

func (m *BackupRestoreIncrementallyRequest) XXX_Merge(src proto.Message)

func (*BackupRestoreIncrementallyRequest) XXX_Size 

func (m *BackupRestoreIncrementallyRequest) XXX_Size() int

func (*BackupRestoreIncrementallyRequest) XXX_Unmarshal 

func (m *BackupRestoreIncrementallyRequest) XXX_Unmarshal(b []byte) error

type BackupRestoreRequest 

type BackupRestoreRequest struct {
	Backup               string            `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	SnapshotFileName     string            `protobuf:"bytes,2,opt,name=snapshotFileName,proto3" json:"snapshotFileName,omitempty"`
	Credential           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BackupRestoreRequest) Descriptor 

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

func (*BackupRestoreRequest) GetBackup 

func (m *BackupRestoreRequest) GetBackup() string

func (*BackupRestoreRequest) GetCredential 

func (m *BackupRestoreRequest) GetCredential() map[string]string

func (*BackupRestoreRequest) GetSnapshotFileName 

func (m *BackupRestoreRequest) GetSnapshotFileName() string

func (*BackupRestoreRequest) ProtoMessage 

func (*BackupRestoreRequest) ProtoMessage()

func (*BackupRestoreRequest) Reset 

func (m *BackupRestoreRequest) Reset()

func (*BackupRestoreRequest) String 

func (m *BackupRestoreRequest) String() string

func (*BackupRestoreRequest) XXX_DiscardUnknown 

func (m *BackupRestoreRequest) XXX_DiscardUnknown()

func (*BackupRestoreRequest) XXX_Marshal 

func (m *BackupRestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupRestoreRequest) XXX_Merge 

func (m *BackupRestoreRequest) XXX_Merge(src proto.Message)

func (*BackupRestoreRequest) XXX_Size 

func (m *BackupRestoreRequest) XXX_Size() int

func (*BackupRestoreRequest) XXX_Unmarshal 

func (m *BackupRestoreRequest) XXX_Unmarshal(b []byte) error

type BackupStatusReply 

type BackupStatusReply struct {
	Progress             int32    `protobuf:"varint,1,opt,name=progress,proto3" json:"progress,omitempty"`
	BackupURL            string   `protobuf:"bytes,2,opt,name=backupURL,proto3" json:"backupURL,omitempty"`
	Error                string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	SnapshotName         string   `protobuf:"bytes,4,opt,name=snapshotName,proto3" json:"snapshotName,omitempty"`
	State                string   `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupStatusReply) Descriptor 

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

func (*BackupStatusReply) GetBackupURL 

func (m *BackupStatusReply) GetBackupURL() string

func (*BackupStatusReply) GetError 

func (m *BackupStatusReply) GetError() string

func (*BackupStatusReply) GetProgress 

func (m *BackupStatusReply) GetProgress() int32

func (*BackupStatusReply) GetSnapshotName 

func (m *BackupStatusReply) GetSnapshotName() string

func (*BackupStatusReply) GetState 

func (m *BackupStatusReply) GetState() string

func (*BackupStatusReply) ProtoMessage 

func (*BackupStatusReply) ProtoMessage()

func (*BackupStatusReply) Reset 

func (m *BackupStatusReply) Reset()

func (*BackupStatusReply) String 

func (m *BackupStatusReply) String() string

func (*BackupStatusReply) XXX_DiscardUnknown 

func (m *BackupStatusReply) XXX_DiscardUnknown()

func (*BackupStatusReply) XXX_Marshal 

func (m *BackupStatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupStatusReply) XXX_Merge 

func (m *BackupStatusReply) XXX_Merge(src proto.Message)

func (*BackupStatusReply) XXX_Size 

func (m *BackupStatusReply) XXX_Size() int

func (*BackupStatusReply) XXX_Unmarshal 

func (m *BackupStatusReply) XXX_Unmarshal(b []byte) error

type ControllerReplica 

type ControllerReplica struct {
	Address              *ReplicaAddress `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Mode                 ReplicaMode     `protobuf:"varint,2,opt,name=mode,proto3,enum=ptypes.ReplicaMode" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ControllerReplica) Descriptor 

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

func (*ControllerReplica) GetAddress 

func (m *ControllerReplica) GetAddress() *ReplicaAddress

func (*ControllerReplica) GetMode 

func (m *ControllerReplica) GetMode() ReplicaMode

func (*ControllerReplica) ProtoMessage 

func (*ControllerReplica) ProtoMessage()

func (*ControllerReplica) Reset 

func (m *ControllerReplica) Reset()

func (*ControllerReplica) String 

func (m *ControllerReplica) String() string

func (*ControllerReplica) XXX_DiscardUnknown 

func (m *ControllerReplica) XXX_DiscardUnknown()

func (*ControllerReplica) XXX_Marshal 

func (m *ControllerReplica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerReplica) XXX_Merge 

func (m *ControllerReplica) XXX_Merge(src proto.Message)

func (*ControllerReplica) XXX_Size 

func (m *ControllerReplica) XXX_Size() int

func (*ControllerReplica) XXX_Unmarshal 

func (m *ControllerReplica) XXX_Unmarshal(b []byte) error

type ControllerServiceClient 

type ControllerServiceClient interface {
	VolumeGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Volume, error)
	VolumeStart(ctx context.Context, in *VolumeStartRequest, opts ...grpc.CallOption) (*Volume, error)
	VolumeShutdown(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Volume, error)
	VolumeSnapshot(ctx context.Context, in *VolumeSnapshotRequest, opts ...grpc.CallOption) (*VolumeSnapshotReply, error)
	VolumeRevert(ctx context.Context, in *VolumeRevertRequest, opts ...grpc.CallOption) (*Volume, error)
	VolumeExpand(ctx context.Context, in *VolumeExpandRequest, opts ...grpc.CallOption) (*Volume, error)
	VolumeFrontendStart(ctx context.Context, in *VolumeFrontendStartRequest, opts ...grpc.CallOption) (*Volume, error)
	VolumeFrontendShutdown(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Volume, error)
	ReplicaList(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ReplicaListReply, error)
	ReplicaGet(ctx context.Context, in *ReplicaAddress, opts ...grpc.CallOption) (*ControllerReplica, error)
	ReplicaCreate(ctx context.Context, in *ReplicaAddress, opts ...grpc.CallOption) (*ControllerReplica, error)
	ReplicaDelete(ctx context.Context, in *ReplicaAddress, opts ...grpc.CallOption) (*empty.Empty, error)
	ReplicaUpdate(ctx context.Context, in *ControllerReplica, opts ...grpc.CallOption) (*ControllerReplica, error)
	ReplicaPrepareRebuild(ctx context.Context, in *ReplicaAddress, opts ...grpc.CallOption) (*ReplicaPrepareRebuildReply, error)
	ReplicaVerifyRebuild(ctx context.Context, in *ReplicaAddress, opts ...grpc.CallOption) (*ControllerReplica, error)
	BackupReplicaMappingCreate(ctx context.Context, in *BackupReplicaMapping, opts ...grpc.CallOption) (*empty.Empty, error)
	BackupReplicaMappingGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*BackupReplicaMap, error)
	BackupReplicaMappingDelete(ctx context.Context, in *BackupReplicaMappingDeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	JournalList(ctx context.Context, in *JournalListRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	VersionDetailGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VersionDetailGetReply, error)
	MetricGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (ControllerService_MetricGetClient, error)
}

ControllerServiceClient is the client API for ControllerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerServiceClient 

func NewControllerServiceClient(cc *grpc.ClientConn) ControllerServiceClient

type ControllerServiceServer 

type ControllerServiceServer interface {
	VolumeGet(context.Context, *empty.Empty) (*Volume, error)
	VolumeStart(context.Context, *VolumeStartRequest) (*Volume, error)
	VolumeShutdown(context.Context, *empty.Empty) (*Volume, error)
	VolumeSnapshot(context.Context, *VolumeSnapshotRequest) (*VolumeSnapshotReply, error)
	VolumeRevert(context.Context, *VolumeRevertRequest) (*Volume, error)
	VolumeExpand(context.Context, *VolumeExpandRequest) (*Volume, error)
	VolumeFrontendStart(context.Context, *VolumeFrontendStartRequest) (*Volume, error)
	VolumeFrontendShutdown(context.Context, *empty.Empty) (*Volume, error)
	ReplicaList(context.Context, *empty.Empty) (*ReplicaListReply, error)
	ReplicaGet(context.Context, *ReplicaAddress) (*ControllerReplica, error)
	ReplicaCreate(context.Context, *ReplicaAddress) (*ControllerReplica, error)
	ReplicaDelete(context.Context, *ReplicaAddress) (*empty.Empty, error)
	ReplicaUpdate(context.Context, *ControllerReplica) (*ControllerReplica, error)
	ReplicaPrepareRebuild(context.Context, *ReplicaAddress) (*ReplicaPrepareRebuildReply, error)
	ReplicaVerifyRebuild(context.Context, *ReplicaAddress) (*ControllerReplica, error)
	BackupReplicaMappingCreate(context.Context, *BackupReplicaMapping) (*empty.Empty, error)
	BackupReplicaMappingGet(context.Context, *empty.Empty) (*BackupReplicaMap, error)
	BackupReplicaMappingDelete(context.Context, *BackupReplicaMappingDeleteRequest) (*empty.Empty, error)
	JournalList(context.Context, *JournalListRequest) (*empty.Empty, error)
	VersionDetailGet(context.Context, *empty.Empty) (*VersionDetailGetReply, error)
	MetricGet(*empty.Empty, ControllerService_MetricGetServer) error
}

ControllerServiceServer is the server API for ControllerService service.

type ControllerService_MetricGetClient 

type ControllerService_MetricGetClient interface {
	Recv() (*MetricGetReply, error)
	grpc.ClientStream
}

type ControllerService_MetricGetServer 

type ControllerService_MetricGetServer interface {
	Send(*MetricGetReply) error
	grpc.ServerStream
}

type DiskInfo 

type DiskInfo struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parent               string            `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	Children             map[string]bool   `` /* 158-byte string literal not displayed */
	Removed              bool              `protobuf:"varint,4,opt,name=removed,proto3" json:"removed,omitempty"`
	UserCreated          bool              `protobuf:"varint,5,opt,name=userCreated,proto3" json:"userCreated,omitempty"`
	Created              string            `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	Size                 string            `protobuf:"bytes,7,opt,name=size,proto3" json:"size,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DiskInfo) Descriptor 

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

func (*DiskInfo) GetChildren 

func (m *DiskInfo) GetChildren() map[string]bool

func (*DiskInfo) GetCreated 

func (m *DiskInfo) GetCreated() string

func (*DiskInfo) GetLabels 

func (m *DiskInfo) GetLabels() map[string]string

func (*DiskInfo) GetName 

func (m *DiskInfo) GetName() string

func (*DiskInfo) GetParent 

func (m *DiskInfo) GetParent() string

func (*DiskInfo) GetRemoved 

func (m *DiskInfo) GetRemoved() bool

func (*DiskInfo) GetSize 

func (m *DiskInfo) GetSize() string

func (*DiskInfo) GetUserCreated 

func (m *DiskInfo) GetUserCreated() bool

func (*DiskInfo) ProtoMessage 

func (*DiskInfo) ProtoMessage()

func (*DiskInfo) Reset 

func (m *DiskInfo) Reset()

func (*DiskInfo) String 

func (m *DiskInfo) String() string

func (*DiskInfo) XXX_DiscardUnknown 

func (m *DiskInfo) XXX_DiscardUnknown()

func (*DiskInfo) XXX_Marshal 

func (m *DiskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskInfo) XXX_Merge 

func (m *DiskInfo) XXX_Merge(src proto.Message)

func (*DiskInfo) XXX_Size 

func (m *DiskInfo) XXX_Size() int

func (*DiskInfo) XXX_Unmarshal 

func (m *DiskInfo) XXX_Unmarshal(b []byte) error

type DiskMarkAsRemovedRequest 

type DiskMarkAsRemovedRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskMarkAsRemovedRequest) Descriptor 

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

func (*DiskMarkAsRemovedRequest) GetName 

func (m *DiskMarkAsRemovedRequest) GetName() string

func (*DiskMarkAsRemovedRequest) ProtoMessage 

func (*DiskMarkAsRemovedRequest) ProtoMessage()

func (*DiskMarkAsRemovedRequest) Reset 

func (m *DiskMarkAsRemovedRequest) Reset()

func (*DiskMarkAsRemovedRequest) String 

func (m *DiskMarkAsRemovedRequest) String() string

func (*DiskMarkAsRemovedRequest) XXX_DiscardUnknown 

func (m *DiskMarkAsRemovedRequest) XXX_DiscardUnknown()

func (*DiskMarkAsRemovedRequest) XXX_Marshal 

func (m *DiskMarkAsRemovedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskMarkAsRemovedRequest) XXX_Merge 

func (m *DiskMarkAsRemovedRequest) XXX_Merge(src proto.Message)

func (*DiskMarkAsRemovedRequest) XXX_Size 

func (m *DiskMarkAsRemovedRequest) XXX_Size() int

func (*DiskMarkAsRemovedRequest) XXX_Unmarshal 

func (m *DiskMarkAsRemovedRequest) XXX_Unmarshal(b []byte) error

type DiskPrepareRemoveReply 

type DiskPrepareRemoveReply struct {
	Operations           []*PrepareRemoveAction `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DiskPrepareRemoveReply) Descriptor 

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

func (*DiskPrepareRemoveReply) GetOperations 

func (m *DiskPrepareRemoveReply) GetOperations() []*PrepareRemoveAction

func (*DiskPrepareRemoveReply) ProtoMessage 

func (*DiskPrepareRemoveReply) ProtoMessage()

func (*DiskPrepareRemoveReply) Reset 

func (m *DiskPrepareRemoveReply) Reset()

func (*DiskPrepareRemoveReply) String 

func (m *DiskPrepareRemoveReply) String() string

func (*DiskPrepareRemoveReply) XXX_DiscardUnknown 

func (m *DiskPrepareRemoveReply) XXX_DiscardUnknown()

func (*DiskPrepareRemoveReply) XXX_Marshal 

func (m *DiskPrepareRemoveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskPrepareRemoveReply) XXX_Merge 

func (m *DiskPrepareRemoveReply) XXX_Merge(src proto.Message)

func (*DiskPrepareRemoveReply) XXX_Size 

func (m *DiskPrepareRemoveReply) XXX_Size() int

func (*DiskPrepareRemoveReply) XXX_Unmarshal 

func (m *DiskPrepareRemoveReply) XXX_Unmarshal(b []byte) error

type DiskPrepareRemoveRequest 

type DiskPrepareRemoveRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskPrepareRemoveRequest) Descriptor 

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

func (*DiskPrepareRemoveRequest) GetName 

func (m *DiskPrepareRemoveRequest) GetName() string

func (*DiskPrepareRemoveRequest) ProtoMessage 

func (*DiskPrepareRemoveRequest) ProtoMessage()

func (*DiskPrepareRemoveRequest) Reset 

func (m *DiskPrepareRemoveRequest) Reset()

func (*DiskPrepareRemoveRequest) String 

func (m *DiskPrepareRemoveRequest) String() string

func (*DiskPrepareRemoveRequest) XXX_DiscardUnknown 

func (m *DiskPrepareRemoveRequest) XXX_DiscardUnknown()

func (*DiskPrepareRemoveRequest) XXX_Marshal 

func (m *DiskPrepareRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskPrepareRemoveRequest) XXX_Merge 

func (m *DiskPrepareRemoveRequest) XXX_Merge(src proto.Message)

func (*DiskPrepareRemoveRequest) XXX_Size 

func (m *DiskPrepareRemoveRequest) XXX_Size() int

func (*DiskPrepareRemoveRequest) XXX_Unmarshal 

func (m *DiskPrepareRemoveRequest) XXX_Unmarshal(b []byte) error

type DiskRemoveRequest 

type DiskRemoveRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Force                bool     `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskRemoveRequest) Descriptor 

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

func (*DiskRemoveRequest) GetForce 

func (m *DiskRemoveRequest) GetForce() bool

func (*DiskRemoveRequest) GetName 

func (m *DiskRemoveRequest) GetName() string

func (*DiskRemoveRequest) ProtoMessage 

func (*DiskRemoveRequest) ProtoMessage()

func (*DiskRemoveRequest) Reset 

func (m *DiskRemoveRequest) Reset()

func (*DiskRemoveRequest) String 

func (m *DiskRemoveRequest) String() string

func (*DiskRemoveRequest) XXX_DiscardUnknown 

func (m *DiskRemoveRequest) XXX_DiscardUnknown()

func (*DiskRemoveRequest) XXX_Marshal 

func (m *DiskRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskRemoveRequest) XXX_Merge 

func (m *DiskRemoveRequest) XXX_Merge(src proto.Message)

func (*DiskRemoveRequest) XXX_Size 

func (m *DiskRemoveRequest) XXX_Size() int

func (*DiskRemoveRequest) XXX_Unmarshal 

func (m *DiskRemoveRequest) XXX_Unmarshal(b []byte) error

type DiskReplaceRequest 

type DiskReplaceRequest struct {
	Target               string   `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskReplaceRequest) Descriptor 

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

func (*DiskReplaceRequest) GetSource 

func (m *DiskReplaceRequest) GetSource() string

func (*DiskReplaceRequest) GetTarget 

func (m *DiskReplaceRequest) GetTarget() string

func (*DiskReplaceRequest) ProtoMessage 

func (*DiskReplaceRequest) ProtoMessage()

func (*DiskReplaceRequest) Reset 

func (m *DiskReplaceRequest) Reset()

func (*DiskReplaceRequest) String 

func (m *DiskReplaceRequest) String() string

func (*DiskReplaceRequest) XXX_DiscardUnknown 

func (m *DiskReplaceRequest) XXX_DiscardUnknown()

func (*DiskReplaceRequest) XXX_Marshal 

func (m *DiskReplaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskReplaceRequest) XXX_Merge 

func (m *DiskReplaceRequest) XXX_Merge(src proto.Message)

func (*DiskReplaceRequest) XXX_Size 

func (m *DiskReplaceRequest) XXX_Size() int

func (*DiskReplaceRequest) XXX_Unmarshal 

func (m *DiskReplaceRequest) XXX_Unmarshal(b []byte) error

type FileRemoveRequest 

type FileRemoveRequest struct {
	FileName             string   `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileRemoveRequest) Descriptor 

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

func (*FileRemoveRequest) GetFileName 

func (m *FileRemoveRequest) GetFileName() string

func (*FileRemoveRequest) ProtoMessage 

func (*FileRemoveRequest) ProtoMessage()

func (*FileRemoveRequest) Reset 

func (m *FileRemoveRequest) Reset()

func (*FileRemoveRequest) String 

func (m *FileRemoveRequest) String() string

func (*FileRemoveRequest) XXX_DiscardUnknown 

func (m *FileRemoveRequest) XXX_DiscardUnknown()

func (*FileRemoveRequest) XXX_Marshal 

func (m *FileRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileRemoveRequest) XXX_Merge 

func (m *FileRemoveRequest) XXX_Merge(src proto.Message)

func (*FileRemoveRequest) XXX_Size 

func (m *FileRemoveRequest) XXX_Size() int

func (*FileRemoveRequest) XXX_Unmarshal 

func (m *FileRemoveRequest) XXX_Unmarshal(b []byte) error

type FileRenameRequest 

type FileRenameRequest struct {
	OldFileName          string   `protobuf:"bytes,1,opt,name=oldFileName,proto3" json:"oldFileName,omitempty"`
	NewFileName          string   `protobuf:"bytes,2,opt,name=newFileName,proto3" json:"newFileName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileRenameRequest) Descriptor 

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

func (*FileRenameRequest) GetNewFileName 

func (m *FileRenameRequest) GetNewFileName() string

func (*FileRenameRequest) GetOldFileName 

func (m *FileRenameRequest) GetOldFileName() string

func (*FileRenameRequest) ProtoMessage 

func (*FileRenameRequest) ProtoMessage()

func (*FileRenameRequest) Reset 

func (m *FileRenameRequest) Reset()

func (*FileRenameRequest) String 

func (m *FileRenameRequest) String() string

func (*FileRenameRequest) XXX_DiscardUnknown 

func (m *FileRenameRequest) XXX_DiscardUnknown()

func (*FileRenameRequest) XXX_Marshal 

func (m *FileRenameRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileRenameRequest) XXX_Merge 

func (m *FileRenameRequest) XXX_Merge(src proto.Message)

func (*FileRenameRequest) XXX_Size 

func (m *FileRenameRequest) XXX_Size() int

func (*FileRenameRequest) XXX_Unmarshal 

func (m *FileRenameRequest) XXX_Unmarshal(b []byte) error

type FileSendRequest 

type FileSendRequest struct {
	FromFileName         string   `protobuf:"bytes,1,opt,name=fromFileName,proto3" json:"fromFileName,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port                 int32    `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileSendRequest) Descriptor 

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

func (*FileSendRequest) GetFromFileName 

func (m *FileSendRequest) GetFromFileName() string

func (*FileSendRequest) GetHost 

func (m *FileSendRequest) GetHost() string

func (*FileSendRequest) GetPort 

func (m *FileSendRequest) GetPort() int32

func (*FileSendRequest) ProtoMessage 

func (*FileSendRequest) ProtoMessage()

func (*FileSendRequest) Reset 

func (m *FileSendRequest) Reset()

func (*FileSendRequest) String 

func (m *FileSendRequest) String() string

func (*FileSendRequest) XXX_DiscardUnknown 

func (m *FileSendRequest) XXX_DiscardUnknown()

func (*FileSendRequest) XXX_Marshal 

func (m *FileSendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSendRequest) XXX_Merge 

func (m *FileSendRequest) XXX_Merge(src proto.Message)

func (*FileSendRequest) XXX_Size 

func (m *FileSendRequest) XXX_Size() int

func (*FileSendRequest) XXX_Unmarshal 

func (m *FileSendRequest) XXX_Unmarshal(b []byte) error

type FilesSyncRequest 

type FilesSyncRequest struct {
	FromAddress          string          `protobuf:"bytes,1,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	ToHost               string          `protobuf:"bytes,2,opt,name=to_host,json=toHost,proto3" json:"to_host,omitempty"`
	SyncFileInfoList     []*SyncFileInfo `protobuf:"bytes,3,rep,name=sync_file_info_list,json=syncFileInfoList,proto3" json:"sync_file_info_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*FilesSyncRequest) Descriptor 

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

func (*FilesSyncRequest) GetFromAddress 

func (m *FilesSyncRequest) GetFromAddress() string

func (*FilesSyncRequest) GetSyncFileInfoList 

func (m *FilesSyncRequest) GetSyncFileInfoList() []*SyncFileInfo

func (*FilesSyncRequest) GetToHost 

func (m *FilesSyncRequest) GetToHost() string

func (*FilesSyncRequest) ProtoMessage 

func (*FilesSyncRequest) ProtoMessage()

func (*FilesSyncRequest) Reset 

func (m *FilesSyncRequest) Reset()

func (*FilesSyncRequest) String 

func (m *FilesSyncRequest) String() string

func (*FilesSyncRequest) XXX_DiscardUnknown 

func (m *FilesSyncRequest) XXX_DiscardUnknown()

func (*FilesSyncRequest) XXX_Marshal 

func (m *FilesSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilesSyncRequest) XXX_Merge 

func (m *FilesSyncRequest) XXX_Merge(src proto.Message)

func (*FilesSyncRequest) XXX_Size 

func (m *FilesSyncRequest) XXX_Size() int

func (*FilesSyncRequest) XXX_Unmarshal 

func (m *FilesSyncRequest) XXX_Unmarshal(b []byte) error

type JournalListRequest 

type JournalListRequest struct {
	Limit                int64    `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JournalListRequest) Descriptor 

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

func (*JournalListRequest) GetLimit 

func (m *JournalListRequest) GetLimit() int64

func (*JournalListRequest) ProtoMessage 

func (*JournalListRequest) ProtoMessage()

func (*JournalListRequest) Reset 

func (m *JournalListRequest) Reset()

func (*JournalListRequest) String 

func (m *JournalListRequest) String() string

func (*JournalListRequest) XXX_DiscardUnknown 

func (m *JournalListRequest) XXX_DiscardUnknown()

func (*JournalListRequest) XXX_Marshal 

func (m *JournalListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JournalListRequest) XXX_Merge 

func (m *JournalListRequest) XXX_Merge(src proto.Message)

func (*JournalListRequest) XXX_Size 

func (m *JournalListRequest) XXX_Size() int

func (*JournalListRequest) XXX_Unmarshal 

func (m *JournalListRequest) XXX_Unmarshal(b []byte) error

type Metric 

type Metric struct {
	ReadBandwidth        uint64   `protobuf:"varint,1,opt,name=readBandwidth,proto3" json:"readBandwidth,omitempty"`
	WriteBandwidth       uint64   `protobuf:"varint,2,opt,name=writeBandwidth,proto3" json:"writeBandwidth,omitempty"`
	ReadLatency          uint64   `protobuf:"varint,3,opt,name=readLatency,proto3" json:"readLatency,omitempty"`
	WriteLatency         uint64   `protobuf:"varint,4,opt,name=writeLatency,proto3" json:"writeLatency,omitempty"`
	IOPS                 uint64   `protobuf:"varint,5,opt,name=iOPS,proto3" json:"iOPS,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metric) Descriptor 

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

func (*Metric) GetIOPS 

func (m *Metric) GetIOPS() uint64

func (*Metric) GetReadBandwidth 

func (m *Metric) GetReadBandwidth() uint64

func (*Metric) GetReadLatency 

func (m *Metric) GetReadLatency() uint64

func (*Metric) GetWriteBandwidth 

func (m *Metric) GetWriteBandwidth() uint64

func (*Metric) GetWriteLatency 

func (m *Metric) GetWriteLatency() uint64

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) String 

func (m *Metric) String() string

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

func (m *Metric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metric) XXX_Merge 

func (m *Metric) XXX_Merge(src proto.Message)

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

func (m *Metric) XXX_Unmarshal(b []byte) error

type MetricGetReply 

type MetricGetReply struct {
	Metric               *Metric  `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetricGetReply) Descriptor 

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

func (*MetricGetReply) GetMetric 

func (m *MetricGetReply) GetMetric() *Metric

func (*MetricGetReply) ProtoMessage 

func (*MetricGetReply) ProtoMessage()

func (*MetricGetReply) Reset 

func (m *MetricGetReply) Reset()

func (*MetricGetReply) String 

func (m *MetricGetReply) String() string

func (*MetricGetReply) XXX_DiscardUnknown 

func (m *MetricGetReply) XXX_DiscardUnknown()

func (*MetricGetReply) XXX_Marshal 

func (m *MetricGetReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricGetReply) XXX_Merge 

func (m *MetricGetReply) XXX_Merge(src proto.Message)

func (*MetricGetReply) XXX_Size 

func (m *MetricGetReply) XXX_Size() int

func (*MetricGetReply) XXX_Unmarshal 

func (m *MetricGetReply) XXX_Unmarshal(b []byte) error

type PrepareRemoveAction 

type PrepareRemoveAction struct {
	Action               string   `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Target               string   `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrepareRemoveAction) Descriptor 

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

func (*PrepareRemoveAction) GetAction 

func (m *PrepareRemoveAction) GetAction() string

func (*PrepareRemoveAction) GetSource 

func (m *PrepareRemoveAction) GetSource() string

func (*PrepareRemoveAction) GetTarget 

func (m *PrepareRemoveAction) GetTarget() string

func (*PrepareRemoveAction) ProtoMessage 

func (*PrepareRemoveAction) ProtoMessage()

func (*PrepareRemoveAction) Reset 

func (m *PrepareRemoveAction) Reset()

func (*PrepareRemoveAction) String 

func (m *PrepareRemoveAction) String() string

func (*PrepareRemoveAction) XXX_DiscardUnknown 

func (m *PrepareRemoveAction) XXX_DiscardUnknown()

func (*PrepareRemoveAction) XXX_Marshal 

func (m *PrepareRemoveAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareRemoveAction) XXX_Merge 

func (m *PrepareRemoveAction) XXX_Merge(src proto.Message)

func (*PrepareRemoveAction) XXX_Size 

func (m *PrepareRemoveAction) XXX_Size() int

func (*PrepareRemoveAction) XXX_Unmarshal 

func (m *PrepareRemoveAction) XXX_Unmarshal(b []byte) error

type RebuildingSetRequest 

type RebuildingSetRequest struct {
	Rebuilding           bool     `protobuf:"varint,1,opt,name=rebuilding,proto3" json:"rebuilding,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RebuildingSetRequest) Descriptor 

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

func (*RebuildingSetRequest) GetRebuilding 

func (m *RebuildingSetRequest) GetRebuilding() bool

func (*RebuildingSetRequest) ProtoMessage 

func (*RebuildingSetRequest) ProtoMessage()

func (*RebuildingSetRequest) Reset 

func (m *RebuildingSetRequest) Reset()

func (*RebuildingSetRequest) String 

func (m *RebuildingSetRequest) String() string

func (*RebuildingSetRequest) XXX_DiscardUnknown 

func (m *RebuildingSetRequest) XXX_DiscardUnknown()

func (*RebuildingSetRequest) XXX_Marshal 

func (m *RebuildingSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RebuildingSetRequest) XXX_Merge 

func (m *RebuildingSetRequest) XXX_Merge(src proto.Message)

func (*RebuildingSetRequest) XXX_Size 

func (m *RebuildingSetRequest) XXX_Size() int

func (*RebuildingSetRequest) XXX_Unmarshal 

func (m *RebuildingSetRequest) XXX_Unmarshal(b []byte) error

type ReceiverLaunchReply 

type ReceiverLaunchReply struct {
	Port                 int32    `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReceiverLaunchReply) Descriptor 

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

func (*ReceiverLaunchReply) GetPort 

func (m *ReceiverLaunchReply) GetPort() int32

func (*ReceiverLaunchReply) ProtoMessage 

func (*ReceiverLaunchReply) ProtoMessage()

func (*ReceiverLaunchReply) Reset 

func (m *ReceiverLaunchReply) Reset()

func (*ReceiverLaunchReply) String 

func (m *ReceiverLaunchReply) String() string

func (*ReceiverLaunchReply) XXX_DiscardUnknown 

func (m *ReceiverLaunchReply) XXX_DiscardUnknown()

func (*ReceiverLaunchReply) XXX_Marshal 

func (m *ReceiverLaunchReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReceiverLaunchReply) XXX_Merge 

func (m *ReceiverLaunchReply) XXX_Merge(src proto.Message)

func (*ReceiverLaunchReply) XXX_Size 

func (m *ReceiverLaunchReply) XXX_Size() int

func (*ReceiverLaunchReply) XXX_Unmarshal 

func (m *ReceiverLaunchReply) XXX_Unmarshal(b []byte) error

type ReceiverLaunchRequest 

type ReceiverLaunchRequest struct {
	ToFileName           string   `protobuf:"bytes,1,opt,name=toFileName,proto3" json:"toFileName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReceiverLaunchRequest) Descriptor 

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

func (*ReceiverLaunchRequest) GetToFileName 

func (m *ReceiverLaunchRequest) GetToFileName() string

func (*ReceiverLaunchRequest) ProtoMessage 

func (*ReceiverLaunchRequest) ProtoMessage()

func (*ReceiverLaunchRequest) Reset 

func (m *ReceiverLaunchRequest) Reset()

func (*ReceiverLaunchRequest) String 

func (m *ReceiverLaunchRequest) String() string

func (*ReceiverLaunchRequest) XXX_DiscardUnknown 

func (m *ReceiverLaunchRequest) XXX_DiscardUnknown()

func (*ReceiverLaunchRequest) XXX_Marshal 

func (m *ReceiverLaunchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReceiverLaunchRequest) XXX_Merge 

func (m *ReceiverLaunchRequest) XXX_Merge(src proto.Message)

func (*ReceiverLaunchRequest) XXX_Size 

func (m *ReceiverLaunchRequest) XXX_Size() int

func (*ReceiverLaunchRequest) XXX_Unmarshal 

func (m *ReceiverLaunchRequest) XXX_Unmarshal(b []byte) error

type Replica 

type Replica struct {
	Dirty                bool                 `protobuf:"varint,1,opt,name=dirty,proto3" json:"dirty,omitempty"`
	Rebuilding           bool                 `protobuf:"varint,2,opt,name=rebuilding,proto3" json:"rebuilding,omitempty"`
	Head                 string               `protobuf:"bytes,3,opt,name=head,proto3" json:"head,omitempty"`
	Parent               string               `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
	Size                 string               `protobuf:"bytes,5,opt,name=size,proto3" json:"size,omitempty"`
	SectorSize           int64                `protobuf:"varint,6,opt,name=sectorSize,proto3" json:"sectorSize,omitempty"`
	BackingFile          string               `protobuf:"bytes,7,opt,name=backingFile,proto3" json:"backingFile,omitempty"`
	State                string               `protobuf:"bytes,8,opt,name=state,proto3" json:"state,omitempty"`
	Chain                []string             `protobuf:"bytes,9,rep,name=chain,proto3" json:"chain,omitempty"`
	Disks                map[string]*DiskInfo `` /* 152-byte string literal not displayed */
	RemainSnapshots      int32                `protobuf:"varint,11,opt,name=remainSnapshots,proto3" json:"remainSnapshots,omitempty"`
	RevisionCounter      int64                `protobuf:"varint,12,opt,name=revisionCounter,proto3" json:"revisionCounter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Replica) Descriptor 

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

func (*Replica) GetBackingFile 

func (m *Replica) GetBackingFile() string

func (*Replica) GetChain 

func (m *Replica) GetChain() []string

func (*Replica) GetDirty 

func (m *Replica) GetDirty() bool

func (*Replica) GetDisks 

func (m *Replica) GetDisks() map[string]*DiskInfo

func (*Replica) GetHead 

func (m *Replica) GetHead() string

func (*Replica) GetParent 

func (m *Replica) GetParent() string

func (*Replica) GetRebuilding 

func (m *Replica) GetRebuilding() bool

func (*Replica) GetRemainSnapshots 

func (m *Replica) GetRemainSnapshots() int32

func (*Replica) GetRevisionCounter 

func (m *Replica) GetRevisionCounter() int64

func (*Replica) GetSectorSize 

func (m *Replica) GetSectorSize() int64

func (*Replica) GetSize 

func (m *Replica) GetSize() string

func (*Replica) GetState 

func (m *Replica) GetState() string

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) Reset 

func (m *Replica) Reset()

func (*Replica) String 

func (m *Replica) String() string

func (*Replica) XXX_DiscardUnknown 

func (m *Replica) XXX_DiscardUnknown()

func (*Replica) XXX_Marshal 

func (m *Replica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Replica) XXX_Merge 

func (m *Replica) XXX_Merge(src proto.Message)

func (*Replica) XXX_Size 

func (m *Replica) XXX_Size() int

func (*Replica) XXX_Unmarshal 

func (m *Replica) XXX_Unmarshal(b []byte) error

type ReplicaAddress 

type ReplicaAddress struct {
	Address              string   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaAddress) Descriptor 

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

func (*ReplicaAddress) GetAddress 

func (m *ReplicaAddress) GetAddress() string

func (*ReplicaAddress) ProtoMessage 

func (*ReplicaAddress) ProtoMessage()

func (*ReplicaAddress) Reset 

func (m *ReplicaAddress) Reset()

func (*ReplicaAddress) String 

func (m *ReplicaAddress) String() string

func (*ReplicaAddress) XXX_DiscardUnknown 

func (m *ReplicaAddress) XXX_DiscardUnknown()

func (*ReplicaAddress) XXX_Marshal 

func (m *ReplicaAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaAddress) XXX_Merge 

func (m *ReplicaAddress) XXX_Merge(src proto.Message)

func (*ReplicaAddress) XXX_Size 

func (m *ReplicaAddress) XXX_Size() int

func (*ReplicaAddress) XXX_Unmarshal 

func (m *ReplicaAddress) XXX_Unmarshal(b []byte) error

type ReplicaCreateRequest 

type ReplicaCreateRequest struct {
	Size                 string   `protobuf:"bytes,1,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaCreateRequest) Descriptor 

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

func (*ReplicaCreateRequest) GetSize 

func (m *ReplicaCreateRequest) GetSize() string

func (*ReplicaCreateRequest) ProtoMessage 

func (*ReplicaCreateRequest) ProtoMessage()

func (*ReplicaCreateRequest) Reset 

func (m *ReplicaCreateRequest) Reset()

func (*ReplicaCreateRequest) String 

func (m *ReplicaCreateRequest) String() string

func (*ReplicaCreateRequest) XXX_DiscardUnknown 

func (m *ReplicaCreateRequest) XXX_DiscardUnknown()

func (*ReplicaCreateRequest) XXX_Marshal 

func (m *ReplicaCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaCreateRequest) XXX_Merge 

func (m *ReplicaCreateRequest) XXX_Merge(src proto.Message)

func (*ReplicaCreateRequest) XXX_Size 

func (m *ReplicaCreateRequest) XXX_Size() int

func (*ReplicaCreateRequest) XXX_Unmarshal 

func (m *ReplicaCreateRequest) XXX_Unmarshal(b []byte) error

type ReplicaExpandRequest 

type ReplicaExpandRequest struct {
	Size                 int64    `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaExpandRequest) Descriptor 

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

func (*ReplicaExpandRequest) GetSize 

func (m *ReplicaExpandRequest) GetSize() int64

func (*ReplicaExpandRequest) ProtoMessage 

func (*ReplicaExpandRequest) ProtoMessage()

func (*ReplicaExpandRequest) Reset 

func (m *ReplicaExpandRequest) Reset()

func (*ReplicaExpandRequest) String 

func (m *ReplicaExpandRequest) String() string

func (*ReplicaExpandRequest) XXX_DiscardUnknown 

func (m *ReplicaExpandRequest) XXX_DiscardUnknown()

func (*ReplicaExpandRequest) XXX_Marshal 

func (m *ReplicaExpandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaExpandRequest) XXX_Merge 

func (m *ReplicaExpandRequest) XXX_Merge(src proto.Message)

func (*ReplicaExpandRequest) XXX_Size 

func (m *ReplicaExpandRequest) XXX_Size() int

func (*ReplicaExpandRequest) XXX_Unmarshal 

func (m *ReplicaExpandRequest) XXX_Unmarshal(b []byte) error

type ReplicaListReply 

type ReplicaListReply struct {
	Replicas             []*ControllerReplica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReplicaListReply) Descriptor 

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

func (*ReplicaListReply) GetReplicas 

func (m *ReplicaListReply) GetReplicas() []*ControllerReplica

func (*ReplicaListReply) ProtoMessage 

func (*ReplicaListReply) ProtoMessage()

func (*ReplicaListReply) Reset 

func (m *ReplicaListReply) Reset()

func (*ReplicaListReply) String 

func (m *ReplicaListReply) String() string

func (*ReplicaListReply) XXX_DiscardUnknown 

func (m *ReplicaListReply) XXX_DiscardUnknown()

func (*ReplicaListReply) XXX_Marshal 

func (m *ReplicaListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaListReply) XXX_Merge 

func (m *ReplicaListReply) XXX_Merge(src proto.Message)

func (*ReplicaListReply) XXX_Size 

func (m *ReplicaListReply) XXX_Size() int

func (*ReplicaListReply) XXX_Unmarshal 

func (m *ReplicaListReply) XXX_Unmarshal(b []byte) error

type ReplicaMode 

type ReplicaMode int32
const (
	ReplicaMode_WO  ReplicaMode = 0
	ReplicaMode_RW  ReplicaMode = 1
	ReplicaMode_ERR ReplicaMode = 2
)

func (ReplicaMode) EnumDescriptor 

func (ReplicaMode) EnumDescriptor() ([]byte, []int)

func (ReplicaMode) String 

func (x ReplicaMode) String() string

type ReplicaPrepareRebuildReply 

type ReplicaPrepareRebuildReply struct {
	Replica              *ControllerReplica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	SyncFileInfoList     []*SyncFileInfo    `protobuf:"bytes,2,rep,name=sync_file_info_list,json=syncFileInfoList,proto3" json:"sync_file_info_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ReplicaPrepareRebuildReply) Descriptor 

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

func (*ReplicaPrepareRebuildReply) GetReplica 

func (m *ReplicaPrepareRebuildReply) GetReplica() *ControllerReplica

func (*ReplicaPrepareRebuildReply) GetSyncFileInfoList 

func (m *ReplicaPrepareRebuildReply) GetSyncFileInfoList() []*SyncFileInfo

func (*ReplicaPrepareRebuildReply) ProtoMessage 

func (*ReplicaPrepareRebuildReply) ProtoMessage()

func (*ReplicaPrepareRebuildReply) Reset 

func (m *ReplicaPrepareRebuildReply) Reset()

func (*ReplicaPrepareRebuildReply) String 

func (m *ReplicaPrepareRebuildReply) String() string

func (*ReplicaPrepareRebuildReply) XXX_DiscardUnknown 

func (m *ReplicaPrepareRebuildReply) XXX_DiscardUnknown()

func (*ReplicaPrepareRebuildReply) XXX_Marshal 

func (m *ReplicaPrepareRebuildReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaPrepareRebuildReply) XXX_Merge 

func (m *ReplicaPrepareRebuildReply) XXX_Merge(src proto.Message)

func (*ReplicaPrepareRebuildReply) XXX_Size 

func (m *ReplicaPrepareRebuildReply) XXX_Size() int

func (*ReplicaPrepareRebuildReply) XXX_Unmarshal 

func (m *ReplicaPrepareRebuildReply) XXX_Unmarshal(b []byte) error

type ReplicaRebuildStatusReply 

type ReplicaRebuildStatusReply struct {
	IsRebuilding         bool     `protobuf:"varint,1,opt,name=is_rebuilding,json=isRebuilding,proto3" json:"is_rebuilding,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Progress             int32    `protobuf:"varint,3,opt,name=progress,proto3" json:"progress,omitempty"`
	State                string   `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	FromReplicaAddress   string   `protobuf:"bytes,5,opt,name=from_replica_address,json=fromReplicaAddress,proto3" json:"from_replica_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaRebuildStatusReply) Descriptor 

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

func (*ReplicaRebuildStatusReply) GetError 

func (m *ReplicaRebuildStatusReply) GetError() string

func (*ReplicaRebuildStatusReply) GetFromReplicaAddress added in v0.8.1 

func (m *ReplicaRebuildStatusReply) GetFromReplicaAddress() string

func (*ReplicaRebuildStatusReply) GetIsRebuilding 

func (m *ReplicaRebuildStatusReply) GetIsRebuilding() bool

func (*ReplicaRebuildStatusReply) GetProgress 

func (m *ReplicaRebuildStatusReply) GetProgress() int32

func (*ReplicaRebuildStatusReply) GetState 

func (m *ReplicaRebuildStatusReply) GetState() string

func (*ReplicaRebuildStatusReply) ProtoMessage 

func (*ReplicaRebuildStatusReply) ProtoMessage()

func (*ReplicaRebuildStatusReply) Reset 

func (m *ReplicaRebuildStatusReply) Reset()

func (*ReplicaRebuildStatusReply) String 

func (m *ReplicaRebuildStatusReply) String() string

func (*ReplicaRebuildStatusReply) XXX_DiscardUnknown 

func (m *ReplicaRebuildStatusReply) XXX_DiscardUnknown()

func (*ReplicaRebuildStatusReply) XXX_Marshal 

func (m *ReplicaRebuildStatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaRebuildStatusReply) XXX_Merge 

func (m *ReplicaRebuildStatusReply) XXX_Merge(src proto.Message)

func (*ReplicaRebuildStatusReply) XXX_Size 

func (m *ReplicaRebuildStatusReply) XXX_Size() int

func (*ReplicaRebuildStatusReply) XXX_Unmarshal 

func (m *ReplicaRebuildStatusReply) XXX_Unmarshal(b []byte) error

type ReplicaRevertRequest 

type ReplicaRevertRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Created              string   `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaRevertRequest) Descriptor 

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

func (*ReplicaRevertRequest) GetCreated 

func (m *ReplicaRevertRequest) GetCreated() string

func (*ReplicaRevertRequest) GetName 

func (m *ReplicaRevertRequest) GetName() string

func (*ReplicaRevertRequest) ProtoMessage 

func (*ReplicaRevertRequest) ProtoMessage()

func (*ReplicaRevertRequest) Reset 

func (m *ReplicaRevertRequest) Reset()

func (*ReplicaRevertRequest) String 

func (m *ReplicaRevertRequest) String() string

func (*ReplicaRevertRequest) XXX_DiscardUnknown 

func (m *ReplicaRevertRequest) XXX_DiscardUnknown()

func (*ReplicaRevertRequest) XXX_Marshal 

func (m *ReplicaRevertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaRevertRequest) XXX_Merge 

func (m *ReplicaRevertRequest) XXX_Merge(src proto.Message)

func (*ReplicaRevertRequest) XXX_Size 

func (m *ReplicaRevertRequest) XXX_Size() int

func (*ReplicaRevertRequest) XXX_Unmarshal 

func (m *ReplicaRevertRequest) XXX_Unmarshal(b []byte) error

type ReplicaServiceClient 

type ReplicaServiceClient interface {
	ReplicaCreate(ctx context.Context, in *ReplicaCreateRequest, opts ...grpc.CallOption) (*Replica, error)
	ReplicaDelete(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	ReplicaGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaOpen(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaClose(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaReload(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaRevert(ctx context.Context, in *ReplicaRevertRequest, opts ...grpc.CallOption) (*Replica, error)
	ReplicaSnapshot(ctx context.Context, in *ReplicaSnapshotRequest, opts ...grpc.CallOption) (*Replica, error)
	ReplicaExpand(ctx context.Context, in *ReplicaExpandRequest, opts ...grpc.CallOption) (*Replica, error)
	DiskRemove(ctx context.Context, in *DiskRemoveRequest, opts ...grpc.CallOption) (*Replica, error)
	DiskReplace(ctx context.Context, in *DiskReplaceRequest, opts ...grpc.CallOption) (*Replica, error)
	DiskPrepareRemove(ctx context.Context, in *DiskPrepareRemoveRequest, opts ...grpc.CallOption) (*DiskPrepareRemoveReply, error)
	DiskMarkAsRemoved(ctx context.Context, in *DiskMarkAsRemovedRequest, opts ...grpc.CallOption) (*Replica, error)
	RebuildingSet(ctx context.Context, in *RebuildingSetRequest, opts ...grpc.CallOption) (*Replica, error)
	RevisionCounterSet(ctx context.Context, in *RevisionCounterSetRequest, opts ...grpc.CallOption) (*Replica, error)
}

ReplicaServiceClient is the client API for ReplicaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewReplicaServiceClient 

func NewReplicaServiceClient(cc *grpc.ClientConn) ReplicaServiceClient

type ReplicaServiceServer 

type ReplicaServiceServer interface {
	ReplicaCreate(context.Context, *ReplicaCreateRequest) (*Replica, error)
	ReplicaDelete(context.Context, *empty.Empty) (*empty.Empty, error)
	ReplicaGet(context.Context, *empty.Empty) (*Replica, error)
	ReplicaOpen(context.Context, *empty.Empty) (*Replica, error)
	ReplicaClose(context.Context, *empty.Empty) (*Replica, error)
	ReplicaReload(context.Context, *empty.Empty) (*Replica, error)
	ReplicaRevert(context.Context, *ReplicaRevertRequest) (*Replica, error)
	ReplicaSnapshot(context.Context, *ReplicaSnapshotRequest) (*Replica, error)
	ReplicaExpand(context.Context, *ReplicaExpandRequest) (*Replica, error)
	DiskRemove(context.Context, *DiskRemoveRequest) (*Replica, error)
	DiskReplace(context.Context, *DiskReplaceRequest) (*Replica, error)
	DiskPrepareRemove(context.Context, *DiskPrepareRemoveRequest) (*DiskPrepareRemoveReply, error)
	DiskMarkAsRemoved(context.Context, *DiskMarkAsRemovedRequest) (*Replica, error)
	RebuildingSet(context.Context, *RebuildingSetRequest) (*Replica, error)
	RevisionCounterSet(context.Context, *RevisionCounterSetRequest) (*Replica, error)
}

ReplicaServiceServer is the server API for ReplicaService service.

type ReplicaSnapshotRequest 

type ReplicaSnapshotRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UserCreated          bool              `protobuf:"varint,2,opt,name=userCreated,proto3" json:"userCreated,omitempty"`
	Created              string            `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ReplicaSnapshotRequest) Descriptor 

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

func (*ReplicaSnapshotRequest) GetCreated 

func (m *ReplicaSnapshotRequest) GetCreated() string

func (*ReplicaSnapshotRequest) GetLabels 

func (m *ReplicaSnapshotRequest) GetLabels() map[string]string

func (*ReplicaSnapshotRequest) GetName 

func (m *ReplicaSnapshotRequest) GetName() string

func (*ReplicaSnapshotRequest) GetUserCreated 

func (m *ReplicaSnapshotRequest) GetUserCreated() bool

func (*ReplicaSnapshotRequest) ProtoMessage 

func (*ReplicaSnapshotRequest) ProtoMessage()

func (*ReplicaSnapshotRequest) Reset 

func (m *ReplicaSnapshotRequest) Reset()

func (*ReplicaSnapshotRequest) String 

func (m *ReplicaSnapshotRequest) String() string

func (*ReplicaSnapshotRequest) XXX_DiscardUnknown 

func (m *ReplicaSnapshotRequest) XXX_DiscardUnknown()

func (*ReplicaSnapshotRequest) XXX_Marshal 

func (m *ReplicaSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaSnapshotRequest) XXX_Merge 

func (m *ReplicaSnapshotRequest) XXX_Merge(src proto.Message)

func (*ReplicaSnapshotRequest) XXX_Size 

func (m *ReplicaSnapshotRequest) XXX_Size() int

func (*ReplicaSnapshotRequest) XXX_Unmarshal 

func (m *ReplicaSnapshotRequest) XXX_Unmarshal(b []byte) error

type RestoreStatusReply 

type RestoreStatusReply struct {
	IsRestoring          bool     `protobuf:"varint,1,opt,name=isRestoring,proto3" json:"isRestoring,omitempty"`
	LastRestored         string   `protobuf:"bytes,2,opt,name=lastRestored,proto3" json:"lastRestored,omitempty"`
	Progress             int32    `protobuf:"varint,3,opt,name=progress,proto3" json:"progress,omitempty"`
	Error                string   `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	DestFileName         string   `protobuf:"bytes,5,opt,name=destFileName,proto3" json:"destFileName,omitempty"`
	State                string   `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	BackupURL            string   `protobuf:"bytes,7,opt,name=backupURL,proto3" json:"backupURL,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestoreStatusReply) Descriptor 

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

func (*RestoreStatusReply) GetBackupURL 

func (m *RestoreStatusReply) GetBackupURL() string

func (*RestoreStatusReply) GetDestFileName 

func (m *RestoreStatusReply) GetDestFileName() string

func (*RestoreStatusReply) GetError 

func (m *RestoreStatusReply) GetError() string

func (*RestoreStatusReply) GetIsRestoring 

func (m *RestoreStatusReply) GetIsRestoring() bool

func (*RestoreStatusReply) GetLastRestored 

func (m *RestoreStatusReply) GetLastRestored() string

func (*RestoreStatusReply) GetProgress 

func (m *RestoreStatusReply) GetProgress() int32

func (*RestoreStatusReply) GetState 

func (m *RestoreStatusReply) GetState() string

func (*RestoreStatusReply) ProtoMessage 

func (*RestoreStatusReply) ProtoMessage()

func (*RestoreStatusReply) Reset 

func (m *RestoreStatusReply) Reset()

func (*RestoreStatusReply) String 

func (m *RestoreStatusReply) String() string

func (*RestoreStatusReply) XXX_DiscardUnknown 

func (m *RestoreStatusReply) XXX_DiscardUnknown()

func (*RestoreStatusReply) XXX_Marshal 

func (m *RestoreStatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreStatusReply) XXX_Merge 

func (m *RestoreStatusReply) XXX_Merge(src proto.Message)

func (*RestoreStatusReply) XXX_Size 

func (m *RestoreStatusReply) XXX_Size() int

func (*RestoreStatusReply) XXX_Unmarshal 

func (m *RestoreStatusReply) XXX_Unmarshal(b []byte) error

type RevisionCounterSetRequest 

type RevisionCounterSetRequest struct {
	Counter              int64    `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevisionCounterSetRequest) Descriptor 

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

func (*RevisionCounterSetRequest) GetCounter 

func (m *RevisionCounterSetRequest) GetCounter() int64

func (*RevisionCounterSetRequest) ProtoMessage 

func (*RevisionCounterSetRequest) ProtoMessage()

func (*RevisionCounterSetRequest) Reset 

func (m *RevisionCounterSetRequest) Reset()

func (*RevisionCounterSetRequest) String 

func (m *RevisionCounterSetRequest) String() string

func (*RevisionCounterSetRequest) XXX_DiscardUnknown 

func (m *RevisionCounterSetRequest) XXX_DiscardUnknown()

func (*RevisionCounterSetRequest) XXX_Marshal 

func (m *RevisionCounterSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RevisionCounterSetRequest) XXX_Merge 

func (m *RevisionCounterSetRequest) XXX_Merge(src proto.Message)

func (*RevisionCounterSetRequest) XXX_Size 

func (m *RevisionCounterSetRequest) XXX_Size() int

func (*RevisionCounterSetRequest) XXX_Unmarshal 

func (m *RevisionCounterSetRequest) XXX_Unmarshal(b []byte) error

type SnapshotPurgeStatusReply 

type SnapshotPurgeStatusReply struct {
	IsPurging            bool     `protobuf:"varint,1,opt,name=isPurging,proto3" json:"isPurging,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Progress             int32    `protobuf:"varint,3,opt,name=progress,proto3" json:"progress,omitempty"`
	State                string   `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SnapshotPurgeStatusReply) Descriptor 

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

func (*SnapshotPurgeStatusReply) GetError 

func (m *SnapshotPurgeStatusReply) GetError() string

func (*SnapshotPurgeStatusReply) GetIsPurging 

func (m *SnapshotPurgeStatusReply) GetIsPurging() bool

func (*SnapshotPurgeStatusReply) GetProgress 

func (m *SnapshotPurgeStatusReply) GetProgress() int32

func (*SnapshotPurgeStatusReply) GetState 

func (m *SnapshotPurgeStatusReply) GetState() string

func (*SnapshotPurgeStatusReply) ProtoMessage 

func (*SnapshotPurgeStatusReply) ProtoMessage()

func (*SnapshotPurgeStatusReply) Reset 

func (m *SnapshotPurgeStatusReply) Reset()

func (*SnapshotPurgeStatusReply) String 

func (m *SnapshotPurgeStatusReply) String() string

func (*SnapshotPurgeStatusReply) XXX_DiscardUnknown 

func (m *SnapshotPurgeStatusReply) XXX_DiscardUnknown()

func (*SnapshotPurgeStatusReply) XXX_Marshal 

func (m *SnapshotPurgeStatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SnapshotPurgeStatusReply) XXX_Merge 

func (m *SnapshotPurgeStatusReply) XXX_Merge(src proto.Message)

func (*SnapshotPurgeStatusReply) XXX_Size 

func (m *SnapshotPurgeStatusReply) XXX_Size() int

func (*SnapshotPurgeStatusReply) XXX_Unmarshal 

func (m *SnapshotPurgeStatusReply) XXX_Unmarshal(b []byte) error

type SyncAgentServiceClient 

type SyncAgentServiceClient interface {
	FileRemove(ctx context.Context, in *FileRemoveRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FileRename(ctx context.Context, in *FileRenameRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FileSend(ctx context.Context, in *FileSendRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FilesSync(ctx context.Context, in *FilesSyncRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ReceiverLaunch(ctx context.Context, in *ReceiverLaunchRequest, opts ...grpc.CallOption) (*ReceiverLaunchReply, error)
	BackupCreate(ctx context.Context, in *BackupCreateRequest, opts ...grpc.CallOption) (*BackupCreateReply, error)
	BackupRemove(ctx context.Context, in *BackupRemoveRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	BackupRestore(ctx context.Context, in *BackupRestoreRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	BackupRestoreIncrementally(ctx context.Context, in *BackupRestoreIncrementallyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	BackupGetStatus(ctx context.Context, in *BackupProgressRequest, opts ...grpc.CallOption) (*BackupStatusReply, error)
	Reset(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	RestoreStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RestoreStatusReply, error)
	SnapshotPurge(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	SnapshotPurgeStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*SnapshotPurgeStatusReply, error)
	ReplicaRebuildStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ReplicaRebuildStatusReply, error)
}

SyncAgentServiceClient is the client API for SyncAgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSyncAgentServiceClient 

func NewSyncAgentServiceClient(cc *grpc.ClientConn) SyncAgentServiceClient

type SyncAgentServiceServer 

type SyncAgentServiceServer interface {
	FileRemove(context.Context, *FileRemoveRequest) (*empty.Empty, error)
	FileRename(context.Context, *FileRenameRequest) (*empty.Empty, error)
	FileSend(context.Context, *FileSendRequest) (*empty.Empty, error)
	FilesSync(context.Context, *FilesSyncRequest) (*empty.Empty, error)
	ReceiverLaunch(context.Context, *ReceiverLaunchRequest) (*ReceiverLaunchReply, error)
	BackupCreate(context.Context, *BackupCreateRequest) (*BackupCreateReply, error)
	BackupRemove(context.Context, *BackupRemoveRequest) (*empty.Empty, error)
	BackupRestore(context.Context, *BackupRestoreRequest) (*empty.Empty, error)
	BackupRestoreIncrementally(context.Context, *BackupRestoreIncrementallyRequest) (*empty.Empty, error)
	BackupGetStatus(context.Context, *BackupProgressRequest) (*BackupStatusReply, error)
	Reset(context.Context, *empty.Empty) (*empty.Empty, error)
	RestoreStatus(context.Context, *empty.Empty) (*RestoreStatusReply, error)
	SnapshotPurge(context.Context, *empty.Empty) (*empty.Empty, error)
	SnapshotPurgeStatus(context.Context, *empty.Empty) (*SnapshotPurgeStatusReply, error)
	ReplicaRebuildStatus(context.Context, *empty.Empty) (*ReplicaRebuildStatusReply, error)
}

SyncAgentServiceServer is the server API for SyncAgentService service.

type SyncFileInfo 

type SyncFileInfo struct {
	FromFileName         string   `protobuf:"bytes,1,opt,name=from_file_name,json=fromFileName,proto3" json:"from_file_name,omitempty"`
	ToFileName           string   `protobuf:"bytes,2,opt,name=to_file_name,json=toFileName,proto3" json:"to_file_name,omitempty"`
	ActualSize           int64    `protobuf:"varint,3,opt,name=actual_size,json=actualSize,proto3" json:"actual_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncFileInfo) Descriptor 

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

func (*SyncFileInfo) GetActualSize 

func (m *SyncFileInfo) GetActualSize() int64

func (*SyncFileInfo) GetFromFileName 

func (m *SyncFileInfo) GetFromFileName() string

func (*SyncFileInfo) GetToFileName 

func (m *SyncFileInfo) GetToFileName() string

func (*SyncFileInfo) ProtoMessage 

func (*SyncFileInfo) ProtoMessage()

func (*SyncFileInfo) Reset 

func (m *SyncFileInfo) Reset()

func (*SyncFileInfo) String 

func (m *SyncFileInfo) String() string

func (*SyncFileInfo) XXX_DiscardUnknown 

func (m *SyncFileInfo) XXX_DiscardUnknown()

func (*SyncFileInfo) XXX_Marshal 

func (m *SyncFileInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncFileInfo) XXX_Merge 

func (m *SyncFileInfo) XXX_Merge(src proto.Message)

func (*SyncFileInfo) XXX_Size 

func (m *SyncFileInfo) XXX_Size() int

func (*SyncFileInfo) XXX_Unmarshal 

func (m *SyncFileInfo) XXX_Unmarshal(b []byte) error

type UnimplementedControllerServiceServer 

type UnimplementedControllerServiceServer struct {
}

UnimplementedControllerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServiceServer) BackupReplicaMappingCreate 

func (*UnimplementedControllerServiceServer) BackupReplicaMappingCreate(ctx context.Context, req *BackupReplicaMapping) (*empty.Empty, error)

func (*UnimplementedControllerServiceServer) BackupReplicaMappingDelete 

func (*UnimplementedControllerServiceServer) BackupReplicaMappingDelete(ctx context.Context, req *BackupReplicaMappingDeleteRequest) (*empty.Empty, error)

func (*UnimplementedControllerServiceServer) BackupReplicaMappingGet 

func (*UnimplementedControllerServiceServer) BackupReplicaMappingGet(ctx context.Context, req *empty.Empty) (*BackupReplicaMap, error)

func (*UnimplementedControllerServiceServer) JournalList 

func (*UnimplementedControllerServiceServer) JournalList(ctx context.Context, req *JournalListRequest) (*empty.Empty, error)

func (*UnimplementedControllerServiceServer) MetricGet 

func (*UnimplementedControllerServiceServer) MetricGet(req *empty.Empty, srv ControllerService_MetricGetServer) error

func (*UnimplementedControllerServiceServer) ReplicaCreate 

func (*UnimplementedControllerServiceServer) ReplicaCreate(ctx context.Context, req *ReplicaAddress) (*ControllerReplica, error)

func (*UnimplementedControllerServiceServer) ReplicaDelete 

func (*UnimplementedControllerServiceServer) ReplicaDelete(ctx context.Context, req *ReplicaAddress) (*empty.Empty, error)

func (*UnimplementedControllerServiceServer) ReplicaGet 

func (*UnimplementedControllerServiceServer) ReplicaGet(ctx context.Context, req *ReplicaAddress) (*ControllerReplica, error)

func (*UnimplementedControllerServiceServer) ReplicaList 

func (*UnimplementedControllerServiceServer) ReplicaList(ctx context.Context, req *empty.Empty) (*ReplicaListReply, error)

func (*UnimplementedControllerServiceServer) ReplicaPrepareRebuild 

func (*UnimplementedControllerServiceServer) ReplicaPrepareRebuild(ctx context.Context, req *ReplicaAddress) (*ReplicaPrepareRebuildReply, error)

func (*UnimplementedControllerServiceServer) ReplicaUpdate 

func (*UnimplementedControllerServiceServer) ReplicaUpdate(ctx context.Context, req *ControllerReplica) (*ControllerReplica, error)

func (*UnimplementedControllerServiceServer) ReplicaVerifyRebuild 

func (*UnimplementedControllerServiceServer) ReplicaVerifyRebuild(ctx context.Context, req *ReplicaAddress) (*ControllerReplica, error)

func (*UnimplementedControllerServiceServer) VersionDetailGet 

func (*UnimplementedControllerServiceServer) VersionDetailGet(ctx context.Context, req *empty.Empty) (*VersionDetailGetReply, error)

func (*UnimplementedControllerServiceServer) VolumeExpand 

func (*UnimplementedControllerServiceServer) VolumeExpand(ctx context.Context, req *VolumeExpandRequest) (*Volume, error)

func (*UnimplementedControllerServiceServer) VolumeFrontendShutdown 

func (*UnimplementedControllerServiceServer) VolumeFrontendShutdown(ctx context.Context, req *empty.Empty) (*Volume, error)

func (*UnimplementedControllerServiceServer) VolumeFrontendStart 

func (*UnimplementedControllerServiceServer) VolumeFrontendStart(ctx context.Context, req *VolumeFrontendStartRequest) (*Volume, error)

func (*UnimplementedControllerServiceServer) VolumeGet 

func (*UnimplementedControllerServiceServer) VolumeGet(ctx context.Context, req *empty.Empty) (*Volume, error)

func (*UnimplementedControllerServiceServer) VolumeRevert 

func (*UnimplementedControllerServiceServer) VolumeRevert(ctx context.Context, req *VolumeRevertRequest) (*Volume, error)

func (*UnimplementedControllerServiceServer) VolumeShutdown 

func (*UnimplementedControllerServiceServer) VolumeShutdown(ctx context.Context, req *empty.Empty) (*Volume, error)

func (*UnimplementedControllerServiceServer) VolumeSnapshot 

func (*UnimplementedControllerServiceServer) VolumeSnapshot(ctx context.Context, req *VolumeSnapshotRequest) (*VolumeSnapshotReply, error)

func (*UnimplementedControllerServiceServer) VolumeStart 

func (*UnimplementedControllerServiceServer) VolumeStart(ctx context.Context, req *VolumeStartRequest) (*Volume, error)

type UnimplementedReplicaServiceServer 

type UnimplementedReplicaServiceServer struct {
}

UnimplementedReplicaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicaServiceServer) DiskMarkAsRemoved 

func (*UnimplementedReplicaServiceServer) DiskMarkAsRemoved(ctx context.Context, req *DiskMarkAsRemovedRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) DiskPrepareRemove 

func (*UnimplementedReplicaServiceServer) DiskPrepareRemove(ctx context.Context, req *DiskPrepareRemoveRequest) (*DiskPrepareRemoveReply, error)

func (*UnimplementedReplicaServiceServer) DiskRemove 

func (*UnimplementedReplicaServiceServer) DiskRemove(ctx context.Context, req *DiskRemoveRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) DiskReplace 

func (*UnimplementedReplicaServiceServer) DiskReplace(ctx context.Context, req *DiskReplaceRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) RebuildingSet 

func (*UnimplementedReplicaServiceServer) RebuildingSet(ctx context.Context, req *RebuildingSetRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaClose 

func (*UnimplementedReplicaServiceServer) ReplicaClose(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaCreate 

func (*UnimplementedReplicaServiceServer) ReplicaCreate(ctx context.Context, req *ReplicaCreateRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaDelete 

func (*UnimplementedReplicaServiceServer) ReplicaDelete(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedReplicaServiceServer) ReplicaExpand 

func (*UnimplementedReplicaServiceServer) ReplicaExpand(ctx context.Context, req *ReplicaExpandRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaGet 

func (*UnimplementedReplicaServiceServer) ReplicaGet(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaOpen 

func (*UnimplementedReplicaServiceServer) ReplicaOpen(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaReload 

func (*UnimplementedReplicaServiceServer) ReplicaReload(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaRevert 

func (*UnimplementedReplicaServiceServer) ReplicaRevert(ctx context.Context, req *ReplicaRevertRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaSnapshot 

func (*UnimplementedReplicaServiceServer) ReplicaSnapshot(ctx context.Context, req *ReplicaSnapshotRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) RevisionCounterSet 

func (*UnimplementedReplicaServiceServer) RevisionCounterSet(ctx context.Context, req *RevisionCounterSetRequest) (*Replica, error)

type UnimplementedSyncAgentServiceServer 

type UnimplementedSyncAgentServiceServer struct {
}

UnimplementedSyncAgentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSyncAgentServiceServer) BackupCreate 

func (*UnimplementedSyncAgentServiceServer) BackupCreate(ctx context.Context, req *BackupCreateRequest) (*BackupCreateReply, error)

func (*UnimplementedSyncAgentServiceServer) BackupGetStatus 

func (*UnimplementedSyncAgentServiceServer) BackupGetStatus(ctx context.Context, req *BackupProgressRequest) (*BackupStatusReply, error)

func (*UnimplementedSyncAgentServiceServer) BackupRemove 

func (*UnimplementedSyncAgentServiceServer) BackupRemove(ctx context.Context, req *BackupRemoveRequest) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) BackupRestore 

func (*UnimplementedSyncAgentServiceServer) BackupRestore(ctx context.Context, req *BackupRestoreRequest) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) BackupRestoreIncrementally 

func (*UnimplementedSyncAgentServiceServer) BackupRestoreIncrementally(ctx context.Context, req *BackupRestoreIncrementallyRequest) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) FileRemove 

func (*UnimplementedSyncAgentServiceServer) FileRemove(ctx context.Context, req *FileRemoveRequest) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) FileRename 

func (*UnimplementedSyncAgentServiceServer) FileRename(ctx context.Context, req *FileRenameRequest) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) FileSend 

func (*UnimplementedSyncAgentServiceServer) FileSend(ctx context.Context, req *FileSendRequest) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) FilesSync 

func (*UnimplementedSyncAgentServiceServer) FilesSync(ctx context.Context, req *FilesSyncRequest) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) ReceiverLaunch 

func (*UnimplementedSyncAgentServiceServer) ReceiverLaunch(ctx context.Context, req *ReceiverLaunchRequest) (*ReceiverLaunchReply, error)

func (*UnimplementedSyncAgentServiceServer) ReplicaRebuildStatus 

func (*UnimplementedSyncAgentServiceServer) ReplicaRebuildStatus(ctx context.Context, req *empty.Empty) (*ReplicaRebuildStatusReply, error)

func (*UnimplementedSyncAgentServiceServer) Reset 

func (*UnimplementedSyncAgentServiceServer) Reset(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) RestoreStatus 

func (*UnimplementedSyncAgentServiceServer) RestoreStatus(ctx context.Context, req *empty.Empty) (*RestoreStatusReply, error)

func (*UnimplementedSyncAgentServiceServer) SnapshotPurge 

func (*UnimplementedSyncAgentServiceServer) SnapshotPurge(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedSyncAgentServiceServer) SnapshotPurgeStatus 

func (*UnimplementedSyncAgentServiceServer) SnapshotPurgeStatus(ctx context.Context, req *empty.Empty) (*SnapshotPurgeStatusReply, error)

type VersionDetailGetReply 

type VersionDetailGetReply struct {
	Version              *VersionOutput `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*VersionDetailGetReply) Descriptor 

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

func (*VersionDetailGetReply) GetVersion 

func (m *VersionDetailGetReply) GetVersion() *VersionOutput

func (*VersionDetailGetReply) ProtoMessage 

func (*VersionDetailGetReply) ProtoMessage()

func (*VersionDetailGetReply) Reset 

func (m *VersionDetailGetReply) Reset()

func (*VersionDetailGetReply) String 

func (m *VersionDetailGetReply) String() string

func (*VersionDetailGetReply) XXX_DiscardUnknown 

func (m *VersionDetailGetReply) XXX_DiscardUnknown()

func (*VersionDetailGetReply) XXX_Marshal 

func (m *VersionDetailGetReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionDetailGetReply) XXX_Merge 

func (m *VersionDetailGetReply) XXX_Merge(src proto.Message)

func (*VersionDetailGetReply) XXX_Size 

func (m *VersionDetailGetReply) XXX_Size() int

func (*VersionDetailGetReply) XXX_Unmarshal 

func (m *VersionDetailGetReply) XXX_Unmarshal(b []byte) error

type VersionOutput 

type VersionOutput struct {
	Version                 string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	GitCommit               string   `protobuf:"bytes,2,opt,name=gitCommit,proto3" json:"gitCommit,omitempty"`
	BuildDate               string   `protobuf:"bytes,3,opt,name=buildDate,proto3" json:"buildDate,omitempty"`
	CliAPIVersion           int64    `protobuf:"varint,4,opt,name=cliAPIVersion,proto3" json:"cliAPIVersion,omitempty"`
	CliAPIMinVersion        int64    `protobuf:"varint,5,opt,name=cliAPIMinVersion,proto3" json:"cliAPIMinVersion,omitempty"`
	ControllerAPIVersion    int64    `protobuf:"varint,6,opt,name=controllerAPIVersion,proto3" json:"controllerAPIVersion,omitempty"`
	ControllerAPIMinVersion int64    `protobuf:"varint,7,opt,name=controllerAPIMinVersion,proto3" json:"controllerAPIMinVersion,omitempty"`
	DataFormatVersion       int64    `protobuf:"varint,8,opt,name=dataFormatVersion,proto3" json:"dataFormatVersion,omitempty"`
	DataFormatMinVersion    int64    `protobuf:"varint,9,opt,name=dataFormatMinVersion,proto3" json:"dataFormatMinVersion,omitempty"`
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

func (*VersionOutput) Descriptor 

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

func (*VersionOutput) GetBuildDate 

func (m *VersionOutput) GetBuildDate() string

func (*VersionOutput) GetCliAPIMinVersion 

func (m *VersionOutput) GetCliAPIMinVersion() int64

func (*VersionOutput) GetCliAPIVersion 

func (m *VersionOutput) GetCliAPIVersion() int64

func (*VersionOutput) GetControllerAPIMinVersion 

func (m *VersionOutput) GetControllerAPIMinVersion() int64

func (*VersionOutput) GetControllerAPIVersion 

func (m *VersionOutput) GetControllerAPIVersion() int64

func (*VersionOutput) GetDataFormatMinVersion 

func (m *VersionOutput) GetDataFormatMinVersion() int64

func (*VersionOutput) GetDataFormatVersion 

func (m *VersionOutput) GetDataFormatVersion() int64

func (*VersionOutput) GetGitCommit 

func (m *VersionOutput) GetGitCommit() string

func (*VersionOutput) GetVersion 

func (m *VersionOutput) GetVersion() string

func (*VersionOutput) ProtoMessage 

func (*VersionOutput) ProtoMessage()

func (*VersionOutput) Reset 

func (m *VersionOutput) Reset()

func (*VersionOutput) String 

func (m *VersionOutput) String() string

func (*VersionOutput) XXX_DiscardUnknown 

func (m *VersionOutput) XXX_DiscardUnknown()

func (*VersionOutput) XXX_Marshal 

func (m *VersionOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionOutput) XXX_Merge 

func (m *VersionOutput) XXX_Merge(src proto.Message)

func (*VersionOutput) XXX_Size 

func (m *VersionOutput) XXX_Size() int

func (*VersionOutput) XXX_Unmarshal 

func (m *VersionOutput) XXX_Unmarshal(b []byte) error

type Volume 

type Volume struct {
	Name                  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size                  int64    `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	ReplicaCount          int32    `protobuf:"varint,3,opt,name=replicaCount,proto3" json:"replicaCount,omitempty"`
	Endpoint              string   `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Frontend              string   `protobuf:"bytes,5,opt,name=frontend,proto3" json:"frontend,omitempty"`
	FrontendState         string   `protobuf:"bytes,6,opt,name=frontendState,proto3" json:"frontendState,omitempty"`
	IsExpanding           bool     `protobuf:"varint,7,opt,name=isExpanding,proto3" json:"isExpanding,omitempty"`
	LastExpansionError    string   `protobuf:"bytes,8,opt,name=last_expansion_error,json=lastExpansionError,proto3" json:"last_expansion_error,omitempty"`
	LastExpansionFailedAt string   `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*Volume) Descriptor 

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

func (*Volume) GetEndpoint 

func (m *Volume) GetEndpoint() string

func (*Volume) GetFrontend 

func (m *Volume) GetFrontend() string

func (*Volume) GetFrontendState 

func (m *Volume) GetFrontendState() string

func (*Volume) GetIsExpanding 

func (m *Volume) GetIsExpanding() bool

func (*Volume) GetLastExpansionError added in v0.8.1 

func (m *Volume) GetLastExpansionError() string

func (*Volume) GetLastExpansionFailedAt added in v0.8.1 

func (m *Volume) GetLastExpansionFailedAt() string

func (*Volume) GetName 

func (m *Volume) GetName() string

func (*Volume) GetReplicaCount 

func (m *Volume) GetReplicaCount() int32

func (*Volume) GetSize 

func (m *Volume) GetSize() int64

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) String 

func (m *Volume) String() string

func (*Volume) XXX_DiscardUnknown 

func (m *Volume) XXX_DiscardUnknown()

func (*Volume) XXX_Marshal 

func (m *Volume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Volume) XXX_Merge 

func (m *Volume) XXX_Merge(src proto.Message)

func (*Volume) XXX_Size 

func (m *Volume) XXX_Size() int

func (*Volume) XXX_Unmarshal 

func (m *Volume) XXX_Unmarshal(b []byte) error

type VolumeExpandRequest 

type VolumeExpandRequest struct {
	Size                 int64    `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeExpandRequest) Descriptor 

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

func (*VolumeExpandRequest) GetSize 

func (m *VolumeExpandRequest) GetSize() int64

func (*VolumeExpandRequest) ProtoMessage 

func (*VolumeExpandRequest) ProtoMessage()

func (*VolumeExpandRequest) Reset 

func (m *VolumeExpandRequest) Reset()

func (*VolumeExpandRequest) String 

func (m *VolumeExpandRequest) String() string

func (*VolumeExpandRequest) XXX_DiscardUnknown 

func (m *VolumeExpandRequest) XXX_DiscardUnknown()

func (*VolumeExpandRequest) XXX_Marshal 

func (m *VolumeExpandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeExpandRequest) XXX_Merge 

func (m *VolumeExpandRequest) XXX_Merge(src proto.Message)

func (*VolumeExpandRequest) XXX_Size 

func (m *VolumeExpandRequest) XXX_Size() int

func (*VolumeExpandRequest) XXX_Unmarshal 

func (m *VolumeExpandRequest) XXX_Unmarshal(b []byte) error

type VolumeFinishRestoreRequest 

type VolumeFinishRestoreRequest struct {
	CurrentRestored      string   `protobuf:"bytes,1,opt,name=currentRestored,proto3" json:"currentRestored,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeFinishRestoreRequest) Descriptor 

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

func (*VolumeFinishRestoreRequest) GetCurrentRestored 

func (m *VolumeFinishRestoreRequest) GetCurrentRestored() string

func (*VolumeFinishRestoreRequest) ProtoMessage 

func (*VolumeFinishRestoreRequest) ProtoMessage()

func (*VolumeFinishRestoreRequest) Reset 

func (m *VolumeFinishRestoreRequest) Reset()

func (*VolumeFinishRestoreRequest) String 

func (m *VolumeFinishRestoreRequest) String() string

func (*VolumeFinishRestoreRequest) XXX_DiscardUnknown 

func (m *VolumeFinishRestoreRequest) XXX_DiscardUnknown()

func (*VolumeFinishRestoreRequest) XXX_Marshal 

func (m *VolumeFinishRestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeFinishRestoreRequest) XXX_Merge 

func (m *VolumeFinishRestoreRequest) XXX_Merge(src proto.Message)

func (*VolumeFinishRestoreRequest) XXX_Size 

func (m *VolumeFinishRestoreRequest) XXX_Size() int

func (*VolumeFinishRestoreRequest) XXX_Unmarshal 

func (m *VolumeFinishRestoreRequest) XXX_Unmarshal(b []byte) error

type VolumeFrontendStartRequest 

type VolumeFrontendStartRequest struct {
	Frontend             string   `protobuf:"bytes,1,opt,name=frontend,proto3" json:"frontend,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeFrontendStartRequest) Descriptor 

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

func (*VolumeFrontendStartRequest) GetFrontend 

func (m *VolumeFrontendStartRequest) GetFrontend() string

func (*VolumeFrontendStartRequest) ProtoMessage 

func (*VolumeFrontendStartRequest) ProtoMessage()

func (*VolumeFrontendStartRequest) Reset 

func (m *VolumeFrontendStartRequest) Reset()

func (*VolumeFrontendStartRequest) String 

func (m *VolumeFrontendStartRequest) String() string

func (*VolumeFrontendStartRequest) XXX_DiscardUnknown 

func (m *VolumeFrontendStartRequest) XXX_DiscardUnknown()

func (*VolumeFrontendStartRequest) XXX_Marshal 

func (m *VolumeFrontendStartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeFrontendStartRequest) XXX_Merge 

func (m *VolumeFrontendStartRequest) XXX_Merge(src proto.Message)

func (*VolumeFrontendStartRequest) XXX_Size 

func (m *VolumeFrontendStartRequest) XXX_Size() int

func (*VolumeFrontendStartRequest) XXX_Unmarshal 

func (m *VolumeFrontendStartRequest) XXX_Unmarshal(b []byte) error

type VolumePrepareRestoreRequest 

type VolumePrepareRestoreRequest struct {
	LastRestored         string   `protobuf:"bytes,1,opt,name=lastRestored,proto3" json:"lastRestored,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumePrepareRestoreRequest) Descriptor 

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

func (*VolumePrepareRestoreRequest) GetLastRestored 

func (m *VolumePrepareRestoreRequest) GetLastRestored() string

func (*VolumePrepareRestoreRequest) ProtoMessage 

func (*VolumePrepareRestoreRequest) ProtoMessage()

func (*VolumePrepareRestoreRequest) Reset 

func (m *VolumePrepareRestoreRequest) Reset()

func (*VolumePrepareRestoreRequest) String 

func (m *VolumePrepareRestoreRequest) String() string

func (*VolumePrepareRestoreRequest) XXX_DiscardUnknown 

func (m *VolumePrepareRestoreRequest) XXX_DiscardUnknown()

func (*VolumePrepareRestoreRequest) XXX_Marshal 

func (m *VolumePrepareRestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumePrepareRestoreRequest) XXX_Merge 

func (m *VolumePrepareRestoreRequest) XXX_Merge(src proto.Message)

func (*VolumePrepareRestoreRequest) XXX_Size 

func (m *VolumePrepareRestoreRequest) XXX_Size() int

func (*VolumePrepareRestoreRequest) XXX_Unmarshal 

func (m *VolumePrepareRestoreRequest) XXX_Unmarshal(b []byte) error

type VolumeRevertRequest 

type VolumeRevertRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeRevertRequest) Descriptor 

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

func (*VolumeRevertRequest) GetName 

func (m *VolumeRevertRequest) GetName() string

func (*VolumeRevertRequest) ProtoMessage 

func (*VolumeRevertRequest) ProtoMessage()

func (*VolumeRevertRequest) Reset 

func (m *VolumeRevertRequest) Reset()

func (*VolumeRevertRequest) String 

func (m *VolumeRevertRequest) String() string

func (*VolumeRevertRequest) XXX_DiscardUnknown 

func (m *VolumeRevertRequest) XXX_DiscardUnknown()

func (*VolumeRevertRequest) XXX_Marshal 

func (m *VolumeRevertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeRevertRequest) XXX_Merge 

func (m *VolumeRevertRequest) XXX_Merge(src proto.Message)

func (*VolumeRevertRequest) XXX_Size 

func (m *VolumeRevertRequest) XXX_Size() int

func (*VolumeRevertRequest) XXX_Unmarshal 

func (m *VolumeRevertRequest) XXX_Unmarshal(b []byte) error

type VolumeSnapshotReply 

type VolumeSnapshotReply struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeSnapshotReply) Descriptor 

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

func (*VolumeSnapshotReply) GetName 

func (m *VolumeSnapshotReply) GetName() string

func (*VolumeSnapshotReply) ProtoMessage 

func (*VolumeSnapshotReply) ProtoMessage()

func (*VolumeSnapshotReply) Reset 

func (m *VolumeSnapshotReply) Reset()

func (*VolumeSnapshotReply) String 

func (m *VolumeSnapshotReply) String() string

func (*VolumeSnapshotReply) XXX_DiscardUnknown 

func (m *VolumeSnapshotReply) XXX_DiscardUnknown()

func (*VolumeSnapshotReply) XXX_Marshal 

func (m *VolumeSnapshotReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeSnapshotReply) XXX_Merge 

func (m *VolumeSnapshotReply) XXX_Merge(src proto.Message)

func (*VolumeSnapshotReply) XXX_Size 

func (m *VolumeSnapshotReply) XXX_Size() int

func (*VolumeSnapshotReply) XXX_Unmarshal 

func (m *VolumeSnapshotReply) XXX_Unmarshal(b []byte) error

type VolumeSnapshotRequest 

type VolumeSnapshotRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*VolumeSnapshotRequest) Descriptor 

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

func (*VolumeSnapshotRequest) GetLabels 

func (m *VolumeSnapshotRequest) GetLabels() map[string]string

func (*VolumeSnapshotRequest) GetName 

func (m *VolumeSnapshotRequest) GetName() string

func (*VolumeSnapshotRequest) ProtoMessage 

func (*VolumeSnapshotRequest) ProtoMessage()

func (*VolumeSnapshotRequest) Reset 

func (m *VolumeSnapshotRequest) Reset()

func (*VolumeSnapshotRequest) String 

func (m *VolumeSnapshotRequest) String() string

func (*VolumeSnapshotRequest) XXX_DiscardUnknown 

func (m *VolumeSnapshotRequest) XXX_DiscardUnknown()

func (*VolumeSnapshotRequest) XXX_Marshal 

func (m *VolumeSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeSnapshotRequest) XXX_Merge 

func (m *VolumeSnapshotRequest) XXX_Merge(src proto.Message)

func (*VolumeSnapshotRequest) XXX_Size 

func (m *VolumeSnapshotRequest) XXX_Size() int

func (*VolumeSnapshotRequest) XXX_Unmarshal 

func (m *VolumeSnapshotRequest) XXX_Unmarshal(b []byte) error

type VolumeStartRequest 

type VolumeStartRequest struct {
	ReplicaAddresses     []string `protobuf:"bytes,1,rep,name=replicaAddresses,proto3" json:"replicaAddresses,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeStartRequest) Descriptor 

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

func (*VolumeStartRequest) GetReplicaAddresses 

func (m *VolumeStartRequest) GetReplicaAddresses() []string

func (*VolumeStartRequest) ProtoMessage 

func (*VolumeStartRequest) ProtoMessage()

func (*VolumeStartRequest) Reset 

func (m *VolumeStartRequest) Reset()

func (*VolumeStartRequest) String 

func (m *VolumeStartRequest) String() string

func (*VolumeStartRequest) XXX_DiscardUnknown 

func (m *VolumeStartRequest) XXX_DiscardUnknown()

func (*VolumeStartRequest) XXX_Marshal 

func (m *VolumeStartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeStartRequest) XXX_Merge 

func (m *VolumeStartRequest) XXX_Merge(src proto.Message)

func (*VolumeStartRequest) XXX_Size 

func (m *VolumeStartRequest) XXX_Size() int

func (*VolumeStartRequest) XXX_Unmarshal 

func (m *VolumeStartRequest) XXX_Unmarshal(b []byte) error

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.