client

Documentation

Index

• Constants
• Variables
• type AccountDetails
  • func (ad *AccountDetails) AccountKey(ctx context.Context, client Client) (*string, error)
  • func (ad *AccountDetails) DataPlaneEndpoint(endpointType EndpointType) (*string, error)
• type Client
  • func NewClient(o *common.ClientOptions) (*Client, error)
  • func (c Client) AccountsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*accounts.Client, error)
  • func (c Client) AddToCache(accountId commonids.StorageAccountId, account storageaccounts.StorageAccount) error
  • func (c Client) BlobsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*blobs.Client, error)
  • func (c Client) ContainersDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageContainerWrapper, error)
  • func (c Client) DataLakeFilesystemsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*filesystems.Client, error)
  • func (c Client) DataLakePathsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*paths.Client, error)
  • func (Client) DataPlaneOperationSupportingAnyAuthMethod() DataPlaneOperation
  • func (Client) DataPlaneOperationSupportingOnlySharedKeyAuth() DataPlaneOperation
  • func (c Client) FileShareDirectoriesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*directories.Client, error)
  • func (c Client) FileShareFilesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*files.Client, error)
  • func (c Client) FileSharesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageShareWrapper, error)
  • func (c Client) FindAccount(ctx context.Context, subscriptionIdRaw, accountName string) (*AccountDetails, error)
  • func (c Client) QueuesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageQueuesWrapper, error)
  • func (c Client) RemoveAccountFromCache(accountId commonids.StorageAccountId)
  • func (c Client) TableEntityDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*entities.Client, error)
  • func (c Client) TablesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageTableWrapper, error)
• type DataPlaneOperation
• type EndpointType

Constants

const (
	EndpointTypeBlob  = "blob"
	EndpointTypeDfs   = "dfs"
	EndpointTypeFile  = "file"
	EndpointTypeQueue = "queue"
	EndpointTypeTable = "table"
)

Variables

var StorageDomainSuffix *string

StorageDomainSuffix is used by validation functions

Types

type AccountDetails

type AccountDetails struct {
	Kind             storageaccounts.Kind
	IsHnsEnabled     bool
	StorageAccountId commonids.StorageAccountId
	// contains filtered or unexported fields
}

func (*AccountDetails) AccountKey

func (ad *AccountDetails) AccountKey(ctx context.Context, client Client) (*string, error)

func (*AccountDetails) DataPlaneEndpoint

func (ad *AccountDetails) DataPlaneEndpoint(endpointType EndpointType) (*string, error)

type Client

type Client struct {
	StorageDomainSuffix string

	ResourceManager *storage_v2023_01_01.Client
	// TODO: import the Storage Sync Meta Client and use that
	SyncCloudEndpointsClient   *cloudendpointresource.CloudEndpointResourceClient
	SyncGroupsClient           *syncgroupresource.SyncGroupResourceClient
	SyncRegisteredServerClient *registeredserverresource.RegisteredServerResourceClient
	SyncServerEndpointsClient  *serverendpointresource.ServerEndpointResourceClient
	SyncServiceClient          *storagesyncservicesresource.StorageSyncServicesResourceClient
	// contains filtered or unexported fields
}

func NewClient

func NewClient(o *common.ClientOptions) (*Client, error)

func (Client) AccountsDataPlaneClient

func (c Client) AccountsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*accounts.Client, error)

func (Client) AddToCache

func (c Client) AddToCache(accountId commonids.StorageAccountId, account storageaccounts.StorageAccount) error

func (Client) BlobsDataPlaneClient

func (c Client) BlobsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*blobs.Client, error)

func (Client) ContainersDataPlaneClient

func (c Client) ContainersDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageContainerWrapper, error)

func (Client) DataLakeFilesystemsDataPlaneClient

func (c Client) DataLakeFilesystemsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*filesystems.Client, error)

func (Client) DataLakePathsDataPlaneClient

func (c Client) DataLakePathsDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*paths.Client, error)

func (Client) DataPlaneOperationSupportingAnyAuthMethod

func (Client) DataPlaneOperationSupportingAnyAuthMethod() DataPlaneOperation

func (Client) DataPlaneOperationSupportingOnlySharedKeyAuth

func (Client) DataPlaneOperationSupportingOnlySharedKeyAuth() DataPlaneOperation

func (Client) FileShareDirectoriesDataPlaneClient

func (c Client) FileShareDirectoriesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*directories.Client, error)

func (Client) FileShareFilesDataPlaneClient

func (c Client) FileShareFilesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*files.Client, error)

func (Client) FileSharesDataPlaneClient

func (c Client) FileSharesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageShareWrapper, error)

func (Client) FindAccount

func (c Client) FindAccount(ctx context.Context, subscriptionIdRaw, accountName string) (*AccountDetails, error)

func (Client) QueuesDataPlaneClient

func (c Client) QueuesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageQueuesWrapper, error)

func (Client) RemoveAccountFromCache

func (c Client) RemoveAccountFromCache(accountId commonids.StorageAccountId)

func (Client) TableEntityDataPlaneClient

func (c Client) TableEntityDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (*entities.Client, error)

func (Client) TablesDataPlaneClient

func (c Client) TablesDataPlaneClient(ctx context.Context, account AccountDetails, operation DataPlaneOperation) (shim.StorageTableWrapper, error)

type DataPlaneOperation

type DataPlaneOperation struct {
	SupportsAadAuthentication       bool
	SupportsSharedKeyAuthentication bool
	// contains filtered or unexported fields
}

type EndpointType

type EndpointType string