-
Notifications
You must be signed in to change notification settings - Fork 21
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
yupwei68
committed
May 20, 2021
1 parent
9de4e97
commit 03bad5d
Showing
209 changed files
with
18,542 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,31 @@ | ||
# Storage API Version 2020-08-04 | ||
|
||
The following API's are supported by this SDK - more information about each SDK can be found within the README in each package. | ||
|
||
## Blob Storage | ||
|
||
- [Blobs API](blob/blobs) | ||
- [Containers API](blob/containers) | ||
- [Accounts API](blob/accounts) | ||
|
||
## DataLakeStore Gen2 | ||
|
||
- [FileSystems API](datalakestore/filesystems) | ||
- [Paths API](datalakestore/paths) | ||
|
||
## File Storage | ||
|
||
- [Directories API](file/directories) | ||
- [Files API](file/files) | ||
- [Shares API](file/shares) | ||
|
||
## Queue Storage | ||
|
||
- [Queues API](queue/queues) | ||
- [Messages API](queue/messages) | ||
|
||
## Table Storage | ||
|
||
- [Entities API](table/entities) | ||
- [Tables API](table/tables) | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,57 @@ | ||
## Blob Storage Account SDK for API version 2020-08-04 | ||
|
||
This package allows you to interact with the Accounts Blob Storage API | ||
|
||
### Supported Authorizers | ||
|
||
* Azure Active Directory | ||
|
||
### Example Usage | ||
|
||
```go | ||
package main | ||
|
||
import ( | ||
"context" | ||
"fmt" | ||
"time" | ||
|
||
"github.com/Azure/go-autorest/autorest" | ||
"github.com/tombuildsstuff/giovanni/storage/2020-08-04/blob/accounts" | ||
) | ||
|
||
func Example() error { | ||
accountName := "storageaccount1" | ||
|
||
// e.g. https://github.com/tombuildsstuff/giovanni/blob/76f5f686c99ecdcc3fa533a0330d0e1aacb1c327/example/azuread-auth/main.go#L54 | ||
client, err := buildClient() | ||
if err != nil { | ||
return fmt.Errorf("error building client: %s", err) | ||
} | ||
|
||
ctx := context.TODO() | ||
|
||
input := StorageServiceProperties{ | ||
StaticWebsite: &StaticWebsite{ | ||
Enabled: true, | ||
IndexDocument: index, | ||
ErrorDocument404Path: errorDocument, | ||
}, | ||
} | ||
|
||
_, err = client.SetServiceProperties(ctx, accountName, input) | ||
if err != nil { | ||
return fmt.Errorf("error setting properties: %s", err) | ||
} | ||
|
||
time.Sleep(2 * time.Second) | ||
|
||
_, err = accountsClient.GetServiceProperties(ctx, accountName) | ||
if err != nil { | ||
return fmt.Errorf("error getting properties: %s", err) | ||
} | ||
|
||
return nil | ||
} | ||
|
||
``` |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,25 @@ | ||
package accounts | ||
|
||
import ( | ||
"github.com/Azure/go-autorest/autorest" | ||
"github.com/Azure/go-autorest/autorest/azure" | ||
) | ||
|
||
// Client is the base client for Blob Storage Blobs. | ||
type Client struct { | ||
autorest.Client | ||
BaseURI string | ||
} | ||
|
||
// New creates an instance of the Client client. | ||
func New() Client { | ||
return NewWithEnvironment(azure.PublicCloud) | ||
} | ||
|
||
// NewWithBaseURI creates an instance of the Client client. | ||
func NewWithEnvironment(environment azure.Environment) Client { | ||
return Client{ | ||
Client: autorest.NewClientWithUserAgent(UserAgent()), | ||
BaseURI: environment.StorageEndpointSuffix, | ||
} | ||
} |
84 changes: 84 additions & 0 deletions
84
storage/2020-08-04/blob/accounts/get_service_properties.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,84 @@ | ||
package accounts | ||
|
||
import ( | ||
"context" | ||
"net/http" | ||
|
||
"github.com/Azure/go-autorest/autorest" | ||
"github.com/Azure/go-autorest/autorest/azure" | ||
"github.com/Azure/go-autorest/autorest/validation" | ||
"github.com/tombuildsstuff/giovanni/storage/internal/endpoints" | ||
) | ||
|
||
type GetServicePropertiesResult struct { | ||
autorest.Response | ||
|
||
ContentType string | ||
StorageServiceProperties *StorageServiceProperties | ||
} | ||
|
||
// GetServicePropertiesPreparer prepares the GetServiceProperties request. | ||
func (client Client) GetServicePropertiesPreparer(ctx context.Context, accountName string) (*http.Request, error) { | ||
queryParameters := map[string]interface{}{ | ||
"restype": "service", | ||
"comp": "properties", | ||
} | ||
|
||
headers := map[string]interface{}{ | ||
"x-ms-version": APIVersion, | ||
} | ||
|
||
preparer := autorest.CreatePreparer( | ||
autorest.AsGet(), | ||
autorest.WithBaseURL(endpoints.GetBlobEndpoint(client.BaseURI, accountName)), | ||
autorest.WithHeaders(headers), | ||
autorest.WithQueryParameters(queryParameters)) | ||
return preparer.Prepare((&http.Request{}).WithContext(ctx)) | ||
} | ||
|
||
func (client Client) GetServicePropertiesSender(req *http.Request) (*http.Response, error) { | ||
return autorest.SendWithSender(client, req, | ||
azure.DoRetryWithRegistration(client.Client)) | ||
} | ||
|
||
func (client Client) GetServicePropertiesResponder(resp *http.Response) (result GetServicePropertiesResult, err error) { | ||
if resp != nil && resp.Header != nil { | ||
result.ContentType = resp.Header.Get("Content-Type") | ||
} | ||
|
||
err = autorest.Respond( | ||
resp, | ||
client.ByInspecting(), | ||
azure.WithErrorUnlessStatusCode(http.StatusOK), | ||
autorest.ByUnmarshallingXML(&result.StorageServiceProperties), | ||
autorest.ByClosing()) | ||
result.Response = autorest.Response{Response: resp} | ||
return | ||
} | ||
|
||
func (client Client) GetServiceProperties(ctx context.Context, accountName string) (result GetServicePropertiesResult, err error) { | ||
if accountName == "" { | ||
return result, validation.NewError("accounts.Client", "GetServiceProperties", "`accountName` cannot be an empty string.") | ||
} | ||
|
||
req, err := client.GetServicePropertiesPreparer(ctx, accountName) | ||
if err != nil { | ||
err = autorest.NewErrorWithError(err, "accounts.Client", "GetServiceProperties", nil, "Failure preparing request") | ||
return | ||
} | ||
|
||
resp, err := client.GetServicePropertiesSender(req) | ||
if err != nil { | ||
result.Response = autorest.Response{Response: resp} | ||
err = autorest.NewErrorWithError(err, "accounts.Client", "GetServiceProperties", resp, "Failure sending request") | ||
return | ||
} | ||
|
||
result, err = client.GetServicePropertiesResponder(resp) | ||
if err != nil { | ||
err = autorest.NewErrorWithError(err, "accounts.Client", "GetServiceProperties", resp, "Failure responding to request") | ||
return | ||
} | ||
|
||
return | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,80 @@ | ||
package accounts | ||
|
||
import "github.com/Azure/go-autorest/autorest" | ||
|
||
type SetServicePropertiesResult struct { | ||
autorest.Response | ||
} | ||
|
||
type StorageServiceProperties struct { | ||
// Cors - Specifies CORS rules for the Blob service. You can include up to five CorsRule elements in the request. If no CorsRule elements are included in the request body, all CORS rules will be deleted, and CORS will be disabled for the Blob service. | ||
Cors *CorsRules `xml:"Cors,omitempty"` | ||
// DefaultServiceVersion - DefaultServiceVersion indicates the default version to use for requests to the Blob service if an incoming request’s version is not specified. Possible values include version 2008-10-27 and all more recent versions. | ||
DefaultServiceVersion *string `xml:"DefaultServiceVersion,omitempty"` | ||
// DeleteRetentionPolicy - The blob service properties for soft delete. | ||
DeleteRetentionPolicy *DeleteRetentionPolicy `xml:"DeleteRetentionPolicy,omitempty"` | ||
// Logging - The blob service properties for logging access | ||
Logging *Logging `xml:"Logging,omitempty"` | ||
// HourMetrics - The blob service properties for hour metrics | ||
HourMetrics *MetricsConfig `xml:"HourMetrics,omitempty"` | ||
// HourMetrics - The blob service properties for minute metrics | ||
MinuteMetrics *MetricsConfig `xml:"MinuteMetrics,omitempty"` | ||
// StaticWebsite - Optional | ||
StaticWebsite *StaticWebsite `xml:"StaticWebsite,omitempty"` | ||
} | ||
|
||
// StaticWebsite sets the static website support properties on the Blob service. | ||
type StaticWebsite struct { | ||
// Enabled - Required. Indicates whether static website support is enabled for the given account. | ||
Enabled bool `xml:"Enabled"` | ||
// IndexDocument - Optional. The webpage that Azure Storage serves for requests to the root of a website or any subfolder. For example, index.html. The value is case-sensitive. | ||
IndexDocument string `xml:"IndexDocument,omitempty"` | ||
// ErrorDocument404Path - Optional. The absolute path to a webpage that Azure Storage serves for requests that do not correspond to an existing file. For example, error/404.html. Only a single custom 404 page is supported in each static website. The value is case-sensitive. | ||
ErrorDocument404Path string `xml:"ErrorDocument404Path,omitempty"` | ||
} | ||
|
||
// CorsRules sets the CORS rules. You can include up to five CorsRule elements in the request. | ||
type CorsRules struct { | ||
// CorsRules - The List of CORS rules. You can include up to five CorsRule elements in the request. | ||
CorsRules []CorsRule `xml:"CorsRules,omitempty"` | ||
} | ||
|
||
// DeleteRetentionPolicy the blob service properties for soft delete. | ||
type DeleteRetentionPolicy struct { | ||
// Enabled - Indicates whether DeleteRetentionPolicy is enabled for the Blob service. | ||
Enabled bool `xml:"Enabled,omitempty"` | ||
// Days - Indicates the number of days that the deleted blob should be retained. The minimum specified value can be 1 and the maximum value can be 365. | ||
Days int32 `xml:"Days,omitempty"` | ||
} | ||
|
||
// CorsRule specifies a CORS rule for the Blob service. | ||
type CorsRule struct { | ||
// AllowedOrigins - Required if CorsRule element is present. A list of origin domains that will be allowed via CORS, or "" to allow all domains | ||
AllowedOrigins []string `xml:"AllowedOrigins,omitempty"` | ||
// AllowedMethods - Required if CorsRule element is present. A list of HTTP methods that are allowed to be executed by the origin. | ||
AllowedMethods []string `xml:"AllowedMethods,omitempty"` | ||
// MaxAgeInSeconds - Required if CorsRule element is present. The number of seconds that the client/browser should cache a preflight response. | ||
MaxAgeInSeconds int32 `xml:"MaxAgeInSeconds,omitempty"` | ||
// ExposedHeaders - Required if CorsRule element is present. A list of response headers to expose to CORS clients. | ||
ExposedHeaders []string `xml:"ExposedHeaders,omitempty"` | ||
// AllowedHeaders - Required if CorsRule element is present. A list of headers allowed to be part of the cross-origin request. | ||
AllowedHeaders []string `xml:"AllowedHeaders,omitempty"` | ||
} | ||
|
||
// Logging specifies the access logging options for the Blob service. | ||
type Logging struct { | ||
Version string `xml:"Version"` | ||
Delete bool `xml:"Delete"` | ||
Read bool `xml:"Read"` | ||
Write bool `xml:"Write"` | ||
RetentionPolicy DeleteRetentionPolicy `xml:"RetentionPolicy"` | ||
} | ||
|
||
// MetricsConfig specifies the hour and/or minute metrics options for the Blob service. | ||
// Elements are all expected | ||
type MetricsConfig struct { | ||
Version string `xml:"Version"` | ||
Enabled bool `xml:"Enabled"` | ||
RetentionPolicy DeleteRetentionPolicy `xml:"RetentionPolicy"` | ||
IncludeAPIs bool `xml:"IncludeAPIs"` | ||
} |
Oops, something went wrong.