imrpc

package
v0.0.0-...-38dbed8 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DiskService_DiskCreate_FullMethodName                = "/imrpc.DiskService/DiskCreate"
	DiskService_DiskDelete_FullMethodName                = "/imrpc.DiskService/DiskDelete"
	DiskService_DiskGet_FullMethodName                   = "/imrpc.DiskService/DiskGet"
	DiskService_DiskReplicaInstanceList_FullMethodName   = "/imrpc.DiskService/DiskReplicaInstanceList"
	DiskService_DiskReplicaInstanceDelete_FullMethodName = "/imrpc.DiskService/DiskReplicaInstanceDelete"
	DiskService_VersionGet_FullMethodName                = "/imrpc.DiskService/VersionGet"
)
View Source 
const (
	ProcessManagerService_ProcessCreate_FullMethodName  = "/ProcessManagerService/ProcessCreate"
	ProcessManagerService_ProcessDelete_FullMethodName  = "/ProcessManagerService/ProcessDelete"
	ProcessManagerService_ProcessGet_FullMethodName     = "/ProcessManagerService/ProcessGet"
	ProcessManagerService_ProcessList_FullMethodName    = "/ProcessManagerService/ProcessList"
	ProcessManagerService_ProcessLog_FullMethodName     = "/ProcessManagerService/ProcessLog"
	ProcessManagerService_ProcessWatch_FullMethodName   = "/ProcessManagerService/ProcessWatch"
	ProcessManagerService_ProcessReplace_FullMethodName = "/ProcessManagerService/ProcessReplace"
	ProcessManagerService_VersionGet_FullMethodName     = "/ProcessManagerService/VersionGet"
)
View Source 
const (
	InstanceService_InstanceCreate_FullMethodName  = "/imrpc.InstanceService/InstanceCreate"
	InstanceService_InstanceDelete_FullMethodName  = "/imrpc.InstanceService/InstanceDelete"
	InstanceService_InstanceGet_FullMethodName     = "/imrpc.InstanceService/InstanceGet"
	InstanceService_InstanceList_FullMethodName    = "/imrpc.InstanceService/InstanceList"
	InstanceService_InstanceLog_FullMethodName     = "/imrpc.InstanceService/InstanceLog"
	InstanceService_InstanceWatch_FullMethodName   = "/imrpc.InstanceService/InstanceWatch"
	InstanceService_InstanceReplace_FullMethodName = "/imrpc.InstanceService/InstanceReplace"
	InstanceService_LogSetLevel_FullMethodName     = "/imrpc.InstanceService/LogSetLevel"
	InstanceService_LogSetFlags_FullMethodName     = "/imrpc.InstanceService/LogSetFlags"
	InstanceService_LogGetLevel_FullMethodName     = "/imrpc.InstanceService/LogGetLevel"
	InstanceService_LogGetFlags_FullMethodName     = "/imrpc.InstanceService/LogGetFlags"
	InstanceService_VersionGet_FullMethodName      = "/imrpc.InstanceService/VersionGet"
)
View Source 
const (
	ProxyEngineService_ServerVersionGet_FullMethodName                   = "/imrpc.ProxyEngineService/ServerVersionGet"
	ProxyEngineService_VolumeGet_FullMethodName                          = "/imrpc.ProxyEngineService/VolumeGet"
	ProxyEngineService_VolumeExpand_FullMethodName                       = "/imrpc.ProxyEngineService/VolumeExpand"
	ProxyEngineService_VolumeFrontendStart_FullMethodName                = "/imrpc.ProxyEngineService/VolumeFrontendStart"
	ProxyEngineService_VolumeFrontendShutdown_FullMethodName             = "/imrpc.ProxyEngineService/VolumeFrontendShutdown"
	ProxyEngineService_VolumeUnmapMarkSnapChainRemovedSet_FullMethodName = "/imrpc.ProxyEngineService/VolumeUnmapMarkSnapChainRemovedSet"
	ProxyEngineService_VolumeSnapshotMaxCountSet_FullMethodName          = "/imrpc.ProxyEngineService/VolumeSnapshotMaxCountSet"
	ProxyEngineService_VolumeSnapshotMaxSizeSet_FullMethodName           = "/imrpc.ProxyEngineService/VolumeSnapshotMaxSizeSet"
	ProxyEngineService_VolumeSnapshot_FullMethodName                     = "/imrpc.ProxyEngineService/VolumeSnapshot"
	ProxyEngineService_SnapshotList_FullMethodName                       = "/imrpc.ProxyEngineService/SnapshotList"
	ProxyEngineService_SnapshotRevert_FullMethodName                     = "/imrpc.ProxyEngineService/SnapshotRevert"
	ProxyEngineService_SnapshotPurge_FullMethodName                      = "/imrpc.ProxyEngineService/SnapshotPurge"
	ProxyEngineService_SnapshotPurgeStatus_FullMethodName                = "/imrpc.ProxyEngineService/SnapshotPurgeStatus"
	ProxyEngineService_SnapshotClone_FullMethodName                      = "/imrpc.ProxyEngineService/SnapshotClone"
	ProxyEngineService_SnapshotCloneStatus_FullMethodName                = "/imrpc.ProxyEngineService/SnapshotCloneStatus"
	ProxyEngineService_SnapshotRemove_FullMethodName                     = "/imrpc.ProxyEngineService/SnapshotRemove"
	ProxyEngineService_SnapshotHash_FullMethodName                       = "/imrpc.ProxyEngineService/SnapshotHash"
	ProxyEngineService_SnapshotHashStatus_FullMethodName                 = "/imrpc.ProxyEngineService/SnapshotHashStatus"
	ProxyEngineService_SnapshotBackup_FullMethodName                     = "/imrpc.ProxyEngineService/SnapshotBackup"
	ProxyEngineService_SnapshotBackupStatus_FullMethodName               = "/imrpc.ProxyEngineService/SnapshotBackupStatus"
	ProxyEngineService_BackupRestore_FullMethodName                      = "/imrpc.ProxyEngineService/BackupRestore"
	ProxyEngineService_BackupRestoreStatus_FullMethodName                = "/imrpc.ProxyEngineService/BackupRestoreStatus"
	ProxyEngineService_BackupRestoreFinish_FullMethodName                = "/imrpc.ProxyEngineService/BackupRestoreFinish"
	ProxyEngineService_CleanupBackupMountPoints_FullMethodName           = "/imrpc.ProxyEngineService/CleanupBackupMountPoints"
	ProxyEngineService_ReplicaAdd_FullMethodName                         = "/imrpc.ProxyEngineService/ReplicaAdd"
	ProxyEngineService_ReplicaList_FullMethodName                        = "/imrpc.ProxyEngineService/ReplicaList"
	ProxyEngineService_ReplicaRebuildingStatus_FullMethodName            = "/imrpc.ProxyEngineService/ReplicaRebuildingStatus"
	ProxyEngineService_ReplicaVerifyRebuild_FullMethodName               = "/imrpc.ProxyEngineService/ReplicaVerifyRebuild"
	ProxyEngineService_ReplicaRemove_FullMethodName                      = "/imrpc.ProxyEngineService/ReplicaRemove"
	ProxyEngineService_ReplicaModeUpdate_FullMethodName                  = "/imrpc.ProxyEngineService/ReplicaModeUpdate"
	ProxyEngineService_MetricsGet_FullMethodName                         = "/imrpc.ProxyEngineService/MetricsGet"
	ProxyEngineService_RemountReadOnlyVolume_FullMethodName              = "/imrpc.ProxyEngineService/RemountReadOnlyVolume"
)

Variables

View Source 
var (
	BackendStoreDriver_name = map[int32]string{
		0: "v1",
		1: "v2",
	}
	BackendStoreDriver_value = map[string]int32{
		"v1": 0,
		"v2": 1,
	}
)

Enum value maps for BackendStoreDriver.

View Source 
var (
	DataEngine_name = map[int32]string{
		0: "DATA_ENGINE_V1",
		1: "DATA_ENGINE_V2",
	}
	DataEngine_value = map[string]int32{
		"DATA_ENGINE_V1": 0,
		"DATA_ENGINE_V2": 1,
	}
)

Enum value maps for DataEngine.

View Source 
var (
	DiskType_name = map[int32]string{
		0: "filesystem",
		1: "block",
	}
	DiskType_value = map[string]int32{
		"filesystem": 0,
		"block":      1,
	}
)

Enum value maps for DiskType.

View Source 
var DiskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "imrpc.DiskService",
	HandlerType: (*DiskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DiskCreate",
			Handler:    _DiskService_DiskCreate_Handler,
		},
		{
			MethodName: "DiskDelete",
			Handler:    _DiskService_DiskDelete_Handler,
		},
		{
			MethodName: "DiskGet",
			Handler:    _DiskService_DiskGet_Handler,
		},
		{
			MethodName: "DiskReplicaInstanceList",
			Handler:    _DiskService_DiskReplicaInstanceList_Handler,
		},
		{
			MethodName: "DiskReplicaInstanceDelete",
			Handler:    _DiskService_DiskReplicaInstanceDelete_Handler,
		},
		{
			MethodName: "VersionGet",
			Handler:    _DiskService_VersionGet_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "imrpc/disk.proto",
}

DiskService_ServiceDesc is the grpc.ServiceDesc for DiskService 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_imrpc_common_proto protoreflect.FileDescriptor
View Source 
var File_imrpc_disk_proto protoreflect.FileDescriptor
View Source 
var File_imrpc_imrpc_proto protoreflect.FileDescriptor
View Source 
var File_imrpc_instance_proto protoreflect.FileDescriptor
View Source 
var File_imrpc_proxy_proto protoreflect.FileDescriptor
View Source 
var InstanceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "imrpc.InstanceService",
	HandlerType: (*InstanceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InstanceCreate",
			Handler:    _InstanceService_InstanceCreate_Handler,
		},
		{
			MethodName: "InstanceDelete",
			Handler:    _InstanceService_InstanceDelete_Handler,
		},
		{
			MethodName: "InstanceGet",
			Handler:    _InstanceService_InstanceGet_Handler,
		},
		{
			MethodName: "InstanceList",
			Handler:    _InstanceService_InstanceList_Handler,
		},
		{
			MethodName: "InstanceReplace",
			Handler:    _InstanceService_InstanceReplace_Handler,
		},
		{
			MethodName: "LogSetLevel",
			Handler:    _InstanceService_LogSetLevel_Handler,
		},
		{
			MethodName: "LogSetFlags",
			Handler:    _InstanceService_LogSetFlags_Handler,
		},
		{
			MethodName: "LogGetLevel",
			Handler:    _InstanceService_LogGetLevel_Handler,
		},
		{
			MethodName: "LogGetFlags",
			Handler:    _InstanceService_LogGetFlags_Handler,
		},
		{
			MethodName: "VersionGet",
			Handler:    _InstanceService_VersionGet_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InstanceLog",
			Handler:       _InstanceService_InstanceLog_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "InstanceWatch",
			Handler:       _InstanceService_InstanceWatch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "imrpc/instance.proto",
}

InstanceService_ServiceDesc is the grpc.ServiceDesc for InstanceService 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 ProcessManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ProcessManagerService",
	HandlerType: (*ProcessManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProcessCreate",
			Handler:    _ProcessManagerService_ProcessCreate_Handler,
		},
		{
			MethodName: "ProcessDelete",
			Handler:    _ProcessManagerService_ProcessDelete_Handler,
		},
		{
			MethodName: "ProcessGet",
			Handler:    _ProcessManagerService_ProcessGet_Handler,
		},
		{
			MethodName: "ProcessList",
			Handler:    _ProcessManagerService_ProcessList_Handler,
		},
		{
			MethodName: "ProcessReplace",
			Handler:    _ProcessManagerService_ProcessReplace_Handler,
		},
		{
			MethodName: "VersionGet",
			Handler:    _ProcessManagerService_VersionGet_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ProcessLog",
			Handler:       _ProcessManagerService_ProcessLog_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ProcessWatch",
			Handler:       _ProcessManagerService_ProcessWatch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "imrpc/imrpc.proto",
}

ProcessManagerService_ServiceDesc is the grpc.ServiceDesc for ProcessManagerService 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 ProxyEngineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "imrpc.ProxyEngineService",
	HandlerType: (*ProxyEngineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ServerVersionGet",
			Handler:    _ProxyEngineService_ServerVersionGet_Handler,
		},
		{
			MethodName: "VolumeGet",
			Handler:    _ProxyEngineService_VolumeGet_Handler,
		},
		{
			MethodName: "VolumeExpand",
			Handler:    _ProxyEngineService_VolumeExpand_Handler,
		},
		{
			MethodName: "VolumeFrontendStart",
			Handler:    _ProxyEngineService_VolumeFrontendStart_Handler,
		},
		{
			MethodName: "VolumeFrontendShutdown",
			Handler:    _ProxyEngineService_VolumeFrontendShutdown_Handler,
		},
		{
			MethodName: "VolumeUnmapMarkSnapChainRemovedSet",
			Handler:    _ProxyEngineService_VolumeUnmapMarkSnapChainRemovedSet_Handler,
		},
		{
			MethodName: "VolumeSnapshotMaxCountSet",
			Handler:    _ProxyEngineService_VolumeSnapshotMaxCountSet_Handler,
		},
		{
			MethodName: "VolumeSnapshotMaxSizeSet",
			Handler:    _ProxyEngineService_VolumeSnapshotMaxSizeSet_Handler,
		},
		{
			MethodName: "VolumeSnapshot",
			Handler:    _ProxyEngineService_VolumeSnapshot_Handler,
		},
		{
			MethodName: "SnapshotList",
			Handler:    _ProxyEngineService_SnapshotList_Handler,
		},
		{
			MethodName: "SnapshotRevert",
			Handler:    _ProxyEngineService_SnapshotRevert_Handler,
		},
		{
			MethodName: "SnapshotPurge",
			Handler:    _ProxyEngineService_SnapshotPurge_Handler,
		},
		{
			MethodName: "SnapshotPurgeStatus",
			Handler:    _ProxyEngineService_SnapshotPurgeStatus_Handler,
		},
		{
			MethodName: "SnapshotClone",
			Handler:    _ProxyEngineService_SnapshotClone_Handler,
		},
		{
			MethodName: "SnapshotCloneStatus",
			Handler:    _ProxyEngineService_SnapshotCloneStatus_Handler,
		},
		{
			MethodName: "SnapshotRemove",
			Handler:    _ProxyEngineService_SnapshotRemove_Handler,
		},
		{
			MethodName: "SnapshotHash",
			Handler:    _ProxyEngineService_SnapshotHash_Handler,
		},
		{
			MethodName: "SnapshotHashStatus",
			Handler:    _ProxyEngineService_SnapshotHashStatus_Handler,
		},
		{
			MethodName: "SnapshotBackup",
			Handler:    _ProxyEngineService_SnapshotBackup_Handler,
		},
		{
			MethodName: "SnapshotBackupStatus",
			Handler:    _ProxyEngineService_SnapshotBackupStatus_Handler,
		},
		{
			MethodName: "BackupRestore",
			Handler:    _ProxyEngineService_BackupRestore_Handler,
		},
		{
			MethodName: "BackupRestoreStatus",
			Handler:    _ProxyEngineService_BackupRestoreStatus_Handler,
		},
		{
			MethodName: "BackupRestoreFinish",
			Handler:    _ProxyEngineService_BackupRestoreFinish_Handler,
		},
		{
			MethodName: "CleanupBackupMountPoints",
			Handler:    _ProxyEngineService_CleanupBackupMountPoints_Handler,
		},
		{
			MethodName: "ReplicaAdd",
			Handler:    _ProxyEngineService_ReplicaAdd_Handler,
		},
		{
			MethodName: "ReplicaList",
			Handler:    _ProxyEngineService_ReplicaList_Handler,
		},
		{
			MethodName: "ReplicaRebuildingStatus",
			Handler:    _ProxyEngineService_ReplicaRebuildingStatus_Handler,
		},
		{
			MethodName: "ReplicaVerifyRebuild",
			Handler:    _ProxyEngineService_ReplicaVerifyRebuild_Handler,
		},
		{
			MethodName: "ReplicaRemove",
			Handler:    _ProxyEngineService_ReplicaRemove_Handler,
		},
		{
			MethodName: "ReplicaModeUpdate",
			Handler:    _ProxyEngineService_ReplicaModeUpdate_Handler,
		},
		{
			MethodName: "MetricsGet",
			Handler:    _ProxyEngineService_MetricsGet_Handler,
		},
		{
			MethodName: "RemountReadOnlyVolume",
			Handler:    _ProxyEngineService_RemountReadOnlyVolume_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "imrpc/proxy.proto",
}

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

Functions

func RegisterDiskServiceServer 

func RegisterDiskServiceServer(s grpc.ServiceRegistrar, srv DiskServiceServer)

func RegisterInstanceServiceServer 

func RegisterInstanceServiceServer(s grpc.ServiceRegistrar, srv InstanceServiceServer)

func RegisterProcessManagerServiceServer 

func RegisterProcessManagerServiceServer(s grpc.ServiceRegistrar, srv ProcessManagerServiceServer)

func RegisterProxyEngineServiceServer 

func RegisterProxyEngineServiceServer(s grpc.ServiceRegistrar, srv ProxyEngineServiceServer)

Types

type BackendStoreDriver deprecated 

type BackendStoreDriver int32

Deprecated: Use DataEngine instead. 

const (
	BackendStoreDriver_v1 BackendStoreDriver = 0
	BackendStoreDriver_v2 BackendStoreDriver = 1
)

func (BackendStoreDriver) Descriptor 

func (BackendStoreDriver) Descriptor() protoreflect.EnumDescriptor

func (BackendStoreDriver) Enum 

func (x BackendStoreDriver) Enum() *BackendStoreDriver

func (BackendStoreDriver) EnumDescriptor deprecated 

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

Deprecated: Use BackendStoreDriver.Descriptor instead.

func (BackendStoreDriver) Number 

func (x BackendStoreDriver) Number() protoreflect.EnumNumber

func (BackendStoreDriver) String 

func (x BackendStoreDriver) String() string

func (BackendStoreDriver) Type 

func (BackendStoreDriver) Type() protoreflect.EnumType

type DataEngine 

type DataEngine int32
const (
	DataEngine_DATA_ENGINE_V1 DataEngine = 0
	DataEngine_DATA_ENGINE_V2 DataEngine = 1
)

func (DataEngine) Descriptor 

func (DataEngine) Descriptor() protoreflect.EnumDescriptor

func (DataEngine) Enum 

func (x DataEngine) Enum() *DataEngine

func (DataEngine) EnumDescriptor deprecated 

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

Deprecated: Use DataEngine.Descriptor instead.

func (DataEngine) Number 

func (x DataEngine) Number() protoreflect.EnumNumber

func (DataEngine) String 

func (x DataEngine) String() string

func (DataEngine) Type 

func (DataEngine) Type() protoreflect.EnumType

type Disk 

type Disk struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Uuid        string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Path        string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Type        string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	TotalSize   int64  `protobuf:"varint,5,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	FreeSize    int64  `protobuf:"varint,6,opt,name=free_size,json=freeSize,proto3" json:"free_size,omitempty"`
	TotalBlocks int64  `protobuf:"varint,7,opt,name=total_blocks,json=totalBlocks,proto3" json:"total_blocks,omitempty"`
	FreeBlocks  int64  `protobuf:"varint,8,opt,name=free_blocks,json=freeBlocks,proto3" json:"free_blocks,omitempty"`
	BlockSize   int64  `protobuf:"varint,9,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
	ClusterSize int64  `protobuf:"varint,10,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`
	Driver      string `protobuf:"bytes,11,opt,name=driver,proto3" json:"driver,omitempty"`
	Name        string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Disk) Descriptor deprecated 

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

Deprecated: Use Disk.ProtoReflect.Descriptor instead.

func (*Disk) GetBlockSize 

func (x *Disk) GetBlockSize() int64

func (*Disk) GetClusterSize 

func (x *Disk) GetClusterSize() int64

func (*Disk) GetDriver 

func (x *Disk) GetDriver() string

func (*Disk) GetFreeBlocks 

func (x *Disk) GetFreeBlocks() int64

func (*Disk) GetFreeSize 

func (x *Disk) GetFreeSize() int64

func (*Disk) GetId 

func (x *Disk) GetId() string

func (*Disk) GetName 

func (x *Disk) GetName() string

func (*Disk) GetPath 

func (x *Disk) GetPath() string

func (*Disk) GetTotalBlocks 

func (x *Disk) GetTotalBlocks() int64

func (*Disk) GetTotalSize 

func (x *Disk) GetTotalSize() int64

func (*Disk) GetType 

func (x *Disk) GetType() string

func (*Disk) GetUuid 

func (x *Disk) GetUuid() string

func (*Disk) ProtoMessage 

func (*Disk) ProtoMessage()

func (*Disk) ProtoReflect 

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

func (*Disk) Reset 

func (x *Disk) Reset()

func (*Disk) String 

func (x *Disk) String() string

type DiskCreateRequest 

type DiskCreateRequest struct {
	DiskType   DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName   string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid   string   `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	DiskPath   string   `protobuf:"bytes,4,opt,name=disk_path,json=diskPath,proto3" json:"disk_path,omitempty"`
	BlockSize  int64    `protobuf:"varint,5,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
	DiskDriver string   `protobuf:"bytes,6,opt,name=disk_driver,json=diskDriver,proto3" json:"disk_driver,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskCreateRequest) Descriptor deprecated 

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

Deprecated: Use DiskCreateRequest.ProtoReflect.Descriptor instead.

func (*DiskCreateRequest) GetBlockSize 

func (x *DiskCreateRequest) GetBlockSize() int64

func (*DiskCreateRequest) GetDiskDriver 

func (x *DiskCreateRequest) GetDiskDriver() string

func (*DiskCreateRequest) GetDiskName 

func (x *DiskCreateRequest) GetDiskName() string

func (*DiskCreateRequest) GetDiskPath 

func (x *DiskCreateRequest) GetDiskPath() string

func (*DiskCreateRequest) GetDiskType 

func (x *DiskCreateRequest) GetDiskType() DiskType

func (*DiskCreateRequest) GetDiskUuid 

func (x *DiskCreateRequest) GetDiskUuid() string

func (*DiskCreateRequest) ProtoMessage 

func (*DiskCreateRequest) ProtoMessage()

func (*DiskCreateRequest) ProtoReflect 

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

func (*DiskCreateRequest) Reset 

func (x *DiskCreateRequest) Reset()

func (*DiskCreateRequest) String 

func (x *DiskCreateRequest) String() string

type DiskDeleteRequest 

type DiskDeleteRequest struct {
	DiskType   DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName   string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid   string   `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	DiskPath   string   `protobuf:"bytes,4,opt,name=disk_path,json=diskPath,proto3" json:"disk_path,omitempty"`
	DiskDriver string   `protobuf:"bytes,5,opt,name=disk_driver,json=diskDriver,proto3" json:"disk_driver,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskDeleteRequest) Descriptor deprecated 

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

Deprecated: Use DiskDeleteRequest.ProtoReflect.Descriptor instead.

func (*DiskDeleteRequest) GetDiskDriver 

func (x *DiskDeleteRequest) GetDiskDriver() string

func (*DiskDeleteRequest) GetDiskName 

func (x *DiskDeleteRequest) GetDiskName() string

func (*DiskDeleteRequest) GetDiskPath 

func (x *DiskDeleteRequest) GetDiskPath() string

func (*DiskDeleteRequest) GetDiskType 

func (x *DiskDeleteRequest) GetDiskType() DiskType

func (*DiskDeleteRequest) GetDiskUuid 

func (x *DiskDeleteRequest) GetDiskUuid() string

func (*DiskDeleteRequest) ProtoMessage 

func (*DiskDeleteRequest) ProtoMessage()

func (*DiskDeleteRequest) ProtoReflect 

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

func (*DiskDeleteRequest) Reset 

func (x *DiskDeleteRequest) Reset()

func (*DiskDeleteRequest) String 

func (x *DiskDeleteRequest) String() string

type DiskGetRequest 

type DiskGetRequest struct {
	DiskType   DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName   string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskPath   string   `protobuf:"bytes,3,opt,name=disk_path,json=diskPath,proto3" json:"disk_path,omitempty"`
	DiskDriver string   `protobuf:"bytes,4,opt,name=disk_driver,json=diskDriver,proto3" json:"disk_driver,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskGetRequest) Descriptor deprecated 

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

Deprecated: Use DiskGetRequest.ProtoReflect.Descriptor instead.

func (*DiskGetRequest) GetDiskDriver 

func (x *DiskGetRequest) GetDiskDriver() string

func (*DiskGetRequest) GetDiskName 

func (x *DiskGetRequest) GetDiskName() string

func (*DiskGetRequest) GetDiskPath 

func (x *DiskGetRequest) GetDiskPath() string

func (*DiskGetRequest) GetDiskType 

func (x *DiskGetRequest) GetDiskType() DiskType

func (*DiskGetRequest) ProtoMessage 

func (*DiskGetRequest) ProtoMessage()

func (*DiskGetRequest) ProtoReflect 

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

func (*DiskGetRequest) Reset 

func (x *DiskGetRequest) Reset()

func (*DiskGetRequest) String 

func (x *DiskGetRequest) String() string

type DiskReplicaInstanceDeleteRequest 

type DiskReplicaInstanceDeleteRequest struct {
	DiskType            DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName            string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid            string   `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	ReplciaInstanceName string   `protobuf:"bytes,4,opt,name=replcia_instance_name,json=replciaInstanceName,proto3" json:"replcia_instance_name,omitempty"`
	DiskDriver          string   `protobuf:"bytes,5,opt,name=disk_driver,json=diskDriver,proto3" json:"disk_driver,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskReplicaInstanceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use DiskReplicaInstanceDeleteRequest.ProtoReflect.Descriptor instead.

func (*DiskReplicaInstanceDeleteRequest) GetDiskDriver 

func (x *DiskReplicaInstanceDeleteRequest) GetDiskDriver() string

func (*DiskReplicaInstanceDeleteRequest) GetDiskName 

func (x *DiskReplicaInstanceDeleteRequest) GetDiskName() string

func (*DiskReplicaInstanceDeleteRequest) GetDiskType 

func (x *DiskReplicaInstanceDeleteRequest) GetDiskType() DiskType

func (*DiskReplicaInstanceDeleteRequest) GetDiskUuid 

func (x *DiskReplicaInstanceDeleteRequest) GetDiskUuid() string

func (*DiskReplicaInstanceDeleteRequest) GetReplciaInstanceName 

func (x *DiskReplicaInstanceDeleteRequest) GetReplciaInstanceName() string

func (*DiskReplicaInstanceDeleteRequest) ProtoMessage 

func (*DiskReplicaInstanceDeleteRequest) ProtoMessage()

func (*DiskReplicaInstanceDeleteRequest) ProtoReflect 

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

func (*DiskReplicaInstanceDeleteRequest) Reset 

func (x *DiskReplicaInstanceDeleteRequest) Reset()

func (*DiskReplicaInstanceDeleteRequest) String 

func (x *DiskReplicaInstanceDeleteRequest) String() string

type DiskReplicaInstanceListRequest 

type DiskReplicaInstanceListRequest struct {
	DiskType   DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName   string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskDriver string   `protobuf:"bytes,3,opt,name=disk_driver,json=diskDriver,proto3" json:"disk_driver,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskReplicaInstanceListRequest) Descriptor deprecated 

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

Deprecated: Use DiskReplicaInstanceListRequest.ProtoReflect.Descriptor instead.

func (*DiskReplicaInstanceListRequest) GetDiskDriver 

func (x *DiskReplicaInstanceListRequest) GetDiskDriver() string

func (*DiskReplicaInstanceListRequest) GetDiskName 

func (x *DiskReplicaInstanceListRequest) GetDiskName() string

func (*DiskReplicaInstanceListRequest) GetDiskType 

func (x *DiskReplicaInstanceListRequest) GetDiskType() DiskType

func (*DiskReplicaInstanceListRequest) ProtoMessage 

func (*DiskReplicaInstanceListRequest) ProtoMessage()

func (*DiskReplicaInstanceListRequest) ProtoReflect 

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

func (*DiskReplicaInstanceListRequest) Reset 

func (x *DiskReplicaInstanceListRequest) Reset()

func (*DiskReplicaInstanceListRequest) String 

func (x *DiskReplicaInstanceListRequest) String() string

type DiskReplicaInstanceListResponse 

type DiskReplicaInstanceListResponse struct {
	ReplicaInstances map[string]*ReplicaInstance `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DiskReplicaInstanceListResponse) Descriptor deprecated 

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

Deprecated: Use DiskReplicaInstanceListResponse.ProtoReflect.Descriptor instead.

func (*DiskReplicaInstanceListResponse) GetReplicaInstances 

func (x *DiskReplicaInstanceListResponse) GetReplicaInstances() map[string]*ReplicaInstance

func (*DiskReplicaInstanceListResponse) ProtoMessage 

func (*DiskReplicaInstanceListResponse) ProtoMessage()

func (*DiskReplicaInstanceListResponse) ProtoReflect 

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

func (*DiskReplicaInstanceListResponse) Reset 

func (x *DiskReplicaInstanceListResponse) Reset()

func (*DiskReplicaInstanceListResponse) String 

func (x *DiskReplicaInstanceListResponse) String() string

type DiskServiceClient 

type DiskServiceClient interface {
	DiskCreate(ctx context.Context, in *DiskCreateRequest, opts ...grpc.CallOption) (*Disk, error)
	DiskDelete(ctx context.Context, in *DiskDeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DiskGet(ctx context.Context, in *DiskGetRequest, opts ...grpc.CallOption) (*Disk, error)
	DiskReplicaInstanceList(ctx context.Context, in *DiskReplicaInstanceListRequest, opts ...grpc.CallOption) (*DiskReplicaInstanceListResponse, error)
	DiskReplicaInstanceDelete(ctx context.Context, in *DiskReplicaInstanceDeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VersionGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DiskVersionResponse, error)
}

DiskServiceClient is the client API for DiskService 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 NewDiskServiceClient 

func NewDiskServiceClient(cc grpc.ClientConnInterface) DiskServiceClient

type DiskServiceServer 

type DiskServiceServer interface {
	DiskCreate(context.Context, *DiskCreateRequest) (*Disk, error)
	DiskDelete(context.Context, *DiskDeleteRequest) (*emptypb.Empty, error)
	DiskGet(context.Context, *DiskGetRequest) (*Disk, error)
	DiskReplicaInstanceList(context.Context, *DiskReplicaInstanceListRequest) (*DiskReplicaInstanceListResponse, error)
	DiskReplicaInstanceDelete(context.Context, *DiskReplicaInstanceDeleteRequest) (*emptypb.Empty, error)
	VersionGet(context.Context, *emptypb.Empty) (*DiskVersionResponse, error)
	// contains filtered or unexported methods
}

DiskServiceServer is the server API for DiskService service. All implementations must embed UnimplementedDiskServiceServer for forward compatibility

type DiskType 

type DiskType int32
const (
	DiskType_filesystem DiskType = 0
	DiskType_block      DiskType = 1
)

func (DiskType) Descriptor 

func (DiskType) Descriptor() protoreflect.EnumDescriptor

func (DiskType) Enum 

func (x DiskType) Enum() *DiskType

func (DiskType) EnumDescriptor deprecated 

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

Deprecated: Use DiskType.Descriptor instead.

func (DiskType) Number 

func (x DiskType) Number() protoreflect.EnumNumber

func (DiskType) String 

func (x DiskType) String() string

func (DiskType) Type 

func (DiskType) Type() protoreflect.EnumType

type DiskVersionResponse 

type DiskVersionResponse 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"`
	InstanceManagerDiskServiceAPIVersion    int64  `` /* 126-byte string literal not displayed */
	InstanceManagerDiskServiceAPIMinVersion int64  `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DiskVersionResponse) Descriptor deprecated 

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

Deprecated: Use DiskVersionResponse.ProtoReflect.Descriptor instead.

func (*DiskVersionResponse) GetBuildDate 

func (x *DiskVersionResponse) GetBuildDate() string

func (*DiskVersionResponse) GetGitCommit 

func (x *DiskVersionResponse) GetGitCommit() string

func (*DiskVersionResponse) GetInstanceManagerDiskServiceAPIMinVersion 

func (x *DiskVersionResponse) GetInstanceManagerDiskServiceAPIMinVersion() int64

func (*DiskVersionResponse) GetInstanceManagerDiskServiceAPIVersion 

func (x *DiskVersionResponse) GetInstanceManagerDiskServiceAPIVersion() int64

func (*DiskVersionResponse) GetVersion 

func (x *DiskVersionResponse) GetVersion() string

func (*DiskVersionResponse) ProtoMessage 

func (*DiskVersionResponse) ProtoMessage()

func (*DiskVersionResponse) ProtoReflect 

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

func (*DiskVersionResponse) Reset 

func (x *DiskVersionResponse) Reset()

func (*DiskVersionResponse) String 

func (x *DiskVersionResponse) String() string

type EngineBackupRestoreFinishRequest 

type EngineBackupRestoreFinishRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineBackupRestoreFinishRequest) Descriptor deprecated 

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

Deprecated: Use EngineBackupRestoreFinishRequest.ProtoReflect.Descriptor instead.

func (*EngineBackupRestoreFinishRequest) GetProxyEngineRequest 

func (x *EngineBackupRestoreFinishRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineBackupRestoreFinishRequest) ProtoMessage 

func (*EngineBackupRestoreFinishRequest) ProtoMessage()

func (*EngineBackupRestoreFinishRequest) ProtoReflect 

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

func (*EngineBackupRestoreFinishRequest) Reset 

func (x *EngineBackupRestoreFinishRequest) Reset()

func (*EngineBackupRestoreFinishRequest) String 

func (x *EngineBackupRestoreFinishRequest) String() string

type EngineBackupRestoreProxyResponse 

type EngineBackupRestoreProxyResponse struct {
	TaskError []byte `protobuf:"bytes,1,opt,name=taskError,proto3" json:"taskError,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineBackupRestoreProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineBackupRestoreProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineBackupRestoreProxyResponse) GetTaskError 

func (x *EngineBackupRestoreProxyResponse) GetTaskError() []byte

func (*EngineBackupRestoreProxyResponse) ProtoMessage 

func (*EngineBackupRestoreProxyResponse) ProtoMessage()

func (*EngineBackupRestoreProxyResponse) ProtoReflect 

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

func (*EngineBackupRestoreProxyResponse) Reset 

func (x *EngineBackupRestoreProxyResponse) Reset()

func (*EngineBackupRestoreProxyResponse) String 

func (x *EngineBackupRestoreProxyResponse) String() string

type EngineBackupRestoreRequest 

type EngineBackupRestoreRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Envs               []string            `protobuf:"bytes,2,rep,name=envs,proto3" json:"envs,omitempty"`
	Url                string              `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Target             string              `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	VolumeName         string              `protobuf:"bytes,5,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	ConcurrentLimit    int32               `protobuf:"varint,6,opt,name=concurrent_limit,json=concurrentLimit,proto3" json:"concurrent_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineBackupRestoreRequest) Descriptor deprecated 

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

Deprecated: Use EngineBackupRestoreRequest.ProtoReflect.Descriptor instead.

func (*EngineBackupRestoreRequest) GetConcurrentLimit 

func (x *EngineBackupRestoreRequest) GetConcurrentLimit() int32

func (*EngineBackupRestoreRequest) GetEnvs 

func (x *EngineBackupRestoreRequest) GetEnvs() []string

func (*EngineBackupRestoreRequest) GetProxyEngineRequest 

func (x *EngineBackupRestoreRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineBackupRestoreRequest) GetTarget 

func (x *EngineBackupRestoreRequest) GetTarget() string

func (*EngineBackupRestoreRequest) GetUrl 

func (x *EngineBackupRestoreRequest) GetUrl() string

func (*EngineBackupRestoreRequest) GetVolumeName 

func (x *EngineBackupRestoreRequest) GetVolumeName() string

func (*EngineBackupRestoreRequest) ProtoMessage 

func (*EngineBackupRestoreRequest) ProtoMessage()

func (*EngineBackupRestoreRequest) ProtoReflect 

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

func (*EngineBackupRestoreRequest) Reset 

func (x *EngineBackupRestoreRequest) Reset()

func (*EngineBackupRestoreRequest) String 

func (x *EngineBackupRestoreRequest) String() string

type EngineBackupRestoreStatus 

type EngineBackupRestoreStatus 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"`
	CurrentRestoringBackup string `` /* 129-byte string literal not displayed */
	Progress               int32  `protobuf:"varint,4,opt,name=progress,proto3" json:"progress,omitempty"`
	Error                  string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Filename               string `protobuf:"bytes,6,opt,name=filename,proto3" json:"filename,omitempty"`
	State                  string `protobuf:"bytes,7,opt,name=state,proto3" json:"state,omitempty"`
	BackupUrl              string `protobuf:"bytes,8,opt,name=backup_url,json=backupUrl,proto3" json:"backup_url,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineBackupRestoreStatus) Descriptor deprecated 

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

Deprecated: Use EngineBackupRestoreStatus.ProtoReflect.Descriptor instead.

func (*EngineBackupRestoreStatus) GetBackupUrl 

func (x *EngineBackupRestoreStatus) GetBackupUrl() string

func (*EngineBackupRestoreStatus) GetCurrentRestoringBackup 

func (x *EngineBackupRestoreStatus) GetCurrentRestoringBackup() string

func (*EngineBackupRestoreStatus) GetError 

func (x *EngineBackupRestoreStatus) GetError() string

func (*EngineBackupRestoreStatus) GetFilename 

func (x *EngineBackupRestoreStatus) GetFilename() string

func (*EngineBackupRestoreStatus) GetIsRestoring 

func (x *EngineBackupRestoreStatus) GetIsRestoring() bool

func (*EngineBackupRestoreStatus) GetLastRestored 

func (x *EngineBackupRestoreStatus) GetLastRestored() string

func (*EngineBackupRestoreStatus) GetProgress 

func (x *EngineBackupRestoreStatus) GetProgress() int32

func (*EngineBackupRestoreStatus) GetState 

func (x *EngineBackupRestoreStatus) GetState() string

func (*EngineBackupRestoreStatus) ProtoMessage 

func (*EngineBackupRestoreStatus) ProtoMessage()

func (*EngineBackupRestoreStatus) ProtoReflect 

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

func (*EngineBackupRestoreStatus) Reset 

func (x *EngineBackupRestoreStatus) Reset()

func (*EngineBackupRestoreStatus) String 

func (x *EngineBackupRestoreStatus) String() string

type EngineBackupRestoreStatusProxyResponse 

type EngineBackupRestoreStatusProxyResponse struct {
	Status map[string]*EngineBackupRestoreStatus `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EngineBackupRestoreStatusProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineBackupRestoreStatusProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineBackupRestoreStatusProxyResponse) GetStatus 

func (x *EngineBackupRestoreStatusProxyResponse) GetStatus() map[string]*EngineBackupRestoreStatus

func (*EngineBackupRestoreStatusProxyResponse) ProtoMessage 

func (*EngineBackupRestoreStatusProxyResponse) ProtoMessage()

func (*EngineBackupRestoreStatusProxyResponse) ProtoReflect 

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

func (*EngineBackupRestoreStatusProxyResponse) Reset 

func (x *EngineBackupRestoreStatusProxyResponse) Reset()

func (*EngineBackupRestoreStatusProxyResponse) String 

func (x *EngineBackupRestoreStatusProxyResponse) String() string

type EngineMetricsGetProxyResponse 

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

func (*EngineMetricsGetProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineMetricsGetProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineMetricsGetProxyResponse) GetMetrics 

func (x *EngineMetricsGetProxyResponse) GetMetrics() *enginerpc.Metrics

func (*EngineMetricsGetProxyResponse) ProtoMessage 

func (*EngineMetricsGetProxyResponse) ProtoMessage()

func (*EngineMetricsGetProxyResponse) ProtoReflect 

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

func (*EngineMetricsGetProxyResponse) Reset 

func (x *EngineMetricsGetProxyResponse) Reset()

func (*EngineMetricsGetProxyResponse) String 

func (x *EngineMetricsGetProxyResponse) String() string

type EngineReplicaAddRequest 

type EngineReplicaAddRequest struct {
	ProxyEngineRequest        *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress            string              `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	Restore                   bool                `protobuf:"varint,3,opt,name=restore,proto3" json:"restore,omitempty"`
	Size                      int64               `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	CurrentSize               int64               `protobuf:"varint,5,opt,name=current_size,json=currentSize,proto3" json:"current_size,omitempty"`
	FastSync                  bool                `protobuf:"varint,6,opt,name=fast_sync,json=fastSync,proto3" json:"fast_sync,omitempty"`
	FileSyncHttpClientTimeout int32               `` /* 143-byte string literal not displayed */
	ReplicaName               string              `protobuf:"bytes,8,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineReplicaAddRequest) Descriptor deprecated 

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

Deprecated: Use EngineReplicaAddRequest.ProtoReflect.Descriptor instead.

func (*EngineReplicaAddRequest) GetCurrentSize 

func (x *EngineReplicaAddRequest) GetCurrentSize() int64

func (*EngineReplicaAddRequest) GetFastSync 

func (x *EngineReplicaAddRequest) GetFastSync() bool

func (*EngineReplicaAddRequest) GetFileSyncHttpClientTimeout 

func (x *EngineReplicaAddRequest) GetFileSyncHttpClientTimeout() int32

func (*EngineReplicaAddRequest) GetProxyEngineRequest 

func (x *EngineReplicaAddRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaAddRequest) GetReplicaAddress 

func (x *EngineReplicaAddRequest) GetReplicaAddress() string

func (*EngineReplicaAddRequest) GetReplicaName 

func (x *EngineReplicaAddRequest) GetReplicaName() string

func (*EngineReplicaAddRequest) GetRestore 

func (x *EngineReplicaAddRequest) GetRestore() bool

func (*EngineReplicaAddRequest) GetSize 

func (x *EngineReplicaAddRequest) GetSize() int64

func (*EngineReplicaAddRequest) ProtoMessage 

func (*EngineReplicaAddRequest) ProtoMessage()

func (*EngineReplicaAddRequest) ProtoReflect 

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

func (*EngineReplicaAddRequest) Reset 

func (x *EngineReplicaAddRequest) Reset()

func (*EngineReplicaAddRequest) String 

func (x *EngineReplicaAddRequest) String() string

type EngineReplicaListProxyResponse 

type EngineReplicaListProxyResponse struct {
	ReplicaList *enginerpc.ReplicaListReply `protobuf:"bytes,1,opt,name=replica_list,json=replicaList,proto3" json:"replica_list,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineReplicaListProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineReplicaListProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineReplicaListProxyResponse) GetReplicaList 

func (x *EngineReplicaListProxyResponse) GetReplicaList() *enginerpc.ReplicaListReply

func (*EngineReplicaListProxyResponse) ProtoMessage 

func (*EngineReplicaListProxyResponse) ProtoMessage()

func (*EngineReplicaListProxyResponse) ProtoReflect 

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

func (*EngineReplicaListProxyResponse) Reset 

func (x *EngineReplicaListProxyResponse) Reset()

func (*EngineReplicaListProxyResponse) String 

func (x *EngineReplicaListProxyResponse) String() string

type EngineReplicaModeUpdateRequest 

type EngineReplicaModeUpdateRequest struct {
	ProxyEngineRequest *ProxyEngineRequest   `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress     string                `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	Mode               enginerpc.ReplicaMode `protobuf:"varint,3,opt,name=mode,proto3,enum=ptypes.ReplicaMode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineReplicaModeUpdateRequest) Descriptor deprecated 

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

Deprecated: Use EngineReplicaModeUpdateRequest.ProtoReflect.Descriptor instead.

func (*EngineReplicaModeUpdateRequest) GetMode 

func (x *EngineReplicaModeUpdateRequest) GetMode() enginerpc.ReplicaMode

func (*EngineReplicaModeUpdateRequest) GetProxyEngineRequest 

func (x *EngineReplicaModeUpdateRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaModeUpdateRequest) GetReplicaAddress 

func (x *EngineReplicaModeUpdateRequest) GetReplicaAddress() string

func (*EngineReplicaModeUpdateRequest) ProtoMessage 

func (*EngineReplicaModeUpdateRequest) ProtoMessage()

func (*EngineReplicaModeUpdateRequest) ProtoReflect 

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

func (*EngineReplicaModeUpdateRequest) Reset 

func (x *EngineReplicaModeUpdateRequest) Reset()

func (*EngineReplicaModeUpdateRequest) String 

func (x *EngineReplicaModeUpdateRequest) String() string

type EngineReplicaRebuildStatusProxyResponse 

type EngineReplicaRebuildStatusProxyResponse struct {
	Status map[string]*enginerpc.ReplicaRebuildStatusResponse `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EngineReplicaRebuildStatusProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineReplicaRebuildStatusProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineReplicaRebuildStatusProxyResponse) GetStatus 

func (x *EngineReplicaRebuildStatusProxyResponse) GetStatus() map[string]*enginerpc.ReplicaRebuildStatusResponse

func (*EngineReplicaRebuildStatusProxyResponse) ProtoMessage 

func (*EngineReplicaRebuildStatusProxyResponse) ProtoMessage()

func (*EngineReplicaRebuildStatusProxyResponse) ProtoReflect 

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

func (*EngineReplicaRebuildStatusProxyResponse) Reset 

func (x *EngineReplicaRebuildStatusProxyResponse) Reset()

func (*EngineReplicaRebuildStatusProxyResponse) String 

func (x *EngineReplicaRebuildStatusProxyResponse) String() string

type EngineReplicaRemoveRequest 

type EngineReplicaRemoveRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress     string              `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	ReplicaName        string              `protobuf:"bytes,3,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineReplicaRemoveRequest) Descriptor deprecated 

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

Deprecated: Use EngineReplicaRemoveRequest.ProtoReflect.Descriptor instead.

func (*EngineReplicaRemoveRequest) GetProxyEngineRequest 

func (x *EngineReplicaRemoveRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaRemoveRequest) GetReplicaAddress 

func (x *EngineReplicaRemoveRequest) GetReplicaAddress() string

func (*EngineReplicaRemoveRequest) GetReplicaName 

func (x *EngineReplicaRemoveRequest) GetReplicaName() string

func (*EngineReplicaRemoveRequest) ProtoMessage 

func (*EngineReplicaRemoveRequest) ProtoMessage()

func (*EngineReplicaRemoveRequest) ProtoReflect 

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

func (*EngineReplicaRemoveRequest) Reset 

func (x *EngineReplicaRemoveRequest) Reset()

func (*EngineReplicaRemoveRequest) String 

func (x *EngineReplicaRemoveRequest) String() string

type EngineReplicaVerifyRebuildRequest 

type EngineReplicaVerifyRebuildRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress     string              `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	ReplicaName        string              `protobuf:"bytes,3,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineReplicaVerifyRebuildRequest) Descriptor deprecated 

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

Deprecated: Use EngineReplicaVerifyRebuildRequest.ProtoReflect.Descriptor instead.

func (*EngineReplicaVerifyRebuildRequest) GetProxyEngineRequest 

func (x *EngineReplicaVerifyRebuildRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaVerifyRebuildRequest) GetReplicaAddress 

func (x *EngineReplicaVerifyRebuildRequest) GetReplicaAddress() string

func (*EngineReplicaVerifyRebuildRequest) GetReplicaName 

func (x *EngineReplicaVerifyRebuildRequest) GetReplicaName() string

func (*EngineReplicaVerifyRebuildRequest) ProtoMessage 

func (*EngineReplicaVerifyRebuildRequest) ProtoMessage()

func (*EngineReplicaVerifyRebuildRequest) ProtoReflect 

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

func (*EngineReplicaVerifyRebuildRequest) Reset 

func (x *EngineReplicaVerifyRebuildRequest) Reset()

func (*EngineReplicaVerifyRebuildRequest) String 

func (x *EngineReplicaVerifyRebuildRequest) String() string

type EngineSnapshotBackupProxyResponse 

type EngineSnapshotBackupProxyResponse struct {
	BackupId      string `protobuf:"bytes,1,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	Replica       string `protobuf:"bytes,2,opt,name=replica,proto3" json:"replica,omitempty"`
	IsIncremental bool   `protobuf:"varint,3,opt,name=is_incremental,json=isIncremental,proto3" json:"is_incremental,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotBackupProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotBackupProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineSnapshotBackupProxyResponse) GetBackupId 

func (x *EngineSnapshotBackupProxyResponse) GetBackupId() string

func (*EngineSnapshotBackupProxyResponse) GetIsIncremental 

func (x *EngineSnapshotBackupProxyResponse) GetIsIncremental() bool

func (*EngineSnapshotBackupProxyResponse) GetReplica 

func (x *EngineSnapshotBackupProxyResponse) GetReplica() string

func (*EngineSnapshotBackupProxyResponse) ProtoMessage 

func (*EngineSnapshotBackupProxyResponse) ProtoMessage()

func (*EngineSnapshotBackupProxyResponse) ProtoReflect 

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

func (*EngineSnapshotBackupProxyResponse) Reset 

func (x *EngineSnapshotBackupProxyResponse) Reset()

func (*EngineSnapshotBackupProxyResponse) String 

func (x *EngineSnapshotBackupProxyResponse) String() string

type EngineSnapshotBackupRequest 

type EngineSnapshotBackupRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Envs                 []string            `protobuf:"bytes,8,rep,name=envs,proto3" json:"envs,omitempty"`
	BackupName           string              `protobuf:"bytes,2,opt,name=backup_name,json=backupName,proto3" json:"backup_name,omitempty"`
	SnapshotName         string              `protobuf:"bytes,3,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	BackupTarget         string              `protobuf:"bytes,4,opt,name=backup_target,json=backupTarget,proto3" json:"backup_target,omitempty"`
	BackingImageName     string              `protobuf:"bytes,5,opt,name=backing_image_name,json=backingImageName,proto3" json:"backing_image_name,omitempty"`
	BackingImageChecksum string              `protobuf:"bytes,6,opt,name=backing_image_checksum,json=backingImageChecksum,proto3" json:"backing_image_checksum,omitempty"`
	Labels               map[string]string   `` /* 153-byte string literal not displayed */
	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"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotBackupRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotBackupRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotBackupRequest) GetBackingImageChecksum 

func (x *EngineSnapshotBackupRequest) GetBackingImageChecksum() string

func (*EngineSnapshotBackupRequest) GetBackingImageName 

func (x *EngineSnapshotBackupRequest) GetBackingImageName() string

func (*EngineSnapshotBackupRequest) GetBackupName 

func (x *EngineSnapshotBackupRequest) GetBackupName() string

func (*EngineSnapshotBackupRequest) GetBackupTarget 

func (x *EngineSnapshotBackupRequest) GetBackupTarget() string

func (*EngineSnapshotBackupRequest) GetCompressionMethod 

func (x *EngineSnapshotBackupRequest) GetCompressionMethod() string

func (*EngineSnapshotBackupRequest) GetConcurrentLimit 

func (x *EngineSnapshotBackupRequest) GetConcurrentLimit() int32

func (*EngineSnapshotBackupRequest) GetEnvs 

func (x *EngineSnapshotBackupRequest) GetEnvs() []string

func (*EngineSnapshotBackupRequest) GetLabels 

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

func (*EngineSnapshotBackupRequest) GetProxyEngineRequest 

func (x *EngineSnapshotBackupRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotBackupRequest) GetSnapshotName 

func (x *EngineSnapshotBackupRequest) GetSnapshotName() string

func (*EngineSnapshotBackupRequest) GetStorageClassName 

func (x *EngineSnapshotBackupRequest) GetStorageClassName() string

func (*EngineSnapshotBackupRequest) ProtoMessage 

func (*EngineSnapshotBackupRequest) ProtoMessage()

func (*EngineSnapshotBackupRequest) ProtoReflect 

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

func (*EngineSnapshotBackupRequest) Reset 

func (x *EngineSnapshotBackupRequest) Reset()

func (*EngineSnapshotBackupRequest) String 

func (x *EngineSnapshotBackupRequest) String() string

type EngineSnapshotBackupStatusProxyResponse 

type EngineSnapshotBackupStatusProxyResponse struct {
	BackupUrl      string `protobuf:"bytes,1,opt,name=backup_url,json=backupUrl,proto3" json:"backup_url,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"`
	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"`
	ReplicaAddress string `protobuf:"bytes,6,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotBackupStatusProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotBackupStatusProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineSnapshotBackupStatusProxyResponse) GetBackupUrl 

func (x *EngineSnapshotBackupStatusProxyResponse) GetBackupUrl() string

func (*EngineSnapshotBackupStatusProxyResponse) GetError 

func (x *EngineSnapshotBackupStatusProxyResponse) GetError() string

func (*EngineSnapshotBackupStatusProxyResponse) GetProgress 

func (x *EngineSnapshotBackupStatusProxyResponse) GetProgress() int32

func (*EngineSnapshotBackupStatusProxyResponse) GetReplicaAddress 

func (x *EngineSnapshotBackupStatusProxyResponse) GetReplicaAddress() string

func (*EngineSnapshotBackupStatusProxyResponse) GetSnapshotName 

func (x *EngineSnapshotBackupStatusProxyResponse) GetSnapshotName() string

func (*EngineSnapshotBackupStatusProxyResponse) GetState 

func (x *EngineSnapshotBackupStatusProxyResponse) GetState() string

func (*EngineSnapshotBackupStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotBackupStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotBackupStatusProxyResponse) ProtoReflect 

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

func (*EngineSnapshotBackupStatusProxyResponse) Reset 

func (x *EngineSnapshotBackupStatusProxyResponse) Reset()

func (*EngineSnapshotBackupStatusProxyResponse) String 

func (x *EngineSnapshotBackupStatusProxyResponse) String() string

type EngineSnapshotBackupStatusRequest 

type EngineSnapshotBackupStatusRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	BackupName         string              `protobuf:"bytes,2,opt,name=backup_name,json=backupName,proto3" json:"backup_name,omitempty"`
	ReplicaAddress     string              `protobuf:"bytes,3,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	ReplicaName        string              `protobuf:"bytes,4,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotBackupStatusRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotBackupStatusRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotBackupStatusRequest) GetBackupName 

func (x *EngineSnapshotBackupStatusRequest) GetBackupName() string

func (*EngineSnapshotBackupStatusRequest) GetProxyEngineRequest 

func (x *EngineSnapshotBackupStatusRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotBackupStatusRequest) GetReplicaAddress 

func (x *EngineSnapshotBackupStatusRequest) GetReplicaAddress() string

func (*EngineSnapshotBackupStatusRequest) GetReplicaName 

func (x *EngineSnapshotBackupStatusRequest) GetReplicaName() string

func (*EngineSnapshotBackupStatusRequest) ProtoMessage 

func (*EngineSnapshotBackupStatusRequest) ProtoMessage()

func (*EngineSnapshotBackupStatusRequest) ProtoReflect 

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

func (*EngineSnapshotBackupStatusRequest) Reset 

func (x *EngineSnapshotBackupStatusRequest) Reset()

func (*EngineSnapshotBackupStatusRequest) String 

func (x *EngineSnapshotBackupStatusRequest) String() string

type EngineSnapshotCloneRequest 

type EngineSnapshotCloneRequest struct {
	ProxyEngineRequest        *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	FromEngineAddress         string              `protobuf:"bytes,2,opt,name=from_engine_address,json=fromEngineAddress,proto3" json:"from_engine_address,omitempty"`
	SnapshotName              string              `protobuf:"bytes,3,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	ExportBackingImageIfExist bool                `` /* 143-byte string literal not displayed */
	FileSyncHttpClientTimeout int32               `` /* 143-byte string literal not displayed */
	FromEngineName            string              `protobuf:"bytes,6,opt,name=from_engine_name,json=fromEngineName,proto3" json:"from_engine_name,omitempty"`
	FromVolumeName            string              `protobuf:"bytes,7,opt,name=from_volume_name,json=fromVolumeName,proto3" json:"from_volume_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotCloneRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotCloneRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotCloneRequest) GetExportBackingImageIfExist 

func (x *EngineSnapshotCloneRequest) GetExportBackingImageIfExist() bool

func (*EngineSnapshotCloneRequest) GetFileSyncHttpClientTimeout 

func (x *EngineSnapshotCloneRequest) GetFileSyncHttpClientTimeout() int32

func (*EngineSnapshotCloneRequest) GetFromEngineAddress 

func (x *EngineSnapshotCloneRequest) GetFromEngineAddress() string

func (*EngineSnapshotCloneRequest) GetFromEngineName 

func (x *EngineSnapshotCloneRequest) GetFromEngineName() string

func (*EngineSnapshotCloneRequest) GetFromVolumeName 

func (x *EngineSnapshotCloneRequest) GetFromVolumeName() string

func (*EngineSnapshotCloneRequest) GetProxyEngineRequest 

func (x *EngineSnapshotCloneRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotCloneRequest) GetSnapshotName 

func (x *EngineSnapshotCloneRequest) GetSnapshotName() string

func (*EngineSnapshotCloneRequest) ProtoMessage 

func (*EngineSnapshotCloneRequest) ProtoMessage()

func (*EngineSnapshotCloneRequest) ProtoReflect 

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

func (*EngineSnapshotCloneRequest) Reset 

func (x *EngineSnapshotCloneRequest) Reset()

func (*EngineSnapshotCloneRequest) String 

func (x *EngineSnapshotCloneRequest) String() string

type EngineSnapshotCloneStatusProxyResponse 

type EngineSnapshotCloneStatusProxyResponse struct {
	Status map[string]*enginerpc.SnapshotCloneStatusResponse `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EngineSnapshotCloneStatusProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotCloneStatusProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineSnapshotCloneStatusProxyResponse) GetStatus 

func (x *EngineSnapshotCloneStatusProxyResponse) GetStatus() map[string]*enginerpc.SnapshotCloneStatusResponse

func (*EngineSnapshotCloneStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotCloneStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotCloneStatusProxyResponse) ProtoReflect 

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

func (*EngineSnapshotCloneStatusProxyResponse) Reset 

func (x *EngineSnapshotCloneStatusProxyResponse) Reset()

func (*EngineSnapshotCloneStatusProxyResponse) String 

func (x *EngineSnapshotCloneStatusProxyResponse) String() string

type EngineSnapshotDiskInfo 

type EngineSnapshotDiskInfo 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 (*EngineSnapshotDiskInfo) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotDiskInfo.ProtoReflect.Descriptor instead.

func (*EngineSnapshotDiskInfo) GetChildren 

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

func (*EngineSnapshotDiskInfo) GetCreated 

func (x *EngineSnapshotDiskInfo) GetCreated() string

func (*EngineSnapshotDiskInfo) GetLabels 

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

func (*EngineSnapshotDiskInfo) GetName 

func (x *EngineSnapshotDiskInfo) GetName() string

func (*EngineSnapshotDiskInfo) GetParent 

func (x *EngineSnapshotDiskInfo) GetParent() string

func (*EngineSnapshotDiskInfo) GetRemoved 

func (x *EngineSnapshotDiskInfo) GetRemoved() bool

func (*EngineSnapshotDiskInfo) GetSize 

func (x *EngineSnapshotDiskInfo) GetSize() string

func (*EngineSnapshotDiskInfo) GetUserCreated 

func (x *EngineSnapshotDiskInfo) GetUserCreated() bool

func (*EngineSnapshotDiskInfo) ProtoMessage 

func (*EngineSnapshotDiskInfo) ProtoMessage()

func (*EngineSnapshotDiskInfo) ProtoReflect 

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

func (*EngineSnapshotDiskInfo) Reset 

func (x *EngineSnapshotDiskInfo) Reset()

func (*EngineSnapshotDiskInfo) String 

func (x *EngineSnapshotDiskInfo) String() string

type EngineSnapshotHashRequest 

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

func (*EngineSnapshotHashRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotHashRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotHashRequest) GetProxyEngineRequest 

func (x *EngineSnapshotHashRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotHashRequest) GetRehash 

func (x *EngineSnapshotHashRequest) GetRehash() bool

func (*EngineSnapshotHashRequest) GetSnapshotName 

func (x *EngineSnapshotHashRequest) GetSnapshotName() string

func (*EngineSnapshotHashRequest) ProtoMessage 

func (*EngineSnapshotHashRequest) ProtoMessage()

func (*EngineSnapshotHashRequest) ProtoReflect 

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

func (*EngineSnapshotHashRequest) Reset 

func (x *EngineSnapshotHashRequest) Reset()

func (*EngineSnapshotHashRequest) String 

func (x *EngineSnapshotHashRequest) String() string

type EngineSnapshotHashStatusProxyResponse 

type EngineSnapshotHashStatusProxyResponse struct {
	Status map[string]*enginerpc.SnapshotHashStatusResponse `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EngineSnapshotHashStatusProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotHashStatusProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineSnapshotHashStatusProxyResponse) GetStatus 

func (x *EngineSnapshotHashStatusProxyResponse) GetStatus() map[string]*enginerpc.SnapshotHashStatusResponse

func (*EngineSnapshotHashStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotHashStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotHashStatusProxyResponse) ProtoReflect 

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

func (*EngineSnapshotHashStatusProxyResponse) Reset 

func (x *EngineSnapshotHashStatusProxyResponse) Reset()

func (*EngineSnapshotHashStatusProxyResponse) String 

func (x *EngineSnapshotHashStatusProxyResponse) String() string

type EngineSnapshotHashStatusRequest 

type EngineSnapshotHashStatusRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	SnapshotName       string              `protobuf:"bytes,2,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotHashStatusRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotHashStatusRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotHashStatusRequest) GetProxyEngineRequest 

func (x *EngineSnapshotHashStatusRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotHashStatusRequest) GetSnapshotName 

func (x *EngineSnapshotHashStatusRequest) GetSnapshotName() string

func (*EngineSnapshotHashStatusRequest) ProtoMessage 

func (*EngineSnapshotHashStatusRequest) ProtoMessage()

func (*EngineSnapshotHashStatusRequest) ProtoReflect 

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

func (*EngineSnapshotHashStatusRequest) Reset 

func (x *EngineSnapshotHashStatusRequest) Reset()

func (*EngineSnapshotHashStatusRequest) String 

func (x *EngineSnapshotHashStatusRequest) String() string

type EngineSnapshotListProxyResponse 

type EngineSnapshotListProxyResponse struct {
	Disks map[string]*EngineSnapshotDiskInfo `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EngineSnapshotListProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotListProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineSnapshotListProxyResponse) GetDisks 

func (x *EngineSnapshotListProxyResponse) GetDisks() map[string]*EngineSnapshotDiskInfo

func (*EngineSnapshotListProxyResponse) ProtoMessage 

func (*EngineSnapshotListProxyResponse) ProtoMessage()

func (*EngineSnapshotListProxyResponse) ProtoReflect 

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

func (*EngineSnapshotListProxyResponse) Reset 

func (x *EngineSnapshotListProxyResponse) Reset()

func (*EngineSnapshotListProxyResponse) String 

func (x *EngineSnapshotListProxyResponse) String() string

type EngineSnapshotPurgeRequest 

type EngineSnapshotPurgeRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	SkipIfInProgress   bool                `protobuf:"varint,2,opt,name=skip_if_in_progress,json=skipIfInProgress,proto3" json:"skip_if_in_progress,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotPurgeRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotPurgeRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotPurgeRequest) GetProxyEngineRequest 

func (x *EngineSnapshotPurgeRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotPurgeRequest) GetSkipIfInProgress 

func (x *EngineSnapshotPurgeRequest) GetSkipIfInProgress() bool

func (*EngineSnapshotPurgeRequest) ProtoMessage 

func (*EngineSnapshotPurgeRequest) ProtoMessage()

func (*EngineSnapshotPurgeRequest) ProtoReflect 

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

func (*EngineSnapshotPurgeRequest) Reset 

func (x *EngineSnapshotPurgeRequest) Reset()

func (*EngineSnapshotPurgeRequest) String 

func (x *EngineSnapshotPurgeRequest) String() string

type EngineSnapshotPurgeStatusProxyResponse 

type EngineSnapshotPurgeStatusProxyResponse struct {
	Status map[string]*enginerpc.SnapshotPurgeStatusResponse `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EngineSnapshotPurgeStatusProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotPurgeStatusProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineSnapshotPurgeStatusProxyResponse) GetStatus 

func (x *EngineSnapshotPurgeStatusProxyResponse) GetStatus() map[string]*enginerpc.SnapshotPurgeStatusResponse

func (*EngineSnapshotPurgeStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotPurgeStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotPurgeStatusProxyResponse) ProtoReflect 

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

func (*EngineSnapshotPurgeStatusProxyResponse) Reset 

func (x *EngineSnapshotPurgeStatusProxyResponse) Reset()

func (*EngineSnapshotPurgeStatusProxyResponse) String 

func (x *EngineSnapshotPurgeStatusProxyResponse) String() string

type EngineSnapshotRemoveRequest 

type EngineSnapshotRemoveRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Names              []string            `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotRemoveRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotRemoveRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotRemoveRequest) GetNames 

func (x *EngineSnapshotRemoveRequest) GetNames() []string

func (*EngineSnapshotRemoveRequest) GetProxyEngineRequest 

func (x *EngineSnapshotRemoveRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotRemoveRequest) ProtoMessage 

func (*EngineSnapshotRemoveRequest) ProtoMessage()

func (*EngineSnapshotRemoveRequest) ProtoReflect 

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

func (*EngineSnapshotRemoveRequest) Reset 

func (x *EngineSnapshotRemoveRequest) Reset()

func (*EngineSnapshotRemoveRequest) String 

func (x *EngineSnapshotRemoveRequest) String() string

type EngineSnapshotRevertRequest 

type EngineSnapshotRevertRequest struct {
	ProxyEngineRequest *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Name               string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineSnapshotRevertRequest) Descriptor deprecated 

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

Deprecated: Use EngineSnapshotRevertRequest.ProtoReflect.Descriptor instead.

func (*EngineSnapshotRevertRequest) GetName 

func (x *EngineSnapshotRevertRequest) GetName() string

func (*EngineSnapshotRevertRequest) GetProxyEngineRequest 

func (x *EngineSnapshotRevertRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotRevertRequest) ProtoMessage 

func (*EngineSnapshotRevertRequest) ProtoMessage()

func (*EngineSnapshotRevertRequest) ProtoReflect 

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

func (*EngineSnapshotRevertRequest) Reset 

func (x *EngineSnapshotRevertRequest) Reset()

func (*EngineSnapshotRevertRequest) String 

func (x *EngineSnapshotRevertRequest) String() string

type EngineVersionProxyResponse 

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

func (*EngineVersionProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineVersionProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineVersionProxyResponse) GetVersion 

func (x *EngineVersionProxyResponse) GetVersion() *enginerpc.VersionOutput

func (*EngineVersionProxyResponse) ProtoMessage 

func (*EngineVersionProxyResponse) ProtoMessage()

func (*EngineVersionProxyResponse) ProtoReflect 

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

func (*EngineVersionProxyResponse) Reset 

func (x *EngineVersionProxyResponse) Reset()

func (*EngineVersionProxyResponse) String 

func (x *EngineVersionProxyResponse) String() string

type EngineVolumeExpandRequest 

type EngineVolumeExpandRequest struct {
	ProxyEngineRequest *ProxyEngineRequest            `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Expand             *enginerpc.VolumeExpandRequest `protobuf:"bytes,2,opt,name=expand,proto3" json:"expand,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeExpandRequest) Descriptor deprecated 

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

Deprecated: Use EngineVolumeExpandRequest.ProtoReflect.Descriptor instead.

func (*EngineVolumeExpandRequest) GetExpand 

func (x *EngineVolumeExpandRequest) GetExpand() *enginerpc.VolumeExpandRequest

func (*EngineVolumeExpandRequest) GetProxyEngineRequest 

func (x *EngineVolumeExpandRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeExpandRequest) ProtoMessage 

func (*EngineVolumeExpandRequest) ProtoMessage()

func (*EngineVolumeExpandRequest) ProtoReflect 

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

func (*EngineVolumeExpandRequest) Reset 

func (x *EngineVolumeExpandRequest) Reset()

func (*EngineVolumeExpandRequest) String 

func (x *EngineVolumeExpandRequest) String() string

type EngineVolumeFrontendStartRequest 

type EngineVolumeFrontendStartRequest struct {
	ProxyEngineRequest *ProxyEngineRequest                   `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	FrontendStart      *enginerpc.VolumeFrontendStartRequest `protobuf:"bytes,2,opt,name=frontend_start,json=frontendStart,proto3" json:"frontend_start,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeFrontendStartRequest) Descriptor deprecated 

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

Deprecated: Use EngineVolumeFrontendStartRequest.ProtoReflect.Descriptor instead.

func (*EngineVolumeFrontendStartRequest) GetFrontendStart 

func (x *EngineVolumeFrontendStartRequest) GetFrontendStart() *enginerpc.VolumeFrontendStartRequest

func (*EngineVolumeFrontendStartRequest) GetProxyEngineRequest 

func (x *EngineVolumeFrontendStartRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeFrontendStartRequest) ProtoMessage 

func (*EngineVolumeFrontendStartRequest) ProtoMessage()

func (*EngineVolumeFrontendStartRequest) ProtoReflect 

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

func (*EngineVolumeFrontendStartRequest) Reset 

func (x *EngineVolumeFrontendStartRequest) Reset()

func (*EngineVolumeFrontendStartRequest) String 

func (x *EngineVolumeFrontendStartRequest) String() string

type EngineVolumeGetProxyResponse 

type EngineVolumeGetProxyResponse struct {
	Volume *enginerpc.Volume `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeGetProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineVolumeGetProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineVolumeGetProxyResponse) GetVolume 

func (x *EngineVolumeGetProxyResponse) GetVolume() *enginerpc.Volume

func (*EngineVolumeGetProxyResponse) ProtoMessage 

func (*EngineVolumeGetProxyResponse) ProtoMessage()

func (*EngineVolumeGetProxyResponse) ProtoReflect 

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

func (*EngineVolumeGetProxyResponse) Reset 

func (x *EngineVolumeGetProxyResponse) Reset()

func (*EngineVolumeGetProxyResponse) String 

func (x *EngineVolumeGetProxyResponse) String() string

type EngineVolumeSnapshotMaxCountSetRequest 

type EngineVolumeSnapshotMaxCountSetRequest struct {
	ProxyEngineRequest *ProxyEngineRequest                         `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Count              *enginerpc.VolumeSnapshotMaxCountSetRequest `protobuf:"bytes,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeSnapshotMaxCountSetRequest) Descriptor deprecated 

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

Deprecated: Use EngineVolumeSnapshotMaxCountSetRequest.ProtoReflect.Descriptor instead.

func (*EngineVolumeSnapshotMaxCountSetRequest) GetCount 

func (x *EngineVolumeSnapshotMaxCountSetRequest) GetCount() *enginerpc.VolumeSnapshotMaxCountSetRequest

func (*EngineVolumeSnapshotMaxCountSetRequest) GetProxyEngineRequest 

func (x *EngineVolumeSnapshotMaxCountSetRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeSnapshotMaxCountSetRequest) ProtoMessage 

func (*EngineVolumeSnapshotMaxCountSetRequest) ProtoMessage()

func (*EngineVolumeSnapshotMaxCountSetRequest) ProtoReflect 

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

func (*EngineVolumeSnapshotMaxCountSetRequest) Reset 

func (x *EngineVolumeSnapshotMaxCountSetRequest) Reset()

func (*EngineVolumeSnapshotMaxCountSetRequest) String 

func (x *EngineVolumeSnapshotMaxCountSetRequest) String() string

type EngineVolumeSnapshotMaxSizeSetRequest 

type EngineVolumeSnapshotMaxSizeSetRequest struct {
	ProxyEngineRequest *ProxyEngineRequest                        `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Size               *enginerpc.VolumeSnapshotMaxSizeSetRequest `protobuf:"bytes,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeSnapshotMaxSizeSetRequest) Descriptor deprecated 

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

Deprecated: Use EngineVolumeSnapshotMaxSizeSetRequest.ProtoReflect.Descriptor instead.

func (*EngineVolumeSnapshotMaxSizeSetRequest) GetProxyEngineRequest 

func (x *EngineVolumeSnapshotMaxSizeSetRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeSnapshotMaxSizeSetRequest) GetSize 

func (x *EngineVolumeSnapshotMaxSizeSetRequest) GetSize() *enginerpc.VolumeSnapshotMaxSizeSetRequest

func (*EngineVolumeSnapshotMaxSizeSetRequest) ProtoMessage 

func (*EngineVolumeSnapshotMaxSizeSetRequest) ProtoMessage()

func (*EngineVolumeSnapshotMaxSizeSetRequest) ProtoReflect 

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

func (*EngineVolumeSnapshotMaxSizeSetRequest) Reset 

func (x *EngineVolumeSnapshotMaxSizeSetRequest) Reset()

func (*EngineVolumeSnapshotMaxSizeSetRequest) String 

func (x *EngineVolumeSnapshotMaxSizeSetRequest) String() string

type EngineVolumeSnapshotProxyResponse 

type EngineVolumeSnapshotProxyResponse struct {
	Snapshot *enginerpc.VolumeSnapshotReply `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeSnapshotProxyResponse) Descriptor deprecated 

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

Deprecated: Use EngineVolumeSnapshotProxyResponse.ProtoReflect.Descriptor instead.

func (*EngineVolumeSnapshotProxyResponse) GetSnapshot 

func (x *EngineVolumeSnapshotProxyResponse) GetSnapshot() *enginerpc.VolumeSnapshotReply

func (*EngineVolumeSnapshotProxyResponse) ProtoMessage 

func (*EngineVolumeSnapshotProxyResponse) ProtoMessage()

func (*EngineVolumeSnapshotProxyResponse) ProtoReflect 

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

func (*EngineVolumeSnapshotProxyResponse) Reset 

func (x *EngineVolumeSnapshotProxyResponse) Reset()

func (*EngineVolumeSnapshotProxyResponse) String 

func (x *EngineVolumeSnapshotProxyResponse) String() string

type EngineVolumeSnapshotRequest 

type EngineVolumeSnapshotRequest struct {
	ProxyEngineRequest *ProxyEngineRequest              `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	SnapshotVolume     *enginerpc.VolumeSnapshotRequest `protobuf:"bytes,2,opt,name=snapshot_volume,json=snapshotVolume,proto3" json:"snapshot_volume,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use EngineVolumeSnapshotRequest.ProtoReflect.Descriptor instead.

func (*EngineVolumeSnapshotRequest) GetProxyEngineRequest 

func (x *EngineVolumeSnapshotRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeSnapshotRequest) GetSnapshotVolume 

func (x *EngineVolumeSnapshotRequest) GetSnapshotVolume() *enginerpc.VolumeSnapshotRequest

func (*EngineVolumeSnapshotRequest) ProtoMessage 

func (*EngineVolumeSnapshotRequest) ProtoMessage()

func (*EngineVolumeSnapshotRequest) ProtoReflect 

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

func (*EngineVolumeSnapshotRequest) Reset 

func (x *EngineVolumeSnapshotRequest) Reset()

func (*EngineVolumeSnapshotRequest) String 

func (x *EngineVolumeSnapshotRequest) String() string

type EngineVolumeUnmapMarkSnapChainRemovedSetRequest 

type EngineVolumeUnmapMarkSnapChainRemovedSetRequest struct {
	ProxyEngineRequest *ProxyEngineRequest                                  `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	UnmapMarkSnap      *enginerpc.VolumeUnmapMarkSnapChainRemovedSetRequest `protobuf:"bytes,2,opt,name=unmap_mark_snap,json=unmapMarkSnap,proto3" json:"unmap_mark_snap,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) Descriptor deprecated 

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

Deprecated: Use EngineVolumeUnmapMarkSnapChainRemovedSetRequest.ProtoReflect.Descriptor instead.

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetProxyEngineRequest 

func (x *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetUnmapMarkSnap 

func (x *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetUnmapMarkSnap() *enginerpc.VolumeUnmapMarkSnapChainRemovedSetRequest

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) ProtoMessage 

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) ProtoMessage()

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) ProtoReflect 

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

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) Reset 

func (x *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) Reset()

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) String 

func (x *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) String() string

type InstanceCreateRequest 

type InstanceCreateRequest struct {
	Spec *InstanceSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceCreateRequest) Descriptor deprecated 

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

Deprecated: Use InstanceCreateRequest.ProtoReflect.Descriptor instead.

func (*InstanceCreateRequest) GetSpec 

func (x *InstanceCreateRequest) GetSpec() *InstanceSpec

func (*InstanceCreateRequest) ProtoMessage 

func (*InstanceCreateRequest) ProtoMessage()

func (*InstanceCreateRequest) ProtoReflect 

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

func (*InstanceCreateRequest) Reset 

func (x *InstanceCreateRequest) Reset()

func (*InstanceCreateRequest) String 

func (x *InstanceCreateRequest) String() string

type InstanceDeleteRequest 

type InstanceDeleteRequest struct {

	// Deprecated: Replaced by `data_engine`.
	//
	// Deprecated: Marked as deprecated in imrpc/instance.proto.
	BackendStoreDriver BackendStoreDriver `` /* 148-byte string literal not displayed */
	Name               string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type               string             `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	DiskUuid           string             `protobuf:"bytes,4,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	CleanupRequired    bool               `protobuf:"varint,5,opt,name=cleanup_required,json=cleanupRequired,proto3" json:"cleanup_required,omitempty"`
	DataEngine         DataEngine         `protobuf:"varint,6,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use InstanceDeleteRequest.ProtoReflect.Descriptor instead.

func (*InstanceDeleteRequest) GetBackendStoreDriver deprecated 

func (x *InstanceDeleteRequest) GetBackendStoreDriver() BackendStoreDriver

Deprecated: Marked as deprecated in imrpc/instance.proto.

func (*InstanceDeleteRequest) GetCleanupRequired 

func (x *InstanceDeleteRequest) GetCleanupRequired() bool

func (*InstanceDeleteRequest) GetDataEngine 

func (x *InstanceDeleteRequest) GetDataEngine() DataEngine

func (*InstanceDeleteRequest) GetDiskUuid 

func (x *InstanceDeleteRequest) GetDiskUuid() string

func (*InstanceDeleteRequest) GetName 

func (x *InstanceDeleteRequest) GetName() string

func (*InstanceDeleteRequest) GetType 

func (x *InstanceDeleteRequest) GetType() string

func (*InstanceDeleteRequest) ProtoMessage 

func (*InstanceDeleteRequest) ProtoMessage()

func (*InstanceDeleteRequest) ProtoReflect 

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

func (*InstanceDeleteRequest) Reset 

func (x *InstanceDeleteRequest) Reset()

func (*InstanceDeleteRequest) String 

func (x *InstanceDeleteRequest) String() string

type InstanceGetRequest 

type InstanceGetRequest struct {

	// Deprecated: Replaced by `data_engine`.
	//
	// Deprecated: Marked as deprecated in imrpc/instance.proto.
	BackendStoreDriver BackendStoreDriver `` /* 148-byte string literal not displayed */
	Name               string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type               string             `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	DataEngine         DataEngine         `protobuf:"varint,4,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceGetRequest) Descriptor deprecated 

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

Deprecated: Use InstanceGetRequest.ProtoReflect.Descriptor instead.

func (*InstanceGetRequest) GetBackendStoreDriver deprecated 

func (x *InstanceGetRequest) GetBackendStoreDriver() BackendStoreDriver

Deprecated: Marked as deprecated in imrpc/instance.proto.

func (*InstanceGetRequest) GetDataEngine 

func (x *InstanceGetRequest) GetDataEngine() DataEngine

func (*InstanceGetRequest) GetName 

func (x *InstanceGetRequest) GetName() string

func (*InstanceGetRequest) GetType 

func (x *InstanceGetRequest) GetType() string

func (*InstanceGetRequest) ProtoMessage 

func (*InstanceGetRequest) ProtoMessage()

func (*InstanceGetRequest) ProtoReflect 

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

func (*InstanceGetRequest) Reset 

func (x *InstanceGetRequest) Reset()

func (*InstanceGetRequest) String 

func (x *InstanceGetRequest) String() string

type InstanceListResponse 

type InstanceListResponse struct {
	Instances map[string]*InstanceResponse `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InstanceListResponse) Descriptor deprecated 

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

Deprecated: Use InstanceListResponse.ProtoReflect.Descriptor instead.

func (*InstanceListResponse) GetInstances 

func (x *InstanceListResponse) GetInstances() map[string]*InstanceResponse

func (*InstanceListResponse) ProtoMessage 

func (*InstanceListResponse) ProtoMessage()

func (*InstanceListResponse) ProtoReflect 

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

func (*InstanceListResponse) Reset 

func (x *InstanceListResponse) Reset()

func (*InstanceListResponse) String 

func (x *InstanceListResponse) String() string

type InstanceLogRequest 

type InstanceLogRequest struct {

	// Deprecated: Replaced by `data_engine`.
	//
	// Deprecated: Marked as deprecated in imrpc/instance.proto.
	BackendStoreDriver BackendStoreDriver `` /* 148-byte string literal not displayed */
	Name               string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type               string             `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	DataEngine         DataEngine         `protobuf:"varint,4,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceLogRequest) Descriptor deprecated 

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

Deprecated: Use InstanceLogRequest.ProtoReflect.Descriptor instead.

func (*InstanceLogRequest) GetBackendStoreDriver deprecated 

func (x *InstanceLogRequest) GetBackendStoreDriver() BackendStoreDriver

Deprecated: Marked as deprecated in imrpc/instance.proto.

func (*InstanceLogRequest) GetDataEngine 

func (x *InstanceLogRequest) GetDataEngine() DataEngine

func (*InstanceLogRequest) GetName 

func (x *InstanceLogRequest) GetName() string

func (*InstanceLogRequest) GetType 

func (x *InstanceLogRequest) GetType() string

func (*InstanceLogRequest) ProtoMessage 

func (*InstanceLogRequest) ProtoMessage()

func (*InstanceLogRequest) ProtoReflect 

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

func (*InstanceLogRequest) Reset 

func (x *InstanceLogRequest) Reset()

func (*InstanceLogRequest) String 

func (x *InstanceLogRequest) String() string

type InstanceReplaceRequest 

type InstanceReplaceRequest struct {
	Spec            *InstanceSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	TerminateSignal string        `protobuf:"bytes,2,opt,name=terminate_signal,json=terminateSignal,proto3" json:"terminate_signal,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceReplaceRequest) Descriptor deprecated 

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

Deprecated: Use InstanceReplaceRequest.ProtoReflect.Descriptor instead.

func (*InstanceReplaceRequest) GetSpec 

func (x *InstanceReplaceRequest) GetSpec() *InstanceSpec

func (*InstanceReplaceRequest) GetTerminateSignal 

func (x *InstanceReplaceRequest) GetTerminateSignal() string

func (*InstanceReplaceRequest) ProtoMessage 

func (*InstanceReplaceRequest) ProtoMessage()

func (*InstanceReplaceRequest) ProtoReflect 

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

func (*InstanceReplaceRequest) Reset 

func (x *InstanceReplaceRequest) Reset()

func (*InstanceReplaceRequest) String 

func (x *InstanceReplaceRequest) String() string

type InstanceResponse 

type InstanceResponse struct {
	Spec    *InstanceSpec   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Status  *InstanceStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Deleted bool            `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceResponse) Descriptor deprecated 

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

Deprecated: Use InstanceResponse.ProtoReflect.Descriptor instead.

func (*InstanceResponse) GetDeleted 

func (x *InstanceResponse) GetDeleted() bool

func (*InstanceResponse) GetSpec 

func (x *InstanceResponse) GetSpec() *InstanceSpec

func (*InstanceResponse) GetStatus 

func (x *InstanceResponse) GetStatus() *InstanceStatus

func (*InstanceResponse) ProtoMessage 

func (*InstanceResponse) ProtoMessage()

func (*InstanceResponse) ProtoReflect 

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

func (*InstanceResponse) Reset 

func (x *InstanceResponse) Reset()

func (*InstanceResponse) String 

func (x *InstanceResponse) String() string

type InstanceServiceClient 

type InstanceServiceClient interface {
	InstanceCreate(ctx context.Context, in *InstanceCreateRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	InstanceDelete(ctx context.Context, in *InstanceDeleteRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	InstanceGet(ctx context.Context, in *InstanceGetRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	InstanceList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*InstanceListResponse, error)
	InstanceLog(ctx context.Context, in *InstanceLogRequest, opts ...grpc.CallOption) (InstanceService_InstanceLogClient, error)
	InstanceWatch(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (InstanceService_InstanceWatchClient, error)
	InstanceReplace(ctx context.Context, in *InstanceReplaceRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	LogSetLevel(ctx context.Context, in *LogSetLevelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	LogSetFlags(ctx context.Context, in *LogSetFlagsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	LogGetLevel(ctx context.Context, in *LogGetLevelRequest, opts ...grpc.CallOption) (*LogGetLevelResponse, error)
	LogGetFlags(ctx context.Context, in *LogGetFlagsRequest, opts ...grpc.CallOption) (*LogGetFlagsResponse, error)
	VersionGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionResponse, error)
}

InstanceServiceClient is the client API for InstanceService 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 NewInstanceServiceClient 

func NewInstanceServiceClient(cc grpc.ClientConnInterface) InstanceServiceClient

type InstanceServiceServer 

type InstanceServiceServer interface {
	InstanceCreate(context.Context, *InstanceCreateRequest) (*InstanceResponse, error)
	InstanceDelete(context.Context, *InstanceDeleteRequest) (*InstanceResponse, error)
	InstanceGet(context.Context, *InstanceGetRequest) (*InstanceResponse, error)
	InstanceList(context.Context, *emptypb.Empty) (*InstanceListResponse, error)
	InstanceLog(*InstanceLogRequest, InstanceService_InstanceLogServer) error
	InstanceWatch(*emptypb.Empty, InstanceService_InstanceWatchServer) error
	InstanceReplace(context.Context, *InstanceReplaceRequest) (*InstanceResponse, error)
	LogSetLevel(context.Context, *LogSetLevelRequest) (*emptypb.Empty, error)
	LogSetFlags(context.Context, *LogSetFlagsRequest) (*emptypb.Empty, error)
	LogGetLevel(context.Context, *LogGetLevelRequest) (*LogGetLevelResponse, error)
	LogGetFlags(context.Context, *LogGetFlagsRequest) (*LogGetFlagsResponse, error)
	VersionGet(context.Context, *emptypb.Empty) (*VersionResponse, error)
	// contains filtered or unexported methods
}

InstanceServiceServer is the server API for InstanceService service. All implementations must embed UnimplementedInstanceServiceServer for forward compatibility

type InstanceService_InstanceLogClient 

type InstanceService_InstanceLogClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type InstanceService_InstanceLogServer 

type InstanceService_InstanceLogServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type InstanceService_InstanceWatchClient 

type InstanceService_InstanceWatchClient interface {
	Recv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type InstanceService_InstanceWatchServer 

type InstanceService_InstanceWatchServer interface {
	Send(*emptypb.Empty) error
	grpc.ServerStream
}

type InstanceSpec 

type InstanceSpec struct {

	// Deprecated: Replaced by `data_engine`.
	//
	// Deprecated: Marked as deprecated in imrpc/instance.proto.
	BackendStoreDriver  BackendStoreDriver   `` /* 148-byte string literal not displayed */
	Name                string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                string               `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	VolumeName          string               `protobuf:"bytes,4,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	PortCount           int32                `protobuf:"varint,5,opt,name=port_count,json=portCount,proto3" json:"port_count,omitempty"`
	PortArgs            []string             `protobuf:"bytes,6,rep,name=port_args,json=portArgs,proto3" json:"port_args,omitempty"`
	ProcessInstanceSpec *ProcessInstanceSpec `protobuf:"bytes,7,opt,name=process_instance_spec,json=processInstanceSpec,proto3" json:"process_instance_spec,omitempty"`
	SpdkInstanceSpec    *SpdkInstanceSpec    `protobuf:"bytes,8,opt,name=spdk_instance_spec,json=spdkInstanceSpec,proto3" json:"spdk_instance_spec,omitempty"`
	DataEngine          DataEngine           `protobuf:"varint,9,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceSpec) Descriptor deprecated 

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

Deprecated: Use InstanceSpec.ProtoReflect.Descriptor instead.

func (*InstanceSpec) GetBackendStoreDriver deprecated 

func (x *InstanceSpec) GetBackendStoreDriver() BackendStoreDriver

Deprecated: Marked as deprecated in imrpc/instance.proto.

func (*InstanceSpec) GetDataEngine 

func (x *InstanceSpec) GetDataEngine() DataEngine

func (*InstanceSpec) GetName 

func (x *InstanceSpec) GetName() string

func (*InstanceSpec) GetPortArgs 

func (x *InstanceSpec) GetPortArgs() []string

func (*InstanceSpec) GetPortCount 

func (x *InstanceSpec) GetPortCount() int32

func (*InstanceSpec) GetProcessInstanceSpec 

func (x *InstanceSpec) GetProcessInstanceSpec() *ProcessInstanceSpec

func (*InstanceSpec) GetSpdkInstanceSpec 

func (x *InstanceSpec) GetSpdkInstanceSpec() *SpdkInstanceSpec

func (*InstanceSpec) GetType 

func (x *InstanceSpec) GetType() string

func (*InstanceSpec) GetVolumeName 

func (x *InstanceSpec) GetVolumeName() string

func (*InstanceSpec) ProtoMessage 

func (*InstanceSpec) ProtoMessage()

func (*InstanceSpec) ProtoReflect 

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

func (*InstanceSpec) Reset 

func (x *InstanceSpec) Reset()

func (*InstanceSpec) String 

func (x *InstanceSpec) String() string

type InstanceStatus 

type InstanceStatus struct {
	State      string          `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	ErrorMsg   string          `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	PortStart  int32           `protobuf:"varint,3,opt,name=port_start,json=portStart,proto3" json:"port_start,omitempty"`
	PortEnd    int32           `protobuf:"varint,4,opt,name=port_end,json=portEnd,proto3" json:"port_end,omitempty"`
	Conditions map[string]bool `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InstanceStatus) Descriptor deprecated 

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

Deprecated: Use InstanceStatus.ProtoReflect.Descriptor instead.

func (*InstanceStatus) GetConditions 

func (x *InstanceStatus) GetConditions() map[string]bool

func (*InstanceStatus) GetErrorMsg 

func (x *InstanceStatus) GetErrorMsg() string

func (*InstanceStatus) GetPortEnd 

func (x *InstanceStatus) GetPortEnd() int32

func (*InstanceStatus) GetPortStart 

func (x *InstanceStatus) GetPortStart() int32

func (*InstanceStatus) GetState 

func (x *InstanceStatus) GetState() string

func (*InstanceStatus) ProtoMessage 

func (*InstanceStatus) ProtoMessage()

func (*InstanceStatus) ProtoReflect 

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

func (*InstanceStatus) Reset 

func (x *InstanceStatus) Reset()

func (*InstanceStatus) String 

func (x *InstanceStatus) String() string

type LogGetFlagsRequest 

type LogGetFlagsRequest struct {
	DataEngine DataEngine `protobuf:"varint,1,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*LogGetFlagsRequest) Descriptor deprecated 

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

Deprecated: Use LogGetFlagsRequest.ProtoReflect.Descriptor instead.

func (*LogGetFlagsRequest) GetDataEngine 

func (x *LogGetFlagsRequest) GetDataEngine() DataEngine

func (*LogGetFlagsRequest) ProtoMessage 

func (*LogGetFlagsRequest) ProtoMessage()

func (*LogGetFlagsRequest) ProtoReflect 

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

func (*LogGetFlagsRequest) Reset 

func (x *LogGetFlagsRequest) Reset()

func (*LogGetFlagsRequest) String 

func (x *LogGetFlagsRequest) String() string

type LogGetFlagsResponse 

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

func (*LogGetFlagsResponse) Descriptor deprecated 

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

Deprecated: Use LogGetFlagsResponse.ProtoReflect.Descriptor instead.

func (*LogGetFlagsResponse) GetFlags 

func (x *LogGetFlagsResponse) GetFlags() string

func (*LogGetFlagsResponse) ProtoMessage 

func (*LogGetFlagsResponse) ProtoMessage()

func (*LogGetFlagsResponse) ProtoReflect 

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

func (*LogGetFlagsResponse) Reset 

func (x *LogGetFlagsResponse) Reset()

func (*LogGetFlagsResponse) String 

func (x *LogGetFlagsResponse) String() string

type LogGetLevelRequest 

type LogGetLevelRequest struct {
	DataEngine DataEngine `protobuf:"varint,1,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*LogGetLevelRequest) Descriptor deprecated 

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

Deprecated: Use LogGetLevelRequest.ProtoReflect.Descriptor instead.

func (*LogGetLevelRequest) GetDataEngine 

func (x *LogGetLevelRequest) GetDataEngine() DataEngine

func (*LogGetLevelRequest) ProtoMessage 

func (*LogGetLevelRequest) ProtoMessage()

func (*LogGetLevelRequest) ProtoReflect 

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

func (*LogGetLevelRequest) Reset 

func (x *LogGetLevelRequest) Reset()

func (*LogGetLevelRequest) String 

func (x *LogGetLevelRequest) String() string

type LogGetLevelResponse 

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

func (*LogGetLevelResponse) Descriptor deprecated 

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

Deprecated: Use LogGetLevelResponse.ProtoReflect.Descriptor instead.

func (*LogGetLevelResponse) GetLevel 

func (x *LogGetLevelResponse) GetLevel() string

func (*LogGetLevelResponse) ProtoMessage 

func (*LogGetLevelResponse) ProtoMessage()

func (*LogGetLevelResponse) ProtoReflect 

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

func (*LogGetLevelResponse) Reset 

func (x *LogGetLevelResponse) Reset()

func (*LogGetLevelResponse) String 

func (x *LogGetLevelResponse) String() string

type LogRequest 

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

func (*LogRequest) Descriptor deprecated 

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetName 

func (x *LogRequest) GetName() string

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect 

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

func (*LogRequest) Reset 

func (x *LogRequest) Reset()

func (*LogRequest) String 

func (x *LogRequest) String() string

type LogResponse 

type LogResponse struct {
	Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

func (*LogResponse) Descriptor deprecated 

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) GetLine 

func (x *LogResponse) GetLine() string

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect 

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

func (*LogResponse) Reset 

func (x *LogResponse) Reset()

func (*LogResponse) String 

func (x *LogResponse) String() string

type LogSetFlagsRequest 

type LogSetFlagsRequest struct {
	DataEngine DataEngine `protobuf:"varint,1,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	Flags      string     `protobuf:"bytes,2,opt,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSetFlagsRequest) Descriptor deprecated 

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

Deprecated: Use LogSetFlagsRequest.ProtoReflect.Descriptor instead.

func (*LogSetFlagsRequest) GetDataEngine 

func (x *LogSetFlagsRequest) GetDataEngine() DataEngine

func (*LogSetFlagsRequest) GetFlags 

func (x *LogSetFlagsRequest) GetFlags() string

func (*LogSetFlagsRequest) ProtoMessage 

func (*LogSetFlagsRequest) ProtoMessage()

func (*LogSetFlagsRequest) ProtoReflect 

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

func (*LogSetFlagsRequest) Reset 

func (x *LogSetFlagsRequest) Reset()

func (*LogSetFlagsRequest) String 

func (x *LogSetFlagsRequest) String() string

type LogSetLevelRequest 

type LogSetLevelRequest struct {
	DataEngine DataEngine `protobuf:"varint,1,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	Level      string     `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSetLevelRequest) Descriptor deprecated 

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

Deprecated: Use LogSetLevelRequest.ProtoReflect.Descriptor instead.

func (*LogSetLevelRequest) GetDataEngine 

func (x *LogSetLevelRequest) GetDataEngine() DataEngine

func (*LogSetLevelRequest) GetLevel 

func (x *LogSetLevelRequest) GetLevel() string

func (*LogSetLevelRequest) ProtoMessage 

func (*LogSetLevelRequest) ProtoMessage()

func (*LogSetLevelRequest) ProtoReflect 

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

func (*LogSetLevelRequest) Reset 

func (x *LogSetLevelRequest) Reset()

func (*LogSetLevelRequest) String 

func (x *LogSetLevelRequest) String() string

type ProcessCreateRequest 

type ProcessCreateRequest struct {
	Spec *ProcessSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessCreateRequest) Descriptor deprecated 

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

Deprecated: Use ProcessCreateRequest.ProtoReflect.Descriptor instead.

func (*ProcessCreateRequest) GetSpec 

func (x *ProcessCreateRequest) GetSpec() *ProcessSpec

func (*ProcessCreateRequest) ProtoMessage 

func (*ProcessCreateRequest) ProtoMessage()

func (*ProcessCreateRequest) ProtoReflect 

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

func (*ProcessCreateRequest) Reset 

func (x *ProcessCreateRequest) Reset()

func (*ProcessCreateRequest) String 

func (x *ProcessCreateRequest) String() string

type ProcessDeleteRequest 

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

func (*ProcessDeleteRequest) Descriptor deprecated 

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

Deprecated: Use ProcessDeleteRequest.ProtoReflect.Descriptor instead.

func (*ProcessDeleteRequest) GetName 

func (x *ProcessDeleteRequest) GetName() string

func (*ProcessDeleteRequest) ProtoMessage 

func (*ProcessDeleteRequest) ProtoMessage()

func (*ProcessDeleteRequest) ProtoReflect 

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

func (*ProcessDeleteRequest) Reset 

func (x *ProcessDeleteRequest) Reset()

func (*ProcessDeleteRequest) String 

func (x *ProcessDeleteRequest) String() string

type ProcessGetRequest 

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

func (*ProcessGetRequest) Descriptor deprecated 

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

Deprecated: Use ProcessGetRequest.ProtoReflect.Descriptor instead.

func (*ProcessGetRequest) GetName 

func (x *ProcessGetRequest) GetName() string

func (*ProcessGetRequest) ProtoMessage 

func (*ProcessGetRequest) ProtoMessage()

func (*ProcessGetRequest) ProtoReflect 

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

func (*ProcessGetRequest) Reset 

func (x *ProcessGetRequest) Reset()

func (*ProcessGetRequest) String 

func (x *ProcessGetRequest) String() string

type ProcessInstanceSpec 

type ProcessInstanceSpec struct {
	Binary string   `protobuf:"bytes,1,opt,name=binary,proto3" json:"binary,omitempty"`
	Args   []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInstanceSpec) Descriptor deprecated 

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

Deprecated: Use ProcessInstanceSpec.ProtoReflect.Descriptor instead.

func (*ProcessInstanceSpec) GetArgs 

func (x *ProcessInstanceSpec) GetArgs() []string

func (*ProcessInstanceSpec) GetBinary 

func (x *ProcessInstanceSpec) GetBinary() string

func (*ProcessInstanceSpec) ProtoMessage 

func (*ProcessInstanceSpec) ProtoMessage()

func (*ProcessInstanceSpec) ProtoReflect 

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

func (*ProcessInstanceSpec) Reset 

func (x *ProcessInstanceSpec) Reset()

func (*ProcessInstanceSpec) String 

func (x *ProcessInstanceSpec) String() string

type ProcessListRequest 

type ProcessListRequest struct {
	// contains filtered or unexported fields
}

func (*ProcessListRequest) Descriptor deprecated 

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

Deprecated: Use ProcessListRequest.ProtoReflect.Descriptor instead.

func (*ProcessListRequest) ProtoMessage 

func (*ProcessListRequest) ProtoMessage()

func (*ProcessListRequest) ProtoReflect 

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

func (*ProcessListRequest) Reset 

func (x *ProcessListRequest) Reset()

func (*ProcessListRequest) String 

func (x *ProcessListRequest) String() string

type ProcessListResponse 

type ProcessListResponse struct {
	Processes map[string]*ProcessResponse `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProcessListResponse) Descriptor deprecated 

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

Deprecated: Use ProcessListResponse.ProtoReflect.Descriptor instead.

func (*ProcessListResponse) GetProcesses 

func (x *ProcessListResponse) GetProcesses() map[string]*ProcessResponse

func (*ProcessListResponse) ProtoMessage 

func (*ProcessListResponse) ProtoMessage()

func (*ProcessListResponse) ProtoReflect 

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

func (*ProcessListResponse) Reset 

func (x *ProcessListResponse) Reset()

func (*ProcessListResponse) String 

func (x *ProcessListResponse) String() string

type ProcessManagerServiceClient 

type ProcessManagerServiceClient interface {
	ProcessCreate(ctx context.Context, in *ProcessCreateRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessDelete(ctx context.Context, in *ProcessDeleteRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessGet(ctx context.Context, in *ProcessGetRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessList(ctx context.Context, in *ProcessListRequest, opts ...grpc.CallOption) (*ProcessListResponse, error)
	ProcessLog(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (ProcessManagerService_ProcessLogClient, error)
	ProcessWatch(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (ProcessManagerService_ProcessWatchClient, error)
	ProcessReplace(ctx context.Context, in *ProcessReplaceRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	VersionGet(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionResponse, error)
}

ProcessManagerServiceClient is the client API for ProcessManagerService 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 NewProcessManagerServiceClient 

func NewProcessManagerServiceClient(cc grpc.ClientConnInterface) ProcessManagerServiceClient

type ProcessManagerServiceServer 

type ProcessManagerServiceServer interface {
	ProcessCreate(context.Context, *ProcessCreateRequest) (*ProcessResponse, error)
	ProcessDelete(context.Context, *ProcessDeleteRequest) (*ProcessResponse, error)
	ProcessGet(context.Context, *ProcessGetRequest) (*ProcessResponse, error)
	ProcessList(context.Context, *ProcessListRequest) (*ProcessListResponse, error)
	ProcessLog(*LogRequest, ProcessManagerService_ProcessLogServer) error
	ProcessWatch(*emptypb.Empty, ProcessManagerService_ProcessWatchServer) error
	ProcessReplace(context.Context, *ProcessReplaceRequest) (*ProcessResponse, error)
	VersionGet(context.Context, *emptypb.Empty) (*VersionResponse, error)
	// contains filtered or unexported methods
}

ProcessManagerServiceServer is the server API for ProcessManagerService service. All implementations must embed UnimplementedProcessManagerServiceServer for forward compatibility

type ProcessManagerService_ProcessLogClient 

type ProcessManagerService_ProcessLogClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type ProcessManagerService_ProcessLogServer 

type ProcessManagerService_ProcessLogServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type ProcessManagerService_ProcessWatchClient 

type ProcessManagerService_ProcessWatchClient interface {
	Recv() (*ProcessResponse, error)
	grpc.ClientStream
}

type ProcessManagerService_ProcessWatchServer 

type ProcessManagerService_ProcessWatchServer interface {
	Send(*ProcessResponse) error
	grpc.ServerStream
}

type ProcessReplaceRequest 

type ProcessReplaceRequest struct {
	Spec            *ProcessSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	TerminateSignal string       `protobuf:"bytes,2,opt,name=terminate_signal,json=terminateSignal,proto3" json:"terminate_signal,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessReplaceRequest) Descriptor deprecated 

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

Deprecated: Use ProcessReplaceRequest.ProtoReflect.Descriptor instead.

func (*ProcessReplaceRequest) GetSpec 

func (x *ProcessReplaceRequest) GetSpec() *ProcessSpec

func (*ProcessReplaceRequest) GetTerminateSignal 

func (x *ProcessReplaceRequest) GetTerminateSignal() string

func (*ProcessReplaceRequest) ProtoMessage 

func (*ProcessReplaceRequest) ProtoMessage()

func (*ProcessReplaceRequest) ProtoReflect 

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

func (*ProcessReplaceRequest) Reset 

func (x *ProcessReplaceRequest) Reset()

func (*ProcessReplaceRequest) String 

func (x *ProcessReplaceRequest) String() string

type ProcessResponse 

type ProcessResponse struct {
	Spec    *ProcessSpec   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Status  *ProcessStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Deleted bool           `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessResponse) Descriptor deprecated 

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

Deprecated: Use ProcessResponse.ProtoReflect.Descriptor instead.

func (*ProcessResponse) GetDeleted 

func (x *ProcessResponse) GetDeleted() bool

func (*ProcessResponse) GetSpec 

func (x *ProcessResponse) GetSpec() *ProcessSpec

func (*ProcessResponse) GetStatus 

func (x *ProcessResponse) GetStatus() *ProcessStatus

func (*ProcessResponse) ProtoMessage 

func (*ProcessResponse) ProtoMessage()

func (*ProcessResponse) ProtoReflect 

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

func (*ProcessResponse) Reset 

func (x *ProcessResponse) Reset()

func (*ProcessResponse) String 

func (x *ProcessResponse) String() string

type ProcessSpec 

type ProcessSpec struct {
	Name      string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Binary    string   `protobuf:"bytes,2,opt,name=binary,proto3" json:"binary,omitempty"`
	Args      []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	PortCount int32    `protobuf:"varint,4,opt,name=port_count,json=portCount,proto3" json:"port_count,omitempty"`
	PortArgs  []string `protobuf:"bytes,5,rep,name=port_args,json=portArgs,proto3" json:"port_args,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessSpec) Descriptor deprecated 

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

Deprecated: Use ProcessSpec.ProtoReflect.Descriptor instead.

func (*ProcessSpec) GetArgs 

func (x *ProcessSpec) GetArgs() []string

func (*ProcessSpec) GetBinary 

func (x *ProcessSpec) GetBinary() string

func (*ProcessSpec) GetName 

func (x *ProcessSpec) GetName() string

func (*ProcessSpec) GetPortArgs 

func (x *ProcessSpec) GetPortArgs() []string

func (*ProcessSpec) GetPortCount 

func (x *ProcessSpec) GetPortCount() int32

func (*ProcessSpec) ProtoMessage 

func (*ProcessSpec) ProtoMessage()

func (*ProcessSpec) ProtoReflect 

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

func (*ProcessSpec) Reset 

func (x *ProcessSpec) Reset()

func (*ProcessSpec) String 

func (x *ProcessSpec) String() string

type ProcessStatus 

type ProcessStatus struct {
	State      string          `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	ErrorMsg   string          `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	PortStart  int32           `protobuf:"varint,3,opt,name=port_start,json=portStart,proto3" json:"port_start,omitempty"`
	PortEnd    int32           `protobuf:"varint,4,opt,name=port_end,json=portEnd,proto3" json:"port_end,omitempty"`
	Conditions map[string]bool `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProcessStatus) Descriptor deprecated 

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

Deprecated: Use ProcessStatus.ProtoReflect.Descriptor instead.

func (*ProcessStatus) GetConditions 

func (x *ProcessStatus) GetConditions() map[string]bool

func (*ProcessStatus) GetErrorMsg 

func (x *ProcessStatus) GetErrorMsg() string

func (*ProcessStatus) GetPortEnd 

func (x *ProcessStatus) GetPortEnd() int32

func (*ProcessStatus) GetPortStart 

func (x *ProcessStatus) GetPortStart() int32

func (*ProcessStatus) GetState 

func (x *ProcessStatus) GetState() string

func (*ProcessStatus) ProtoMessage 

func (*ProcessStatus) ProtoMessage()

func (*ProcessStatus) ProtoReflect 

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

func (*ProcessStatus) Reset 

func (x *ProcessStatus) Reset()

func (*ProcessStatus) String 

func (x *ProcessStatus) String() string

type ProxyEngineRequest 

type ProxyEngineRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Deprecated: Replaced by `data_engine`.
	//
	// Deprecated: Marked as deprecated in imrpc/proxy.proto.
	BackendStoreDriver BackendStoreDriver `` /* 148-byte string literal not displayed */
	EngineName         string             `protobuf:"bytes,3,opt,name=engine_name,json=engineName,proto3" json:"engine_name,omitempty"`
	VolumeName         string             `protobuf:"bytes,4,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	DataEngine         DataEngine         `protobuf:"varint,5,opt,name=data_engine,json=dataEngine,proto3,enum=imrpc.DataEngine" json:"data_engine,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyEngineRequest) Descriptor deprecated 

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

Deprecated: Use ProxyEngineRequest.ProtoReflect.Descriptor instead.

func (*ProxyEngineRequest) GetAddress 

func (x *ProxyEngineRequest) GetAddress() string

func (*ProxyEngineRequest) GetBackendStoreDriver deprecated 

func (x *ProxyEngineRequest) GetBackendStoreDriver() BackendStoreDriver

Deprecated: Marked as deprecated in imrpc/proxy.proto.

func (*ProxyEngineRequest) GetDataEngine 

func (x *ProxyEngineRequest) GetDataEngine() DataEngine

func (*ProxyEngineRequest) GetEngineName 

func (x *ProxyEngineRequest) GetEngineName() string

func (*ProxyEngineRequest) GetVolumeName 

func (x *ProxyEngineRequest) GetVolumeName() string

func (*ProxyEngineRequest) ProtoMessage 

func (*ProxyEngineRequest) ProtoMessage()

func (*ProxyEngineRequest) ProtoReflect 

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

func (*ProxyEngineRequest) Reset 

func (x *ProxyEngineRequest) Reset()

func (*ProxyEngineRequest) String 

func (x *ProxyEngineRequest) String() string

type ProxyEngineServiceClient 

type ProxyEngineServiceClient interface {
	ServerVersionGet(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineVersionProxyResponse, error)
	VolumeGet(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineVolumeGetProxyResponse, error)
	VolumeExpand(ctx context.Context, in *EngineVolumeExpandRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VolumeFrontendStart(ctx context.Context, in *EngineVolumeFrontendStartRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VolumeFrontendShutdown(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VolumeUnmapMarkSnapChainRemovedSet(ctx context.Context, in *EngineVolumeUnmapMarkSnapChainRemovedSetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VolumeSnapshotMaxCountSet(ctx context.Context, in *EngineVolumeSnapshotMaxCountSetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VolumeSnapshotMaxSizeSet(ctx context.Context, in *EngineVolumeSnapshotMaxSizeSetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	VolumeSnapshot(ctx context.Context, in *EngineVolumeSnapshotRequest, opts ...grpc.CallOption) (*EngineVolumeSnapshotProxyResponse, error)
	SnapshotList(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineSnapshotListProxyResponse, error)
	SnapshotRevert(ctx context.Context, in *EngineSnapshotRevertRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotPurge(ctx context.Context, in *EngineSnapshotPurgeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotPurgeStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineSnapshotPurgeStatusProxyResponse, error)
	SnapshotClone(ctx context.Context, in *EngineSnapshotCloneRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotCloneStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineSnapshotCloneStatusProxyResponse, error)
	SnapshotRemove(ctx context.Context, in *EngineSnapshotRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotHash(ctx context.Context, in *EngineSnapshotHashRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SnapshotHashStatus(ctx context.Context, in *EngineSnapshotHashStatusRequest, opts ...grpc.CallOption) (*EngineSnapshotHashStatusProxyResponse, error)
	SnapshotBackup(ctx context.Context, in *EngineSnapshotBackupRequest, opts ...grpc.CallOption) (*EngineSnapshotBackupProxyResponse, error)
	SnapshotBackupStatus(ctx context.Context, in *EngineSnapshotBackupStatusRequest, opts ...grpc.CallOption) (*EngineSnapshotBackupStatusProxyResponse, error)
	BackupRestore(ctx context.Context, in *EngineBackupRestoreRequest, opts ...grpc.CallOption) (*EngineBackupRestoreProxyResponse, error)
	BackupRestoreStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineBackupRestoreStatusProxyResponse, error)
	BackupRestoreFinish(ctx context.Context, in *EngineBackupRestoreFinishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CleanupBackupMountPoints(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReplicaAdd(ctx context.Context, in *EngineReplicaAddRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReplicaList(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineReplicaListProxyResponse, error)
	ReplicaRebuildingStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineReplicaRebuildStatusProxyResponse, error)
	ReplicaVerifyRebuild(ctx context.Context, in *EngineReplicaVerifyRebuildRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReplicaRemove(ctx context.Context, in *EngineReplicaRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReplicaModeUpdate(ctx context.Context, in *EngineReplicaModeUpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	MetricsGet(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineMetricsGetProxyResponse, error)
	RemountReadOnlyVolume(ctx context.Context, in *RemountVolumeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ProxyEngineServiceClient is the client API for ProxyEngineService 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 NewProxyEngineServiceClient 

func NewProxyEngineServiceClient(cc grpc.ClientConnInterface) ProxyEngineServiceClient

type ProxyEngineServiceServer 

type ProxyEngineServiceServer interface {
	ServerVersionGet(context.Context, *ProxyEngineRequest) (*EngineVersionProxyResponse, error)
	VolumeGet(context.Context, *ProxyEngineRequest) (*EngineVolumeGetProxyResponse, error)
	VolumeExpand(context.Context, *EngineVolumeExpandRequest) (*emptypb.Empty, error)
	VolumeFrontendStart(context.Context, *EngineVolumeFrontendStartRequest) (*emptypb.Empty, error)
	VolumeFrontendShutdown(context.Context, *ProxyEngineRequest) (*emptypb.Empty, error)
	VolumeUnmapMarkSnapChainRemovedSet(context.Context, *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) (*emptypb.Empty, error)
	VolumeSnapshotMaxCountSet(context.Context, *EngineVolumeSnapshotMaxCountSetRequest) (*emptypb.Empty, error)
	VolumeSnapshotMaxSizeSet(context.Context, *EngineVolumeSnapshotMaxSizeSetRequest) (*emptypb.Empty, error)
	VolumeSnapshot(context.Context, *EngineVolumeSnapshotRequest) (*EngineVolumeSnapshotProxyResponse, error)
	SnapshotList(context.Context, *ProxyEngineRequest) (*EngineSnapshotListProxyResponse, error)
	SnapshotRevert(context.Context, *EngineSnapshotRevertRequest) (*emptypb.Empty, error)
	SnapshotPurge(context.Context, *EngineSnapshotPurgeRequest) (*emptypb.Empty, error)
	SnapshotPurgeStatus(context.Context, *ProxyEngineRequest) (*EngineSnapshotPurgeStatusProxyResponse, error)
	SnapshotClone(context.Context, *EngineSnapshotCloneRequest) (*emptypb.Empty, error)
	SnapshotCloneStatus(context.Context, *ProxyEngineRequest) (*EngineSnapshotCloneStatusProxyResponse, error)
	SnapshotRemove(context.Context, *EngineSnapshotRemoveRequest) (*emptypb.Empty, error)
	SnapshotHash(context.Context, *EngineSnapshotHashRequest) (*emptypb.Empty, error)
	SnapshotHashStatus(context.Context, *EngineSnapshotHashStatusRequest) (*EngineSnapshotHashStatusProxyResponse, error)
	SnapshotBackup(context.Context, *EngineSnapshotBackupRequest) (*EngineSnapshotBackupProxyResponse, error)
	SnapshotBackupStatus(context.Context, *EngineSnapshotBackupStatusRequest) (*EngineSnapshotBackupStatusProxyResponse, error)
	BackupRestore(context.Context, *EngineBackupRestoreRequest) (*EngineBackupRestoreProxyResponse, error)
	BackupRestoreStatus(context.Context, *ProxyEngineRequest) (*EngineBackupRestoreStatusProxyResponse, error)
	BackupRestoreFinish(context.Context, *EngineBackupRestoreFinishRequest) (*emptypb.Empty, error)
	CleanupBackupMountPoints(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ReplicaAdd(context.Context, *EngineReplicaAddRequest) (*emptypb.Empty, error)
	ReplicaList(context.Context, *ProxyEngineRequest) (*EngineReplicaListProxyResponse, error)
	ReplicaRebuildingStatus(context.Context, *ProxyEngineRequest) (*EngineReplicaRebuildStatusProxyResponse, error)
	ReplicaVerifyRebuild(context.Context, *EngineReplicaVerifyRebuildRequest) (*emptypb.Empty, error)
	ReplicaRemove(context.Context, *EngineReplicaRemoveRequest) (*emptypb.Empty, error)
	ReplicaModeUpdate(context.Context, *EngineReplicaModeUpdateRequest) (*emptypb.Empty, error)
	MetricsGet(context.Context, *ProxyEngineRequest) (*EngineMetricsGetProxyResponse, error)
	RemountReadOnlyVolume(context.Context, *RemountVolumeRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ProxyEngineServiceServer is the server API for ProxyEngineService service. All implementations must embed UnimplementedProxyEngineServiceServer for forward compatibility

type RemountVolumeRequest 

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

func (*RemountVolumeRequest) Descriptor deprecated 

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

Deprecated: Use RemountVolumeRequest.ProtoReflect.Descriptor instead.

func (*RemountVolumeRequest) GetVolumeName 

func (x *RemountVolumeRequest) GetVolumeName() string

func (*RemountVolumeRequest) ProtoMessage 

func (*RemountVolumeRequest) ProtoMessage()

func (*RemountVolumeRequest) ProtoReflect 

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

func (*RemountVolumeRequest) Reset 

func (x *RemountVolumeRequest) Reset()

func (*RemountVolumeRequest) String 

func (x *RemountVolumeRequest) String() string

type ReplicaInstance 

type ReplicaInstance struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uuid       string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	DiskName   string `protobuf:"bytes,3,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid   string `protobuf:"bytes,4,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	SpecSize   uint64 `protobuf:"varint,5,opt,name=spec_size,json=specSize,proto3" json:"spec_size,omitempty"`
	ActualSize uint64 `protobuf:"varint,6,opt,name=actual_size,json=actualSize,proto3" json:"actual_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaInstance) Descriptor deprecated 

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

Deprecated: Use ReplicaInstance.ProtoReflect.Descriptor instead.

func (*ReplicaInstance) GetActualSize 

func (x *ReplicaInstance) GetActualSize() uint64

func (*ReplicaInstance) GetDiskName 

func (x *ReplicaInstance) GetDiskName() string

func (*ReplicaInstance) GetDiskUuid 

func (x *ReplicaInstance) GetDiskUuid() string

func (*ReplicaInstance) GetName 

func (x *ReplicaInstance) GetName() string

func (*ReplicaInstance) GetSpecSize 

func (x *ReplicaInstance) GetSpecSize() uint64

func (*ReplicaInstance) GetUuid 

func (x *ReplicaInstance) GetUuid() string

func (*ReplicaInstance) ProtoMessage 

func (*ReplicaInstance) ProtoMessage()

func (*ReplicaInstance) ProtoReflect 

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

func (*ReplicaInstance) Reset 

func (x *ReplicaInstance) Reset()

func (*ReplicaInstance) String 

func (x *ReplicaInstance) String() string

type SpdkInstanceSpec 

type SpdkInstanceSpec struct {
	ReplicaAddressMap map[string]string `` /* 202-byte string literal not displayed */
	DiskName          string            `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid          string            `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	Size              uint64            `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	ExposeRequired    bool              `protobuf:"varint,5,opt,name=expose_required,json=exposeRequired,proto3" json:"expose_required,omitempty"`
	Frontend          string            `protobuf:"bytes,6,opt,name=frontend,proto3" json:"frontend,omitempty"`
	// contains filtered or unexported fields
}

func (*SpdkInstanceSpec) Descriptor deprecated 

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

Deprecated: Use SpdkInstanceSpec.ProtoReflect.Descriptor instead.

func (*SpdkInstanceSpec) GetDiskName 

func (x *SpdkInstanceSpec) GetDiskName() string

func (*SpdkInstanceSpec) GetDiskUuid 

func (x *SpdkInstanceSpec) GetDiskUuid() string

func (*SpdkInstanceSpec) GetExposeRequired 

func (x *SpdkInstanceSpec) GetExposeRequired() bool

func (*SpdkInstanceSpec) GetFrontend 

func (x *SpdkInstanceSpec) GetFrontend() string

func (*SpdkInstanceSpec) GetReplicaAddressMap 

func (x *SpdkInstanceSpec) GetReplicaAddressMap() map[string]string

func (*SpdkInstanceSpec) GetSize 

func (x *SpdkInstanceSpec) GetSize() uint64

func (*SpdkInstanceSpec) ProtoMessage 

func (*SpdkInstanceSpec) ProtoMessage()

func (*SpdkInstanceSpec) ProtoReflect 

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

func (*SpdkInstanceSpec) Reset 

func (x *SpdkInstanceSpec) Reset()

func (*SpdkInstanceSpec) String 

func (x *SpdkInstanceSpec) String() string

type UnimplementedDiskServiceServer 

type UnimplementedDiskServiceServer struct {
}

UnimplementedDiskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDiskServiceServer) DiskCreate 

func (UnimplementedDiskServiceServer) DiskCreate(context.Context, *DiskCreateRequest) (*Disk, error)

func (UnimplementedDiskServiceServer) DiskDelete 

func (UnimplementedDiskServiceServer) DiskDelete(context.Context, *DiskDeleteRequest) (*emptypb.Empty, error)

func (UnimplementedDiskServiceServer) DiskGet 

func (UnimplementedDiskServiceServer) DiskGet(context.Context, *DiskGetRequest) (*Disk, error)

func (UnimplementedDiskServiceServer) DiskReplicaInstanceDelete 

func (UnimplementedDiskServiceServer) DiskReplicaInstanceDelete(context.Context, *DiskReplicaInstanceDeleteRequest) (*emptypb.Empty, error)

func (UnimplementedDiskServiceServer) DiskReplicaInstanceList 

func (UnimplementedDiskServiceServer) DiskReplicaInstanceList(context.Context, *DiskReplicaInstanceListRequest) (*DiskReplicaInstanceListResponse, error)

func (UnimplementedDiskServiceServer) VersionGet 

func (UnimplementedDiskServiceServer) VersionGet(context.Context, *emptypb.Empty) (*DiskVersionResponse, error)

type UnimplementedInstanceServiceServer 

type UnimplementedInstanceServiceServer struct {
}

UnimplementedInstanceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInstanceServiceServer) InstanceCreate 

func (UnimplementedInstanceServiceServer) InstanceCreate(context.Context, *InstanceCreateRequest) (*InstanceResponse, error)

func (UnimplementedInstanceServiceServer) InstanceDelete 

func (UnimplementedInstanceServiceServer) InstanceDelete(context.Context, *InstanceDeleteRequest) (*InstanceResponse, error)

func (UnimplementedInstanceServiceServer) InstanceGet 

func (UnimplementedInstanceServiceServer) InstanceGet(context.Context, *InstanceGetRequest) (*InstanceResponse, error)

func (UnimplementedInstanceServiceServer) InstanceList 

func (UnimplementedInstanceServiceServer) InstanceList(context.Context, *emptypb.Empty) (*InstanceListResponse, error)

func (UnimplementedInstanceServiceServer) InstanceLog 

func (UnimplementedInstanceServiceServer) InstanceLog(*InstanceLogRequest, InstanceService_InstanceLogServer) error

func (UnimplementedInstanceServiceServer) InstanceReplace 

func (UnimplementedInstanceServiceServer) InstanceReplace(context.Context, *InstanceReplaceRequest) (*InstanceResponse, error)

func (UnimplementedInstanceServiceServer) InstanceWatch 

func (UnimplementedInstanceServiceServer) InstanceWatch(*emptypb.Empty, InstanceService_InstanceWatchServer) error

func (UnimplementedInstanceServiceServer) LogGetFlags 

func (UnimplementedInstanceServiceServer) LogGetFlags(context.Context, *LogGetFlagsRequest) (*LogGetFlagsResponse, error)

func (UnimplementedInstanceServiceServer) LogGetLevel 

func (UnimplementedInstanceServiceServer) LogGetLevel(context.Context, *LogGetLevelRequest) (*LogGetLevelResponse, error)

func (UnimplementedInstanceServiceServer) LogSetFlags 

func (UnimplementedInstanceServiceServer) LogSetFlags(context.Context, *LogSetFlagsRequest) (*emptypb.Empty, error)

func (UnimplementedInstanceServiceServer) LogSetLevel 

func (UnimplementedInstanceServiceServer) LogSetLevel(context.Context, *LogSetLevelRequest) (*emptypb.Empty, error)

func (UnimplementedInstanceServiceServer) VersionGet 

func (UnimplementedInstanceServiceServer) VersionGet(context.Context, *emptypb.Empty) (*VersionResponse, error)

type UnimplementedProcessManagerServiceServer 

type UnimplementedProcessManagerServiceServer struct {
}

UnimplementedProcessManagerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProcessManagerServiceServer) ProcessCreate 

func (UnimplementedProcessManagerServiceServer) ProcessCreate(context.Context, *ProcessCreateRequest) (*ProcessResponse, error)

func (UnimplementedProcessManagerServiceServer) ProcessDelete 

func (UnimplementedProcessManagerServiceServer) ProcessDelete(context.Context, *ProcessDeleteRequest) (*ProcessResponse, error)

func (UnimplementedProcessManagerServiceServer) ProcessGet 

func (UnimplementedProcessManagerServiceServer) ProcessGet(context.Context, *ProcessGetRequest) (*ProcessResponse, error)

func (UnimplementedProcessManagerServiceServer) ProcessList 

func (UnimplementedProcessManagerServiceServer) ProcessList(context.Context, *ProcessListRequest) (*ProcessListResponse, error)

func (UnimplementedProcessManagerServiceServer) ProcessLog 

func (UnimplementedProcessManagerServiceServer) ProcessLog(*LogRequest, ProcessManagerService_ProcessLogServer) error

func (UnimplementedProcessManagerServiceServer) ProcessReplace 

func (UnimplementedProcessManagerServiceServer) ProcessReplace(context.Context, *ProcessReplaceRequest) (*ProcessResponse, error)

func (UnimplementedProcessManagerServiceServer) ProcessWatch 

func (UnimplementedProcessManagerServiceServer) ProcessWatch(*emptypb.Empty, ProcessManagerService_ProcessWatchServer) error

func (UnimplementedProcessManagerServiceServer) VersionGet 

func (UnimplementedProcessManagerServiceServer) VersionGet(context.Context, *emptypb.Empty) (*VersionResponse, error)

type UnimplementedProxyEngineServiceServer 

type UnimplementedProxyEngineServiceServer struct {
}

UnimplementedProxyEngineServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyEngineServiceServer) BackupRestore 

func (UnimplementedProxyEngineServiceServer) BackupRestore(context.Context, *EngineBackupRestoreRequest) (*EngineBackupRestoreProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) BackupRestoreFinish 

func (UnimplementedProxyEngineServiceServer) BackupRestoreFinish(context.Context, *EngineBackupRestoreFinishRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) BackupRestoreStatus 

func (UnimplementedProxyEngineServiceServer) BackupRestoreStatus(context.Context, *ProxyEngineRequest) (*EngineBackupRestoreStatusProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) CleanupBackupMountPoints 

func (UnimplementedProxyEngineServiceServer) CleanupBackupMountPoints(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) MetricsGet 

func (UnimplementedProxyEngineServiceServer) MetricsGet(context.Context, *ProxyEngineRequest) (*EngineMetricsGetProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) RemountReadOnlyVolume 

func (UnimplementedProxyEngineServiceServer) RemountReadOnlyVolume(context.Context, *RemountVolumeRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) ReplicaAdd 

func (UnimplementedProxyEngineServiceServer) ReplicaAdd(context.Context, *EngineReplicaAddRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) ReplicaList 

func (UnimplementedProxyEngineServiceServer) ReplicaList(context.Context, *ProxyEngineRequest) (*EngineReplicaListProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) ReplicaModeUpdate 

func (UnimplementedProxyEngineServiceServer) ReplicaModeUpdate(context.Context, *EngineReplicaModeUpdateRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) ReplicaRebuildingStatus 

func (UnimplementedProxyEngineServiceServer) ReplicaRebuildingStatus(context.Context, *ProxyEngineRequest) (*EngineReplicaRebuildStatusProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) ReplicaRemove 

func (UnimplementedProxyEngineServiceServer) ReplicaRemove(context.Context, *EngineReplicaRemoveRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) ReplicaVerifyRebuild 

func (UnimplementedProxyEngineServiceServer) ReplicaVerifyRebuild(context.Context, *EngineReplicaVerifyRebuildRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) ServerVersionGet 

func (UnimplementedProxyEngineServiceServer) ServerVersionGet(context.Context, *ProxyEngineRequest) (*EngineVersionProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) SnapshotBackup 

func (UnimplementedProxyEngineServiceServer) SnapshotBackup(context.Context, *EngineSnapshotBackupRequest) (*EngineSnapshotBackupProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) SnapshotBackupStatus 

func (UnimplementedProxyEngineServiceServer) SnapshotBackupStatus(context.Context, *EngineSnapshotBackupStatusRequest) (*EngineSnapshotBackupStatusProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) SnapshotClone 

func (UnimplementedProxyEngineServiceServer) SnapshotClone(context.Context, *EngineSnapshotCloneRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) SnapshotCloneStatus 

func (UnimplementedProxyEngineServiceServer) SnapshotCloneStatus(context.Context, *ProxyEngineRequest) (*EngineSnapshotCloneStatusProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) SnapshotHash 

func (UnimplementedProxyEngineServiceServer) SnapshotHash(context.Context, *EngineSnapshotHashRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) SnapshotHashStatus 

func (UnimplementedProxyEngineServiceServer) SnapshotHashStatus(context.Context, *EngineSnapshotHashStatusRequest) (*EngineSnapshotHashStatusProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) SnapshotList 

func (UnimplementedProxyEngineServiceServer) SnapshotList(context.Context, *ProxyEngineRequest) (*EngineSnapshotListProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) SnapshotPurge 

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

func (UnimplementedProxyEngineServiceServer) SnapshotPurgeStatus 

func (UnimplementedProxyEngineServiceServer) SnapshotPurgeStatus(context.Context, *ProxyEngineRequest) (*EngineSnapshotPurgeStatusProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) SnapshotRemove 

func (UnimplementedProxyEngineServiceServer) SnapshotRemove(context.Context, *EngineSnapshotRemoveRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) SnapshotRevert 

func (UnimplementedProxyEngineServiceServer) SnapshotRevert(context.Context, *EngineSnapshotRevertRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) VolumeExpand 

func (UnimplementedProxyEngineServiceServer) VolumeExpand(context.Context, *EngineVolumeExpandRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) VolumeFrontendShutdown 

func (UnimplementedProxyEngineServiceServer) VolumeFrontendShutdown(context.Context, *ProxyEngineRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) VolumeFrontendStart 

func (UnimplementedProxyEngineServiceServer) VolumeFrontendStart(context.Context, *EngineVolumeFrontendStartRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) VolumeGet 

func (UnimplementedProxyEngineServiceServer) VolumeGet(context.Context, *ProxyEngineRequest) (*EngineVolumeGetProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) VolumeSnapshot 

func (UnimplementedProxyEngineServiceServer) VolumeSnapshot(context.Context, *EngineVolumeSnapshotRequest) (*EngineVolumeSnapshotProxyResponse, error)

func (UnimplementedProxyEngineServiceServer) VolumeSnapshotMaxCountSet 

func (UnimplementedProxyEngineServiceServer) VolumeSnapshotMaxCountSet(context.Context, *EngineVolumeSnapshotMaxCountSetRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) VolumeSnapshotMaxSizeSet 

func (UnimplementedProxyEngineServiceServer) VolumeSnapshotMaxSizeSet(context.Context, *EngineVolumeSnapshotMaxSizeSetRequest) (*emptypb.Empty, error)

func (UnimplementedProxyEngineServiceServer) VolumeUnmapMarkSnapChainRemovedSet 

func (UnimplementedProxyEngineServiceServer) VolumeUnmapMarkSnapChainRemovedSet(context.Context, *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) (*emptypb.Empty, error)

type UnsafeDiskServiceServer 

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

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

type UnsafeInstanceServiceServer 

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

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

type UnsafeProcessManagerServiceServer 

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

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

type UnsafeProxyEngineServiceServer 

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

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

type VersionResponse 

type VersionResponse 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"`
	InstanceManagerAPIVersion         int64  `protobuf:"varint,4,opt,name=instanceManagerAPIVersion,proto3" json:"instanceManagerAPIVersion,omitempty"`
	InstanceManagerAPIMinVersion      int64  `protobuf:"varint,5,opt,name=instanceManagerAPIMinVersion,proto3" json:"instanceManagerAPIMinVersion,omitempty"`
	InstanceManagerProxyAPIVersion    int64  `protobuf:"varint,6,opt,name=instanceManagerProxyAPIVersion,proto3" json:"instanceManagerProxyAPIVersion,omitempty"`
	InstanceManagerProxyAPIMinVersion int64  `protobuf:"varint,7,opt,name=instanceManagerProxyAPIMinVersion,proto3" json:"instanceManagerProxyAPIMinVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetBuildDate 

func (x *VersionResponse) GetBuildDate() string

func (*VersionResponse) GetGitCommit 

func (x *VersionResponse) GetGitCommit() string

func (*VersionResponse) GetInstanceManagerAPIMinVersion 

func (x *VersionResponse) GetInstanceManagerAPIMinVersion() int64

func (*VersionResponse) GetInstanceManagerAPIVersion 

func (x *VersionResponse) GetInstanceManagerAPIVersion() int64

func (*VersionResponse) GetInstanceManagerProxyAPIMinVersion 

func (x *VersionResponse) GetInstanceManagerProxyAPIMinVersion() int64

func (*VersionResponse) GetInstanceManagerProxyAPIVersion 

func (x *VersionResponse) GetInstanceManagerProxyAPIVersion() int64

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) 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.