api

type Azure interface {
	Init(context.Context, map[string]storage.Pool) error

	RefreshAzureResources(context.Context) error
	DiscoverAzureResources(context.Context) error
	EnableAzureFeatures(context.Context, ...string) error
	Features() map[string]bool
	HasFeature(string) bool
	CapacityPools() *[]*CapacityPool
	CapacityPoolsForStoragePools(context.Context) []*CapacityPool
	CapacityPoolsForStoragePool(context.Context, storage.Pool, string, string) []*CapacityPool
	EnsureVolumeInValidCapacityPool(context.Context, *FileSystem) error
	SubnetsForStoragePool(context.Context, storage.Pool) []*Subnet
	RandomSubnetForStoragePool(context.Context, storage.Pool) *Subnet
	FilteredCapacityPoolMap(ctx context.Context, rgFilter, naFilter, cpFilter []string) map[string]*CapacityPool
	FilteredSubnetMap(ctx context.Context, rgFilter []string, vnFilter, snFilter string) map[string]*Subnet

	Volumes(context.Context) (*[]*FileSystem, error)
	Volume(context.Context, *storage.VolumeConfig) (*FileSystem, error)
	VolumeExists(context.Context, *storage.VolumeConfig) (bool, *FileSystem, error)
	VolumeByCreationToken(context.Context, string) (*FileSystem, error)
	VolumeExistsByCreationToken(context.Context, string) (bool, *FileSystem, error)
	VolumeByID(context.Context, string) (*FileSystem, error)
	VolumeExistsByID(context.Context, string) (bool, *FileSystem, error)
	WaitForVolumeState(context.Context, *FileSystem, string, []string, time.Duration, Operation) (string, error)
	CreateVolume(context.Context, *FilesystemCreateRequest) (*FileSystem, error)
	ModifyVolume(context.Context, *FileSystem, map[string]string, *string, *bool, *ExportRule) error
	ResizeVolume(context.Context, *FileSystem, int64) error
	DeleteVolume(context.Context, *FileSystem) error

	SnapshotsForVolume(context.Context, *FileSystem) (*[]*Snapshot, error)
	SnapshotForVolume(context.Context, *FileSystem, string) (*Snapshot, error)
	WaitForSnapshotState(context.Context, *Snapshot, *FileSystem, string, []string, time.Duration) error
	CreateSnapshot(context.Context, *FileSystem, string) (*Snapshot, error)
	RestoreSnapshot(context.Context, *FileSystem, *Snapshot) error
	DeleteSnapshot(context.Context, *FileSystem, *Snapshot) error

	AvailabilityZones(ctx context.Context) ([]string, error)
}

type AzureClient struct {
	Credential      azcore.TokenCredential
	FeaturesClient  *features.Client
	GraphClient     *resourcegraph.Client
	VolumesClient   *netapp.VolumesClient
	SnapshotsClient *netapp.SnapshotsClient
	ResourceClient  *netapp.ResourceClient
	// contains filtered or unexported fields
}

type AzureError struct {
	Id        string `json:"id"`
	Name      string `json:"name"`
	Status    string `json:"status"`
	StartTime string `json:"startTime"`
	EndTime   string `json:"endTime"`
	AzError   struct {
		Code    string `json:"code"`
		Message string `json:"message"`
		Details []struct {
			Code    string `json:"code"`
			Message string `json:"message"`
		} `json:"details"`
	} `json:"error"`
}

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

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

type CapacityPool struct {
	ID                string
	ResourceGroup     string
	NetAppAccount     string
	Name              string
	FullName          string
	Location          string
	Type              string
	PoolID            string
	ServiceLevel      string
	ProvisioningState string
	QosType           string
}

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

type ClientConfig struct {
	// Azure API authentication parameters
	azclient.AzureAuthConfig
	SubscriptionID    string `json:"subscriptionId"`
	Location          string `json:"location"`
	StorageDriverName string
	TenantID          string `json:"tenantId"`

	// Cloud configuration
	CloudConfig *CloudConfiguration `json:"cloudConfiguration,omitempty"`

	// Options
	DebugTraceFlags map[string]bool
	SDKTimeout      time.Duration // Timeout applied to all calls to the Azure SDK
	MaxCacheAge     time.Duration // The oldest data we should expect in the cached resources
}

type CloudConfiguration struct {
	// Option 1: Predefined cloud name (AzurePublic, AzureChina, AzureGovernment)
	CloudName string `json:"cloudName,omitempty"`

	// Option 2: Custom cloud configuration (all three must be specified together)
	ADAuthorityHost string `json:"adAuthorityHost,omitempty"` // e.g., https://login.chinacloudapi.cn/
	Audience        string `json:"audience,omitempty"`        // e.g., https://management.core.chinacloudapi.cn
	Endpoint        string `json:"endpoint,omitempty"`        // e.g., https://management.chinacloudapi.cn
}

type ExportPolicy struct {
	Rules []ExportRule
}

type ExportRule struct {
	AllowedClients      string
	Cifs                bool
	Nfsv3               bool
	Nfsv41              bool
	RuleIndex           int32
	UnixReadOnly        bool
	UnixReadWrite       bool
	Kerberos5ReadOnly   bool
	Kerberos5ReadWrite  bool
	Kerberos5IReadOnly  bool
	Kerberos5IReadWrite bool
	Kerberos5PReadOnly  bool
	Kerberos5PReadWrite bool
}

type FileSystem struct {
	ID                 string
	ResourceGroup      string
	NetAppAccount      string
	CapacityPool       string
	Name               string
	FullName           string
	Location           string
	Type               string
	ExportPolicy       ExportPolicy
	Labels             map[string]string
	FileSystemID       string
	ProvisioningState  string
	CreationToken      string
	ProtocolTypes      []string
	QuotaInBytes       int64
	ServiceLevel       string
	SnapshotDirectory  bool
	UsedBytes          int
	SubnetID           string
	UnixPermissions    string
	MountTargets       []MountTarget
	NetworkFeatures    string
	KerberosEnabled    bool
	KeyVaultEndpointID string
	Zones              []string
	MaxThroughput      float32
}

type FilesystemCreateRequest struct {
	ResourceGroup      string
	NetAppAccount      string
	CapacityPool       string
	Name               string
	SubnetID           string
	CreationToken      string
	ExportPolicy       ExportPolicy
	Labels             map[string]string
	ProtocolTypes      []string
	QuotaInBytes       int64
	SnapshotDirectory  bool
	SnapshotID         string
	UnixPermissions    string
	NetworkFeatures    string
	KerberosEnabled    bool
	KeyVaultEndpointID string
	Zone               string
	MaxThroughput      *float32
}

type MountTarget struct {
	MountTargetID string
	FileSystemID  string
	IPAddress     string
	ServerFqdn    string
}

type NetAppAccount struct {
	ID            string
	ResourceGroup string
	Name          string
	FullName      string
	Location      string
	Type          string
	CapacityPools []*CapacityPool
}

type Operation int64

type PollerKey struct {
	ID        string
	Operation Operation
}

type PollerResponse interface {
	Result(context.Context) error
}

type PollerResponseCache interface {
	Put(key *PollerKey, value PollerResponse) error
	Get(key PollerKey) (PollerResponse, bool)
	Delete(key PollerKey)
}

type PollerVolumeCreateResponse struct {
	*runtime.Poller[netapp.VolumesClientCreateOrUpdateResponse]
}

type ResourceGroup struct {
	Name            string
	NetAppAccounts  []*NetAppAccount
	VirtualNetworks []*VirtualNetwork
}

type Snapshot struct {
	ID                string
	ResourceGroup     string
	NetAppAccount     string
	CapacityPool      string
	Volume            string
	Name              string
	FullName          string
	Location          string
	Type              string
	Created           time.Time
	SnapshotID        string
	ProvisioningState string
}

type Subnet struct {
	ID             string
	ResourceGroup  string
	VirtualNetwork string
	Name           string
	FullName       string
	Location       string
	Type           string
}

type TerminalStateError struct {
	Err error
}

type VirtualNetwork struct {
	ID            string
	ResourceGroup string
	Name          string
	FullName      string
	Location      string
	Type          string
	Subnets       []*Subnet
}