Versions in this module Expand all Collapse all v1 v1.6.4 Dec 18, 2024 Changes in this version + const GRPCServiceLongTimeout + const GRPCServiceMedTimeout + const GRPCServiceTimeout + type BackupCreateRequest struct + BackingImageChecksum string + BackingImageName string + BackupName string + BackupTarget string + CompressionMethod string + ConcurrentLimit int32 + Credential map[string]string + EngineName string + Labels []string + ReplicaName string + Size uint64 + SnapshotName string + StorageClassName string + VolumeName string + type BackupRestoreRequest struct + BackupUrl string + ConcurrentLimit int32 + Credential map[string]string + EngineName string + ReplicaName string + SnapshotName string + type SPDKClient struct + func NewSPDKClient(serviceURL string) (*SPDKClient, error) + func (c *SPDKClient) DiskCreate(diskName, diskUUID, diskPath string, blockSize int64) (*spdkrpc.Disk, error) + func (c *SPDKClient) DiskDelete(diskName, diskUUID string) error + func (c *SPDKClient) DiskGet(diskName string) (*spdkrpc.Disk, error) + func (c *SPDKClient) EngineBackupCreate(req *BackupCreateRequest) (*spdkrpc.BackupCreateResponse, error) + func (c *SPDKClient) EngineBackupRestore(req *BackupRestoreRequest) error + func (c *SPDKClient) EngineBackupRestoreFinish(engineName string) error + func (c *SPDKClient) EngineBackupStatus(backupName, engineName, replicaAddress string) (*spdkrpc.BackupStatusResponse, error) + func (c *SPDKClient) EngineCreate(name, volumeName, frontend string, specSize uint64, ...) (*api.Engine, error) + func (c *SPDKClient) EngineDelete(name string) error + func (c *SPDKClient) EngineGet(name string) (*api.Engine, error) + func (c *SPDKClient) EngineList() (map[string]*api.Engine, error) + func (c *SPDKClient) EngineReplicaAdd(engineName, replicaName, replicaAddress string) error + func (c *SPDKClient) EngineReplicaDelete(engineName, replicaName, replicaAddress string) error + func (c *SPDKClient) EngineReplicaList(engineName string) (*spdkrpc.EngineReplicaListResponse, error) + func (c *SPDKClient) EngineRestoreStatus(engineName string) (*spdkrpc.RestoreStatusResponse, error) + func (c *SPDKClient) EngineSnapshotCreate(name, snapshotName string, opts *api.SnapshotOptions) (string, error) + func (c *SPDKClient) EngineSnapshotDelete(name, snapshotName string) error + func (c *SPDKClient) EngineSnapshotRevert(name, snapshotName string) error + func (c *SPDKClient) EngineWatch(ctx context.Context) (*api.EngineStream, error) + func (c *SPDKClient) LogGetFlags() (string, error) + func (c *SPDKClient) LogGetLevel() (string, error) + func (c *SPDKClient) LogSetFlags(flags string) error + func (c *SPDKClient) LogSetLevel(level string) error + func (c *SPDKClient) ReplicaBackupCreate(req *BackupCreateRequest) (*spdkrpc.BackupCreateResponse, error) + func (c *SPDKClient) ReplicaBackupRestore(req *BackupRestoreRequest) error + func (c *SPDKClient) ReplicaBackupStatus(backupName string) (*spdkrpc.BackupStatusResponse, error) + func (c *SPDKClient) ReplicaCreate(name, lvsName, lvsUUID string, specSize uint64, exposeRequired bool, ...) (*api.Replica, error) + func (c *SPDKClient) ReplicaDelete(name string, cleanupRequired bool) error + func (c *SPDKClient) ReplicaGet(name string) (*api.Replica, error) + func (c *SPDKClient) ReplicaList() (map[string]*api.Replica, error) + func (c *SPDKClient) ReplicaRebuildingDstFinish(replicaName string, unexposeRequired bool) error + func (c *SPDKClient) ReplicaRebuildingDstSnapshotCreate(name, snapshotName string, opts *api.SnapshotOptions) error + func (c *SPDKClient) ReplicaRebuildingDstSnapshotRevert(name, snapshotName string) error + func (c *SPDKClient) ReplicaRebuildingDstStart(replicaName string, exposeRequired bool) (dstRebuildingLvolAddress string, err error) + func (c *SPDKClient) ReplicaRebuildingSrcAttach(srcReplicaName, dstReplicaName, dstRebuildingLvolAddress string) error + func (c *SPDKClient) ReplicaRebuildingSrcDetach(srcReplicaName, dstReplicaName string) error + func (c *SPDKClient) ReplicaRebuildingSrcFinish(srcReplicaName, dstReplicaName string) error + func (c *SPDKClient) ReplicaRebuildingSrcStart(srcReplicaName, dstReplicaName, dstRebuildingLvolAddress string) error + func (c *SPDKClient) ReplicaRestoreStatus(replicaName string) (*spdkrpc.ReplicaRestoreStatusResponse, error) + func (c *SPDKClient) ReplicaSnapshotCreate(name, snapshotName string, opts *api.SnapshotOptions) error + func (c *SPDKClient) ReplicaSnapshotDelete(name, snapshotName string) error + func (c *SPDKClient) ReplicaSnapshotRevert(name, snapshotName string) error + func (c *SPDKClient) ReplicaSnapshotShallowCopy(srcReplicaName, snapshotName string) error + func (c *SPDKClient) ReplicaWatch(ctx context.Context) (*api.ReplicaStream, error) + type SPDKServiceContext struct + func (c *SPDKServiceContext) Close() error