Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

azure

package

Go to main page

Versions in this module

v1

v1.3.3

Jul 5, 2022

v1.3.2

Jul 19, 2021

v1.3.1

Jul 19, 2021

v1.3.0

Jul 16, 2021

v1.2.0

Jul 14, 2021

Changes in this version

+ const AVERE_USAGE_GUID

+ const AZURE_CLIENT_ID

+ const AZURE_CLIENT_SECRET

+ const AZURE_EVENTHUB_NAMESPACENAME

+ const AZURE_EVENTHUB_SENDERKEY

+ const AZURE_EVENTHUB_SENDERKEYNAME

+ const AZURE_STORAGE_ACCOUNT

+ const AZURE_STORAGE_ACCOUNT_KEY

+ const AZURE_SUBSCRIPTION_ID

+ const AZURE_TENANT_ID

+ const DEFAULT_OPERATION_POLL_TIME

+ const MAX_OPERATION_POLL_TIME

+ const PrintStatsCycle

+ func AnthonyBernieDefaultHTTPClientFactory() pipeline.Factory

+ func FatalValidateContainerName(containerName string)

+ func FatalValidateQueueName(queueName string)

+ func GetSubnetId(subscriptionId string, resourceGroupName string, vnetName string, ...) string

+ func GetUsageAttribution(ctx context.Context) (string, bool)

+ func SetUsageAttribution(ctx context.Context, usageGuid string) context.Context

+ func ValidateContainerName(containerName string) (bool, string)

+ func ValidateQueueName(queueName string) (bool, string)

+ type BlobContainer struct

+ ContainerURL azblob.ContainerURL

+ Context context.Context

+ func InitializeBlobContainer(ctx context.Context, storageAccount string, storageAccountKey string, ...) (*BlobContainer, error)

+ func (b *BlobContainer) DeleteBlob(blobname string) error

+ func (b *BlobContainer) DownloadBlob(blobname string) ([]byte, error)

+ func (b *BlobContainer) UploadBlob(blobname string, data []byte) error

+ type EventHubSender struct

+ func InitializeEventHubSender(ctx context.Context, senderKeyName string, senderKey string, ...) (*EventHubSender, error)

+ func (e *EventHubSender) IsSenderComplete() bool

+ func (e *EventHubSender) RecordTiming(bytes []byte)

+ type Queue struct

+ Context context.Context

+ MessagesURL azqueue.MessagesURL

+ QueueURL azqueue.QueueURL

+ func InitializeQueue(ctx context.Context, storageAccount string, storageAccountKey string, ...) *Queue

+ func InitializeQueueNonFatal(ctx context.Context, storageAccount string, storageAccountKey string, ...) (*Queue, error)

+ func (q *Queue) DeleteMessage(messageID azqueue.MessageID, popReceipt azqueue.PopReceipt) (*azqueue.MessageIDDeleteResponse, error)

+ func (q *Queue) Dequeue(maxMessages int32, visibilityTimeout time.Duration) (*azqueue.DequeuedMessagesResponse, error)

+ func (q *Queue) Enqueue(message string) error

+ func (q *Queue) IsQueueEmpty() (bool, error)

+ func (q *Queue) Peek(maxMessages int32) (*azqueue.PeekedMessagesResponse, error)

+ func (q *Queue) UpdateVisibilityTimeout(messageID azqueue.MessageID, popReceipt azqueue.PopReceipt, ...) (*azqueue.UpdatedMessageResponse, error)

+ type ResourceGroup struct

+ Context context.Context

+ GroupsClient resources.GroupsClient

+ func InitializeResourceGroup(ctx context.Context, authorizer autorest.Authorizer, subscriptionId string) *ResourceGroup

+ func (rg *ResourceGroup) GetResourceGroupIntTag(resourceGroupName string, tagName string) (int, error)

+ func (rg *ResourceGroup) SetTotalNodesIntTag(resourceGroupName string, tagName string, val int) (*resources.Group, error)

+ type Vmss struct

+ Context context.Context

+ VmssClient compute.VirtualMachineScaleSetsClient

+ func InitializeVmss(ctx context.Context, authorizer autorest.Authorizer, subscriptionId string) *Vmss

+ func (v *Vmss) Create(resourceGroupName string, vmss compute.VirtualMachineScaleSet) (compute.VirtualMachineScaleSetsCreateOrUpdateFuture, error)

+ func (v *Vmss) ListVMSS(resourceGroupName string) ([]compute.VirtualMachineScaleSet, error)

+ func (v *Vmss) Update(resourceGroupName string, vmss compute.VirtualMachineScaleSet) (compute.VirtualMachineScaleSetsCreateOrUpdateFuture, error)

+ type VmssOperation struct

+ Attempts int

+ FutureAPI azure.FutureAPI

+ LastQuery time.Time

+ WaitDuration time.Duration

+ type VmssOperationManager struct

+ Client autorest.Client

+ Context context.Context

+ func InitializeVmssOperationManager(ctx context.Context, client autorest.Client) *VmssOperationManager

+ func (v *VmssOperationManager) AddWatchOperation(vmssName string, futureAPI azure.FutureAPI)

+ func (v *VmssOperationManager) IsComplete(vmssName string) bool

+ func (v *VmssOperationManager) Run(syncWaitGroup *sync.WaitGroup)