azure

func CreateDevice ¶

func CreateDevice(hubName, deviceName, iotownerKey string) (string, error)

CreateDevice relies on the REST API to create a new device for testing returning the primary key used for the newly created device.

func CreateEventHubCommon ¶

func CreateEventHubCommon(ctx context.Context, subscriptionID, name, region, rg string, omitHub bool) *eventhubs.Hub

func CreateEventHubComponents ¶

func CreateEventHubComponents(ctx context.Context, subscriptionID, name, region, rg string) *eventhubs.Hub

func CreateEventHubNamespaceOnly ¶

func CreateEventHubNamespaceOnly(ctx context.Context, subscriptionID, name, region, rg string) *eventhubs.Hub

func CreateIOTHubComponents ¶

func CreateIOTHubComponents(ctx context.Context, subscriptionID, rg, region, name string) (string, string)

CreateIOTHubComponents Will create the Azure IOT Hub, and a device to produce data

func CreateNsService ¶

func CreateNsService(ctx context.Context, region string, name string, nsCli *servicebus.NamespacesClient) *sv.Namespace

CreateNsService will create a servicebus namespace service.

func CreateQueueStorage ¶

func CreateQueueStorage(ctx context.Context, name, accountName string, accountKey string) *azqueue.MessagesURL

CreateQueueStorage will create a queue storage message url

func CreateResourceGroup ¶

func CreateResourceGroup(ctx context.Context, subscriptionID, name, region string) armresources.ResourceGroup

CreateResourceGroup will create the resource group containing all of the eventhub components.

func CreateSaSToken ¶

func CreateSaSToken(uri, name, key string, withName bool) string

CreateSaSToken will create a shared access signature to interact with the Azure IOTEventHub for device management.

func CreateServiceBusNamespace ¶

func CreateServiceBusNamespace(ctx context.Context, cli servicebus.NamespacesClient, rgName string, nsName string, region string) error

func CreateServiceBusNamespaceClient ¶

func CreateServiceBusNamespaceClient(ctx context.Context, subscriptionID, region string) *servicebus.NamespacesClient

CreateServiceBusNamespaceClient will create the servicebus client

func CreateStorageAccount ¶

func CreateStorageAccount(ctx context.Context, cli *armstorage.StorageAccountsClient, name, rgName, region string) error

CreateStorageAccount will create the storage account

func CreateStorageAccountsClient ¶

func CreateStorageAccountsClient(subscriptionID string) *armstorage.StorageAccountsClient

CreateStorageAccountsClient will create the storage account client

func DeleteResourceGroup ¶

func DeleteResourceGroup(ctx context.Context, subscriptionID, name string) armresources.ResourceGroupsDeletePollerResponse

DeleteResourceGroup will delete everything under it allowing for easy cleanup

func GetStorageAccountKey ¶

func GetStorageAccountKey(ctx context.Context, cli *armstorage.StorageAccountsClient, name, rgName string) (armstorage.StorageAccountsListKeysResponse, error)

GetStorageAccountKey will return the storage account keys

func WaitForFutureDeletion ¶

func WaitForFutureDeletion(ctx context.Context, subscriptionID string, future armresources.ResourceGroupsDeletePollerResponse)

WaitForFutureDeletion will wait on the resource to be deleted before continuing