enginerpc

package
v0.0.0-...-2e0ecb4 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2024 License: Apache-2.0 Imports: 9 Imported by: 11

Documentation

Index

Constants

View Source 
const (
	ControllerService_VolumeGet_FullMethodName                          = "/ptypes.ControllerService/VolumeGet"
	ControllerService_VolumeStart_FullMethodName                        = "/ptypes.ControllerService/VolumeStart"
	ControllerService_VolumeShutdown_FullMethodName                     = "/ptypes.ControllerService/VolumeShutdown"
	ControllerService_VolumeSnapshot_FullMethodName                     = "/ptypes.ControllerService/VolumeSnapshot"
	ControllerService_VolumeRevert_FullMethodName                       = "/ptypes.ControllerService/VolumeRevert"
	ControllerService_VolumeExpand_FullMethodName                       = "/ptypes.ControllerService/VolumeExpand"
	ControllerService_VolumeFrontendStart_FullMethodName                = "/ptypes.ControllerService/VolumeFrontendStart"
	ControllerService_VolumeFrontendShutdown_FullMethodName             = "/ptypes.ControllerService/VolumeFrontendShutdown"
	ControllerService_VolumeUnmapMarkSnapChainRemovedSet_FullMethodName = "/ptypes.ControllerService/VolumeUnmapMarkSnapChainRemovedSet"
	ControllerService_VolumeSnapshotMaxCountSet_FullMethodName          = "/ptypes.ControllerService/VolumeSnapshotMaxCountSet"
	ControllerService_VolumeSnapshotMaxSizeSet_FullMethodName           = "/ptypes.ControllerService/VolumeSnapshotMaxSizeSet"
	ControllerService_ReplicaList_FullMethodName                        = "/ptypes.ControllerService/ReplicaList"
	ControllerService_ReplicaGet_FullMethodName                         = "/ptypes.ControllerService/ReplicaGet"
	ControllerService_ControllerReplicaCreate_FullMethodName            = "/ptypes.ControllerService/ControllerReplicaCreate"
	ControllerService_ReplicaDelete_FullMethodName                      = "/ptypes.ControllerService/ReplicaDelete"
	ControllerService_ReplicaUpdate_FullMethodName                      = "/ptypes.ControllerService/ReplicaUpdate"
	ControllerService_ReplicaPrepareRebuild_FullMethodName              = "/ptypes.ControllerService/ReplicaPrepareRebuild"
	ControllerService_ReplicaVerifyRebuild_FullMethodName               = "/ptypes.ControllerService/ReplicaVerifyRebuild"
	ControllerService_JournalList_FullMethodName                        = "/ptypes.ControllerService/JournalList"
	ControllerService_VersionDetailGet_FullMethodName                   = "/ptypes.ControllerService/VersionDetailGet"
	ControllerService_MetricsGet_FullMethodName                         = "/ptypes.ControllerService/MetricsGet"
)
View Source 
const (
	ReplicaService_ReplicaCreate_FullMethodName                = "/ptypes.ReplicaService/ReplicaCreate"
	ReplicaService_ReplicaDelete_FullMethodName                = "/ptypes.ReplicaService/ReplicaDelete"
	ReplicaService_ReplicaGet_FullMethodName                   = "/ptypes.ReplicaService/ReplicaGet"
	ReplicaService_ReplicaOpen_FullMethodName                  = "/ptypes.ReplicaService/ReplicaOpen"
	ReplicaService_ReplicaClose_FullMethodName                 = "/ptypes.ReplicaService/ReplicaClose"
	ReplicaService_ReplicaReload_FullMethodName                = "/ptypes.ReplicaService/ReplicaReload"
	ReplicaService_ReplicaRevert_FullMethodName                = "/ptypes.ReplicaService/ReplicaRevert"
	ReplicaService_ReplicaSnapshot_FullMethodName              = "/ptypes.ReplicaService/ReplicaSnapshot"
	ReplicaService_ReplicaExpand_FullMethodName                = "/ptypes.ReplicaService/ReplicaExpand"
	ReplicaService_DiskRemove_FullMethodName                   = "/ptypes.ReplicaService/DiskRemove"
	ReplicaService_DiskReplace_FullMethodName                  = "/ptypes.ReplicaService/DiskReplace"
	ReplicaService_DiskPrepareRemove_FullMethodName            = "/ptypes.ReplicaService/DiskPrepareRemove"
	ReplicaService_DiskMarkAsRemoved_FullMethodName            = "/ptypes.ReplicaService/DiskMarkAsRemoved"
	ReplicaService_RebuildingSet_FullMethodName                = "/ptypes.ReplicaService/RebuildingSet"
	ReplicaService_RevisionCounterSet_FullMethodName           = "/ptypes.ReplicaService/RevisionCounterSet"
	ReplicaService_UnmapMarkDiskChainRemovedSet_FullMethodName = "/ptypes.ReplicaService/UnmapMarkDiskChainRemovedSet"
	ReplicaService_SnapshotMaxCountSet_FullMethodName          = "/ptypes.ReplicaService/SnapshotMaxCountSet"
	ReplicaService_SnapshotMaxSizeSet_FullMethodName           = "/ptypes.ReplicaService/SnapshotMaxSizeSet"
)
View Source 
const (
	SyncAgentService_FileRemove_FullMethodName            = "/ptypes.SyncAgentService/FileRemove"
	SyncAgentService_FileRename_FullMethodName            = "/ptypes.SyncAgentService/FileRename"
	SyncAgentService_FileSend_FullMethodName              = "/ptypes.SyncAgentService/FileSend"
	SyncAgentService_FilesSync_FullMethodName             = "/ptypes.SyncAgentService/FilesSync"
	SyncAgentService_SnapshotClone_FullMethodName         = "/ptypes.SyncAgentService/SnapshotClone"
	SyncAgentService_VolumeExport_FullMethodName          = "/ptypes.SyncAgentService/VolumeExport"
	SyncAgentService_ReceiverLaunch_FullMethodName        = "/ptypes.SyncAgentService/ReceiverLaunch"
	SyncAgentService_BackupCreate_FullMethodName          = "/ptypes.SyncAgentService/BackupCreate"
	SyncAgentService_BackupRemove_FullMethodName          = "/ptypes.SyncAgentService/BackupRemove"
	SyncAgentService_BackupRestore_FullMethodName         = "/ptypes.SyncAgentService/BackupRestore"
	SyncAgentService_BackupStatus_FullMethodName          = "/ptypes.SyncAgentService/BackupStatus"
	SyncAgentService_Reset_FullMethodName                 = "/ptypes.SyncAgentService/Reset"
	SyncAgentService_RestoreStatus_FullMethodName         = "/ptypes.SyncAgentService/RestoreStatus"
	SyncAgentService_SnapshotPurge_FullMethodName         = "/ptypes.SyncAgentService/SnapshotPurge"
	SyncAgentService_SnapshotPurgeStatus_FullMethodName   = "/ptypes.SyncAgentService/SnapshotPurgeStatus"
	SyncAgentService_ReplicaRebuildStatus_FullMethodName  = "/ptypes.SyncAgentService/ReplicaRebuildStatus"
	SyncAgentService_SnapshotCloneStatus_FullMethodName   = "/ptypes.SyncAgentService/SnapshotCloneStatus"
	SyncAgentService_SnapshotHash_FullMethodName          = "/ptypes.SyncAgentService/SnapshotHash"
	SyncAgentService_SnapshotHashStatus_FullMethodName    = "/ptypes.SyncAgentService/SnapshotHashStatus"
	SyncAgentService_SnapshotHashCancel_FullMethodName    = "/ptypes.SyncAgentService/SnapshotHashCancel"
	SyncAgentService_SnapshotHashLockState_FullMethodName = "/ptypes.SyncAgentService/SnapshotHashLockState"
)

Variables

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

Enum value maps for ReplicaMode.

View Source 
var ControllerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ptypes.ControllerService",
	HandlerType: (*ControllerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "VolumeGet",
			Handler:    _ControllerService_VolumeGet_Handler,
		},
		{
			MethodName: "VolumeStart",
			Handler:    _ControllerService_VolumeStart_Handler,
		},
		{
			MethodName: "VolumeShutdown",
			Handler:    _ControllerService_VolumeShutdown_Handler,
		},
		{
			MethodName: "VolumeSnapshot",
			Handler:    _ControllerService_VolumeSnapshot_Handler,
		},
		{
			MethodName: "VolumeRevert",
			Handler:    _ControllerService_VolumeRevert_Handler,
		},
		{
			MethodName: "VolumeExpand",
			Handler:    _ControllerService_VolumeExpand_Handler,
		},
		{
			MethodName: "VolumeFrontendStart",
			Handler:    _ControllerService_VolumeFrontendStart_Handler,
		},
		{
			MethodName: "VolumeFrontendShutdown",
			Handler:    _ControllerService_VolumeFrontendShutdown_Handler,
		},
		{
			MethodName: "VolumeUnmapMarkSnapChainRemovedSet",
			Handler:    _ControllerService_VolumeUnmapMarkSnapChainRemovedSet_Handler,
		},
		{
			MethodName: "VolumeSnapshotMaxCountSet",
			Handler:    _ControllerService_VolumeSnapshotMaxCountSet_Handler,
		},
		{
			MethodName: "VolumeSnapshotMaxSizeSet",
			Handler:    _ControllerService_VolumeSnapshotMaxSizeSet_Handler,
		},
		{
			MethodName: "ReplicaList",
			Handler:    _ControllerService_ReplicaList_Handler,
		},
		{
			MethodName: "ReplicaGet",
			Handler:    _ControllerService_ReplicaGet_Handler,
		},
		{
			MethodName: "ControllerReplicaCreate",
			Handler:    _ControllerService_ControllerReplicaCreate_Handler,
		},
		{
			MethodName: "ReplicaDelete",
			Handler:    _ControllerService_ReplicaDelete_Handler,
		},
		{
			MethodName: "ReplicaUpdate",
			Handler:    _ControllerService_ReplicaUpdate_Handler,
		},
		{
			MethodName: "ReplicaPrepareRebuild",
			Handler:    _ControllerService_ReplicaPrepareRebuild_Handler,
		},
		{
			MethodName: "ReplicaVerifyRebuild",
			Handler:    _ControllerService_ReplicaVerifyRebuild_Handler,
		},
		{
			MethodName: "JournalList",
			Handler:    _ControllerService_JournalList_Handler,
		},
		{
			MethodName: "VersionDetailGet",
			Handler:    _ControllerService_VersionDetailGet_Handler,
		},
		{
			MethodName: "MetricsGet",
			Handler:    _ControllerService_MetricsGet_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ptypes/controller.proto",
}

ControllerService_ServiceDesc is the grpc.ServiceDesc for ControllerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_ptypes_common_proto protoreflect.FileDescriptor
View Source 
var File_ptypes_controller_proto protoreflect.FileDescriptor
View Source 
var File_ptypes_replica_proto protoreflect.FileDescriptor
View Source 
var File_ptypes_syncagent_proto protoreflect.FileDescriptor
View Source 
var ReplicaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ptypes.ReplicaService",
	HandlerType: (*ReplicaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReplicaCreate",
			Handler:    _ReplicaService_ReplicaCreate_Handler,
		},
		{
			MethodName: "ReplicaDelete",
			Handler:    _ReplicaService_ReplicaDelete_Handler,
		},
		{
			MethodName: "ReplicaGet",
			Handler:    _ReplicaService_ReplicaGet_Handler,
		},
		{
			MethodName: "ReplicaOpen",
			Handler:    _ReplicaService_ReplicaOpen_Handler,
		},
		{
			MethodName: "ReplicaClose",
			Handler:    _ReplicaService_ReplicaClose_Handler,
		},
		{
			MethodName: "ReplicaReload",
			Handler:    _ReplicaService_ReplicaReload_Handler,
		},
		{
			MethodName: "ReplicaRevert",
			Handler:    _ReplicaService_ReplicaRevert_Handler,
		},
		{
			MethodName: "ReplicaSnapshot",
			Handler:    _ReplicaService_ReplicaSnapshot_Handler,
		},
		{
			MethodName: "ReplicaExpand",
			Handler:    _ReplicaService_ReplicaExpand_Handler,
		},
		{
			MethodName: "DiskRemove",
			Handler:    _ReplicaService_DiskRemove_Handler,
		},
		{
			MethodName: "DiskReplace",
			Handler:    _ReplicaService_DiskReplace_Handler,
		},
		{
			MethodName: "DiskPrepareRemove",
			Handler:    _ReplicaService_DiskPrepareRemove_Handler,
		},
		{
			MethodName: "DiskMarkAsRemoved",
			Handler:    _ReplicaService_DiskMarkAsRemoved_Handler,
		},
		{
			MethodName: "RebuildingSet",
			Handler:    _ReplicaService_RebuildingSet_Handler,
		},
		{
			MethodName: "RevisionCounterSet",
			Handler:    _ReplicaService_RevisionCounterSet_Handler,
		},
		{
			MethodName: "UnmapMarkDiskChainRemovedSet",
			Handler:    _ReplicaService_UnmapMarkDiskChainRemovedSet_Handler,
		},
		{
			MethodName: "SnapshotMaxCountSet",
			Handler:    _ReplicaService_SnapshotMaxCountSet_Handler,
		},
		{
			MethodName: "SnapshotMaxSizeSet",
			Handler:    _ReplicaService_SnapshotMaxSizeSet_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ptypes/replica.proto",
}

ReplicaService_ServiceDesc is the grpc.ServiceDesc for ReplicaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var SyncAgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ptypes.SyncAgentService",
	HandlerType: (*SyncAgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FileRemove",
			Handler:    _SyncAgentService_FileRemove_Handler,
		},
		{
			MethodName: "FileRename",
			Handler:    _SyncAgentService_FileRename_Handler,
		},
		{
			MethodName: "FileSend",
			Handler:    _SyncAgentService_FileSend_Handler,
		},
		{
			MethodName: "FilesSync",
			Handler:    _SyncAgentService_FilesSync_Handler,
		},
		{
			MethodName: "SnapshotClone",
			Handler:    _SyncAgentService_SnapshotClone_Handler,
		},
		{
			MethodName: "VolumeExport",
			Handler:    _SyncAgentService_VolumeExport_Handler,
		},
		{
			MethodName: "ReceiverLaunch",
			Handler:    _SyncAgentService_ReceiverLaunch_Handler,
		},
		{
			MethodName: "BackupCreate",
			Handler:    _SyncAgentService_BackupCreate_Handler,
		},
		{
			MethodName: "BackupRemove",
			Handler:    _SyncAgentService_BackupRemove_Handler,
		},
		{
			MethodName: "BackupRestore",
			Handler:    _SyncAgentService_BackupRestore_Handler,
		},
		{
			MethodName: "BackupStatus",
			Handler:    _SyncAgentService_BackupStatus_Handler,
		},
		{
			MethodName: "Reset",
			Handler:    _SyncAgentService_Reset_Handler,
		},
		{
			MethodName: "RestoreStatus",
			Handler:    _SyncAgentService_RestoreStatus_Handler,
		},
		{
			MethodName: "SnapshotPurge",
			Handler:    _SyncAgentService_SnapshotPurge_Handler,
		},
		{
			MethodName: "SnapshotPurgeStatus",
			Handler:    _SyncAgentService_SnapshotPurgeStatus_Handler,
		},
		{
			MethodName: "ReplicaRebuildStatus",
			Handler:    _SyncAgentService_ReplicaRebuildStatus_Handler,
		},
		{
			MethodName: "SnapshotCloneStatus",
			Handler:    _SyncAgentService_SnapshotCloneStatus_Handler,
		},
		{
			MethodName: "SnapshotHash",
			Handler:    _SyncAgentService_SnapshotHash_Handler,
		},
		{
			MethodName: "SnapshotHashStatus",
			Handler:    _SyncAgentService_SnapshotHashStatus_Handler,
		},
		{
			MethodName: "SnapshotHashCancel",
			Handler:    _SyncAgentService_SnapshotHashCancel_Handler,
		},
		{
			MethodName: "SnapshotHashLockState",
			Handler:    _SyncAgentService_SnapshotHashLockState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ptypes/syncagent.proto",
}

SyncAgentService_ServiceDesc is the grpc.ServiceDesc for SyncAgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterControllerServiceServer 

func RegisterControllerServiceServer(s grpc.ServiceRegistrar, srv ControllerServiceServer)

func RegisterReplicaServiceServer 

func RegisterReplicaServiceServer(s grpc.ServiceRegistrar, srv ReplicaServiceServer)

func RegisterSyncAgentServiceServer 

func RegisterSyncAgentServiceServer(s grpc.ServiceRegistrar, srv SyncAgentServiceServer)

Types

type BackupCreateRequest 

type BackupCreateRequest struct {
	SnapshotFileName     string            `protobuf:"bytes,1,opt,name=snapshot_file_name,json=snapshotFileName,proto3" json:"snapshot_file_name,omitempty"`
	BackupTarget         string            `protobuf:"bytes,2,opt,name=backup_target,json=backupTarget,proto3" json:"backup_target,omitempty"`
	VolumeName           string            `protobuf:"bytes,3,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	Labels               []string          `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
	Credential           map[string]string `` /* 161-byte string literal not displayed */
	BackingImageName     string            `protobuf:"bytes,6,opt,name=backing_image_name,json=backingImageName,proto3" json:"backing_image_name,omitempty"`
	BackingImageChecksum string            `protobuf:"bytes,7,opt,name=backing_image_checksum,json=backingImageChecksum,proto3" json:"backing_image_checksum,omitempty"`
	BackupName           string            `protobuf:"bytes,8,opt,name=backup_name,json=backupName,proto3" json:"backup_name,omitempty"`
	CompressionMethod    string            `protobuf:"bytes,9,opt,name=compression_method,json=compressionMethod,proto3" json:"compression_method,omitempty"`
	ConcurrentLimit      int32             `protobuf:"varint,10,opt,name=concurrent_limit,json=concurrentLimit,proto3" json:"concurrent_limit,omitempty"`
	StorageClassName     string            `protobuf:"bytes,11,opt,name=storage_class_name,json=storageClassName,proto3" json:"storage_class_name,omitempty"`
	Parameters           map[string]string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BackupCreateRequest) Descriptor deprecated 

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

Deprecated: Use BackupCreateRequest.ProtoReflect.Descriptor instead.

func (*BackupCreateRequest) GetBackingImageChecksum 

func (x *BackupCreateRequest) GetBackingImageChecksum() string

func (*BackupCreateRequest) GetBackingImageName 

func (x *BackupCreateRequest) GetBackingImageName() string

func (*BackupCreateRequest) GetBackupName 

func (x *BackupCreateRequest) GetBackupName() string

func (*BackupCreateRequest) GetBackupTarget 

func (x *BackupCreateRequest) GetBackupTarget() string

func (*BackupCreateRequest) GetCompressionMethod 

func (x *BackupCreateRequest) GetCompressionMethod() string

func (*BackupCreateRequest) GetConcurrentLimit 

func (x *BackupCreateRequest) GetConcurrentLimit() int32

func (*BackupCreateRequest) GetCredential 

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

func (*BackupCreateRequest) GetLabels 

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

func (*BackupCreateRequest) GetParameters 

func (x *BackupCreateRequest) GetParameters() map[string]string

func (*BackupCreateRequest) GetSnapshotFileName 

func (x *BackupCreateRequest) GetSnapshotFileName() string

func (*BackupCreateRequest) GetStorageClassName 

func (x *BackupCreateRequest) GetStorageClassName() string

func (*BackupCreateRequest) GetVolumeName 

func (x *BackupCreateRequest) GetVolumeName() string

func (*BackupCreateRequest) ProtoMessage 

func (*BackupCreateRequest) ProtoMessage()

func (*BackupCreateRequest) ProtoReflect 

func (x *BackupCreateRequest) ProtoReflect() protoreflect.Message

func (*BackupCreateRequest) Reset 

func (x *BackupCreateRequest) Reset()

func (*BackupCreateRequest) String 

func (x *BackupCreateRequest) String() string

type BackupCreateResponse 

type BackupCreateResponse struct {
	Backup        string `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	IsIncremental bool   `protobuf:"varint,2,opt,name=is_incremental,json=isIncremental,proto3" json:"is_incremental,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupCreateResponse) Descriptor deprecated 

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

Deprecated: Use BackupCreateResponse.ProtoReflect.Descriptor instead.

func (*BackupCreateResponse) GetBackup 

func (x *BackupCreateResponse) GetBackup() string

func (*BackupCreateResponse) GetIsIncremental 

func (x *BackupCreateResponse) GetIsIncremental() bool

func (*BackupCreateResponse) ProtoMessage 

func (*BackupCreateResponse) ProtoMessage()

func (*BackupCreateResponse) ProtoReflect 

func (x *BackupCreateResponse) ProtoReflect() protoreflect.Message

func (*BackupCreateResponse) Reset 

func (x *BackupCreateResponse) Reset()

func (*BackupCreateResponse) String 

func (x *BackupCreateResponse) String() string

type BackupRemoveRequest 

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

func (*BackupRemoveRequest) Descriptor deprecated 

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

Deprecated: Use BackupRemoveRequest.ProtoReflect.Descriptor instead.

func (*BackupRemoveRequest) GetBackup 

func (x *BackupRemoveRequest) GetBackup() string

func (*BackupRemoveRequest) ProtoMessage 

func (*BackupRemoveRequest) ProtoMessage()

func (*BackupRemoveRequest) ProtoReflect 

func (x *BackupRemoveRequest) ProtoReflect() protoreflect.Message

func (*BackupRemoveRequest) Reset 

func (x *BackupRemoveRequest) Reset()

func (*BackupRemoveRequest) String 

func (x *BackupRemoveRequest) String() string

type BackupRestoreIncrementallyRequest 

type BackupRestoreIncrementallyRequest struct {
	Backup                 string            `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	DeltaFileName          string            `protobuf:"bytes,2,opt,name=delta_file_name,json=deltaFileName,proto3" json:"delta_file_name,omitempty"`
	LastRestoredBackupName string            `` /* 131-byte string literal not displayed */
	SnapshotDiskName       string            `protobuf:"bytes,4,opt,name=snapshot_disk_name,json=snapshotDiskName,proto3" json:"snapshot_disk_name,omitempty"`
	Credential             map[string]string `` /* 161-byte string literal not displayed */
	ConcurrentLimit        int32             `protobuf:"varint,6,opt,name=concurrent_limit,json=concurrentLimit,proto3" json:"concurrent_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupRestoreIncrementallyRequest) Descriptor deprecated 

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

Deprecated: Use BackupRestoreIncrementallyRequest.ProtoReflect.Descriptor instead.

func (*BackupRestoreIncrementallyRequest) GetBackup 

func (x *BackupRestoreIncrementallyRequest) GetBackup() string

func (*BackupRestoreIncrementallyRequest) GetConcurrentLimit 

func (x *BackupRestoreIncrementallyRequest) GetConcurrentLimit() int32

func (*BackupRestoreIncrementallyRequest) GetCredential 

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

func (*BackupRestoreIncrementallyRequest) GetDeltaFileName 

func (x *BackupRestoreIncrementallyRequest) GetDeltaFileName() string

func (*BackupRestoreIncrementallyRequest) GetLastRestoredBackupName 

func (x *BackupRestoreIncrementallyRequest) GetLastRestoredBackupName() string

func (*BackupRestoreIncrementallyRequest) GetSnapshotDiskName 

func (x *BackupRestoreIncrementallyRequest) GetSnapshotDiskName() string

func (*BackupRestoreIncrementallyRequest) ProtoMessage 

func (*BackupRestoreIncrementallyRequest) ProtoMessage()

func (*BackupRestoreIncrementallyRequest) ProtoReflect 

func (x *BackupRestoreIncrementallyRequest) ProtoReflect() protoreflect.Message

func (*BackupRestoreIncrementallyRequest) Reset 

func (x *BackupRestoreIncrementallyRequest) Reset()

func (*BackupRestoreIncrementallyRequest) String 

func (x *BackupRestoreIncrementallyRequest) String() string

type BackupRestoreRequest 

type BackupRestoreRequest struct {
	Backup           string            `protobuf:"bytes,1,opt,name=backup,proto3" json:"backup,omitempty"`
	SnapshotDiskName string            `protobuf:"bytes,2,opt,name=snapshot_disk_name,json=snapshotDiskName,proto3" json:"snapshot_disk_name,omitempty"`
	Credential       map[string]string `` /* 161-byte string literal not displayed */
	ConcurrentLimit  int32             `protobuf:"varint,4,opt,name=concurrent_limit,json=concurrentLimit,proto3" json:"concurrent_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupRestoreRequest) Descriptor deprecated 

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

Deprecated: Use BackupRestoreRequest.ProtoReflect.Descriptor instead.

func (*BackupRestoreRequest) GetBackup 

func (x *BackupRestoreRequest) GetBackup() string

func (*BackupRestoreRequest) GetConcurrentLimit 

func (x *BackupRestoreRequest) GetConcurrentLimit() int32

func (*BackupRestoreRequest) GetCredential 

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

func (*BackupRestoreRequest) GetSnapshotDiskName 

func (x *BackupRestoreRequest) GetSnapshotDiskName() string

func (*BackupRestoreRequest) ProtoMessage 

func (*BackupRestoreRequest) ProtoMessage()

func (*BackupRestoreRequest) ProtoReflect 

func (x *BackupRestoreRequest) ProtoReflect() protoreflect.Message

func (*BackupRestoreRequest) Reset 

func (x *BackupRestoreRequest) Reset()

func (*BackupRestoreRequest) String 

func (x *BackupRestoreRequest) String() string

type BackupStatusRequest 

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

func (*BackupStatusRequest) Descriptor deprecated 

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

Deprecated: Use BackupStatusRequest.ProtoReflect.Descriptor instead.

func (*BackupStatusRequest) GetBackup 

func (x *BackupStatusRequest) GetBackup() string

func (*BackupStatusRequest) ProtoMessage 

func (*BackupStatusRequest) ProtoMessage()

func (*BackupStatusRequest) ProtoReflect 

func (x *BackupStatusRequest) ProtoReflect() protoreflect.Message

func (*BackupStatusRequest) Reset 

func (x *BackupStatusRequest) Reset()

func (*BackupStatusRequest) String 

func (x *BackupStatusRequest) String() string

type BackupStatusResponse 

type BackupStatusResponse struct {
	Progress     int32  `protobuf:"varint,1,opt,name=progress,proto3" json:"progress,omitempty"`
	BackupUrl    string `protobuf:"bytes,2,opt,name=backup_url,json=backupUrl,proto3" json:"backup_url,omitempty"`
	Error        string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	SnapshotName string `protobuf:"bytes,4,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	State        string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupStatusResponse) Descriptor deprecated 

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

Deprecated: Use BackupStatusResponse.ProtoReflect.Descriptor instead.

func (*BackupStatusResponse) GetBackupUrl 

func (x *BackupStatusResponse) GetBackupUrl() string

func (*BackupStatusResponse) GetError 

func (x *BackupStatusResponse) GetError() string

func (*BackupStatusResponse) GetProgress 

func (x *BackupStatusResponse) GetProgress() int32

func (*BackupStatusResponse) GetSnapshotName 

func (x *BackupStatusResponse) GetSnapshotName() string

func (*BackupStatusResponse) GetState 

func (x *BackupStatusResponse) GetState() string

func (*BackupStatusResponse) ProtoMessage 

func (*BackupStatusResponse) ProtoMessage()

func (*BackupStatusResponse) ProtoReflect 

func (x *BackupStatusResponse) ProtoReflect() protoreflect.Message

func (*BackupStatusResponse) Reset 

func (x *BackupStatusResponse) Reset()

func (*BackupStatusResponse) String 

func (x *BackupStatusResponse) String() string

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

func (*ControllerReplica) Descriptor deprecated 

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

Deprecated: Use ControllerReplica.ProtoReflect.Descriptor instead.

func (*ControllerReplica) GetAddress 

func (x *ControllerReplica) GetAddress() *ReplicaAddress

func (*ControllerReplica) GetMode 

func (x *ControllerReplica) GetMode() ReplicaMode

func (*ControllerReplica) ProtoMessage 

func (*ControllerReplica) ProtoMessage()

func (*ControllerReplica) ProtoReflect 

func (x *ControllerReplica) ProtoReflect() protoreflect.Message

func (*ControllerReplica) Reset 

func (x *ControllerReplica) Reset()

func (*ControllerReplica) String 

func (x *ControllerReplica) String() string

type ControllerReplicaCreateRequest 

type ControllerReplicaCreateRequest struct {
	Address          string      `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	SnapshotRequired bool        `protobuf:"varint,2,opt,name=snapshot_required,json=snapshotRequired,proto3" json:"snapshot_required,omitempty"`
	Mode             ReplicaMode `protobuf:"varint,3,opt,name=mode,proto3,enum=ptypes.ReplicaMode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*ControllerReplicaCreateRequest) Descriptor deprecated 

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

Deprecated: Use ControllerReplicaCreateRequest.ProtoReflect.Descriptor instead.

func (*ControllerReplicaCreateRequest) GetAddress 

func (x *ControllerReplicaCreateRequest) GetAddress() string

func (*ControllerReplicaCreateRequest) GetMode 

func (x *ControllerReplicaCreateRequest) GetMode() ReplicaMode

func (*ControllerReplicaCreateRequest) GetSnapshotRequired 

func (x *ControllerReplicaCreateRequest) GetSnapshotRequired() bool

func (*ControllerReplicaCreateRequest) ProtoMessage 

func (*ControllerReplicaCreateRequest) ProtoMessage()

func (*ControllerReplicaCreateRequest) ProtoReflect 

func (x *ControllerReplicaCreateRequest) ProtoReflect() protoreflect.Message

func (*ControllerReplicaCreateRequest) Reset 

func (x *ControllerReplicaCreateRequest) Reset()

func (*ControllerReplicaCreateRequest) String 

func (x *ControllerReplicaCreateRequest) String() string

type ControllerServiceClient 

type ControllerServiceClient interface {
	VolumeGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Volume, error)
	VolumeStart(ctx context.Context, in *VolumeStartRequest, opts ...grpc.CallOption) (*Volume, error)
	VolumeShutdown(ctx context.Context, in *emptypb.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 *emptypb.Empty, opts ...grpc.CallOption) (*Volume, error)
	VolumeUnmapMarkSnapChainRemovedSet(ctx context.Context, in *VolumeUnmapMarkSnapChainRemovedSetRequest, opts ...grpc.CallOption) (*Volume, error)
	VolumeSnapshotMaxCountSet(ctx context.Context, in *VolumeSnapshotMaxCountSetRequest, opts ...grpc.CallOption) (*Volume, error)
	VolumeSnapshotMaxSizeSet(ctx context.Context, in *VolumeSnapshotMaxSizeSetRequest, opts ...grpc.CallOption) (*Volume, error)
	ReplicaList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaListReply, error)
	ReplicaGet(ctx context.Context, in *ReplicaAddress, opts ...grpc.CallOption) (*ControllerReplica, error)
	ControllerReplicaCreate(ctx context.Context, in *ControllerReplicaCreateRequest, opts ...grpc.CallOption) (*ControllerReplica, error)
	ReplicaDelete(ctx context.Context, in *ReplicaAddress, opts ...grpc.CallOption) (*emptypb.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)
	JournalList(ctx context.Context, in *JournalListRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VersionDetailGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionDetailGetReply, error)
	MetricsGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MetricsGetReply, error)
}

ControllerServiceClient is the client API for ControllerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewControllerServiceClient 

func NewControllerServiceClient(cc grpc.ClientConnInterface) ControllerServiceClient

type ControllerServiceServer 

type ControllerServiceServer interface {
	VolumeGet(context.Context, *emptypb.Empty) (*Volume, error)
	VolumeStart(context.Context, *VolumeStartRequest) (*Volume, error)
	VolumeShutdown(context.Context, *emptypb.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, *emptypb.Empty) (*Volume, error)
	VolumeUnmapMarkSnapChainRemovedSet(context.Context, *VolumeUnmapMarkSnapChainRemovedSetRequest) (*Volume, error)
	VolumeSnapshotMaxCountSet(context.Context, *VolumeSnapshotMaxCountSetRequest) (*Volume, error)
	VolumeSnapshotMaxSizeSet(context.Context, *VolumeSnapshotMaxSizeSetRequest) (*Volume, error)
	ReplicaList(context.Context, *emptypb.Empty) (*ReplicaListReply, error)
	ReplicaGet(context.Context, *ReplicaAddress) (*ControllerReplica, error)
	ControllerReplicaCreate(context.Context, *ControllerReplicaCreateRequest) (*ControllerReplica, error)
	ReplicaDelete(context.Context, *ReplicaAddress) (*emptypb.Empty, error)
	ReplicaUpdate(context.Context, *ControllerReplica) (*ControllerReplica, error)
	ReplicaPrepareRebuild(context.Context, *ReplicaAddress) (*ReplicaPrepareRebuildReply, error)
	ReplicaVerifyRebuild(context.Context, *ReplicaAddress) (*ControllerReplica, error)
	JournalList(context.Context, *JournalListRequest) (*emptypb.Empty, error)
	VersionDetailGet(context.Context, *emptypb.Empty) (*VersionDetailGetReply, error)
	MetricsGet(context.Context, *emptypb.Empty) (*MetricsGetReply, error)
	// contains filtered or unexported methods
}

ControllerServiceServer is the server API for ControllerService service. All implementations must embed UnimplementedControllerServiceServer for forward compatibility

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=user_created,json=userCreated,proto3" json:"user_created,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 */
	// contains filtered or unexported fields
}

func (*DiskInfo) Descriptor deprecated 

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

Deprecated: Use DiskInfo.ProtoReflect.Descriptor instead.

func (*DiskInfo) GetChildren 

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

func (*DiskInfo) GetCreated 

func (x *DiskInfo) GetCreated() string

func (*DiskInfo) GetLabels 

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

func (*DiskInfo) GetName 

func (x *DiskInfo) GetName() string

func (*DiskInfo) GetParent 

func (x *DiskInfo) GetParent() string

func (*DiskInfo) GetRemoved 

func (x *DiskInfo) GetRemoved() bool

func (*DiskInfo) GetSize 

func (x *DiskInfo) GetSize() string

func (*DiskInfo) GetUserCreated 

func (x *DiskInfo) GetUserCreated() bool

func (*DiskInfo) ProtoMessage 

func (*DiskInfo) ProtoMessage()

func (*DiskInfo) ProtoReflect 

func (x *DiskInfo) ProtoReflect() protoreflect.Message

func (*DiskInfo) Reset 

func (x *DiskInfo) Reset()

func (*DiskInfo) String 

func (x *DiskInfo) String() string

type DiskMarkAsRemovedRequest 

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

func (*DiskMarkAsRemovedRequest) Descriptor deprecated 

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

Deprecated: Use DiskMarkAsRemovedRequest.ProtoReflect.Descriptor instead.

func (*DiskMarkAsRemovedRequest) GetName 

func (x *DiskMarkAsRemovedRequest) GetName() string

func (*DiskMarkAsRemovedRequest) ProtoMessage 

func (*DiskMarkAsRemovedRequest) ProtoMessage()

func (*DiskMarkAsRemovedRequest) ProtoReflect 

func (x *DiskMarkAsRemovedRequest) ProtoReflect() protoreflect.Message

func (*DiskMarkAsRemovedRequest) Reset 

func (x *DiskMarkAsRemovedRequest) Reset()

func (*DiskMarkAsRemovedRequest) String 

func (x *DiskMarkAsRemovedRequest) String() string

type DiskMarkAsRemovedResponse 

type DiskMarkAsRemovedResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskMarkAsRemovedResponse) Descriptor deprecated 

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

Deprecated: Use DiskMarkAsRemovedResponse.ProtoReflect.Descriptor instead.

func (*DiskMarkAsRemovedResponse) GetReplica 

func (x *DiskMarkAsRemovedResponse) GetReplica() *Replica

func (*DiskMarkAsRemovedResponse) ProtoMessage 

func (*DiskMarkAsRemovedResponse) ProtoMessage()

func (*DiskMarkAsRemovedResponse) ProtoReflect 

func (x *DiskMarkAsRemovedResponse) ProtoReflect() protoreflect.Message

func (*DiskMarkAsRemovedResponse) Reset 

func (x *DiskMarkAsRemovedResponse) Reset()

func (*DiskMarkAsRemovedResponse) String 

func (x *DiskMarkAsRemovedResponse) String() string

type DiskPrepareRemoveRequest 

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

func (*DiskPrepareRemoveRequest) Descriptor deprecated 

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

Deprecated: Use DiskPrepareRemoveRequest.ProtoReflect.Descriptor instead.

func (*DiskPrepareRemoveRequest) GetName 

func (x *DiskPrepareRemoveRequest) GetName() string

func (*DiskPrepareRemoveRequest) ProtoMessage 

func (*DiskPrepareRemoveRequest) ProtoMessage()

func (*DiskPrepareRemoveRequest) ProtoReflect 

func (x *DiskPrepareRemoveRequest) ProtoReflect() protoreflect.Message

func (*DiskPrepareRemoveRequest) Reset 

func (x *DiskPrepareRemoveRequest) Reset()

func (*DiskPrepareRemoveRequest) String 

func (x *DiskPrepareRemoveRequest) String() string

type DiskPrepareRemoveResponse 

type DiskPrepareRemoveResponse struct {
	Operations []*PrepareRemoveAction `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskPrepareRemoveResponse) Descriptor deprecated 

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

Deprecated: Use DiskPrepareRemoveResponse.ProtoReflect.Descriptor instead.

func (*DiskPrepareRemoveResponse) GetOperations 

func (x *DiskPrepareRemoveResponse) GetOperations() []*PrepareRemoveAction

func (*DiskPrepareRemoveResponse) ProtoMessage 

func (*DiskPrepareRemoveResponse) ProtoMessage()

func (*DiskPrepareRemoveResponse) ProtoReflect 

func (x *DiskPrepareRemoveResponse) ProtoReflect() protoreflect.Message

func (*DiskPrepareRemoveResponse) Reset 

func (x *DiskPrepareRemoveResponse) Reset()

func (*DiskPrepareRemoveResponse) String 

func (x *DiskPrepareRemoveResponse) String() string

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

func (*DiskRemoveRequest) Descriptor deprecated 

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

Deprecated: Use DiskRemoveRequest.ProtoReflect.Descriptor instead.

func (*DiskRemoveRequest) GetForce 

func (x *DiskRemoveRequest) GetForce() bool

func (*DiskRemoveRequest) GetName 

func (x *DiskRemoveRequest) GetName() string

func (*DiskRemoveRequest) ProtoMessage 

func (*DiskRemoveRequest) ProtoMessage()

func (*DiskRemoveRequest) ProtoReflect 

func (x *DiskRemoveRequest) ProtoReflect() protoreflect.Message

func (*DiskRemoveRequest) Reset 

func (x *DiskRemoveRequest) Reset()

func (*DiskRemoveRequest) String 

func (x *DiskRemoveRequest) String() string

type DiskRemoveResponse 

type DiskRemoveResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskRemoveResponse) Descriptor deprecated 

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

Deprecated: Use DiskRemoveResponse.ProtoReflect.Descriptor instead.

func (*DiskRemoveResponse) GetReplica 

func (x *DiskRemoveResponse) GetReplica() *Replica

func (*DiskRemoveResponse) ProtoMessage 

func (*DiskRemoveResponse) ProtoMessage()

func (*DiskRemoveResponse) ProtoReflect 

func (x *DiskRemoveResponse) ProtoReflect() protoreflect.Message

func (*DiskRemoveResponse) Reset 

func (x *DiskRemoveResponse) Reset()

func (*DiskRemoveResponse) String 

func (x *DiskRemoveResponse) String() string

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

func (*DiskReplaceRequest) Descriptor deprecated 

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

Deprecated: Use DiskReplaceRequest.ProtoReflect.Descriptor instead.

func (*DiskReplaceRequest) GetSource 

func (x *DiskReplaceRequest) GetSource() string

func (*DiskReplaceRequest) GetTarget 

func (x *DiskReplaceRequest) GetTarget() string

func (*DiskReplaceRequest) ProtoMessage 

func (*DiskReplaceRequest) ProtoMessage()

func (*DiskReplaceRequest) ProtoReflect 

func (x *DiskReplaceRequest) ProtoReflect() protoreflect.Message

func (*DiskReplaceRequest) Reset 

func (x *DiskReplaceRequest) Reset()

func (*DiskReplaceRequest) String 

func (x *DiskReplaceRequest) String() string

type DiskReplaceResponse 

type DiskReplaceResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskReplaceResponse) Descriptor deprecated 

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

Deprecated: Use DiskReplaceResponse.ProtoReflect.Descriptor instead.

func (*DiskReplaceResponse) GetReplica 

func (x *DiskReplaceResponse) GetReplica() *Replica

func (*DiskReplaceResponse) ProtoMessage 

func (*DiskReplaceResponse) ProtoMessage()

func (*DiskReplaceResponse) ProtoReflect 

func (x *DiskReplaceResponse) ProtoReflect() protoreflect.Message

func (*DiskReplaceResponse) Reset 

func (x *DiskReplaceResponse) Reset()

func (*DiskReplaceResponse) String 

func (x *DiskReplaceResponse) String() string

type FileLocalSync 

type FileLocalSync struct {
	SourcePath string `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	TargetPath string `protobuf:"bytes,2,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
	// contains filtered or unexported fields
}

func (*FileLocalSync) Descriptor deprecated 

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

Deprecated: Use FileLocalSync.ProtoReflect.Descriptor instead.

func (*FileLocalSync) GetSourcePath 

func (x *FileLocalSync) GetSourcePath() string

func (*FileLocalSync) GetTargetPath 

func (x *FileLocalSync) GetTargetPath() string

func (*FileLocalSync) ProtoMessage 

func (*FileLocalSync) ProtoMessage()

func (*FileLocalSync) ProtoReflect 

func (x *FileLocalSync) ProtoReflect() protoreflect.Message

func (*FileLocalSync) Reset 

func (x *FileLocalSync) Reset()

func (*FileLocalSync) String 

func (x *FileLocalSync) String() string

type FileRemoveRequest 

type FileRemoveRequest struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*FileRemoveRequest) Descriptor deprecated 

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

Deprecated: Use FileRemoveRequest.ProtoReflect.Descriptor instead.

func (*FileRemoveRequest) GetFileName 

func (x *FileRemoveRequest) GetFileName() string

func (*FileRemoveRequest) ProtoMessage 

func (*FileRemoveRequest) ProtoMessage()

func (*FileRemoveRequest) ProtoReflect 

func (x *FileRemoveRequest) ProtoReflect() protoreflect.Message

func (*FileRemoveRequest) Reset 

func (x *FileRemoveRequest) Reset()

func (*FileRemoveRequest) String 

func (x *FileRemoveRequest) String() string

type FileRenameRequest 

type FileRenameRequest struct {
	OldFileName string `protobuf:"bytes,1,opt,name=old_file_name,json=oldFileName,proto3" json:"old_file_name,omitempty"`
	NewFileName string `protobuf:"bytes,2,opt,name=new_file_name,json=newFileName,proto3" json:"new_file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*FileRenameRequest) Descriptor deprecated 

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

Deprecated: Use FileRenameRequest.ProtoReflect.Descriptor instead.

func (*FileRenameRequest) GetNewFileName 

func (x *FileRenameRequest) GetNewFileName() string

func (*FileRenameRequest) GetOldFileName 

func (x *FileRenameRequest) GetOldFileName() string

func (*FileRenameRequest) ProtoMessage 

func (*FileRenameRequest) ProtoMessage()

func (*FileRenameRequest) ProtoReflect 

func (x *FileRenameRequest) ProtoReflect() protoreflect.Message

func (*FileRenameRequest) Reset 

func (x *FileRenameRequest) Reset()

func (*FileRenameRequest) String 

func (x *FileRenameRequest) String() string

type FileSendRequest 

type FileSendRequest struct {
	FromFileName              string `protobuf:"bytes,1,opt,name=from_file_name,json=fromFileName,proto3" json:"from_file_name,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"`
	FastSync                  bool   `protobuf:"varint,4,opt,name=fast_sync,json=fastSync,proto3" json:"fast_sync,omitempty"`
	FileSyncHttpClientTimeout int32  `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FileSendRequest) Descriptor deprecated 

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

Deprecated: Use FileSendRequest.ProtoReflect.Descriptor instead.

func (*FileSendRequest) GetFastSync 

func (x *FileSendRequest) GetFastSync() bool

func (*FileSendRequest) GetFileSyncHttpClientTimeout 

func (x *FileSendRequest) GetFileSyncHttpClientTimeout() int32

func (*FileSendRequest) GetFromFileName 

func (x *FileSendRequest) GetFromFileName() string

func (*FileSendRequest) GetHost 

func (x *FileSendRequest) GetHost() string

func (*FileSendRequest) GetPort 

func (x *FileSendRequest) GetPort() int32

func (*FileSendRequest) ProtoMessage 

func (*FileSendRequest) ProtoMessage()

func (*FileSendRequest) ProtoReflect 

func (x *FileSendRequest) ProtoReflect() protoreflect.Message

func (*FileSendRequest) Reset 

func (x *FileSendRequest) Reset()

func (*FileSendRequest) String 

func (x *FileSendRequest) String() string

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"`
	FastSync                  bool            `protobuf:"varint,4,opt,name=fast_sync,json=fastSync,proto3" json:"fast_sync,omitempty"`
	FileSyncHttpClientTimeout int32           `` /* 143-byte string literal not displayed */
	GrpcTimeoutSeconds        int64           `protobuf:"varint,6,opt,name=grpc_timeout_seconds,json=grpcTimeoutSeconds,proto3" json:"grpc_timeout_seconds,omitempty"`
	LocalSync                 *FileLocalSync  `protobuf:"bytes,7,opt,name=local_sync,json=localSync,proto3" json:"local_sync,omitempty"`
	// contains filtered or unexported fields
}

func (*FilesSyncRequest) Descriptor deprecated 

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

Deprecated: Use FilesSyncRequest.ProtoReflect.Descriptor instead.

func (*FilesSyncRequest) GetFastSync 

func (x *FilesSyncRequest) GetFastSync() bool

func (*FilesSyncRequest) GetFileSyncHttpClientTimeout 

func (x *FilesSyncRequest) GetFileSyncHttpClientTimeout() int32

func (*FilesSyncRequest) GetFromAddress 

func (x *FilesSyncRequest) GetFromAddress() string

func (*FilesSyncRequest) GetGrpcTimeoutSeconds 

func (x *FilesSyncRequest) GetGrpcTimeoutSeconds() int64

func (*FilesSyncRequest) GetLocalSync 

func (x *FilesSyncRequest) GetLocalSync() *FileLocalSync

func (*FilesSyncRequest) GetSyncFileInfoList 

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

func (*FilesSyncRequest) GetToHost 

func (x *FilesSyncRequest) GetToHost() string

func (*FilesSyncRequest) ProtoMessage 

func (*FilesSyncRequest) ProtoMessage()

func (*FilesSyncRequest) ProtoReflect 

func (x *FilesSyncRequest) ProtoReflect() protoreflect.Message

func (*FilesSyncRequest) Reset 

func (x *FilesSyncRequest) Reset()

func (*FilesSyncRequest) String 

func (x *FilesSyncRequest) String() string

type JournalListRequest 

type JournalListRequest struct {
	Limit int64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*JournalListRequest) Descriptor deprecated 

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

Deprecated: Use JournalListRequest.ProtoReflect.Descriptor instead.

func (*JournalListRequest) GetLimit 

func (x *JournalListRequest) GetLimit() int64

func (*JournalListRequest) ProtoMessage 

func (*JournalListRequest) ProtoMessage()

func (*JournalListRequest) ProtoReflect 

func (x *JournalListRequest) ProtoReflect() protoreflect.Message

func (*JournalListRequest) Reset 

func (x *JournalListRequest) Reset()

func (*JournalListRequest) String 

func (x *JournalListRequest) String() string

type Metrics 

type Metrics struct {
	ReadThroughput  uint64 `protobuf:"varint,1,opt,name=readThroughput,proto3" json:"readThroughput,omitempty"`
	WriteThroughput uint64 `protobuf:"varint,2,opt,name=writeThroughput,proto3" json:"writeThroughput,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"`
	ReadIOPS        uint64 `protobuf:"varint,5,opt,name=readIOPS,proto3" json:"readIOPS,omitempty"`
	WriteIOPS       uint64 `protobuf:"varint,6,opt,name=writeIOPS,proto3" json:"writeIOPS,omitempty"`
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetReadIOPS 

func (x *Metrics) GetReadIOPS() uint64

func (*Metrics) GetReadLatency 

func (x *Metrics) GetReadLatency() uint64

func (*Metrics) GetReadThroughput 

func (x *Metrics) GetReadThroughput() uint64

func (*Metrics) GetWriteIOPS 

func (x *Metrics) GetWriteIOPS() uint64

func (*Metrics) GetWriteLatency 

func (x *Metrics) GetWriteLatency() uint64

func (*Metrics) GetWriteThroughput 

func (x *Metrics) GetWriteThroughput() uint64

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

func (x *Metrics) ProtoReflect() protoreflect.Message

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type MetricsGetReply 

type MetricsGetReply struct {
	Metrics *Metrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsGetReply) Descriptor deprecated 

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

Deprecated: Use MetricsGetReply.ProtoReflect.Descriptor instead.

func (*MetricsGetReply) GetMetrics 

func (x *MetricsGetReply) GetMetrics() *Metrics

func (*MetricsGetReply) ProtoMessage 

func (*MetricsGetReply) ProtoMessage()

func (*MetricsGetReply) ProtoReflect 

func (x *MetricsGetReply) ProtoReflect() protoreflect.Message

func (*MetricsGetReply) Reset 

func (x *MetricsGetReply) Reset()

func (*MetricsGetReply) String 

func (x *MetricsGetReply) String() string

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

func (*PrepareRemoveAction) Descriptor deprecated 

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

Deprecated: Use PrepareRemoveAction.ProtoReflect.Descriptor instead.

func (*PrepareRemoveAction) GetAction 

func (x *PrepareRemoveAction) GetAction() string

func (*PrepareRemoveAction) GetSource 

func (x *PrepareRemoveAction) GetSource() string

func (*PrepareRemoveAction) GetTarget 

func (x *PrepareRemoveAction) GetTarget() string

func (*PrepareRemoveAction) ProtoMessage 

func (*PrepareRemoveAction) ProtoMessage()

func (*PrepareRemoveAction) ProtoReflect 

func (x *PrepareRemoveAction) ProtoReflect() protoreflect.Message

func (*PrepareRemoveAction) Reset 

func (x *PrepareRemoveAction) Reset()

func (*PrepareRemoveAction) String 

func (x *PrepareRemoveAction) String() string

type RebuildingSetRequest 

type RebuildingSetRequest struct {
	Rebuilding bool `protobuf:"varint,1,opt,name=rebuilding,proto3" json:"rebuilding,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildingSetRequest) Descriptor deprecated 

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

Deprecated: Use RebuildingSetRequest.ProtoReflect.Descriptor instead.

func (*RebuildingSetRequest) GetRebuilding 

func (x *RebuildingSetRequest) GetRebuilding() bool

func (*RebuildingSetRequest) ProtoMessage 

func (*RebuildingSetRequest) ProtoMessage()

func (*RebuildingSetRequest) ProtoReflect 

func (x *RebuildingSetRequest) ProtoReflect() protoreflect.Message

func (*RebuildingSetRequest) Reset 

func (x *RebuildingSetRequest) Reset()

func (*RebuildingSetRequest) String 

func (x *RebuildingSetRequest) String() string

type RebuildingSetResponse 

type RebuildingSetResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildingSetResponse) Descriptor deprecated 

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

Deprecated: Use RebuildingSetResponse.ProtoReflect.Descriptor instead.

func (*RebuildingSetResponse) GetReplica 

func (x *RebuildingSetResponse) GetReplica() *Replica

func (*RebuildingSetResponse) ProtoMessage 

func (*RebuildingSetResponse) ProtoMessage()

func (*RebuildingSetResponse) ProtoReflect 

func (x *RebuildingSetResponse) ProtoReflect() protoreflect.Message

func (*RebuildingSetResponse) Reset 

func (x *RebuildingSetResponse) Reset()

func (*RebuildingSetResponse) String 

func (x *RebuildingSetResponse) String() string

type ReceiverLaunchRequest 

type ReceiverLaunchRequest struct {
	ToFileName string `protobuf:"bytes,1,opt,name=to_file_name,json=toFileName,proto3" json:"to_file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiverLaunchRequest) Descriptor deprecated 

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

Deprecated: Use ReceiverLaunchRequest.ProtoReflect.Descriptor instead.

func (*ReceiverLaunchRequest) GetToFileName 

func (x *ReceiverLaunchRequest) GetToFileName() string

func (*ReceiverLaunchRequest) ProtoMessage 

func (*ReceiverLaunchRequest) ProtoMessage()

func (*ReceiverLaunchRequest) ProtoReflect 

func (x *ReceiverLaunchRequest) ProtoReflect() protoreflect.Message

func (*ReceiverLaunchRequest) Reset 

func (x *ReceiverLaunchRequest) Reset()

func (*ReceiverLaunchRequest) String 

func (x *ReceiverLaunchRequest) String() string

type ReceiverLaunchResponse 

type ReceiverLaunchResponse struct {
	Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiverLaunchResponse) Descriptor deprecated 

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

Deprecated: Use ReceiverLaunchResponse.ProtoReflect.Descriptor instead.

func (*ReceiverLaunchResponse) GetPort 

func (x *ReceiverLaunchResponse) GetPort() int32

func (*ReceiverLaunchResponse) ProtoMessage 

func (*ReceiverLaunchResponse) ProtoMessage()

func (*ReceiverLaunchResponse) ProtoReflect 

func (x *ReceiverLaunchResponse) ProtoReflect() protoreflect.Message

func (*ReceiverLaunchResponse) Reset 

func (x *ReceiverLaunchResponse) Reset()

func (*ReceiverLaunchResponse) String 

func (x *ReceiverLaunchResponse) String() string

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=sector_size,json=sectorSize,proto3" json:"sector_size,omitempty"`
	BackingFile               string               `protobuf:"bytes,7,opt,name=backing_file,json=backingFile,proto3" json:"backing_file,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=remain_snapshots,json=remainSnapshots,proto3" json:"remain_snapshots,omitempty"`
	RevisionCounter           int64                `protobuf:"varint,12,opt,name=revision_counter,json=revisionCounter,proto3" json:"revision_counter,omitempty"`
	LastModifyTime            int64                `protobuf:"varint,13,opt,name=last_modify_time,json=lastModifyTime,proto3" json:"last_modify_time,omitempty"`
	HeadFileSize              int64                `protobuf:"varint,14,opt,name=head_file_size,json=headFileSize,proto3" json:"head_file_size,omitempty"`
	RevisionCounterDisabled   bool                 `` /* 134-byte string literal not displayed */
	UnmapMarkDiskChainRemoved bool                 `` /* 144-byte string literal not displayed */
	SnapshotCountUsage        int32                `protobuf:"varint,17,opt,name=snapshot_count_usage,json=snapshotCountUsage,proto3" json:"snapshot_count_usage,omitempty"`
	SnapshotSizeUsage         int64                `protobuf:"varint,18,opt,name=snapshot_size_usage,json=snapshotSizeUsage,proto3" json:"snapshot_size_usage,omitempty"`
	// contains filtered or unexported fields
}

func (*Replica) Descriptor deprecated 

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

Deprecated: Use Replica.ProtoReflect.Descriptor instead.

func (*Replica) GetBackingFile 

func (x *Replica) GetBackingFile() string

func (*Replica) GetChain 

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

func (*Replica) GetDirty 

func (x *Replica) GetDirty() bool

func (*Replica) GetDisks 

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

func (*Replica) GetHead 

func (x *Replica) GetHead() string

func (*Replica) GetHeadFileSize 

func (x *Replica) GetHeadFileSize() int64

func (*Replica) GetLastModifyTime 

func (x *Replica) GetLastModifyTime() int64

func (*Replica) GetParent 

func (x *Replica) GetParent() string

func (*Replica) GetRebuilding 

func (x *Replica) GetRebuilding() bool

func (*Replica) GetRemainSnapshots 

func (x *Replica) GetRemainSnapshots() int32

func (*Replica) GetRevisionCounter 

func (x *Replica) GetRevisionCounter() int64

func (*Replica) GetRevisionCounterDisabled 

func (x *Replica) GetRevisionCounterDisabled() bool

func (*Replica) GetSectorSize 

func (x *Replica) GetSectorSize() int64

func (*Replica) GetSize 

func (x *Replica) GetSize() string

func (*Replica) GetSnapshotCountUsage 

func (x *Replica) GetSnapshotCountUsage() int32

func (*Replica) GetSnapshotSizeUsage 

func (x *Replica) GetSnapshotSizeUsage() int64

func (*Replica) GetState 

func (x *Replica) GetState() string

func (*Replica) GetUnmapMarkDiskChainRemoved 

func (x *Replica) GetUnmapMarkDiskChainRemoved() bool

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) ProtoReflect 

func (x *Replica) ProtoReflect() protoreflect.Message

func (*Replica) Reset 

func (x *Replica) Reset()

func (*Replica) String 

func (x *Replica) String() string

type ReplicaAddress 

type ReplicaAddress struct {
	Address      string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	InstanceName string `protobuf:"bytes,2,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaAddress) Descriptor deprecated 

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

Deprecated: Use ReplicaAddress.ProtoReflect.Descriptor instead.

func (*ReplicaAddress) GetAddress 

func (x *ReplicaAddress) GetAddress() string

func (*ReplicaAddress) GetInstanceName 

func (x *ReplicaAddress) GetInstanceName() string

func (*ReplicaAddress) ProtoMessage 

func (*ReplicaAddress) ProtoMessage()

func (*ReplicaAddress) ProtoReflect 

func (x *ReplicaAddress) ProtoReflect() protoreflect.Message

func (*ReplicaAddress) Reset 

func (x *ReplicaAddress) Reset()

func (*ReplicaAddress) String 

func (x *ReplicaAddress) String() string

type ReplicaCloseResponse 

type ReplicaCloseResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaCloseResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaCloseResponse.ProtoReflect.Descriptor instead.

func (*ReplicaCloseResponse) GetReplica 

func (x *ReplicaCloseResponse) GetReplica() *Replica

func (*ReplicaCloseResponse) ProtoMessage 

func (*ReplicaCloseResponse) ProtoMessage()

func (*ReplicaCloseResponse) ProtoReflect 

func (x *ReplicaCloseResponse) ProtoReflect() protoreflect.Message

func (*ReplicaCloseResponse) Reset 

func (x *ReplicaCloseResponse) Reset()

func (*ReplicaCloseResponse) String 

func (x *ReplicaCloseResponse) String() string

type ReplicaCreateRequest 

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

func (*ReplicaCreateRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaCreateRequest.ProtoReflect.Descriptor instead.

func (*ReplicaCreateRequest) GetSize 

func (x *ReplicaCreateRequest) GetSize() string

func (*ReplicaCreateRequest) ProtoMessage 

func (*ReplicaCreateRequest) ProtoMessage()

func (*ReplicaCreateRequest) ProtoReflect 

func (x *ReplicaCreateRequest) ProtoReflect() protoreflect.Message

func (*ReplicaCreateRequest) Reset 

func (x *ReplicaCreateRequest) Reset()

func (*ReplicaCreateRequest) String 

func (x *ReplicaCreateRequest) String() string

type ReplicaCreateResponse 

type ReplicaCreateResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaCreateResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaCreateResponse.ProtoReflect.Descriptor instead.

func (*ReplicaCreateResponse) GetReplica 

func (x *ReplicaCreateResponse) GetReplica() *Replica

func (*ReplicaCreateResponse) ProtoMessage 

func (*ReplicaCreateResponse) ProtoMessage()

func (*ReplicaCreateResponse) ProtoReflect 

func (x *ReplicaCreateResponse) ProtoReflect() protoreflect.Message

func (*ReplicaCreateResponse) Reset 

func (x *ReplicaCreateResponse) Reset()

func (*ReplicaCreateResponse) String 

func (x *ReplicaCreateResponse) String() string

type ReplicaExpandRequest 

type ReplicaExpandRequest struct {
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaExpandRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaExpandRequest.ProtoReflect.Descriptor instead.

func (*ReplicaExpandRequest) GetSize 

func (x *ReplicaExpandRequest) GetSize() int64

func (*ReplicaExpandRequest) ProtoMessage 

func (*ReplicaExpandRequest) ProtoMessage()

func (*ReplicaExpandRequest) ProtoReflect 

func (x *ReplicaExpandRequest) ProtoReflect() protoreflect.Message

func (*ReplicaExpandRequest) Reset 

func (x *ReplicaExpandRequest) Reset()

func (*ReplicaExpandRequest) String 

func (x *ReplicaExpandRequest) String() string

type ReplicaExpandResponse 

type ReplicaExpandResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaExpandResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaExpandResponse.ProtoReflect.Descriptor instead.

func (*ReplicaExpandResponse) GetReplica 

func (x *ReplicaExpandResponse) GetReplica() *Replica

func (*ReplicaExpandResponse) ProtoMessage 

func (*ReplicaExpandResponse) ProtoMessage()

func (*ReplicaExpandResponse) ProtoReflect 

func (x *ReplicaExpandResponse) ProtoReflect() protoreflect.Message

func (*ReplicaExpandResponse) Reset 

func (x *ReplicaExpandResponse) Reset()

func (*ReplicaExpandResponse) String 

func (x *ReplicaExpandResponse) String() string

type ReplicaGetResponse 

type ReplicaGetResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaGetResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaGetResponse.ProtoReflect.Descriptor instead.

func (*ReplicaGetResponse) GetReplica 

func (x *ReplicaGetResponse) GetReplica() *Replica

func (*ReplicaGetResponse) ProtoMessage 

func (*ReplicaGetResponse) ProtoMessage()

func (*ReplicaGetResponse) ProtoReflect 

func (x *ReplicaGetResponse) ProtoReflect() protoreflect.Message

func (*ReplicaGetResponse) Reset 

func (x *ReplicaGetResponse) Reset()

func (*ReplicaGetResponse) String 

func (x *ReplicaGetResponse) String() string

type ReplicaListReply 

type ReplicaListReply struct {
	Replicas []*ControllerReplica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaListReply) Descriptor deprecated 

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

Deprecated: Use ReplicaListReply.ProtoReflect.Descriptor instead.

func (*ReplicaListReply) GetReplicas 

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

func (*ReplicaListReply) ProtoMessage 

func (*ReplicaListReply) ProtoMessage()

func (*ReplicaListReply) ProtoReflect 

func (x *ReplicaListReply) ProtoReflect() protoreflect.Message

func (*ReplicaListReply) Reset 

func (x *ReplicaListReply) Reset()

func (*ReplicaListReply) String 

func (x *ReplicaListReply) String() string

type ReplicaMode 

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

func (ReplicaMode) Descriptor 

func (ReplicaMode) Descriptor() protoreflect.EnumDescriptor

func (ReplicaMode) Enum 

func (x ReplicaMode) Enum() *ReplicaMode

func (ReplicaMode) EnumDescriptor deprecated 

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

Deprecated: Use ReplicaMode.Descriptor instead.

func (ReplicaMode) Number 

func (x ReplicaMode) Number() protoreflect.EnumNumber

func (ReplicaMode) String 

func (x ReplicaMode) String() string

func (ReplicaMode) Type 

func (ReplicaMode) Type() protoreflect.EnumType

type ReplicaOpenResponse 

type ReplicaOpenResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaOpenResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaOpenResponse.ProtoReflect.Descriptor instead.

func (*ReplicaOpenResponse) GetReplica 

func (x *ReplicaOpenResponse) GetReplica() *Replica

func (*ReplicaOpenResponse) ProtoMessage 

func (*ReplicaOpenResponse) ProtoMessage()

func (*ReplicaOpenResponse) ProtoReflect 

func (x *ReplicaOpenResponse) ProtoReflect() protoreflect.Message

func (*ReplicaOpenResponse) Reset 

func (x *ReplicaOpenResponse) Reset()

func (*ReplicaOpenResponse) String 

func (x *ReplicaOpenResponse) 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"`
	// contains filtered or unexported fields
}

func (*ReplicaPrepareRebuildReply) Descriptor deprecated 

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

Deprecated: Use ReplicaPrepareRebuildReply.ProtoReflect.Descriptor instead.

func (*ReplicaPrepareRebuildReply) GetReplica 

func (x *ReplicaPrepareRebuildReply) GetReplica() *ControllerReplica

func (*ReplicaPrepareRebuildReply) GetSyncFileInfoList 

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

func (*ReplicaPrepareRebuildReply) ProtoMessage 

func (*ReplicaPrepareRebuildReply) ProtoMessage()

func (*ReplicaPrepareRebuildReply) ProtoReflect 

func (x *ReplicaPrepareRebuildReply) ProtoReflect() protoreflect.Message

func (*ReplicaPrepareRebuildReply) Reset 

func (x *ReplicaPrepareRebuildReply) Reset()

func (*ReplicaPrepareRebuildReply) String 

func (x *ReplicaPrepareRebuildReply) String() string

type ReplicaRebuildStatusResponse 

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

func (*ReplicaRebuildStatusResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaRebuildStatusResponse.ProtoReflect.Descriptor instead.

func (*ReplicaRebuildStatusResponse) GetError 

func (x *ReplicaRebuildStatusResponse) GetError() string

func (*ReplicaRebuildStatusResponse) GetFromReplicaAddress 

func (x *ReplicaRebuildStatusResponse) GetFromReplicaAddress() string

func (*ReplicaRebuildStatusResponse) GetIsRebuilding 

func (x *ReplicaRebuildStatusResponse) GetIsRebuilding() bool

func (*ReplicaRebuildStatusResponse) GetProgress 

func (x *ReplicaRebuildStatusResponse) GetProgress() int32

func (*ReplicaRebuildStatusResponse) GetState 

func (x *ReplicaRebuildStatusResponse) GetState() string

func (*ReplicaRebuildStatusResponse) ProtoMessage 

func (*ReplicaRebuildStatusResponse) ProtoMessage()

func (*ReplicaRebuildStatusResponse) ProtoReflect 

func (x *ReplicaRebuildStatusResponse) ProtoReflect() protoreflect.Message

func (*ReplicaRebuildStatusResponse) Reset 

func (x *ReplicaRebuildStatusResponse) Reset()

func (*ReplicaRebuildStatusResponse) String 

func (x *ReplicaRebuildStatusResponse) String() string

type ReplicaReloadResponse 

type ReplicaReloadResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaReloadResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaReloadResponse.ProtoReflect.Descriptor instead.

func (*ReplicaReloadResponse) GetReplica 

func (x *ReplicaReloadResponse) GetReplica() *Replica

func (*ReplicaReloadResponse) ProtoMessage 

func (*ReplicaReloadResponse) ProtoMessage()

func (*ReplicaReloadResponse) ProtoReflect 

func (x *ReplicaReloadResponse) ProtoReflect() protoreflect.Message

func (*ReplicaReloadResponse) Reset 

func (x *ReplicaReloadResponse) Reset()

func (*ReplicaReloadResponse) String 

func (x *ReplicaReloadResponse) String() string

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

func (*ReplicaRevertRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaRevertRequest.ProtoReflect.Descriptor instead.

func (*ReplicaRevertRequest) GetCreated 

func (x *ReplicaRevertRequest) GetCreated() string

func (*ReplicaRevertRequest) GetName 

func (x *ReplicaRevertRequest) GetName() string

func (*ReplicaRevertRequest) ProtoMessage 

func (*ReplicaRevertRequest) ProtoMessage()

func (*ReplicaRevertRequest) ProtoReflect 

func (x *ReplicaRevertRequest) ProtoReflect() protoreflect.Message

func (*ReplicaRevertRequest) Reset 

func (x *ReplicaRevertRequest) Reset()

func (*ReplicaRevertRequest) String 

func (x *ReplicaRevertRequest) String() string

type ReplicaRevertResponse 

type ReplicaRevertResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaRevertResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaRevertResponse.ProtoReflect.Descriptor instead.

func (*ReplicaRevertResponse) GetReplica 

func (x *ReplicaRevertResponse) GetReplica() *Replica

func (*ReplicaRevertResponse) ProtoMessage 

func (*ReplicaRevertResponse) ProtoMessage()

func (*ReplicaRevertResponse) ProtoReflect 

func (x *ReplicaRevertResponse) ProtoReflect() protoreflect.Message

func (*ReplicaRevertResponse) Reset 

func (x *ReplicaRevertResponse) Reset()

func (*ReplicaRevertResponse) String 

func (x *ReplicaRevertResponse) String() string

type ReplicaServiceClient 

type ReplicaServiceClient interface {
	ReplicaCreate(ctx context.Context, in *ReplicaCreateRequest, opts ...grpc.CallOption) (*ReplicaCreateResponse, error)
	ReplicaDelete(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReplicaGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaGetResponse, error)
	ReplicaOpen(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaOpenResponse, error)
	ReplicaClose(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaCloseResponse, error)
	ReplicaReload(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaReloadResponse, error)
	ReplicaRevert(ctx context.Context, in *ReplicaRevertRequest, opts ...grpc.CallOption) (*ReplicaRevertResponse, error)
	ReplicaSnapshot(ctx context.Context, in *ReplicaSnapshotRequest, opts ...grpc.CallOption) (*ReplicaSnapshotResponse, error)
	ReplicaExpand(ctx context.Context, in *ReplicaExpandRequest, opts ...grpc.CallOption) (*ReplicaExpandResponse, error)
	DiskRemove(ctx context.Context, in *DiskRemoveRequest, opts ...grpc.CallOption) (*DiskRemoveResponse, error)
	DiskReplace(ctx context.Context, in *DiskReplaceRequest, opts ...grpc.CallOption) (*DiskReplaceResponse, error)
	DiskPrepareRemove(ctx context.Context, in *DiskPrepareRemoveRequest, opts ...grpc.CallOption) (*DiskPrepareRemoveResponse, error)
	DiskMarkAsRemoved(ctx context.Context, in *DiskMarkAsRemovedRequest, opts ...grpc.CallOption) (*DiskMarkAsRemovedResponse, error)
	RebuildingSet(ctx context.Context, in *RebuildingSetRequest, opts ...grpc.CallOption) (*RebuildingSetResponse, error)
	RevisionCounterSet(ctx context.Context, in *RevisionCounterSetRequest, opts ...grpc.CallOption) (*RevisionCounterSetResponse, error)
	UnmapMarkDiskChainRemovedSet(ctx context.Context, in *UnmapMarkDiskChainRemovedSetRequest, opts ...grpc.CallOption) (*UnmapMarkDiskChainRemovedSetResponse, error)
	SnapshotMaxCountSet(ctx context.Context, in *SnapshotMaxCountSetRequest, opts ...grpc.CallOption) (*SnapshotMaxCountSetResponse, error)
	SnapshotMaxSizeSet(ctx context.Context, in *SnapshotMaxSizeSetRequest, opts ...grpc.CallOption) (*SnapshotMaxSizeSetResponse, error)
}

ReplicaServiceClient is the client API for ReplicaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewReplicaServiceClient 

func NewReplicaServiceClient(cc grpc.ClientConnInterface) ReplicaServiceClient

type ReplicaServiceServer 

type ReplicaServiceServer interface {
	ReplicaCreate(context.Context, *ReplicaCreateRequest) (*ReplicaCreateResponse, error)
	ReplicaDelete(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ReplicaGet(context.Context, *emptypb.Empty) (*ReplicaGetResponse, error)
	ReplicaOpen(context.Context, *emptypb.Empty) (*ReplicaOpenResponse, error)
	ReplicaClose(context.Context, *emptypb.Empty) (*ReplicaCloseResponse, error)
	ReplicaReload(context.Context, *emptypb.Empty) (*ReplicaReloadResponse, error)
	ReplicaRevert(context.Context, *ReplicaRevertRequest) (*ReplicaRevertResponse, error)
	ReplicaSnapshot(context.Context, *ReplicaSnapshotRequest) (*ReplicaSnapshotResponse, error)
	ReplicaExpand(context.Context, *ReplicaExpandRequest) (*ReplicaExpandResponse, error)
	DiskRemove(context.Context, *DiskRemoveRequest) (*DiskRemoveResponse, error)
	DiskReplace(context.Context, *DiskReplaceRequest) (*DiskReplaceResponse, error)
	DiskPrepareRemove(context.Context, *DiskPrepareRemoveRequest) (*DiskPrepareRemoveResponse, error)
	DiskMarkAsRemoved(context.Context, *DiskMarkAsRemovedRequest) (*DiskMarkAsRemovedResponse, error)
	RebuildingSet(context.Context, *RebuildingSetRequest) (*RebuildingSetResponse, error)
	RevisionCounterSet(context.Context, *RevisionCounterSetRequest) (*RevisionCounterSetResponse, error)
	UnmapMarkDiskChainRemovedSet(context.Context, *UnmapMarkDiskChainRemovedSetRequest) (*UnmapMarkDiskChainRemovedSetResponse, error)
	SnapshotMaxCountSet(context.Context, *SnapshotMaxCountSetRequest) (*SnapshotMaxCountSetResponse, error)
	SnapshotMaxSizeSet(context.Context, *SnapshotMaxSizeSetRequest) (*SnapshotMaxSizeSetResponse, error)
	// contains filtered or unexported methods
}

ReplicaServiceServer is the server API for ReplicaService service. All implementations must embed UnimplementedReplicaServiceServer for forward compatibility

type ReplicaSnapshotRequest 

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

func (*ReplicaSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaSnapshotRequest.ProtoReflect.Descriptor instead.

func (*ReplicaSnapshotRequest) GetCreated 

func (x *ReplicaSnapshotRequest) GetCreated() string

func (*ReplicaSnapshotRequest) GetLabels 

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

func (*ReplicaSnapshotRequest) GetName 

func (x *ReplicaSnapshotRequest) GetName() string

func (*ReplicaSnapshotRequest) GetUserCreated 

func (x *ReplicaSnapshotRequest) GetUserCreated() bool

func (*ReplicaSnapshotRequest) ProtoMessage 

func (*ReplicaSnapshotRequest) ProtoMessage()

func (*ReplicaSnapshotRequest) ProtoReflect 

func (x *ReplicaSnapshotRequest) ProtoReflect() protoreflect.Message

func (*ReplicaSnapshotRequest) Reset 

func (x *ReplicaSnapshotRequest) Reset()

func (*ReplicaSnapshotRequest) String 

func (x *ReplicaSnapshotRequest) String() string

type ReplicaSnapshotResponse 

type ReplicaSnapshotResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use ReplicaSnapshotResponse.ProtoReflect.Descriptor instead.

func (*ReplicaSnapshotResponse) GetReplica 

func (x *ReplicaSnapshotResponse) GetReplica() *Replica

func (*ReplicaSnapshotResponse) ProtoMessage 

func (*ReplicaSnapshotResponse) ProtoMessage()

func (*ReplicaSnapshotResponse) ProtoReflect 

func (x *ReplicaSnapshotResponse) ProtoReflect() protoreflect.Message

func (*ReplicaSnapshotResponse) Reset 

func (x *ReplicaSnapshotResponse) Reset()

func (*ReplicaSnapshotResponse) String 

func (x *ReplicaSnapshotResponse) String() string

type RestoreStatusResponse 

type RestoreStatusResponse struct {
	IsRestoring            bool   `protobuf:"varint,1,opt,name=is_restoring,json=isRestoring,proto3" json:"is_restoring,omitempty"`
	LastRestored           string `protobuf:"bytes,2,opt,name=last_restored,json=lastRestored,proto3" json:"last_restored,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=dest_file_name,json=destFileName,proto3" json:"dest_file_name,omitempty"`
	State                  string `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	BackupUrl              string `protobuf:"bytes,7,opt,name=backup_url,json=backupUrl,proto3" json:"backup_url,omitempty"`
	CurrentRestoringBackup string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RestoreStatusResponse) Descriptor deprecated 

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

Deprecated: Use RestoreStatusResponse.ProtoReflect.Descriptor instead.

func (*RestoreStatusResponse) GetBackupUrl 

func (x *RestoreStatusResponse) GetBackupUrl() string

func (*RestoreStatusResponse) GetCurrentRestoringBackup 

func (x *RestoreStatusResponse) GetCurrentRestoringBackup() string

func (*RestoreStatusResponse) GetDestFileName 

func (x *RestoreStatusResponse) GetDestFileName() string

func (*RestoreStatusResponse) GetError 

func (x *RestoreStatusResponse) GetError() string

func (*RestoreStatusResponse) GetIsRestoring 

func (x *RestoreStatusResponse) GetIsRestoring() bool

func (*RestoreStatusResponse) GetLastRestored 

func (x *RestoreStatusResponse) GetLastRestored() string

func (*RestoreStatusResponse) GetProgress 

func (x *RestoreStatusResponse) GetProgress() int32

func (*RestoreStatusResponse) GetState 

func (x *RestoreStatusResponse) GetState() string

func (*RestoreStatusResponse) ProtoMessage 

func (*RestoreStatusResponse) ProtoMessage()

func (*RestoreStatusResponse) ProtoReflect 

func (x *RestoreStatusResponse) ProtoReflect() protoreflect.Message

func (*RestoreStatusResponse) Reset 

func (x *RestoreStatusResponse) Reset()

func (*RestoreStatusResponse) String 

func (x *RestoreStatusResponse) String() string

type RevisionCounterSetRequest 

type RevisionCounterSetRequest struct {
	Counter int64 `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	// contains filtered or unexported fields
}

func (*RevisionCounterSetRequest) Descriptor deprecated 

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

Deprecated: Use RevisionCounterSetRequest.ProtoReflect.Descriptor instead.

func (*RevisionCounterSetRequest) GetCounter 

func (x *RevisionCounterSetRequest) GetCounter() int64

func (*RevisionCounterSetRequest) ProtoMessage 

func (*RevisionCounterSetRequest) ProtoMessage()

func (*RevisionCounterSetRequest) ProtoReflect 

func (x *RevisionCounterSetRequest) ProtoReflect() protoreflect.Message

func (*RevisionCounterSetRequest) Reset 

func (x *RevisionCounterSetRequest) Reset()

func (*RevisionCounterSetRequest) String 

func (x *RevisionCounterSetRequest) String() string

type RevisionCounterSetResponse 

type RevisionCounterSetResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*RevisionCounterSetResponse) Descriptor deprecated 

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

Deprecated: Use RevisionCounterSetResponse.ProtoReflect.Descriptor instead.

func (*RevisionCounterSetResponse) GetReplica 

func (x *RevisionCounterSetResponse) GetReplica() *Replica

func (*RevisionCounterSetResponse) ProtoMessage 

func (*RevisionCounterSetResponse) ProtoMessage()

func (*RevisionCounterSetResponse) ProtoReflect 

func (x *RevisionCounterSetResponse) ProtoReflect() protoreflect.Message

func (*RevisionCounterSetResponse) Reset 

func (x *RevisionCounterSetResponse) Reset()

func (*RevisionCounterSetResponse) String 

func (x *RevisionCounterSetResponse) String() string

type SnapshotCloneRequest 

type SnapshotCloneRequest 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"`
	SnapshotFileName          string `protobuf:"bytes,3,opt,name=snapshot_file_name,json=snapshotFileName,proto3" json:"snapshot_file_name,omitempty"`
	ExportBackingImageIfExist bool   `` /* 143-byte string literal not displayed */
	FileSyncHttpClientTimeout int32  `` /* 143-byte string literal not displayed */
	FromVolumeName            string `protobuf:"bytes,6,opt,name=from_volume_name,json=fromVolumeName,proto3" json:"from_volume_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotCloneRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotCloneRequest.ProtoReflect.Descriptor instead.

func (*SnapshotCloneRequest) GetExportBackingImageIfExist 

func (x *SnapshotCloneRequest) GetExportBackingImageIfExist() bool

func (*SnapshotCloneRequest) GetFileSyncHttpClientTimeout 

func (x *SnapshotCloneRequest) GetFileSyncHttpClientTimeout() int32

func (*SnapshotCloneRequest) GetFromAddress 

func (x *SnapshotCloneRequest) GetFromAddress() string

func (*SnapshotCloneRequest) GetFromVolumeName 

func (x *SnapshotCloneRequest) GetFromVolumeName() string

func (*SnapshotCloneRequest) GetSnapshotFileName 

func (x *SnapshotCloneRequest) GetSnapshotFileName() string

func (*SnapshotCloneRequest) GetToHost 

func (x *SnapshotCloneRequest) GetToHost() string

func (*SnapshotCloneRequest) ProtoMessage 

func (*SnapshotCloneRequest) ProtoMessage()

func (*SnapshotCloneRequest) ProtoReflect 

func (x *SnapshotCloneRequest) ProtoReflect() protoreflect.Message

func (*SnapshotCloneRequest) Reset 

func (x *SnapshotCloneRequest) Reset()

func (*SnapshotCloneRequest) String 

func (x *SnapshotCloneRequest) String() string

type SnapshotCloneStatusResponse 

type SnapshotCloneStatusResponse struct {
	IsCloning          bool   `protobuf:"varint,1,opt,name=is_cloning,json=isCloning,proto3" json:"is_cloning,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"`
	SnapshotName       string `protobuf:"bytes,6,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotCloneStatusResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotCloneStatusResponse.ProtoReflect.Descriptor instead.

func (*SnapshotCloneStatusResponse) GetError 

func (x *SnapshotCloneStatusResponse) GetError() string

func (*SnapshotCloneStatusResponse) GetFromReplicaAddress 

func (x *SnapshotCloneStatusResponse) GetFromReplicaAddress() string

func (*SnapshotCloneStatusResponse) GetIsCloning 

func (x *SnapshotCloneStatusResponse) GetIsCloning() bool

func (*SnapshotCloneStatusResponse) GetProgress 

func (x *SnapshotCloneStatusResponse) GetProgress() int32

func (*SnapshotCloneStatusResponse) GetSnapshotName 

func (x *SnapshotCloneStatusResponse) GetSnapshotName() string

func (*SnapshotCloneStatusResponse) GetState 

func (x *SnapshotCloneStatusResponse) GetState() string

func (*SnapshotCloneStatusResponse) ProtoMessage 

func (*SnapshotCloneStatusResponse) ProtoMessage()

func (*SnapshotCloneStatusResponse) ProtoReflect 

func (x *SnapshotCloneStatusResponse) ProtoReflect() protoreflect.Message

func (*SnapshotCloneStatusResponse) Reset 

func (x *SnapshotCloneStatusResponse) Reset()

func (*SnapshotCloneStatusResponse) String 

func (x *SnapshotCloneStatusResponse) String() string

type SnapshotHashCancelRequest 

type SnapshotHashCancelRequest struct {
	SnapshotName string `protobuf:"bytes,1,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotHashCancelRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotHashCancelRequest.ProtoReflect.Descriptor instead.

func (*SnapshotHashCancelRequest) GetSnapshotName 

func (x *SnapshotHashCancelRequest) GetSnapshotName() string

func (*SnapshotHashCancelRequest) ProtoMessage 

func (*SnapshotHashCancelRequest) ProtoMessage()

func (*SnapshotHashCancelRequest) ProtoReflect 

func (x *SnapshotHashCancelRequest) ProtoReflect() protoreflect.Message

func (*SnapshotHashCancelRequest) Reset 

func (x *SnapshotHashCancelRequest) Reset()

func (*SnapshotHashCancelRequest) String 

func (x *SnapshotHashCancelRequest) String() string

type SnapshotHashLockStateResponse 

type SnapshotHashLockStateResponse struct {
	IsLocked bool `protobuf:"varint,1,opt,name=is_locked,json=isLocked,proto3" json:"is_locked,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotHashLockStateResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotHashLockStateResponse.ProtoReflect.Descriptor instead.

func (*SnapshotHashLockStateResponse) GetIsLocked 

func (x *SnapshotHashLockStateResponse) GetIsLocked() bool

func (*SnapshotHashLockStateResponse) ProtoMessage 

func (*SnapshotHashLockStateResponse) ProtoMessage()

func (*SnapshotHashLockStateResponse) ProtoReflect 

func (x *SnapshotHashLockStateResponse) ProtoReflect() protoreflect.Message

func (*SnapshotHashLockStateResponse) Reset 

func (x *SnapshotHashLockStateResponse) Reset()

func (*SnapshotHashLockStateResponse) String 

func (x *SnapshotHashLockStateResponse) String() string

type SnapshotHashRequest 

type SnapshotHashRequest struct {
	SnapshotName string `protobuf:"bytes,1,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	Rehash       bool   `protobuf:"varint,2,opt,name=rehash,proto3" json:"rehash,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotHashRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotHashRequest.ProtoReflect.Descriptor instead.

func (*SnapshotHashRequest) GetRehash 

func (x *SnapshotHashRequest) GetRehash() bool

func (*SnapshotHashRequest) GetSnapshotName 

func (x *SnapshotHashRequest) GetSnapshotName() string

func (*SnapshotHashRequest) ProtoMessage 

func (*SnapshotHashRequest) ProtoMessage()

func (*SnapshotHashRequest) ProtoReflect 

func (x *SnapshotHashRequest) ProtoReflect() protoreflect.Message

func (*SnapshotHashRequest) Reset 

func (x *SnapshotHashRequest) Reset()

func (*SnapshotHashRequest) String 

func (x *SnapshotHashRequest) String() string

type SnapshotHashStatusRequest 

type SnapshotHashStatusRequest struct {
	SnapshotName string `protobuf:"bytes,1,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotHashStatusRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotHashStatusRequest.ProtoReflect.Descriptor instead.

func (*SnapshotHashStatusRequest) GetSnapshotName 

func (x *SnapshotHashStatusRequest) GetSnapshotName() string

func (*SnapshotHashStatusRequest) ProtoMessage 

func (*SnapshotHashStatusRequest) ProtoMessage()

func (*SnapshotHashStatusRequest) ProtoReflect 

func (x *SnapshotHashStatusRequest) ProtoReflect() protoreflect.Message

func (*SnapshotHashStatusRequest) Reset 

func (x *SnapshotHashStatusRequest) Reset()

func (*SnapshotHashStatusRequest) String 

func (x *SnapshotHashStatusRequest) String() string

type SnapshotHashStatusResponse 

type SnapshotHashStatusResponse struct {
	State             string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Checksum          string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Error             string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	SilentlyCorrupted bool   `protobuf:"varint,4,opt,name=silently_corrupted,json=silentlyCorrupted,proto3" json:"silently_corrupted,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotHashStatusResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotHashStatusResponse.ProtoReflect.Descriptor instead.

func (*SnapshotHashStatusResponse) GetChecksum 

func (x *SnapshotHashStatusResponse) GetChecksum() string

func (*SnapshotHashStatusResponse) GetError 

func (x *SnapshotHashStatusResponse) GetError() string

func (*SnapshotHashStatusResponse) GetSilentlyCorrupted 

func (x *SnapshotHashStatusResponse) GetSilentlyCorrupted() bool

func (*SnapshotHashStatusResponse) GetState 

func (x *SnapshotHashStatusResponse) GetState() string

func (*SnapshotHashStatusResponse) ProtoMessage 

func (*SnapshotHashStatusResponse) ProtoMessage()

func (*SnapshotHashStatusResponse) ProtoReflect 

func (x *SnapshotHashStatusResponse) ProtoReflect() protoreflect.Message

func (*SnapshotHashStatusResponse) Reset 

func (x *SnapshotHashStatusResponse) Reset()

func (*SnapshotHashStatusResponse) String 

func (x *SnapshotHashStatusResponse) String() string

type SnapshotMaxCountSetRequest 

type SnapshotMaxCountSetRequest struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotMaxCountSetRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotMaxCountSetRequest.ProtoReflect.Descriptor instead.

func (*SnapshotMaxCountSetRequest) GetCount 

func (x *SnapshotMaxCountSetRequest) GetCount() int32

func (*SnapshotMaxCountSetRequest) ProtoMessage 

func (*SnapshotMaxCountSetRequest) ProtoMessage()

func (*SnapshotMaxCountSetRequest) ProtoReflect 

func (x *SnapshotMaxCountSetRequest) ProtoReflect() protoreflect.Message

func (*SnapshotMaxCountSetRequest) Reset 

func (x *SnapshotMaxCountSetRequest) Reset()

func (*SnapshotMaxCountSetRequest) String 

func (x *SnapshotMaxCountSetRequest) String() string

type SnapshotMaxCountSetResponse 

type SnapshotMaxCountSetResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotMaxCountSetResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotMaxCountSetResponse.ProtoReflect.Descriptor instead.

func (*SnapshotMaxCountSetResponse) GetReplica 

func (x *SnapshotMaxCountSetResponse) GetReplica() *Replica

func (*SnapshotMaxCountSetResponse) ProtoMessage 

func (*SnapshotMaxCountSetResponse) ProtoMessage()

func (*SnapshotMaxCountSetResponse) ProtoReflect 

func (x *SnapshotMaxCountSetResponse) ProtoReflect() protoreflect.Message

func (*SnapshotMaxCountSetResponse) Reset 

func (x *SnapshotMaxCountSetResponse) Reset()

func (*SnapshotMaxCountSetResponse) String 

func (x *SnapshotMaxCountSetResponse) String() string

type SnapshotMaxSizeSetRequest 

type SnapshotMaxSizeSetRequest struct {
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotMaxSizeSetRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotMaxSizeSetRequest.ProtoReflect.Descriptor instead.

func (*SnapshotMaxSizeSetRequest) GetSize 

func (x *SnapshotMaxSizeSetRequest) GetSize() int64

func (*SnapshotMaxSizeSetRequest) ProtoMessage 

func (*SnapshotMaxSizeSetRequest) ProtoMessage()

func (*SnapshotMaxSizeSetRequest) ProtoReflect 

func (x *SnapshotMaxSizeSetRequest) ProtoReflect() protoreflect.Message

func (*SnapshotMaxSizeSetRequest) Reset 

func (x *SnapshotMaxSizeSetRequest) Reset()

func (*SnapshotMaxSizeSetRequest) String 

func (x *SnapshotMaxSizeSetRequest) String() string

type SnapshotMaxSizeSetResponse 

type SnapshotMaxSizeSetResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotMaxSizeSetResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotMaxSizeSetResponse.ProtoReflect.Descriptor instead.

func (*SnapshotMaxSizeSetResponse) GetReplica 

func (x *SnapshotMaxSizeSetResponse) GetReplica() *Replica

func (*SnapshotMaxSizeSetResponse) ProtoMessage 

func (*SnapshotMaxSizeSetResponse) ProtoMessage()

func (*SnapshotMaxSizeSetResponse) ProtoReflect 

func (x *SnapshotMaxSizeSetResponse) ProtoReflect() protoreflect.Message

func (*SnapshotMaxSizeSetResponse) Reset 

func (x *SnapshotMaxSizeSetResponse) Reset()

func (*SnapshotMaxSizeSetResponse) String 

func (x *SnapshotMaxSizeSetResponse) String() string

type SnapshotPurgeStatusResponse 

type SnapshotPurgeStatusResponse struct {
	IsPurging bool   `protobuf:"varint,1,opt,name=is_purging,json=isPurging,proto3" json:"is_purging,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"`
	// contains filtered or unexported fields
}

func (*SnapshotPurgeStatusResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotPurgeStatusResponse.ProtoReflect.Descriptor instead.

func (*SnapshotPurgeStatusResponse) GetError 

func (x *SnapshotPurgeStatusResponse) GetError() string

func (*SnapshotPurgeStatusResponse) GetIsPurging 

func (x *SnapshotPurgeStatusResponse) GetIsPurging() bool

func (*SnapshotPurgeStatusResponse) GetProgress 

func (x *SnapshotPurgeStatusResponse) GetProgress() int32

func (*SnapshotPurgeStatusResponse) GetState 

func (x *SnapshotPurgeStatusResponse) GetState() string

func (*SnapshotPurgeStatusResponse) ProtoMessage 

func (*SnapshotPurgeStatusResponse) ProtoMessage()

func (*SnapshotPurgeStatusResponse) ProtoReflect 

func (x *SnapshotPurgeStatusResponse) ProtoReflect() protoreflect.Message

func (*SnapshotPurgeStatusResponse) Reset 

func (x *SnapshotPurgeStatusResponse) Reset()

func (*SnapshotPurgeStatusResponse) String 

func (x *SnapshotPurgeStatusResponse) String() string

type SyncAgentServiceClient 

type SyncAgentServiceClient interface {
	FileRemove(ctx context.Context, in *FileRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	FileRename(ctx context.Context, in *FileRenameRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	FileSend(ctx context.Context, in *FileSendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	FilesSync(ctx context.Context, in *FilesSyncRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotClone(ctx context.Context, in *SnapshotCloneRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VolumeExport(ctx context.Context, in *VolumeExportRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReceiverLaunch(ctx context.Context, in *ReceiverLaunchRequest, opts ...grpc.CallOption) (*ReceiverLaunchResponse, error)
	BackupCreate(ctx context.Context, in *BackupCreateRequest, opts ...grpc.CallOption) (*BackupCreateResponse, error)
	BackupRemove(ctx context.Context, in *BackupRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	BackupRestore(ctx context.Context, in *BackupRestoreRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	BackupStatus(ctx context.Context, in *BackupStatusRequest, opts ...grpc.CallOption) (*BackupStatusResponse, error)
	Reset(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RestoreStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RestoreStatusResponse, error)
	SnapshotPurge(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotPurgeStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SnapshotPurgeStatusResponse, error)
	ReplicaRebuildStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReplicaRebuildStatusResponse, error)
	SnapshotCloneStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SnapshotCloneStatusResponse, error)
	SnapshotHash(ctx context.Context, in *SnapshotHashRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotHashStatus(ctx context.Context, in *SnapshotHashStatusRequest, opts ...grpc.CallOption) (*SnapshotHashStatusResponse, error)
	SnapshotHashCancel(ctx context.Context, in *SnapshotHashCancelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotHashLockState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SnapshotHashLockStateResponse, error)
}

SyncAgentServiceClient is the client API for SyncAgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSyncAgentServiceClient 

func NewSyncAgentServiceClient(cc grpc.ClientConnInterface) SyncAgentServiceClient

type SyncAgentServiceServer 

type SyncAgentServiceServer interface {
	FileRemove(context.Context, *FileRemoveRequest) (*emptypb.Empty, error)
	FileRename(context.Context, *FileRenameRequest) (*emptypb.Empty, error)
	FileSend(context.Context, *FileSendRequest) (*emptypb.Empty, error)
	FilesSync(context.Context, *FilesSyncRequest) (*emptypb.Empty, error)
	SnapshotClone(context.Context, *SnapshotCloneRequest) (*emptypb.Empty, error)
	VolumeExport(context.Context, *VolumeExportRequest) (*emptypb.Empty, error)
	ReceiverLaunch(context.Context, *ReceiverLaunchRequest) (*ReceiverLaunchResponse, error)
	BackupCreate(context.Context, *BackupCreateRequest) (*BackupCreateResponse, error)
	BackupRemove(context.Context, *BackupRemoveRequest) (*emptypb.Empty, error)
	BackupRestore(context.Context, *BackupRestoreRequest) (*emptypb.Empty, error)
	BackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error)
	Reset(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	RestoreStatus(context.Context, *emptypb.Empty) (*RestoreStatusResponse, error)
	SnapshotPurge(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	SnapshotPurgeStatus(context.Context, *emptypb.Empty) (*SnapshotPurgeStatusResponse, error)
	ReplicaRebuildStatus(context.Context, *emptypb.Empty) (*ReplicaRebuildStatusResponse, error)
	SnapshotCloneStatus(context.Context, *emptypb.Empty) (*SnapshotCloneStatusResponse, error)
	SnapshotHash(context.Context, *SnapshotHashRequest) (*emptypb.Empty, error)
	SnapshotHashStatus(context.Context, *SnapshotHashStatusRequest) (*SnapshotHashStatusResponse, error)
	SnapshotHashCancel(context.Context, *SnapshotHashCancelRequest) (*emptypb.Empty, error)
	SnapshotHashLockState(context.Context, *emptypb.Empty) (*SnapshotHashLockStateResponse, error)
	// contains filtered or unexported methods
}

SyncAgentServiceServer is the server API for SyncAgentService service. All implementations must embed UnimplementedSyncAgentServiceServer for forward compatibility

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

func (*SyncFileInfo) Descriptor deprecated 

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

Deprecated: Use SyncFileInfo.ProtoReflect.Descriptor instead.

func (*SyncFileInfo) GetActualSize 

func (x *SyncFileInfo) GetActualSize() int64

func (*SyncFileInfo) GetFromFileName 

func (x *SyncFileInfo) GetFromFileName() string

func (*SyncFileInfo) GetToFileName 

func (x *SyncFileInfo) GetToFileName() string

func (*SyncFileInfo) ProtoMessage 

func (*SyncFileInfo) ProtoMessage()

func (*SyncFileInfo) ProtoReflect 

func (x *SyncFileInfo) ProtoReflect() protoreflect.Message

func (*SyncFileInfo) Reset 

func (x *SyncFileInfo) Reset()

func (*SyncFileInfo) String 

func (x *SyncFileInfo) String() string

type UnimplementedControllerServiceServer 

type UnimplementedControllerServiceServer struct {
}

UnimplementedControllerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedControllerServiceServer) ControllerReplicaCreate 

func (UnimplementedControllerServiceServer) ControllerReplicaCreate(context.Context, *ControllerReplicaCreateRequest) (*ControllerReplica, error)

func (UnimplementedControllerServiceServer) JournalList 

func (UnimplementedControllerServiceServer) JournalList(context.Context, *JournalListRequest) (*emptypb.Empty, error)

func (UnimplementedControllerServiceServer) MetricsGet 

func (UnimplementedControllerServiceServer) MetricsGet(context.Context, *emptypb.Empty) (*MetricsGetReply, error)

func (UnimplementedControllerServiceServer) ReplicaDelete 

func (UnimplementedControllerServiceServer) ReplicaDelete(context.Context, *ReplicaAddress) (*emptypb.Empty, error)

func (UnimplementedControllerServiceServer) ReplicaGet 

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

func (UnimplementedControllerServiceServer) ReplicaList 

func (UnimplementedControllerServiceServer) ReplicaList(context.Context, *emptypb.Empty) (*ReplicaListReply, error)

func (UnimplementedControllerServiceServer) ReplicaPrepareRebuild 

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

func (UnimplementedControllerServiceServer) ReplicaUpdate 

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

func (UnimplementedControllerServiceServer) ReplicaVerifyRebuild 

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

func (UnimplementedControllerServiceServer) VersionDetailGet 

func (UnimplementedControllerServiceServer) VersionDetailGet(context.Context, *emptypb.Empty) (*VersionDetailGetReply, error)

func (UnimplementedControllerServiceServer) VolumeExpand 

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

func (UnimplementedControllerServiceServer) VolumeFrontendShutdown 

func (UnimplementedControllerServiceServer) VolumeFrontendShutdown(context.Context, *emptypb.Empty) (*Volume, error)

func (UnimplementedControllerServiceServer) VolumeFrontendStart 

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

func (UnimplementedControllerServiceServer) VolumeGet 

func (UnimplementedControllerServiceServer) VolumeGet(context.Context, *emptypb.Empty) (*Volume, error)

func (UnimplementedControllerServiceServer) VolumeRevert 

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

func (UnimplementedControllerServiceServer) VolumeShutdown 

func (UnimplementedControllerServiceServer) VolumeShutdown(context.Context, *emptypb.Empty) (*Volume, error)

func (UnimplementedControllerServiceServer) VolumeSnapshot 

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

func (UnimplementedControllerServiceServer) VolumeSnapshotMaxCountSet 

func (UnimplementedControllerServiceServer) VolumeSnapshotMaxCountSet(context.Context, *VolumeSnapshotMaxCountSetRequest) (*Volume, error)

func (UnimplementedControllerServiceServer) VolumeSnapshotMaxSizeSet 

func (UnimplementedControllerServiceServer) VolumeSnapshotMaxSizeSet(context.Context, *VolumeSnapshotMaxSizeSetRequest) (*Volume, error)

func (UnimplementedControllerServiceServer) VolumeStart 

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

func (UnimplementedControllerServiceServer) VolumeUnmapMarkSnapChainRemovedSet 

func (UnimplementedControllerServiceServer) VolumeUnmapMarkSnapChainRemovedSet(context.Context, *VolumeUnmapMarkSnapChainRemovedSetRequest) (*Volume, error)

type UnimplementedReplicaServiceServer 

type UnimplementedReplicaServiceServer struct {
}

UnimplementedReplicaServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReplicaServiceServer) DiskMarkAsRemoved 

func (UnimplementedReplicaServiceServer) DiskMarkAsRemoved(context.Context, *DiskMarkAsRemovedRequest) (*DiskMarkAsRemovedResponse, error)

func (UnimplementedReplicaServiceServer) DiskPrepareRemove 

func (UnimplementedReplicaServiceServer) DiskPrepareRemove(context.Context, *DiskPrepareRemoveRequest) (*DiskPrepareRemoveResponse, error)

func (UnimplementedReplicaServiceServer) DiskRemove 

func (UnimplementedReplicaServiceServer) DiskRemove(context.Context, *DiskRemoveRequest) (*DiskRemoveResponse, error)

func (UnimplementedReplicaServiceServer) DiskReplace 

func (UnimplementedReplicaServiceServer) DiskReplace(context.Context, *DiskReplaceRequest) (*DiskReplaceResponse, error)

func (UnimplementedReplicaServiceServer) RebuildingSet 

func (UnimplementedReplicaServiceServer) RebuildingSet(context.Context, *RebuildingSetRequest) (*RebuildingSetResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaClose 

func (UnimplementedReplicaServiceServer) ReplicaClose(context.Context, *emptypb.Empty) (*ReplicaCloseResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaCreate 

func (UnimplementedReplicaServiceServer) ReplicaCreate(context.Context, *ReplicaCreateRequest) (*ReplicaCreateResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaDelete 

func (UnimplementedReplicaServiceServer) ReplicaDelete(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedReplicaServiceServer) ReplicaExpand 

func (UnimplementedReplicaServiceServer) ReplicaExpand(context.Context, *ReplicaExpandRequest) (*ReplicaExpandResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaGet 

func (UnimplementedReplicaServiceServer) ReplicaGet(context.Context, *emptypb.Empty) (*ReplicaGetResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaOpen 

func (UnimplementedReplicaServiceServer) ReplicaOpen(context.Context, *emptypb.Empty) (*ReplicaOpenResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaReload 

func (UnimplementedReplicaServiceServer) ReplicaReload(context.Context, *emptypb.Empty) (*ReplicaReloadResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaRevert 

func (UnimplementedReplicaServiceServer) ReplicaRevert(context.Context, *ReplicaRevertRequest) (*ReplicaRevertResponse, error)

func (UnimplementedReplicaServiceServer) ReplicaSnapshot 

func (UnimplementedReplicaServiceServer) ReplicaSnapshot(context.Context, *ReplicaSnapshotRequest) (*ReplicaSnapshotResponse, error)

func (UnimplementedReplicaServiceServer) RevisionCounterSet 

func (UnimplementedReplicaServiceServer) RevisionCounterSet(context.Context, *RevisionCounterSetRequest) (*RevisionCounterSetResponse, error)

func (UnimplementedReplicaServiceServer) SnapshotMaxCountSet 

func (UnimplementedReplicaServiceServer) SnapshotMaxCountSet(context.Context, *SnapshotMaxCountSetRequest) (*SnapshotMaxCountSetResponse, error)

func (UnimplementedReplicaServiceServer) SnapshotMaxSizeSet 

func (UnimplementedReplicaServiceServer) SnapshotMaxSizeSet(context.Context, *SnapshotMaxSizeSetRequest) (*SnapshotMaxSizeSetResponse, error)

func (UnimplementedReplicaServiceServer) UnmapMarkDiskChainRemovedSet 

func (UnimplementedReplicaServiceServer) UnmapMarkDiskChainRemovedSet(context.Context, *UnmapMarkDiskChainRemovedSetRequest) (*UnmapMarkDiskChainRemovedSetResponse, error)

type UnimplementedSyncAgentServiceServer 

type UnimplementedSyncAgentServiceServer struct {
}

UnimplementedSyncAgentServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSyncAgentServiceServer) BackupCreate 

func (UnimplementedSyncAgentServiceServer) BackupCreate(context.Context, *BackupCreateRequest) (*BackupCreateResponse, error)

func (UnimplementedSyncAgentServiceServer) BackupRemove 

func (UnimplementedSyncAgentServiceServer) BackupRemove(context.Context, *BackupRemoveRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) BackupRestore 

func (UnimplementedSyncAgentServiceServer) BackupRestore(context.Context, *BackupRestoreRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) BackupStatus 

func (UnimplementedSyncAgentServiceServer) BackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error)

func (UnimplementedSyncAgentServiceServer) FileRemove 

func (UnimplementedSyncAgentServiceServer) FileRemove(context.Context, *FileRemoveRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) FileRename 

func (UnimplementedSyncAgentServiceServer) FileRename(context.Context, *FileRenameRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) FileSend 

func (UnimplementedSyncAgentServiceServer) FileSend(context.Context, *FileSendRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) FilesSync 

func (UnimplementedSyncAgentServiceServer) FilesSync(context.Context, *FilesSyncRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) ReceiverLaunch 

func (UnimplementedSyncAgentServiceServer) ReceiverLaunch(context.Context, *ReceiverLaunchRequest) (*ReceiverLaunchResponse, error)

func (UnimplementedSyncAgentServiceServer) ReplicaRebuildStatus 

func (UnimplementedSyncAgentServiceServer) ReplicaRebuildStatus(context.Context, *emptypb.Empty) (*ReplicaRebuildStatusResponse, error)

func (UnimplementedSyncAgentServiceServer) Reset 

func (UnimplementedSyncAgentServiceServer) Reset(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) RestoreStatus 

func (UnimplementedSyncAgentServiceServer) RestoreStatus(context.Context, *emptypb.Empty) (*RestoreStatusResponse, error)

func (UnimplementedSyncAgentServiceServer) SnapshotClone 

func (UnimplementedSyncAgentServiceServer) SnapshotClone(context.Context, *SnapshotCloneRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) SnapshotCloneStatus 

func (UnimplementedSyncAgentServiceServer) SnapshotCloneStatus(context.Context, *emptypb.Empty) (*SnapshotCloneStatusResponse, error)

func (UnimplementedSyncAgentServiceServer) SnapshotHash 

func (UnimplementedSyncAgentServiceServer) SnapshotHash(context.Context, *SnapshotHashRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) SnapshotHashCancel 

func (UnimplementedSyncAgentServiceServer) SnapshotHashCancel(context.Context, *SnapshotHashCancelRequest) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) SnapshotHashLockState 

func (UnimplementedSyncAgentServiceServer) SnapshotHashLockState(context.Context, *emptypb.Empty) (*SnapshotHashLockStateResponse, error)

func (UnimplementedSyncAgentServiceServer) SnapshotHashStatus 

func (UnimplementedSyncAgentServiceServer) SnapshotHashStatus(context.Context, *SnapshotHashStatusRequest) (*SnapshotHashStatusResponse, error)

func (UnimplementedSyncAgentServiceServer) SnapshotPurge 

func (UnimplementedSyncAgentServiceServer) SnapshotPurge(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedSyncAgentServiceServer) SnapshotPurgeStatus 

func (UnimplementedSyncAgentServiceServer) SnapshotPurgeStatus(context.Context, *emptypb.Empty) (*SnapshotPurgeStatusResponse, error)

func (UnimplementedSyncAgentServiceServer) VolumeExport 

func (UnimplementedSyncAgentServiceServer) VolumeExport(context.Context, *VolumeExportRequest) (*emptypb.Empty, error)

type UnmapMarkDiskChainRemovedSetRequest 

type UnmapMarkDiskChainRemovedSetRequest struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*UnmapMarkDiskChainRemovedSetRequest) Descriptor deprecated 

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

Deprecated: Use UnmapMarkDiskChainRemovedSetRequest.ProtoReflect.Descriptor instead.

func (*UnmapMarkDiskChainRemovedSetRequest) GetEnabled 

func (x *UnmapMarkDiskChainRemovedSetRequest) GetEnabled() bool

func (*UnmapMarkDiskChainRemovedSetRequest) ProtoMessage 

func (*UnmapMarkDiskChainRemovedSetRequest) ProtoMessage()

func (*UnmapMarkDiskChainRemovedSetRequest) ProtoReflect 

func (x *UnmapMarkDiskChainRemovedSetRequest) ProtoReflect() protoreflect.Message

func (*UnmapMarkDiskChainRemovedSetRequest) Reset 

func (x *UnmapMarkDiskChainRemovedSetRequest) Reset()

func (*UnmapMarkDiskChainRemovedSetRequest) String 

func (x *UnmapMarkDiskChainRemovedSetRequest) String() string

type UnmapMarkDiskChainRemovedSetResponse 

type UnmapMarkDiskChainRemovedSetResponse struct {
	Replica *Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*UnmapMarkDiskChainRemovedSetResponse) Descriptor deprecated 

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

Deprecated: Use UnmapMarkDiskChainRemovedSetResponse.ProtoReflect.Descriptor instead.

func (*UnmapMarkDiskChainRemovedSetResponse) GetReplica 

func (x *UnmapMarkDiskChainRemovedSetResponse) GetReplica() *Replica

func (*UnmapMarkDiskChainRemovedSetResponse) ProtoMessage 

func (*UnmapMarkDiskChainRemovedSetResponse) ProtoMessage()

func (*UnmapMarkDiskChainRemovedSetResponse) ProtoReflect 

func (x *UnmapMarkDiskChainRemovedSetResponse) ProtoReflect() protoreflect.Message

func (*UnmapMarkDiskChainRemovedSetResponse) Reset 

func (x *UnmapMarkDiskChainRemovedSetResponse) Reset()

func (*UnmapMarkDiskChainRemovedSetResponse) String 

func (x *UnmapMarkDiskChainRemovedSetResponse) String() string

type UnsafeControllerServiceServer 

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

UnsafeControllerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControllerServiceServer will result in compilation errors.

type UnsafeReplicaServiceServer 

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

UnsafeReplicaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReplicaServiceServer will result in compilation errors.

type UnsafeSyncAgentServiceServer 

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

UnsafeSyncAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SyncAgentServiceServer will result in compilation errors.

type VersionDetailGetReply 

type VersionDetailGetReply struct {
	Version *VersionOutput `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionDetailGetReply) Descriptor deprecated 

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

Deprecated: Use VersionDetailGetReply.ProtoReflect.Descriptor instead.

func (*VersionDetailGetReply) GetVersion 

func (x *VersionDetailGetReply) GetVersion() *VersionOutput

func (*VersionDetailGetReply) ProtoMessage 

func (*VersionDetailGetReply) ProtoMessage()

func (*VersionDetailGetReply) ProtoReflect 

func (x *VersionDetailGetReply) ProtoReflect() protoreflect.Message

func (*VersionDetailGetReply) Reset 

func (x *VersionDetailGetReply) Reset()

func (*VersionDetailGetReply) String 

func (x *VersionDetailGetReply) String() string

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

func (*VersionOutput) Descriptor deprecated 

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

Deprecated: Use VersionOutput.ProtoReflect.Descriptor instead.

func (*VersionOutput) GetBuildDate 

func (x *VersionOutput) GetBuildDate() string

func (*VersionOutput) GetCliAPIMinVersion 

func (x *VersionOutput) GetCliAPIMinVersion() int64

func (*VersionOutput) GetCliAPIVersion 

func (x *VersionOutput) GetCliAPIVersion() int64

func (*VersionOutput) GetControllerAPIMinVersion 

func (x *VersionOutput) GetControllerAPIMinVersion() int64

func (*VersionOutput) GetControllerAPIVersion 

func (x *VersionOutput) GetControllerAPIVersion() int64

func (*VersionOutput) GetDataFormatMinVersion 

func (x *VersionOutput) GetDataFormatMinVersion() int64

func (*VersionOutput) GetDataFormatVersion 

func (x *VersionOutput) GetDataFormatVersion() int64

func (*VersionOutput) GetGitCommit 

func (x *VersionOutput) GetGitCommit() string

func (*VersionOutput) GetVersion 

func (x *VersionOutput) GetVersion() string

func (*VersionOutput) ProtoMessage 

func (*VersionOutput) ProtoMessage()

func (*VersionOutput) ProtoReflect 

func (x *VersionOutput) ProtoReflect() protoreflect.Message

func (*VersionOutput) Reset 

func (x *VersionOutput) Reset()

func (*VersionOutput) String 

func (x *VersionOutput) String() string

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 */
	UnmapMarkSnapChainRemoved bool   `` /* 144-byte string literal not displayed */
	SnapshotMaxCount          int32  `protobuf:"varint,11,opt,name=snapshot_max_count,json=snapshotMaxCount,proto3" json:"snapshot_max_count,omitempty"`
	SnapshotMaxSize           int64  `protobuf:"varint,12,opt,name=snapshot_max_size,json=snapshotMaxSize,proto3" json:"snapshot_max_size,omitempty"`
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated 

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetEndpoint 

func (x *Volume) GetEndpoint() string

func (*Volume) GetFrontend 

func (x *Volume) GetFrontend() string

func (*Volume) GetFrontendState 

func (x *Volume) GetFrontendState() string

func (*Volume) GetIsExpanding 

func (x *Volume) GetIsExpanding() bool

func (*Volume) GetLastExpansionError 

func (x *Volume) GetLastExpansionError() string

func (*Volume) GetLastExpansionFailedAt 

func (x *Volume) GetLastExpansionFailedAt() string

func (*Volume) GetName 

func (x *Volume) GetName() string

func (*Volume) GetReplicaCount 

func (x *Volume) GetReplicaCount() int32

func (*Volume) GetSize 

func (x *Volume) GetSize() int64

func (*Volume) GetSnapshotMaxCount 

func (x *Volume) GetSnapshotMaxCount() int32

func (*Volume) GetSnapshotMaxSize 

func (x *Volume) GetSnapshotMaxSize() int64

func (*Volume) GetUnmapMarkSnapChainRemoved 

func (x *Volume) GetUnmapMarkSnapChainRemoved() bool

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

func (x *Volume) ProtoReflect() protoreflect.Message

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type VolumeExpandRequest 

type VolumeExpandRequest struct {
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeExpandRequest) Descriptor deprecated 

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

Deprecated: Use VolumeExpandRequest.ProtoReflect.Descriptor instead.

func (*VolumeExpandRequest) GetSize 

func (x *VolumeExpandRequest) GetSize() int64

func (*VolumeExpandRequest) ProtoMessage 

func (*VolumeExpandRequest) ProtoMessage()

func (*VolumeExpandRequest) ProtoReflect 

func (x *VolumeExpandRequest) ProtoReflect() protoreflect.Message

func (*VolumeExpandRequest) Reset 

func (x *VolumeExpandRequest) Reset()

func (*VolumeExpandRequest) String 

func (x *VolumeExpandRequest) String() string

type VolumeExportRequest 

type VolumeExportRequest struct {
	SnapshotFileName          string `protobuf:"bytes,1,opt,name=snapshot_file_name,json=snapshotFileName,proto3" json:"snapshot_file_name,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"`
	ExportBackingImageIfExist bool   `` /* 143-byte string literal not displayed */
	FileSyncHttpClientTimeout int32  `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VolumeExportRequest) Descriptor deprecated 

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

Deprecated: Use VolumeExportRequest.ProtoReflect.Descriptor instead.

func (*VolumeExportRequest) GetExportBackingImageIfExist 

func (x *VolumeExportRequest) GetExportBackingImageIfExist() bool

func (*VolumeExportRequest) GetFileSyncHttpClientTimeout 

func (x *VolumeExportRequest) GetFileSyncHttpClientTimeout() int32

func (*VolumeExportRequest) GetHost 

func (x *VolumeExportRequest) GetHost() string

func (*VolumeExportRequest) GetPort 

func (x *VolumeExportRequest) GetPort() int32

func (*VolumeExportRequest) GetSnapshotFileName 

func (x *VolumeExportRequest) GetSnapshotFileName() string

func (*VolumeExportRequest) ProtoMessage 

func (*VolumeExportRequest) ProtoMessage()

func (*VolumeExportRequest) ProtoReflect 

func (x *VolumeExportRequest) ProtoReflect() protoreflect.Message

func (*VolumeExportRequest) Reset 

func (x *VolumeExportRequest) Reset()

func (*VolumeExportRequest) String 

func (x *VolumeExportRequest) String() string

type VolumeFinishRestoreRequest 

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

func (*VolumeFinishRestoreRequest) Descriptor deprecated 

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

Deprecated: Use VolumeFinishRestoreRequest.ProtoReflect.Descriptor instead.

func (*VolumeFinishRestoreRequest) GetCurrentRestored 

func (x *VolumeFinishRestoreRequest) GetCurrentRestored() string

func (*VolumeFinishRestoreRequest) ProtoMessage 

func (*VolumeFinishRestoreRequest) ProtoMessage()

func (*VolumeFinishRestoreRequest) ProtoReflect 

func (x *VolumeFinishRestoreRequest) ProtoReflect() protoreflect.Message

func (*VolumeFinishRestoreRequest) Reset 

func (x *VolumeFinishRestoreRequest) Reset()

func (*VolumeFinishRestoreRequest) String 

func (x *VolumeFinishRestoreRequest) String() string

type VolumeFrontendStartRequest 

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

func (*VolumeFrontendStartRequest) Descriptor deprecated 

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

Deprecated: Use VolumeFrontendStartRequest.ProtoReflect.Descriptor instead.

func (*VolumeFrontendStartRequest) GetFrontend 

func (x *VolumeFrontendStartRequest) GetFrontend() string

func (*VolumeFrontendStartRequest) ProtoMessage 

func (*VolumeFrontendStartRequest) ProtoMessage()

func (*VolumeFrontendStartRequest) ProtoReflect 

func (x *VolumeFrontendStartRequest) ProtoReflect() protoreflect.Message

func (*VolumeFrontendStartRequest) Reset 

func (x *VolumeFrontendStartRequest) Reset()

func (*VolumeFrontendStartRequest) String 

func (x *VolumeFrontendStartRequest) String() string

type VolumePrepareRestoreRequest 

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

func (*VolumePrepareRestoreRequest) Descriptor deprecated 

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

Deprecated: Use VolumePrepareRestoreRequest.ProtoReflect.Descriptor instead.

func (*VolumePrepareRestoreRequest) GetLastRestored 

func (x *VolumePrepareRestoreRequest) GetLastRestored() string

func (*VolumePrepareRestoreRequest) ProtoMessage 

func (*VolumePrepareRestoreRequest) ProtoMessage()

func (*VolumePrepareRestoreRequest) ProtoReflect 

func (x *VolumePrepareRestoreRequest) ProtoReflect() protoreflect.Message

func (*VolumePrepareRestoreRequest) Reset 

func (x *VolumePrepareRestoreRequest) Reset()

func (*VolumePrepareRestoreRequest) String 

func (x *VolumePrepareRestoreRequest) String() string

type VolumeRevertRequest 

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

func (*VolumeRevertRequest) Descriptor deprecated 

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

Deprecated: Use VolumeRevertRequest.ProtoReflect.Descriptor instead.

func (*VolumeRevertRequest) GetName 

func (x *VolumeRevertRequest) GetName() string

func (*VolumeRevertRequest) ProtoMessage 

func (*VolumeRevertRequest) ProtoMessage()

func (*VolumeRevertRequest) ProtoReflect 

func (x *VolumeRevertRequest) ProtoReflect() protoreflect.Message

func (*VolumeRevertRequest) Reset 

func (x *VolumeRevertRequest) Reset()

func (*VolumeRevertRequest) String 

func (x *VolumeRevertRequest) String() string

type VolumeSnapshotMaxCountSetRequest 

type VolumeSnapshotMaxCountSetRequest struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeSnapshotMaxCountSetRequest) Descriptor deprecated 

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

Deprecated: Use VolumeSnapshotMaxCountSetRequest.ProtoReflect.Descriptor instead.

func (*VolumeSnapshotMaxCountSetRequest) GetCount 

func (x *VolumeSnapshotMaxCountSetRequest) GetCount() int32

func (*VolumeSnapshotMaxCountSetRequest) ProtoMessage 

func (*VolumeSnapshotMaxCountSetRequest) ProtoMessage()

func (*VolumeSnapshotMaxCountSetRequest) ProtoReflect 

func (x *VolumeSnapshotMaxCountSetRequest) ProtoReflect() protoreflect.Message

func (*VolumeSnapshotMaxCountSetRequest) Reset 

func (x *VolumeSnapshotMaxCountSetRequest) Reset()

func (*VolumeSnapshotMaxCountSetRequest) String 

func (x *VolumeSnapshotMaxCountSetRequest) String() string

type VolumeSnapshotMaxSizeSetRequest 

type VolumeSnapshotMaxSizeSetRequest struct {
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeSnapshotMaxSizeSetRequest) Descriptor deprecated 

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

Deprecated: Use VolumeSnapshotMaxSizeSetRequest.ProtoReflect.Descriptor instead.

func (*VolumeSnapshotMaxSizeSetRequest) GetSize 

func (x *VolumeSnapshotMaxSizeSetRequest) GetSize() int64

func (*VolumeSnapshotMaxSizeSetRequest) ProtoMessage 

func (*VolumeSnapshotMaxSizeSetRequest) ProtoMessage()

func (*VolumeSnapshotMaxSizeSetRequest) ProtoReflect 

func (x *VolumeSnapshotMaxSizeSetRequest) ProtoReflect() protoreflect.Message

func (*VolumeSnapshotMaxSizeSetRequest) Reset 

func (x *VolumeSnapshotMaxSizeSetRequest) Reset()

func (*VolumeSnapshotMaxSizeSetRequest) String 

func (x *VolumeSnapshotMaxSizeSetRequest) String() string

type VolumeSnapshotReply 

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

func (*VolumeSnapshotReply) Descriptor deprecated 

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

Deprecated: Use VolumeSnapshotReply.ProtoReflect.Descriptor instead.

func (*VolumeSnapshotReply) GetName 

func (x *VolumeSnapshotReply) GetName() string

func (*VolumeSnapshotReply) ProtoMessage 

func (*VolumeSnapshotReply) ProtoMessage()

func (*VolumeSnapshotReply) ProtoReflect 

func (x *VolumeSnapshotReply) ProtoReflect() protoreflect.Message

func (*VolumeSnapshotReply) Reset 

func (x *VolumeSnapshotReply) Reset()

func (*VolumeSnapshotReply) String 

func (x *VolumeSnapshotReply) String() string

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 */
	// Freeze the filesystem on the root partition. May be implemented with fsfreeze -f,
	// dmsetup suspend without --nolockfs, or similar.
	FreezeFilesystem bool `protobuf:"varint,3,opt,name=freezeFilesystem,proto3" json:"freezeFilesystem,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use VolumeSnapshotRequest.ProtoReflect.Descriptor instead.

func (*VolumeSnapshotRequest) GetFreezeFilesystem 

func (x *VolumeSnapshotRequest) GetFreezeFilesystem() bool

func (*VolumeSnapshotRequest) GetLabels 

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

func (*VolumeSnapshotRequest) GetName 

func (x *VolumeSnapshotRequest) GetName() string

func (*VolumeSnapshotRequest) ProtoMessage 

func (*VolumeSnapshotRequest) ProtoMessage()

func (*VolumeSnapshotRequest) ProtoReflect 

func (x *VolumeSnapshotRequest) ProtoReflect() protoreflect.Message

func (*VolumeSnapshotRequest) Reset 

func (x *VolumeSnapshotRequest) Reset()

func (*VolumeSnapshotRequest) String 

func (x *VolumeSnapshotRequest) String() string

type VolumeStartRequest 

type VolumeStartRequest struct {
	ReplicaAddresses []string `protobuf:"bytes,1,rep,name=replicaAddresses,proto3" json:"replicaAddresses,omitempty"`
	Size             int64    `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	CurrentSize      int64    `protobuf:"varint,3,opt,name=currentSize,proto3" json:"currentSize,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeStartRequest) Descriptor deprecated 

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

Deprecated: Use VolumeStartRequest.ProtoReflect.Descriptor instead.

func (*VolumeStartRequest) GetCurrentSize 

func (x *VolumeStartRequest) GetCurrentSize() int64

func (*VolumeStartRequest) GetReplicaAddresses 

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

func (*VolumeStartRequest) GetSize 

func (x *VolumeStartRequest) GetSize() int64

func (*VolumeStartRequest) ProtoMessage 

func (*VolumeStartRequest) ProtoMessage()

func (*VolumeStartRequest) ProtoReflect 

func (x *VolumeStartRequest) ProtoReflect() protoreflect.Message

func (*VolumeStartRequest) Reset 

func (x *VolumeStartRequest) Reset()

func (*VolumeStartRequest) String 

func (x *VolumeStartRequest) String() string

type VolumeUnmapMarkSnapChainRemovedSetRequest 

type VolumeUnmapMarkSnapChainRemovedSetRequest struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeUnmapMarkSnapChainRemovedSetRequest) Descriptor deprecated 

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

Deprecated: Use VolumeUnmapMarkSnapChainRemovedSetRequest.ProtoReflect.Descriptor instead.

func (*VolumeUnmapMarkSnapChainRemovedSetRequest) GetEnabled 

func (x *VolumeUnmapMarkSnapChainRemovedSetRequest) GetEnabled() bool

func (*VolumeUnmapMarkSnapChainRemovedSetRequest) ProtoMessage 

func (*VolumeUnmapMarkSnapChainRemovedSetRequest) ProtoMessage()

func (*VolumeUnmapMarkSnapChainRemovedSetRequest) ProtoReflect 

func (x *VolumeUnmapMarkSnapChainRemovedSetRequest) ProtoReflect() protoreflect.Message

func (*VolumeUnmapMarkSnapChainRemovedSetRequest) Reset 

func (x *VolumeUnmapMarkSnapChainRemovedSetRequest) Reset()

func (*VolumeUnmapMarkSnapChainRemovedSetRequest) String 

func (x *VolumeUnmapMarkSnapChainRemovedSetRequest) String() string

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.