in pkg/queue/message.go [128:141]
func NewClient(accountName, queueName string) (*Client, error) {
credential, err := azidentity.NewDefaultAzureCredential(nil)
if err != nil {
return nil, err
}
serviceURL := fmt.Sprintf("https://%s.queue.core.windows.net", accountName)
sClient, err := azqueue.NewServiceClient(serviceURL, credential, nil)
if err != nil {
return nil, err
}
return &Client{c: sClient.NewQueueClient(queueName)}, nil
}