Service Client (service.Client)

import "github.com/Azure/azure-sdk-for-go/sdk/storage/azblob/service"

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

// Create with Azure AD credential
func NewClient(serviceURL string, cred azcore.TokenCredential, options *ClientOptions) (*Client, error)

// Create with shared key credential
func NewClientWithSharedKeyCredential(serviceURL string, cred *SharedKeyCredential, options *ClientOptions) (*Client, error)

// Create from connection string
func NewClientFromConnectionString(connectionString string, options *ClientOptions) (*Client, error)

// Create without credential (for SAS URLs)
func NewClientWithNoCredential(serviceURL string, options *ClientOptions) (*Client, error)

func (s *Client) URL() string

func (s *Client) GetAccountInfo(ctx context.Context, o *GetAccountInfoOptions) (GetAccountInfoResponse, error)

func (s *Client) GetProperties(ctx context.Context, o *GetPropertiesOptions) (GetPropertiesResponse, error)

func (s *Client) SetProperties(ctx context.Context, o *SetPropertiesOptions) (SetPropertiesResponse, error)

type SetPropertiesOptions struct {
    CORS                  []*CORSRule
    DefaultServiceVersion *string
    DeleteRetentionPolicy *RetentionPolicy
    HourMetrics           *Metrics
    Logging               *Logging
    MinuteMetrics         *Metrics
    StaticWebsite         *StaticWebsite
}

func (s *Client) GetStatistics(ctx context.Context, o *GetStatisticsOptions) (GetStatisticsResponse, error)

func (s *Client) NewContainerClient(containerName string) *container.Client

func (s *Client) CreateContainer(ctx context.Context, containerName string, options *CreateContainerOptions) (CreateContainerResponse, error)

func (s *Client) DeleteContainer(ctx context.Context, containerName string, options *DeleteContainerOptions) (DeleteContainerResponse, error)

func (s *Client) RestoreContainer(ctx context.Context, deletedContainerName string, deletedContainerVersion string, options *RestoreContainerOptions) (RestoreContainerResponse, error)

func (s *Client) NewListContainersPager(o *ListContainersOptions) *runtime.Pager[ListContainersResponse]

type ListContainersOptions struct {
    Include    ListContainersInclude
    Marker     *string
    MaxResults *int32
    Prefix     *string
}

type ListContainersInclude struct {
    Metadata bool
    Deleted  bool
    System   bool
}

func (s *Client) FilterBlobs(ctx context.Context, where string, o *FilterBlobsOptions) (FilterBlobsResponse, error)

// Find blobs with specific tags
where := "\"Status\"='Active' AND \"Priority\"='High'"
resp, err := serviceClient.FilterBlobs(ctx, where, nil)

func (s *Client) NewBatchBuilder() (*BatchBuilder, error)

func (s *Client) SubmitBatch(ctx context.Context, bb *BatchBuilder, options *SubmitBatchOptions) (SubmitBatchResponse, error)

// Create batch
batch, err := serviceClient.NewBatchBuilder()
if err != nil {
    // handle error
}

// Add operations
err = batch.Delete("container1", "blob1", nil)
err = batch.Delete("container1", "blob2", nil)
err = batch.SetTier("container2", "blob3", blob.AccessTierCool, nil)

// Submit batch
resp, err := serviceClient.SubmitBatch(ctx, batch, nil)

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

// Add delete operation
func (bb *BatchBuilder) Delete(containerName string, blobName string, options *BatchDeleteOptions) error

// Add set tier operation
func (bb *BatchBuilder) SetTier(containerName string, blobName string, accessTier blob.AccessTier, options *BatchSetTierOptions) error

func (s *Client) GetUserDelegationCredential(ctx context.Context, info KeyInfo, o *GetUserDelegationCredentialOptions) (*UserDelegationCredential, error)

type KeyInfo struct {
    Start  *time.Time
    Expiry *time.Time
}

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

func (s *Client) GetSASURL(resources sas.AccountResourceTypes, permissions sas.AccountPermissions, expiry time.Time, o *GetSASURLOptions) (string, error)

import (
    "time"
    "github.com/Azure/azure-sdk-for-go/sdk/storage/azblob/sas"
)

// Set permissions
permissions := sas.AccountPermissions{
    Read:   true,
    Write:  true,
    List:   true,
    Create: true,
}

// Set resource types
resources := sas.AccountResourceTypes{
    Service:   true,
    Container: true,
    Object:    true,
}

// Generate SAS URL
expiry := time.Now().Add(24 * time.Hour)
sasURL, err := serviceClient.GetSASURL(resources, permissions, expiry, nil)

const (
    ContainerNameRoot = "$root" // Root container name
    ContainerNameLogs = "$logs" // Logs container name
)

type StorageServiceProperties struct {
    CORS                  []*CORSRule
    DefaultServiceVersion *string
    DeleteRetentionPolicy *RetentionPolicy
    HourMetrics           *Metrics
    Logging               *Logging
    MinuteMetrics         *Metrics
    StaticWebsite         *StaticWebsite
}

type CORSRule struct {
    AllowedOrigins  *string
    AllowedMethods  *string
    AllowedHeaders  *string
    ExposedHeaders  *string
    MaxAgeInSeconds *int32
}

type Logging struct {
    Version         *string
    Delete          *bool
    Read            *bool
    Write           *bool
    RetentionPolicy *RetentionPolicy
}

type Metrics struct {
    Version         *string
    Enabled         *bool
    IncludeAPIs     *bool
    RetentionPolicy *RetentionPolicy
}

type RetentionPolicy struct {
    Enabled *bool
    Days    *int32
}

type StaticWebsite struct {
    Enabled              *bool
    IndexDocument        *string
    ErrorDocument404Path *string
    DefaultIndexDocumentPath *string
}

type StorageServiceStats struct {
    GeoReplication *GeoReplication
}

type GeoReplication struct {
    Status       *BlobGeoReplicationStatus
    LastSyncTime *time.Time
}

type ContainerItem struct {
    Name       *string
    Version    *string
    Deleted    *bool
    Properties *ContainerProperties
    Metadata   map[string]*string
}

type ContainerProperties struct {
    LastModified                   *time.Time
    ETag                           *azcore.ETag
    LeaseStatus                    *LeaseStatusType
    LeaseState                     *LeaseStateType
    LeaseDuration                  *LeaseDurationType
    PublicAccess                   *PublicAccessType
    HasImmutabilityPolicy          *bool
    HasLegalHold                   *bool
    DefaultEncryptionScope         *string
    PreventEncryptionScopeOverride *bool
    DeletedTime                    *time.Time
    RemainingRetentionDays         *int32
    IsImmutableStorageWithVersioningEnabled *bool
}

type FilterBlobItem struct {
    Name          *string
    ContainerName *string
    Tags          *BlobTags
}

type FilterBlobSegment struct {
    BlobItems  []*FilterBlobItem
    NextMarker *string
}

type BlobTag struct {
    Key   *string
    Value *string
}

type BlobTags struct {
    BlobTagSet []*BlobTag
}

type BatchDeleteOptions struct {
    DeleteSnapshots  *DeleteSnapshotsOptionType
    BlobDeleteType   *DeleteType
    AccessConditions *blob.AccessConditions
    VersionID        *string
    Snapshot         *string
}

type BatchSetTierOptions struct {
    RehydratePriority *RehydratePriority
    AccessConditions  *blob.AccessConditions
    VersionID         *string
    Snapshot          *string
}

type BatchResponseItem struct {
    ContainerName *string
    BlobName      *string
    RequestID     *string
    Version       *string
    Date          *time.Time
    ETag          *azcore.ETag
    // Error information if operation failed
    ErrorCode    *string
    ErrorMessage *string
}

type AccountKind string

const (
    AccountKindStorage          AccountKind = "Storage"
    AccountKindBlobStorage      AccountKind = "BlobStorage"
    AccountKindStorageV2        AccountKind = "StorageV2"
    AccountKindFileStorage      AccountKind = "FileStorage"
    AccountKindBlockBlobStorage AccountKind = "BlockBlobStorage"
)

type SKUName string

const (
    SKUNameStandardLRS   SKUName = "Standard_LRS"
    SKUNameStandardGRS   SKUName = "Standard_GRS"
    SKUNameStandardRAGRS SKUName = "Standard_RAGRS"
    SKUNameStandardZRS   SKUName = "Standard_ZRS"
    SKUNamePremiumLRS    SKUName = "Premium_LRS"
)

type BlobGeoReplicationStatus string

const (
    BlobGeoReplicationStatusLive        BlobGeoReplicationStatus = "live"
    BlobGeoReplicationStatusBootstrap   BlobGeoReplicationStatus = "bootstrap"
    BlobGeoReplicationStatusUnavailable BlobGeoReplicationStatus = "unavailable"
)

type PublicAccessType string

const (
    PublicAccessTypeBlob      PublicAccessType = "blob"
    PublicAccessTypeContainer PublicAccessType = "container"
)

type ListContainersIncludeType string

const (
    ListContainersIncludeTypeMetadata ListContainersIncludeType = "metadata"
    ListContainersIncludeTypeDeleted  ListContainersIncludeType = "deleted"
    ListContainersIncludeTypeSystem   ListContainersIncludeType = "system"
)

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

func NewSharedKeyCredential(accountName, accountKey string) (*SharedKeyCredential, error)

func (c *SharedKeyCredential) AccountName() string

type ClientOptions struct {
    Telemetry                       policy.TelemetryOptions
    Transport                       policy.Transporter
    Retry                           policy.RetryOptions
    PerCallPolicies                 []policy.Policy
    PerRetryPolicies                []policy.Policy
    InsecureAllowCredentialWithHTTP bool
    DisableRPRegistration           bool
}