Versions in this module Expand all Collapse all v4 v4.6.0 Dec 12, 2024 Changes in this version + const DefaultParallelCount + const ForceFlagFalse + const ForceFlagTrue + const GetInfoWaitInternal + const HyperMetroFilesystemMode + const IPLockErrorCode + const LocalFilesystemMode + const MaxParallelCount + const MinParallelCount + const ParentTypeDTree + const ParentTypeFS + const QueryCountPerBatch + const QuotaTypeDir + const QuotaTypeUser + const QuotaTypeUserGroup + const SecurityStyleUnix + const SpaceUnitTypeGB + const SplitCloneFileSystem + const SuccessCode + const UrlNotFound + const UserOffline + const UserUnauthorized + var AccountBeenLocked = []int64 + var ClientSemaphore *utils.Semaphore + var WrongPasswordErrorCodes = []int64 + type AllowNfsShareAccessRequest struct + AccessKrb5 int + AccessKrb5i int + AccessKrb5p int + AccessVal int + AllSquash int + Name string + ParentID string + RootSquash int + Sync int + VStoreID string + type ApplicationType interface + GetApplicationTypeByName func(ctx context.Context, appType string) (string, error) + type BaseClient struct + BackendID string + Client HTTP + CurrentLifWwn string + CurrentSiteWwn string + DeviceId string + LastLif string + Product string + ReLoginMutex sync.Mutex + SecretName string + SecretNamespace string + Storage string + StorageVersion string + SystemInfoRefreshing uint32 + Token string + Url string + Urls []string + User string + VStoreID string + VStoreName string + func NewClient(ctx context.Context, param *NewClientConfig) (*BaseClient, error) + func (cli *BaseClient) ActivateLunSnapshot(ctx context.Context, snapshotID string) error + func (cli *BaseClient) ActivateQos(ctx context.Context, qosID, vStoreID string) error + func (cli *BaseClient) AddFCInitiatorToHost(ctx context.Context, initiator, hostID string) error + func (cli *BaseClient) AddGroupToMapping(ctx context.Context, groupType int, groupID, mappingID string) error + func (cli *BaseClient) AddHostToGroup(ctx context.Context, hostID, hostGroupID string) error + func (cli *BaseClient) AddIscsiInitiator(ctx context.Context, initiator string) (map[string]interface{}, error) + func (cli *BaseClient) AddIscsiInitiatorToHost(ctx context.Context, initiator, hostID string) error + func (cli *BaseClient) AddLunToGroup(ctx context.Context, lunID string, groupID string) error + func (cli *BaseClient) AddRoCEInitiator(ctx context.Context, initiator string) (map[string]interface{}, error) + func (cli *BaseClient) AddRoCEInitiatorToHost(ctx context.Context, initiator, hostID string) error + func (cli *BaseClient) AllowNfsShareAccess(ctx context.Context, req *AllowNfsShareAccessRequest) error + func (cli *BaseClient) BaseCall(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) BatchGetQuota(ctx context.Context, params map[string]interface{}) ([]interface{}, error) + func (cli *BaseClient) Call(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) CloneFileSystem(ctx context.Context, name string, allocType int, ...) (map[string]interface{}, error) + func (cli *BaseClient) CreateClonePair(ctx context.Context, srcLunID, dstLunID string, cloneSpeed int) (map[string]interface{}, error) + func (cli *BaseClient) CreateDTree(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + func (cli *BaseClient) CreateFSSnapshot(ctx context.Context, name, parentID string) (map[string]interface{}, error) + func (cli *BaseClient) CreateFileSystem(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + func (cli *BaseClient) CreateHost(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) CreateHostGroup(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) CreateHyperMetroPair(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error) + func (cli *BaseClient) CreateLun(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + func (cli *BaseClient) CreateLunCopy(ctx context.Context, name, srcLunID, dstLunID string, copySpeed int) (map[string]interface{}, error) + func (cli *BaseClient) CreateLunGroup(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) CreateLunSnapshot(ctx context.Context, name, lunID string) (map[string]interface{}, error) + func (cli *BaseClient) CreateMapping(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) CreateNfsShare(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + func (cli *BaseClient) CreateQos(ctx context.Context, name, objID, objType, vStoreID string, ...) (map[string]interface{}, error) + func (cli *BaseClient) CreateQuota(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + func (cli *BaseClient) CreateReplicationPair(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error) + func (cli *BaseClient) DeactivateLunSnapshot(ctx context.Context, snapshotID string) error + func (cli *BaseClient) DeactivateQos(ctx context.Context, qosID, vStoreID string) error + func (cli *BaseClient) Delete(ctx context.Context, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) DeleteClonePair(ctx context.Context, clonePairID string) error + func (cli *BaseClient) DeleteDTreeByID(ctx context.Context, vStoreID, dTreeID string) error + func (cli *BaseClient) DeleteDTreeByName(ctx context.Context, parentName, dTreeName, vStoreID string) error + func (cli *BaseClient) DeleteFSSnapshot(ctx context.Context, snapshotID string) error + func (cli *BaseClient) DeleteFileSystem(ctx context.Context, params map[string]interface{}) error + func (cli *BaseClient) DeleteHost(ctx context.Context, id string) error + func (cli *BaseClient) DeleteHostGroup(ctx context.Context, id string) error + func (cli *BaseClient) DeleteHyperMetroPair(ctx context.Context, pairID string, onlineDelete bool) error + func (cli *BaseClient) DeleteLun(ctx context.Context, id string) error + func (cli *BaseClient) DeleteLunCopy(ctx context.Context, lunCopyID string) error + func (cli *BaseClient) DeleteLunGroup(ctx context.Context, id string) error + func (cli *BaseClient) DeleteLunSnapshot(ctx context.Context, snapshotID string) error + func (cli *BaseClient) DeleteMapping(ctx context.Context, id string) error + func (cli *BaseClient) DeleteNfsShare(ctx context.Context, id, vStoreID string) error + func (cli *BaseClient) DeleteNfsShareAccess(ctx context.Context, accessID, vStoreID string) error + func (cli *BaseClient) DeleteQos(ctx context.Context, qosID, vStoreID string) error + func (cli *BaseClient) DeleteQuota(ctx context.Context, quotaID, vStoreID string, forceFlag bool) error + func (cli *BaseClient) DeleteReplicationPair(ctx context.Context, pairID string) error + func (cli *BaseClient) DuplicateClient() *BaseClient + func (cli *BaseClient) ExtendFileSystem(ctx context.Context, fsID string, newCapacity int64) error + func (cli *BaseClient) ExtendLun(ctx context.Context, lunID string, newCapacity int64) error + func (cli *BaseClient) Get(ctx context.Context, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) GetAllPools(ctx context.Context) (map[string]interface{}, error) + func (cli *BaseClient) GetAllRemoteDevices(ctx context.Context) ([]map[string]interface{}, error) + func (cli *BaseClient) GetApplicationTypeByName(ctx context.Context, appType string) (string, error) + func (cli *BaseClient) GetBackendID() string + func (cli *BaseClient) GetClonePairInfo(ctx context.Context, clonePairID string) (map[string]interface{}, error) + func (cli *BaseClient) GetCurrentLif(ctx context.Context) string + func (cli *BaseClient) GetCurrentLifWwn() string + func (cli *BaseClient) GetCurrentSiteWwn() string + func (cli *BaseClient) GetDTreeByName(ctx context.Context, parentID, parentName, vStoreID, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetDeviceSN() string + func (cli *BaseClient) GetFCHostLink(ctx context.Context, hostID string) ([]interface{}, error) + func (cli *BaseClient) GetFCInitiator(ctx context.Context, wwn string) (map[string]interface{}, error) + func (cli *BaseClient) GetFCInitiatorByID(ctx context.Context, wwn string) (map[string]interface{}, error) + func (cli *BaseClient) GetFCTargetWWNs(ctx context.Context, initiatorWWN string) ([]string, error) + func (cli *BaseClient) GetFSHyperMetroDomain(ctx context.Context, domainName string) (map[string]interface{}, error) + func (cli *BaseClient) GetFSSnapshotByName(ctx context.Context, parentID, snapshotName string) (map[string]interface{}, error) + func (cli *BaseClient) GetFSSnapshotCountByParentId(ctx context.Context, ParentId string) (int, error) + func (cli *BaseClient) GetFileSystemByID(ctx context.Context, id string) (map[string]interface{}, error) + func (cli *BaseClient) GetFileSystemByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetHostByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetHostGroupByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetHostLunId(ctx context.Context, hostID, lunID string) (string, error) + func (cli *BaseClient) GetHyperMetroDomain(ctx context.Context, domainID string) (map[string]interface{}, error) + func (cli *BaseClient) GetHyperMetroDomainByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetHyperMetroPair(ctx context.Context, pairID string) (map[string]interface{}, error) + func (cli *BaseClient) GetHyperMetroPairByLocalObjID(ctx context.Context, objID string) (map[string]interface{}, error) + func (cli *BaseClient) GetISCSIHostLink(ctx context.Context, hostID string) ([]interface{}, error) + func (cli *BaseClient) GetIscsiInitiator(ctx context.Context, initiator string) (map[string]interface{}, error) + func (cli *BaseClient) GetIscsiInitiatorByID(ctx context.Context, initiator string) (map[string]interface{}, error) + func (cli *BaseClient) GetIscsiTgtPort(ctx context.Context) ([]interface{}, error) + func (cli *BaseClient) GetLicenseFeature(ctx context.Context) (map[string]int, error) + func (cli *BaseClient) GetLogicPort(ctx context.Context, addr string) (*Lif, error) + func (cli *BaseClient) GetLunByID(ctx context.Context, id string) (map[string]interface{}, error) + func (cli *BaseClient) GetLunByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetLunCopyByID(ctx context.Context, lunCopyID string) (map[string]interface{}, error) + func (cli *BaseClient) GetLunCopyByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetLunCountOfHost(ctx context.Context, hostID string) (int64, error) + func (cli *BaseClient) GetLunCountOfMapping(ctx context.Context, mappingID string) (int64, error) + func (cli *BaseClient) GetLunGroupByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetLunSnapshotByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetMappingByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetNFSServiceSetting(ctx context.Context) (map[string]bool, error) + func (cli *BaseClient) GetNfsShareAccess(ctx context.Context, parentID, name, vStoreID string) (map[string]interface{}, error) + func (cli *BaseClient) GetNfsShareAccessCount(ctx context.Context, parentID, vStoreID string) (int64, error) + func (cli *BaseClient) GetNfsShareAccessRange(ctx context.Context, parentID, vStoreID string, startRange, endRange int64) ([]interface{}, error) + func (cli *BaseClient) GetNfsShareByPath(ctx context.Context, path, vStoreID string) (map[string]interface{}, error) + func (cli *BaseClient) GetPoolByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetQosByID(ctx context.Context, qosID, vStoreID string) (map[string]interface{}, error) + func (cli *BaseClient) GetQosByName(ctx context.Context, name, vStoreID string) (map[string]interface{}, error) + func (cli *BaseClient) GetQuota(ctx context.Context, quotaID, vStoreID string, spaceUnitType uint32) (map[string]interface{}, error) + func (cli *BaseClient) GetRemoteDeviceBySN(ctx context.Context, sn string) (map[string]interface{}, error) + func (cli *BaseClient) GetReplicationPairByID(ctx context.Context, pairID string) (map[string]interface{}, error) + func (cli *BaseClient) GetReplicationPairByResID(ctx context.Context, resID string, resType int) ([]map[string]interface{}, error) + func (cli *BaseClient) GetReplicationvStorePairByvStore(ctx context.Context, vStoreID string) (map[string]interface{}, error) + func (cli *BaseClient) GetRequest(ctx context.Context, method string, url string, data map[string]interface{}) (*http.Request, error) + func (cli *BaseClient) GetRoCEInitiator(ctx context.Context, initiator string) (map[string]interface{}, error) + func (cli *BaseClient) GetRoCEInitiatorByID(ctx context.Context, initiator string) (map[string]interface{}, error) + func (cli *BaseClient) GetRoCEPortalByIP(ctx context.Context, tgtPortal string) (map[string]interface{}, error) + func (cli *BaseClient) GetStorageVersion() string + func (cli *BaseClient) GetSystem(ctx context.Context) (map[string]interface{}, error) + func (cli *BaseClient) GetVStorePairs(ctx context.Context) ([]interface{}, error) + func (cli *BaseClient) GetvStoreByName(ctx context.Context, name string) (map[string]interface{}, error) + func (cli *BaseClient) GetvStoreID() string + func (cli *BaseClient) GetvStoreName() string + func (cli *BaseClient) GetvStorePairByID(ctx context.Context, pairID string) (map[string]interface{}, error) + func (cli *BaseClient) IsSupportContainer(ctx context.Context) bool + func (cli *BaseClient) Login(ctx context.Context) error + func (cli *BaseClient) Logout(ctx context.Context) + func (cli *BaseClient) MakeLunName(name string) string + func (cli *BaseClient) Post(ctx context.Context, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) Put(ctx context.Context, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) QueryAssociateHostGroup(ctx context.Context, objType int, objID string) ([]interface{}, error) + func (cli *BaseClient) QueryAssociateLunGroup(ctx context.Context, objType int, objID string) ([]interface{}, error) + func (cli *BaseClient) QueryFCInitiatorByHost(ctx context.Context, hostID string) ([]interface{}, error) + func (cli *BaseClient) ReLogin(ctx context.Context) error + func (cli *BaseClient) RemoveGroupFromMapping(ctx context.Context, groupType int, groupID, mappingID string) error + func (cli *BaseClient) RemoveHostFromGroup(ctx context.Context, hostID, hostGroupID string) error + func (cli *BaseClient) RemoveLunFromGroup(ctx context.Context, lunID, groupID string) error + func (cli *BaseClient) SafeBaseCall(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) SafeCall(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) SafeDelete(ctx context.Context, url string, data map[string]interface{}) (Response, error) + func (cli *BaseClient) SafeDeleteFileSystem(ctx context.Context, params map[string]interface{}) error + func (cli *BaseClient) SafeDeleteNfsShare(ctx context.Context, id, vStoreID string) error + func (cli *BaseClient) SetSystemInfo(ctx context.Context) error + func (cli *BaseClient) SplitCloneFS(ctx context.Context, fsID, vStoreId string, splitSpeed int, ...) error + func (cli *BaseClient) SplitReplicationPair(ctx context.Context, pairID string) error + func (cli *BaseClient) StartLunCopy(ctx context.Context, lunCopyID string) error + func (cli *BaseClient) StopCloneFSSplit(ctx context.Context, fsID string) error + func (cli *BaseClient) StopHyperMetroPair(ctx context.Context, pairID string) error + func (cli *BaseClient) StopLunCopy(ctx context.Context, lunCopyID string) error + func (cli *BaseClient) SyncClonePair(ctx context.Context, clonePairID string) error + func (cli *BaseClient) SyncHyperMetroPair(ctx context.Context, pairID string) error + func (cli *BaseClient) SyncReplicationPair(ctx context.Context, pairID string) error + func (cli *BaseClient) UpdateFCInitiator(ctx context.Context, wwn string, alua map[string]interface{}) error + func (cli *BaseClient) UpdateFileSystem(ctx context.Context, fsID string, params map[string]interface{}) error + func (cli *BaseClient) UpdateHost(ctx context.Context, id string, alua map[string]interface{}) error + func (cli *BaseClient) UpdateIscsiInitiator(ctx context.Context, initiator string, alua map[string]interface{}) error + func (cli *BaseClient) UpdateLun(ctx context.Context, lunID string, params map[string]interface{}) error + func (cli *BaseClient) UpdateQos(ctx context.Context, qosID, vStoreID string, params map[string]interface{}) error + func (cli *BaseClient) UpdateQuota(ctx context.Context, quotaID string, params map[string]interface{}) error + func (cli *BaseClient) ValidateLogin(ctx context.Context) error + type BaseClientInterface interface + BaseCall func(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + Call func(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + Delete func(ctx context.Context, url string, data map[string]interface{}) (Response, error) + DuplicateClient func() *BaseClient + Get func(ctx context.Context, url string, data map[string]interface{}) (Response, error) + GetBackendID func() string + GetRequest func(ctx context.Context, method string, url string, data map[string]interface{}) (*http.Request, error) + Login func(ctx context.Context) error + Logout func(ctx context.Context) + Post func(ctx context.Context, url string, data map[string]interface{}) (Response, error) + Put func(ctx context.Context, url string, data map[string]interface{}) (Response, error) + ReLogin func(ctx context.Context) error + SafeBaseCall func(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + SafeCall func(ctx context.Context, method string, url string, data map[string]interface{}) (Response, error) + SafeDelete func(ctx context.Context, url string, data map[string]interface{}) (Response, error) + type Clone interface + CloneFileSystem func(ctx context.Context, name string, allocType int, ...) (map[string]interface{}, error) + CreateClonePair func(ctx context.Context, srcLunID, dstLunID string, cloneSpeed int) (map[string]interface{}, error) + DeleteClonePair func(ctx context.Context, clonePairID string) error + GetClonePairInfo func(ctx context.Context, clonePairID string) (map[string]interface{}, error) + SplitCloneFS func(ctx context.Context, fsID, vStoreId string, splitSpeed int, ...) error + StopCloneFSSplit func(ctx context.Context, fsID string) error + SyncClonePair func(ctx context.Context, clonePairID string) error + type Container interface + IsSupportContainer func(ctx context.Context) bool + type DTree interface + CreateDTree func(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + DeleteDTreeByID func(ctx context.Context, vStoreID, dTreeID string) error + DeleteDTreeByName func(ctx context.Context, parentName, dTreeName, vStoreID string) error + GetDTreeByName func(ctx context.Context, parentID, parentName, vStoreID, name string) (map[string]interface{}, error) + type FC interface + AddFCInitiatorToHost func(ctx context.Context, initiator, hostID string) error + GetFCHostLink func(ctx context.Context, hostID string) ([]interface{}, error) + GetFCInitiator func(ctx context.Context, wwn string) (map[string]interface{}, error) + GetFCInitiatorByID func(ctx context.Context, wwn string) (map[string]interface{}, error) + GetFCTargetWWNs func(ctx context.Context, initiatorWWN string) ([]string, error) + QueryFCInitiatorByHost func(ctx context.Context, hostID string) ([]interface{}, error) + UpdateFCInitiator func(ctx context.Context, wwn string, alua map[string]interface{}) error + type FSSnapshot interface + CreateFSSnapshot func(ctx context.Context, name, parentID string) (map[string]interface{}, error) + DeleteFSSnapshot func(ctx context.Context, snapshotID string) error + GetFSSnapshotByName func(ctx context.Context, parentID, snapshotName string) (map[string]interface{}, error) + GetFSSnapshotCountByParentId func(ctx context.Context, ParentId string) (int, error) + type Filesystem interface + AllowNfsShareAccess func(ctx context.Context, req *AllowNfsShareAccessRequest) error + CreateFileSystem func(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + CreateNfsShare func(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + DeleteFileSystem func(ctx context.Context, params map[string]interface{}) error + DeleteNfsShare func(ctx context.Context, id, vStoreID string) error + DeleteNfsShareAccess func(ctx context.Context, accessID, vStoreID string) error + ExtendFileSystem func(ctx context.Context, fsID string, newCapacity int64) error + GetFileSystemByID func(ctx context.Context, id string) (map[string]interface{}, error) + GetFileSystemByName func(ctx context.Context, name string) (map[string]interface{}, error) + GetNFSServiceSetting func(ctx context.Context) (map[string]bool, error) + GetNfsShareAccess func(ctx context.Context, parentID, name, vStoreID string) (map[string]interface{}, error) + GetNfsShareAccessCount func(ctx context.Context, parentID, vStoreID string) (int64, error) + GetNfsShareAccessRange func(ctx context.Context, parentID, vStoreID string, startRange, endRange int64) ([]interface{}, error) + GetNfsShareByPath func(ctx context.Context, path, vStoreID string) (map[string]interface{}, error) + SafeDeleteFileSystem func(ctx context.Context, params map[string]interface{}) error + SafeDeleteNfsShare func(ctx context.Context, id, vStoreID string) error + UpdateFileSystem func(ctx context.Context, fsID string, params map[string]interface{}) error + type FilesystemResponse struct + CAPACITY string + FileSystemMode string + HyperMetroPairIds []string + ID string + NAME string + type HTTP interface + Do func(req *http.Request) (*http.Response, error) + type Host interface + AddHostToGroup func(ctx context.Context, hostID, hostGroupID string) error + CreateHost func(ctx context.Context, name string) (map[string]interface{}, error) + CreateHostGroup func(ctx context.Context, name string) (map[string]interface{}, error) + DeleteHost func(ctx context.Context, id string) error + DeleteHostGroup func(ctx context.Context, id string) error + GetHostByName func(ctx context.Context, name string) (map[string]interface{}, error) + GetHostGroupByName func(ctx context.Context, name string) (map[string]interface{}, error) + QueryAssociateHostGroup func(ctx context.Context, objType int, objID string) ([]interface{}, error) + RemoveHostFromGroup func(ctx context.Context, hostID, hostGroupID string) error + UpdateHost func(ctx context.Context, id string, alua map[string]interface{}) error + type HyperMetro interface + CreateHyperMetroPair func(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error) + DeleteHyperMetroPair func(ctx context.Context, pairID string, onlineDelete bool) error + GetFSHyperMetroDomain func(ctx context.Context, domainName string) (map[string]interface{}, error) + GetHyperMetroDomain func(ctx context.Context, domainID string) (map[string]interface{}, error) + GetHyperMetroDomainByName func(ctx context.Context, name string) (map[string]interface{}, error) + GetHyperMetroPair func(ctx context.Context, pairID string) (map[string]interface{}, error) + GetHyperMetroPairByLocalObjID func(ctx context.Context, objID string) (map[string]interface{}, error) + StopHyperMetroPair func(ctx context.Context, pairID string) error + SyncHyperMetroPair func(ctx context.Context, pairID string) error + type Iscsi interface + AddIscsiInitiator func(ctx context.Context, initiator string) (map[string]interface{}, error) + AddIscsiInitiatorToHost func(ctx context.Context, initiator, hostID string) error + GetISCSIHostLink func(ctx context.Context, hostID string) ([]interface{}, error) + GetIscsiInitiator func(ctx context.Context, initiator string) (map[string]interface{}, error) + GetIscsiInitiatorByID func(ctx context.Context, initiator string) (map[string]interface{}, error) + GetIscsiTgtPort func(ctx context.Context) ([]interface{}, error) + UpdateIscsiInitiator func(ctx context.Context, initiator string, alua map[string]interface{}) error + type LIF interface + GetCurrentLif func(ctx context.Context) string + GetCurrentLifWwn func() string + GetLogicPort func(ctx context.Context, addr string) (*Lif, error) + type Lif struct + HomeSiteWwn string + type Lun interface + AddLunToGroup func(ctx context.Context, lunID string, groupID string) error + CreateLun func(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + CreateLunGroup func(ctx context.Context, name string) (map[string]interface{}, error) + DeleteLun func(ctx context.Context, id string) error + DeleteLunGroup func(ctx context.Context, id string) error + ExtendLun func(ctx context.Context, lunID string, newCapacity int64) error + GetHostLunId func(ctx context.Context, hostID, lunID string) (string, error) + GetLunByID func(ctx context.Context, id string) (map[string]interface{}, error) + GetLunByName func(ctx context.Context, name string) (map[string]interface{}, error) + GetLunCountOfHost func(ctx context.Context, hostID string) (int64, error) + GetLunCountOfMapping func(ctx context.Context, mappingID string) (int64, error) + GetLunGroupByName func(ctx context.Context, name string) (map[string]interface{}, error) + MakeLunName func(name string) string + QueryAssociateLunGroup func(ctx context.Context, objType int, objID string) ([]interface{}, error) + RemoveLunFromGroup func(ctx context.Context, lunID, groupID string) error + UpdateLun func(ctx context.Context, lunID string, params map[string]interface{}) error + type LunCopy interface + CreateLunCopy func(ctx context.Context, name, srcLunID, dstLunID string, copySpeed int) (map[string]interface{}, error) + DeleteLunCopy func(ctx context.Context, lunCopyID string) error + GetLunCopyByID func(ctx context.Context, lunCopyID string) (map[string]interface{}, error) + GetLunCopyByName func(ctx context.Context, name string) (map[string]interface{}, error) + StartLunCopy func(ctx context.Context, lunCopyID string) error + StopLunCopy func(ctx context.Context, lunCopyID string) error + type LunSnapshot interface + ActivateLunSnapshot func(ctx context.Context, snapshotID string) error + CreateLunSnapshot func(ctx context.Context, name, lunID string) (map[string]interface{}, error) + DeactivateLunSnapshot func(ctx context.Context, snapshotID string) error + DeleteLunSnapshot func(ctx context.Context, snapshotID string) error + GetLunSnapshotByName func(ctx context.Context, name string) (map[string]interface{}, error) + type Mapping interface + AddGroupToMapping func(ctx context.Context, groupType int, groupID, mappingID string) error + CreateMapping func(ctx context.Context, name string) (map[string]interface{}, error) + DeleteMapping func(ctx context.Context, id string) error + GetMappingByName func(ctx context.Context, name string) (map[string]interface{}, error) + RemoveGroupFromMapping func(ctx context.Context, groupType int, groupID, mappingID string) error + type MockHTTPClient struct + func NewMockHTTPClient(ctrl *gomock.Controller) *MockHTTPClient + func (m *MockHTTPClient) Do(req *http.Request) (*http.Response, error) + func (m *MockHTTPClient) EXPECT() *MockHTTPClientMockRecorder + type MockHTTPClientMockRecorder struct + func (mr *MockHTTPClientMockRecorder) Do(req interface{}) *gomock.Call + type NewClientConfig struct + BackendID string + CertSecretMeta string + Name string + ParallelNum string + SecretName string + SecretNamespace string + Storage string + Urls []string + UseCert bool + User string + VstoreName string + type OceanStorQuota interface + BatchGetQuota func(ctx context.Context, params map[string]interface{}) ([]interface{}, error) + CreateQuota func(ctx context.Context, params map[string]interface{}) (map[string]interface{}, error) + DeleteQuota func(ctx context.Context, quotaID, vStoreID string, forceFlag bool) error + GetQuota func(ctx context.Context, quotaID, vStoreID string, spaceUnitType uint32) (map[string]interface{}, error) + UpdateQuota func(ctx context.Context, quotaID string, params map[string]interface{}) error + type OceanstorSystem struct + ApolloVersion string + CacheWriteQuota string + ConfigModel string + Description string + DomainName string + FreeDisksCapacity string + HealthStatus string + HotSpareDisksCapacity string + ID string + Location string + MappedLunsCountCapacity string + MemberDisksCapacity string + Name string + PatchVersion string + PointRelease string + ProductMode string + ProductModeString string + ProductVersion string + RunningStatus string + SectorSize string + StoragePoolCapacity string + StoragePoolFreeCapacity string + StoragePoolHostSpareCapacity string + StoragePoolRawCapacity string + StoragePoolUsedCapacity string + ThickLunsAllocateCapacity string + ThickLunsUsedCapacity string + ThinLunsAllocateCapacity string + ThinLunsMaxCapacity string + ThinLunsUsedCapacity string + TotalCapacity string + Type int + UnMappedLunsCountCapacity string + UnavailableDisksCapACITY string + UsedCapacity string + UserFreeCapacity string + VasaAlternateName string + VasaSupportBlock string + VasaSupportFilesystem string + VasaSupportProfile string + WriteThroughSw string + WriteThroughTime string + Wwn string + type Qos interface + ActivateQos func(ctx context.Context, qosID, vStoreID string) error + CreateQos func(ctx context.Context, name, objID, objType, vStoreID string, ...) (map[string]interface{}, error) + DeactivateQos func(ctx context.Context, qosID, vStoreID string) error + DeleteQos func(ctx context.Context, qosID, vStoreID string) error + GetQosByID func(ctx context.Context, qosID, vStoreID string) (map[string]interface{}, error) + GetQosByName func(ctx context.Context, name, vStoreID string) (map[string]interface{}, error) + UpdateQos func(ctx context.Context, qosID, vStoreID string, params map[string]interface{}) error + type Replication interface + CreateReplicationPair func(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error) + DeleteReplicationPair func(ctx context.Context, pairID string) error + GetReplicationPairByID func(ctx context.Context, pairID string) (map[string]interface{}, error) + GetReplicationPairByResID func(ctx context.Context, resID string, resType int) ([]map[string]interface{}, error) + GetReplicationvStorePairByvStore func(ctx context.Context, vStoreID string) (map[string]interface{}, error) + SplitReplicationPair func(ctx context.Context, pairID string) error + SyncReplicationPair func(ctx context.Context, pairID string) error + type Response struct + Data interface{} + Error map[string]interface{} + func (resp *Response) AssertErrorCode() error + func (resp *Response) GetData(val any) error + type RoCE interface + AddRoCEInitiator func(ctx context.Context, initiator string) (map[string]interface{}, error) + AddRoCEInitiatorToHost func(ctx context.Context, initiator, hostID string) error + GetRoCEInitiator func(ctx context.Context, initiator string) (map[string]interface{}, error) + GetRoCEInitiatorByID func(ctx context.Context, initiator string) (map[string]interface{}, error) + GetRoCEPortalByIP func(ctx context.Context, tgtPortal string) (map[string]interface{}, error) + type System interface + GetAllPools func(ctx context.Context) (map[string]interface{}, error) + GetAllRemoteDevices func(ctx context.Context) ([]map[string]interface{}, error) + GetCurrentSiteWwn func() string + GetDeviceSN func() string + GetLicenseFeature func(ctx context.Context) (map[string]int, error) + GetPoolByName func(ctx context.Context, name string) (map[string]interface{}, error) + GetRemoteDeviceBySN func(ctx context.Context, sn string) (map[string]interface{}, error) + GetStorageVersion func() string + GetSystem func(ctx context.Context) (map[string]interface{}, error) + SetSystemInfo func(ctx context.Context) error + type VStore interface + GetVStorePairs func(ctx context.Context) ([]interface{}, error) + GetvStoreByName func(ctx context.Context, name string) (map[string]interface{}, error) + GetvStoreID func() string + GetvStoreName func() string + GetvStorePairByID func(ctx context.Context, pairID string) (map[string]interface{}, error)