client

type AddNfsShareAuthClientRequest struct {
	AccessName  string `json:"access_name"`
	ShareId     string `json:"share_id"`
	AccessValue int    `json:"access_value"`
	Sync        int    `json:"sync"`
	AllSquash   int    `json:"all_squash"`
	RootSquash  int    `json:"root_squash"`
	AccountId   int    `json:"account_id"`
}

type AllowNfsShareAccessRequest struct {
	AccessName  string
	ShareId     string
	AccessValue int
	AllSquash   int
	RootSquash  int
	AccountId   string
}

type CreateDTreeNfsShareRequest struct {
	DtreeId     string `json:"dtree_id"`
	Sharepath   string `json:"share_path"`
	Description string `json:"description"`
	AccountId   int    `json:"account_id"`
}

type CreateDTreeNfsShareResponse struct {
	Id string `json:"id"`
}

type CreateDTreeRequest struct {
	Name           string `json:"name"`
	FileSystemName string `json:"file_system_name"`
	UnixPermission string `json:"unix_permission,omitempty"`
	AccountId      int    `json:"account_id"`
}

type DTree interface {
	GetDTreeByName(ctx context.Context, parentName, name string) (*DTreeResponse, error)
	CreateDTree(ctx context.Context, parentName, name, unixPermission string) (*DTreeResponse, error)
	DeleteDTree(ctx context.Context, dtreeId string) error
	GetDTreeNfsShareByPath(ctx context.Context, sharePath string) (*GetDTreeNfsShareResponse, error)
	CreateDTreeNfsShare(ctx context.Context, req *CreateDTreeNfsShareRequest) (*CreateDTreeNfsShareResponse, error)
	DeleteDTreeNfsShare(ctx context.Context, shareId string) error
	AddNfsShareAuthClient(ctx context.Context, req *AddNfsShareAuthClientRequest) error
}

type DTreeQuotaResponse struct {
	Id             string  `json:"id"`
	ParentId       string  `json:"parent_id"`
	SpaceHardQuota int64   `json:"space_hard_quota"`
	SpaceSoftQuota float64 `json:"space_soft_quota"`
	SpaceUnitType  int64   `json:"space_unit_type"`
}

type DTreeResponse struct {
	Id   string `json:"id"`
	Name string `json:"name"`
}

type GetDTreeNfsShareResponse struct {
	Id        string `json:"id"`
	SharePath string `json:"share_path"`
}

type Host interface {
	CreateHost(ctx context.Context, hostName string, alua map[string]interface{}) error
	UpdateHost(ctx context.Context, hostName string, alua map[string]interface{}) error
	QueryHostByPort(ctx context.Context, port string) (string, error)
	AddPortToHost(ctx context.Context, initiatorName, hostName string) error
	AddLunToHost(ctx context.Context, lunName, hostName string) error
	DeleteLunFromHost(ctx context.Context, lunName, hostName string) error
	QueryHostOfVolume(ctx context.Context, lunName string) ([]map[string]interface{}, error)
	GetHostByName(ctx context.Context, hostName string) (map[string]interface{}, error)
}

type HostIscsiInfo struct {
	Flag int    `json:"flag"`
	Key  string `json:"key"`
}

type IRestClient interface {
	Host
	Iscsi
	Namespace
	Qos
	Quota
	Snapshot
	System
	Volume
	DTree

	ValidateLogin(ctx context.Context) error
	Login(ctx context.Context) error
	SetAccountId(ctx context.Context) error
	Logout(ctx context.Context)
	ReLogin(ctx context.Context) error
	KeepAlive(ctx context.Context)
}

type IsSupportDynamicLinksResponse struct {
	*SanBaseResponse
	NewIscsi bool `json:"newIscsi"`
}

type Iscsi interface {
	GetInitiatorByName(ctx context.Context, name string) (map[string]interface{}, error)
	CreateInitiator(ctx context.Context, name string) error
	QueryIscsiPortal(ctx context.Context) ([]map[string]interface{}, error)
	IsSupportDynamicLinks(ctx context.Context, hostname string) (bool, error)
	QueryDynamicLinks(ctx context.Context, poolName, hostname string, amount int) ([]*IscsiLink, error)
}

type IscsiLink struct {
	IP            string `json:"ip"`
	IscsiLinksNum int    `json:"iscsiLinksNum"`
	TargetName    string `json:"targetName"`
	IscsiPortal   string `json:"iscsiPortal"`
}

type Namespace interface {
	CreateFileSystem(ctx context.Context, params map[string]any) (map[string]any, error)
	DeleteFileSystem(ctx context.Context, id string) error
	GetFileSystemByName(ctx context.Context, name string) (map[string]interface{}, error)
	CreateNfsShare(ctx context.Context, params map[string]any) (map[string]any, error)
	DeleteNfsShare(ctx context.Context, id, accountId string) error
	GetNfsShareByPath(ctx context.Context, path, accountId string) (map[string]interface{}, error)
	AllowNfsShareAccess(ctx context.Context, req *AllowNfsShareAccessRequest) error
	DeleteNfsShareAccess(ctx context.Context, accessID string) error
	GetNfsShareAccess(ctx context.Context, shareID string) (map[string]interface{}, error)
	GetQuotaByFileSystemName(ctx context.Context, fsName string) (*QueryQuotaResponse, error)
}

type NasResponse[T any] struct {
	Data       T         `json:"data"`
	Result     NasResult `json:"result"`
	ErrorCode  int64     `json:"errorCode"`
	Suggestion string    `json:"suggestion"`
}

type NasResult struct {
	Code        int64  `json:"code"`
	Description string `json:"description"`
	Suggestion  string `json:"suggestion"`
}

type NewClientConfig struct {
	Url             string
	User            string
	SecretName      string
	SecretNamespace string
	ParallelNum     string
	BackendID       string
	AccountName     string
	UseCert         bool
	CertSecretMeta  string
}

type Qos interface {
	GetConvergedQoSNameByID(ctx context.Context, qosId int) (string, error)
	CreateConvergedQoS(ctx context.Context, req *types.CreateConvergedQoSReq) (int, error)
	DeleteConvergedQoS(ctx context.Context, qosName string) error
	CreateQoS(ctx context.Context, qosName string, qosData map[string]int) error
	DeleteQoS(ctx context.Context, qosName string) error
	DisassociateConvergedQoSWithVolume(ctx context.Context, objectName string) error
	AssociateConvergedQoSWithVolume(ctx context.Context, req *types.AssociateConvergedQoSWithVolumeReq) error
	AssociateQoSWithVolume(ctx context.Context, volName, qosName string) error
	DisassociateQoSWithVolume(ctx context.Context, volName, qosName string) error
	GetQoSPolicyAssociationCount(ctx context.Context, qosPolicyId int) (int, error)
	GetQoSPolicyIdByFsName(ctx context.Context, namespaceName string) (int, error)
	GetQoSNameByVolume(ctx context.Context, volName string) (string, error)
	GetAssociateCountOfQoS(ctx context.Context, qosName string) (int, error)
}

type QueryDynamicLinksRequest struct {
	Amount             int      `json:"amount"`
	IscsiServiceIpType int      `json:"iscsiServiceIpType"`
	PoolList           []string `json:"poolList"`
	HostKey            string   `json:"hostKey"`
}

type QueryDynamicLinksResponse struct {
	*SanBaseResponse
	IscsiLinks []*IscsiLink `json:"iscsiLinks"`
}

type QueryQuotaResponse struct {
	Id             string  `json:"id"`
	SpaceHardQuota uint64  `json:"space_hard_quota"`
	SpaceSoftQuota uint64  `json:"space_soft_quota"`
	SpaceUnitType  float64 `json:"space_unit_type"`
}

type Quota interface {
	CreateQuota(ctx context.Context, params map[string]interface{}) error
	UpdateQuota(ctx context.Context, params map[string]interface{}) error
	GetQuotaByFileSystemById(ctx context.Context, fsID string) (map[string]interface{}, error)
	QueryQuotaByFsId(ctx context.Context, fsID string) (*QueryQuotaResponse, error)
	DeleteQuota(ctx context.Context, quotaID string) error

	GetQuotaByDTreeId(ctx context.Context, dTreeId string) (*DTreeQuotaResponse, error)
	CreateDTreeQuota(ctx context.Context, dTreeId string, capacity int64) (*DTreeQuotaResponse, error)
	DeleteDTreeQuota(ctx context.Context, quotaId string) error
	UpdateDTreeQuota(ctx context.Context, quotaId string, capacity int64) error
}

type RestClient struct {
	RequestSemaphore *utils.Semaphore
	// contains filtered or unexported fields
}

type Retryable interface {
	NeedRetry() bool
}

type SanBaseResponse struct {
	Result      int64  `json:"result"`
	Suggestion  string `json:"suggestion"`
	ErrorCode   any    `json:"errorCode"`
	Description string `json:"description"`
}

type Snapshot interface {
	CreateSnapshot(ctx context.Context, snapshotName, volName string) error
	DeleteSnapshot(ctx context.Context, snapshotName string) error
	GetSnapshotByName(ctx context.Context, snapshotName string) (map[string]interface{}, error)
	CreateVolumeFromSnapshot(ctx context.Context, volName string, volSize int64, snapshotName string) error
}

type System interface {
	GetAccountIdByName(ctx context.Context, accountName string) (string, error)
	GetPoolByName(ctx context.Context, poolName string) (map[string]interface{}, error)
	GetPoolById(ctx context.Context, poolId int64) (map[string]interface{}, error)
	GetAllAccounts(ctx context.Context) ([]string, error)
	GetAllPools(ctx context.Context) (map[string]interface{}, error)
	GetNFSServiceSetting(ctx context.Context) (map[string]bool, error)
}

type Volume interface {
	CreateVolume(ctx context.Context, params map[string]interface{}) error
	GetVolumeByName(ctx context.Context, name string) (map[string]interface{}, error)
	DeleteVolume(ctx context.Context, name string) error
	AttachVolume(ctx context.Context, name, ip string) error
	DetachVolume(ctx context.Context, name, ip string) error
	ExtendVolume(ctx context.Context, lunName string, newCapacity int64) error
	GetHostLunId(ctx context.Context, hostName, lunName string) (string, error)
}