armtimeseriesinsights

package module
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 24, 2023 License: MIT Imports: 14 Imported by: 1

README

Azure Time Series Insights Module for Go

PkgGoDev

The armtimeseriesinsights module provides operations for working with Azure Time Series Insights.

Source code

Getting started

Prerequisites

  • an Azure subscription
  • Go 1.18 or above (You could download and install the latest version of Go from here. It will replace the existing Go on your machine. If you want to install multiple Go versions on the same machine, you could refer this doc.)

Install the package

This project uses Go modules for versioning and dependency management.

Install the Azure Time Series Insights module:

go get github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights

Authorization

When creating a client, you will need to provide a credential for authenticating with Azure Time Series Insights. The azidentity module provides facilities for various ways of authenticating with Azure including client/secret, certificate, managed identity, and more.

cred, err := azidentity.NewDefaultAzureCredential(nil)

For more information on authentication, please see the documentation for azidentity at pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/azidentity.

Client Factory

Azure Time Series Insights module consists of one or more clients. We provide a client factory which could be used to create any client in this module.

clientFactory, err := armtimeseriesinsights.NewClientFactory(<subscription ID>, cred, nil)

You can use ClientOptions in package github.com/Azure/azure-sdk-for-go/sdk/azcore/arm to set endpoint to connect with public and sovereign clouds as well as Azure Stack. For more information, please see the documentation for azcore at pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/azcore.

options := arm.ClientOptions {
    ClientOptions: azcore.ClientOptions {
        Cloud: cloud.AzureChina,
    },
}
clientFactory, err := armtimeseriesinsights.NewClientFactory(<subscription ID>, cred, &options)

Clients

A client groups a set of related APIs, providing access to its functionality. Create one or more clients to access the APIs you require using client factory.

client := clientFactory.NewEventSourcesClient()

Fakes

The fake package contains types used for constructing in-memory fake servers used in unit tests. This allows writing tests to cover various success/error conditions without the need for connecting to a live service.

Please see https://github.com/Azure/azure-sdk-for-go/tree/main/sdk/samples/fakes for details and examples on how to use fakes.

Provide Feedback

If you encounter bugs or have suggestions, please open an issue and assign the Time Series Insights label.

Contributing

This project welcomes contributions and suggestions. Most contributions require you to agree to a Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us the rights to use your contribution. For details, visit https://cla.microsoft.com.

When you submit a pull request, a CLA-bot will automatically determine whether you need to provide a CLA and decorate the PR appropriately (e.g., label, comment). Simply follow the instructions provided by the bot. You will only need to do this once across all repos using our CLA.

This project has adopted the Microsoft Open Source Code of Conduct. For more information, see the Code of Conduct FAQ or contact opencode@microsoft.com with any additional questions or comments.

Documentation

Index

Examples

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessPoliciesClient

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

AccessPoliciesClient contains the methods for the AccessPolicies group. Don't use this type directly, use NewAccessPoliciesClient() instead.

func NewAccessPoliciesClient

func NewAccessPoliciesClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*AccessPoliciesClient, error)

NewAccessPoliciesClient creates a new instance of AccessPoliciesClient with the specified values.

  • subscriptionID - Azure Subscription ID.
  • credential - used to authorize requests. Usually a credential from azidentity.
  • options - pass nil to accept the default values.

func (*AccessPoliciesClient) CreateOrUpdate

func (client *AccessPoliciesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, environmentName string, accessPolicyName string, parameters AccessPolicyCreateOrUpdateParameters, options *AccessPoliciesClientCreateOrUpdateOptions) (AccessPoliciesClientCreateOrUpdateResponse, error)

CreateOrUpdate - Create or update an access policy in the specified environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • accessPolicyName - Name of the access policy.
  • parameters - Parameters for creating an access policy.
  • options - AccessPoliciesClientCreateOrUpdateOptions contains the optional parameters for the AccessPoliciesClient.CreateOrUpdate method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/AccessPoliciesCreate.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewAccessPoliciesClient().CreateOrUpdate(ctx, "rg1", "env1", "ap1", armtimeseriesinsights.AccessPolicyCreateOrUpdateParameters{
		Properties: &armtimeseriesinsights.AccessPolicyResourceProperties{
			Description:       to.Ptr("some description"),
			PrincipalObjectID: to.Ptr("aGuid"),
			Roles: []*armtimeseriesinsights.AccessPolicyRole{
				to.Ptr(armtimeseriesinsights.AccessPolicyRoleReader)},
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.AccessPolicyResource = armtimeseriesinsights.AccessPolicyResource{
	// 	Name: to.Ptr("ap1"),
	// 	Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/AccessPolicies"),
	// 	ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/accessPolicies/ap1"),
	// 	Properties: &armtimeseriesinsights.AccessPolicyResourceProperties{
	// 		Description: to.Ptr("some description"),
	// 		PrincipalObjectID: to.Ptr("aGuid"),
	// 		Roles: []*armtimeseriesinsights.AccessPolicyRole{
	// 			to.Ptr(armtimeseriesinsights.AccessPolicyRoleReader)},
	// 		},
	// 	}
}
Output:

func (*AccessPoliciesClient) Delete

func (client *AccessPoliciesClient) Delete(ctx context.Context, resourceGroupName string, environmentName string, accessPolicyName string, options *AccessPoliciesClientDeleteOptions) (AccessPoliciesClientDeleteResponse, error)

Delete - Deletes the access policy with the specified name in the specified subscription, resource group, and environment If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • accessPolicyName - The name of the Time Series Insights access policy associated with the specified environment.
  • options - AccessPoliciesClientDeleteOptions contains the optional parameters for the AccessPoliciesClient.Delete method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/AccessPoliciesDelete.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	_, err = clientFactory.NewAccessPoliciesClient().Delete(ctx, "rg1", "env1", "ap1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
}
Output:

func (*AccessPoliciesClient) Get

func (client *AccessPoliciesClient) Get(ctx context.Context, resourceGroupName string, environmentName string, accessPolicyName string, options *AccessPoliciesClientGetOptions) (AccessPoliciesClientGetResponse, error)

Get - Gets the access policy with the specified name in the specified environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • accessPolicyName - The name of the Time Series Insights access policy associated with the specified environment.
  • options - AccessPoliciesClientGetOptions contains the optional parameters for the AccessPoliciesClient.Get method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/AccessPoliciesGet.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewAccessPoliciesClient().Get(ctx, "rg1", "env1", "ap1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.AccessPolicyResource = armtimeseriesinsights.AccessPolicyResource{
	// 	Name: to.Ptr("ap1"),
	// 	Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/AccessPolicies"),
	// 	ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/accessPolicies/ap1"),
	// 	Properties: &armtimeseriesinsights.AccessPolicyResourceProperties{
	// 		Description: to.Ptr("some description"),
	// 		PrincipalObjectID: to.Ptr("aGuid"),
	// 		Roles: []*armtimeseriesinsights.AccessPolicyRole{
	// 			to.Ptr(armtimeseriesinsights.AccessPolicyRoleReader)},
	// 		},
	// 	}
}
Output:

func (*AccessPoliciesClient) ListByEnvironment

func (client *AccessPoliciesClient) ListByEnvironment(ctx context.Context, resourceGroupName string, environmentName string, options *AccessPoliciesClientListByEnvironmentOptions) (AccessPoliciesClientListByEnvironmentResponse, error)

ListByEnvironment - Lists all the available access policies associated with the environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • options - AccessPoliciesClientListByEnvironmentOptions contains the optional parameters for the AccessPoliciesClient.ListByEnvironment method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/AccessPoliciesListByEnvironment.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewAccessPoliciesClient().ListByEnvironment(ctx, "rg1", "env1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.AccessPolicyListResponse = armtimeseriesinsights.AccessPolicyListResponse{
	// 	Value: []*armtimeseriesinsights.AccessPolicyResource{
	// 		{
	// 			Name: to.Ptr("ap1"),
	// 			Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/AccessPolicies"),
	// 			ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/accessPolicies/ap1"),
	// 			Properties: &armtimeseriesinsights.AccessPolicyResourceProperties{
	// 				Description: to.Ptr("some description"),
	// 				PrincipalObjectID: to.Ptr("aGuid"),
	// 				Roles: []*armtimeseriesinsights.AccessPolicyRole{
	// 					to.Ptr(armtimeseriesinsights.AccessPolicyRoleReader)},
	// 				},
	// 		}},
	// 	}
}
Output:

func (*AccessPoliciesClient) Update

func (client *AccessPoliciesClient) Update(ctx context.Context, resourceGroupName string, environmentName string, accessPolicyName string, accessPolicyUpdateParameters AccessPolicyUpdateParameters, options *AccessPoliciesClientUpdateOptions) (AccessPoliciesClientUpdateResponse, error)

Update - Updates the access policy with the specified name in the specified subscription, resource group, and environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • accessPolicyName - The name of the Time Series Insights access policy associated with the specified environment.
  • accessPolicyUpdateParameters - Request object that contains the updated information for the access policy.
  • options - AccessPoliciesClientUpdateOptions contains the optional parameters for the AccessPoliciesClient.Update method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/AccessPoliciesPatchRoles.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewAccessPoliciesClient().Update(ctx, "rg1", "env1", "ap1", armtimeseriesinsights.AccessPolicyUpdateParameters{
		Properties: &armtimeseriesinsights.AccessPolicyMutableProperties{
			Roles: []*armtimeseriesinsights.AccessPolicyRole{
				to.Ptr(armtimeseriesinsights.AccessPolicyRoleReader),
				to.Ptr(armtimeseriesinsights.AccessPolicyRoleContributor)},
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.AccessPolicyResource = armtimeseriesinsights.AccessPolicyResource{
	// 	Name: to.Ptr("ap1"),
	// 	Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/AccessPolicies"),
	// 	ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/accessPolicies/ap1"),
	// 	Properties: &armtimeseriesinsights.AccessPolicyResourceProperties{
	// 		Description: to.Ptr("some description"),
	// 		PrincipalObjectID: to.Ptr("aGuid"),
	// 		Roles: []*armtimeseriesinsights.AccessPolicyRole{
	// 			to.Ptr(armtimeseriesinsights.AccessPolicyRoleReader)},
	// 		},
	// 	}
}
Output:

type AccessPoliciesClientCreateOrUpdateOptions

type AccessPoliciesClientCreateOrUpdateOptions struct {
}

AccessPoliciesClientCreateOrUpdateOptions contains the optional parameters for the AccessPoliciesClient.CreateOrUpdate method.

type AccessPoliciesClientCreateOrUpdateResponse

type AccessPoliciesClientCreateOrUpdateResponse struct {
	// An access policy is used to grant users and applications access to the environment. Roles are assigned to service principals
	// in Azure Active Directory. These roles define the actions the principal can perform through the Time Series Insights data
	// plane APIs.
	AccessPolicyResource
}

AccessPoliciesClientCreateOrUpdateResponse contains the response from method AccessPoliciesClient.CreateOrUpdate.

type AccessPoliciesClientDeleteOptions

type AccessPoliciesClientDeleteOptions struct {
}

AccessPoliciesClientDeleteOptions contains the optional parameters for the AccessPoliciesClient.Delete method.

type AccessPoliciesClientDeleteResponse

type AccessPoliciesClientDeleteResponse struct {
}

AccessPoliciesClientDeleteResponse contains the response from method AccessPoliciesClient.Delete.

type AccessPoliciesClientGetOptions

type AccessPoliciesClientGetOptions struct {
}

AccessPoliciesClientGetOptions contains the optional parameters for the AccessPoliciesClient.Get method.

type AccessPoliciesClientGetResponse

type AccessPoliciesClientGetResponse struct {
	// An access policy is used to grant users and applications access to the environment. Roles are assigned to service principals
	// in Azure Active Directory. These roles define the actions the principal can perform through the Time Series Insights data
	// plane APIs.
	AccessPolicyResource
}

AccessPoliciesClientGetResponse contains the response from method AccessPoliciesClient.Get.

type AccessPoliciesClientListByEnvironmentOptions

type AccessPoliciesClientListByEnvironmentOptions struct {
}

AccessPoliciesClientListByEnvironmentOptions contains the optional parameters for the AccessPoliciesClient.ListByEnvironment method.

type AccessPoliciesClientListByEnvironmentResponse

type AccessPoliciesClientListByEnvironmentResponse struct {
	// The response of the List access policies operation.
	AccessPolicyListResponse
}

AccessPoliciesClientListByEnvironmentResponse contains the response from method AccessPoliciesClient.ListByEnvironment.

type AccessPoliciesClientUpdateOptions

type AccessPoliciesClientUpdateOptions struct {
}

AccessPoliciesClientUpdateOptions contains the optional parameters for the AccessPoliciesClient.Update method.

type AccessPoliciesClientUpdateResponse

type AccessPoliciesClientUpdateResponse struct {
	// An access policy is used to grant users and applications access to the environment. Roles are assigned to service principals
	// in Azure Active Directory. These roles define the actions the principal can perform through the Time Series Insights data
	// plane APIs.
	AccessPolicyResource
}

AccessPoliciesClientUpdateResponse contains the response from method AccessPoliciesClient.Update.

type AccessPolicyCreateOrUpdateParameters

type AccessPolicyCreateOrUpdateParameters struct {
	// REQUIRED
	Properties *AccessPolicyResourceProperties
}

func (AccessPolicyCreateOrUpdateParameters) MarshalJSON added in v1.1.0

func (a AccessPolicyCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AccessPolicyCreateOrUpdateParameters.

func (*AccessPolicyCreateOrUpdateParameters) UnmarshalJSON added in v1.1.0

func (a *AccessPolicyCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type AccessPolicyCreateOrUpdateParameters.

type AccessPolicyListResponse

type AccessPolicyListResponse struct {
	// Result of the List access policies operation.
	Value []*AccessPolicyResource
}

AccessPolicyListResponse - The response of the List access policies operation.

func (AccessPolicyListResponse) MarshalJSON added in v1.1.0

func (a AccessPolicyListResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AccessPolicyListResponse.

func (*AccessPolicyListResponse) UnmarshalJSON added in v1.1.0

func (a *AccessPolicyListResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type AccessPolicyListResponse.

type AccessPolicyMutableProperties

type AccessPolicyMutableProperties struct {
	// An description of the access policy.
	Description *string

	// The list of roles the principal is assigned on the environment.
	Roles []*AccessPolicyRole
}

AccessPolicyMutableProperties - An object that represents a set of mutable access policy resource properties.

func (AccessPolicyMutableProperties) MarshalJSON

func (a AccessPolicyMutableProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AccessPolicyMutableProperties.

func (*AccessPolicyMutableProperties) UnmarshalJSON added in v1.1.0

func (a *AccessPolicyMutableProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type AccessPolicyMutableProperties.

type AccessPolicyResource

type AccessPolicyResource struct {
	Properties *AccessPolicyResourceProperties

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

AccessPolicyResource - An access policy is used to grant users and applications access to the environment. Roles are assigned to service principals in Azure Active Directory. These roles define the actions the principal can perform through the Time Series Insights data plane APIs.

func (AccessPolicyResource) MarshalJSON added in v1.1.0

func (a AccessPolicyResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AccessPolicyResource.

func (*AccessPolicyResource) UnmarshalJSON added in v1.1.0

func (a *AccessPolicyResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type AccessPolicyResource.

type AccessPolicyResourceProperties

type AccessPolicyResourceProperties struct {
	// An description of the access policy.
	Description *string

	// The objectId of the principal in Azure Active Directory.
	PrincipalObjectID *string

	// The list of roles the principal is assigned on the environment.
	Roles []*AccessPolicyRole
}

func (AccessPolicyResourceProperties) MarshalJSON

func (a AccessPolicyResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AccessPolicyResourceProperties.

func (*AccessPolicyResourceProperties) UnmarshalJSON added in v1.1.0

func (a *AccessPolicyResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type AccessPolicyResourceProperties.

type AccessPolicyRole

type AccessPolicyRole string

AccessPolicyRole - A role defining the data plane operations that a principal can perform on a Time Series Insights client.

const (
	AccessPolicyRoleContributor AccessPolicyRole = "Contributor"
	AccessPolicyRoleReader      AccessPolicyRole = "Reader"
)

func PossibleAccessPolicyRoleValues

func PossibleAccessPolicyRoleValues() []AccessPolicyRole

PossibleAccessPolicyRoleValues returns the possible values for the AccessPolicyRole const type.

type AccessPolicyUpdateParameters

type AccessPolicyUpdateParameters struct {
	// An object that represents a set of mutable access policy resource properties.
	Properties *AccessPolicyMutableProperties
}

func (AccessPolicyUpdateParameters) MarshalJSON

func (a AccessPolicyUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AccessPolicyUpdateParameters.

func (*AccessPolicyUpdateParameters) UnmarshalJSON added in v1.1.0

func (a *AccessPolicyUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type AccessPolicyUpdateParameters.

type AzureEventSourceProperties

type AzureEventSourceProperties struct {
	// REQUIRED; The resource id of the event source in Azure Resource Manager.
	EventSourceResourceID *string

	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

AzureEventSourceProperties - Properties of an event source that reads events from an event broker in Azure.

func (AzureEventSourceProperties) MarshalJSON

func (a AzureEventSourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AzureEventSourceProperties.

func (*AzureEventSourceProperties) UnmarshalJSON

func (a *AzureEventSourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type AzureEventSourceProperties.

type ClientFactory added in v1.1.0

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

ClientFactory is a client factory used to create any client in this module. Don't use this type directly, use NewClientFactory instead.

func NewClientFactory added in v1.1.0

func NewClientFactory(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*ClientFactory, error)

NewClientFactory creates a new instance of ClientFactory with the specified values. The parameter values will be propagated to any client created from this factory.

  • subscriptionID - Azure Subscription ID.
  • credential - used to authorize requests. Usually a credential from azidentity.
  • options - pass nil to accept the default values.

func (*ClientFactory) NewAccessPoliciesClient added in v1.1.0

func (c *ClientFactory) NewAccessPoliciesClient() *AccessPoliciesClient

NewAccessPoliciesClient creates a new instance of AccessPoliciesClient.

func (*ClientFactory) NewEnvironmentsClient added in v1.1.0

func (c *ClientFactory) NewEnvironmentsClient() *EnvironmentsClient

NewEnvironmentsClient creates a new instance of EnvironmentsClient.

func (*ClientFactory) NewEventSourcesClient added in v1.1.0

func (c *ClientFactory) NewEventSourcesClient() *EventSourcesClient

NewEventSourcesClient creates a new instance of EventSourcesClient.

func (*ClientFactory) NewOperationsClient added in v1.1.0

func (c *ClientFactory) NewOperationsClient() *OperationsClient

NewOperationsClient creates a new instance of OperationsClient.

func (*ClientFactory) NewReferenceDataSetsClient added in v1.1.0

func (c *ClientFactory) NewReferenceDataSetsClient() *ReferenceDataSetsClient

NewReferenceDataSetsClient creates a new instance of ReferenceDataSetsClient.

type CreateOrUpdateTrackedResourceProperties

type CreateOrUpdateTrackedResourceProperties struct {
	// REQUIRED; The location of the resource.
	Location *string

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

CreateOrUpdateTrackedResourceProperties - Properties required to create any resource tracked by Azure Resource Manager.

func (CreateOrUpdateTrackedResourceProperties) MarshalJSON

func (c CreateOrUpdateTrackedResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type CreateOrUpdateTrackedResourceProperties.

func (*CreateOrUpdateTrackedResourceProperties) UnmarshalJSON added in v1.1.0

func (c *CreateOrUpdateTrackedResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type CreateOrUpdateTrackedResourceProperties.

type DataStringComparisonBehavior

type DataStringComparisonBehavior string

DataStringComparisonBehavior - The reference data set key comparison behavior can be set using this property. By default, the value is 'Ordinal' - which means case sensitive key comparison will be performed while joining reference data with events or while adding new reference data. When 'OrdinalIgnoreCase' is set, case insensitive comparison will be used.

const (
	DataStringComparisonBehaviorOrdinal           DataStringComparisonBehavior = "Ordinal"
	DataStringComparisonBehaviorOrdinalIgnoreCase DataStringComparisonBehavior = "OrdinalIgnoreCase"
)

func PossibleDataStringComparisonBehaviorValues

func PossibleDataStringComparisonBehaviorValues() []DataStringComparisonBehavior

PossibleDataStringComparisonBehaviorValues returns the possible values for the DataStringComparisonBehavior const type.

type Dimension

type Dimension struct {
	// Display name of dimension.
	DisplayName *string

	// Display name of dimension.
	Name *string
}

Dimension of blobs, possibly be blob type or access tier.

func (Dimension) MarshalJSON added in v1.1.0

func (d Dimension) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Dimension.

func (*Dimension) UnmarshalJSON added in v1.1.0

func (d *Dimension) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Dimension.

type EnvironmentCreateOrUpdateParameters

type EnvironmentCreateOrUpdateParameters struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentKind

	// REQUIRED; The location of the resource.
	Location *string

	// REQUIRED; The sku determines the type of environment, either Gen1 (S1 or S2) or Gen2 (L1). For Gen1 environments the sku
	// determines the capacity of the environment, the ingress rate, and the billing rate.
	SKU *SKU

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

EnvironmentCreateOrUpdateParameters - Parameters supplied to the CreateOrUpdate Environment operation.

func (*EnvironmentCreateOrUpdateParameters) GetEnvironmentCreateOrUpdateParameters

func (e *EnvironmentCreateOrUpdateParameters) GetEnvironmentCreateOrUpdateParameters() *EnvironmentCreateOrUpdateParameters

GetEnvironmentCreateOrUpdateParameters implements the EnvironmentCreateOrUpdateParametersClassification interface for type EnvironmentCreateOrUpdateParameters.

func (EnvironmentCreateOrUpdateParameters) MarshalJSON

func (e EnvironmentCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentCreateOrUpdateParameters.

func (*EnvironmentCreateOrUpdateParameters) UnmarshalJSON added in v1.1.0

func (e *EnvironmentCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentCreateOrUpdateParameters.

type EnvironmentCreateOrUpdateParametersClassification

type EnvironmentCreateOrUpdateParametersClassification interface {
	// GetEnvironmentCreateOrUpdateParameters returns the EnvironmentCreateOrUpdateParameters content of the underlying type.
	GetEnvironmentCreateOrUpdateParameters() *EnvironmentCreateOrUpdateParameters
}

EnvironmentCreateOrUpdateParametersClassification provides polymorphic access to related types. Call the interface's GetEnvironmentCreateOrUpdateParameters() method to access the common type. Use a type switch to determine the concrete type. The possible types are: - *EnvironmentCreateOrUpdateParameters, *Gen1EnvironmentCreateOrUpdateParameters, *Gen2EnvironmentCreateOrUpdateParameters

type EnvironmentKind

type EnvironmentKind string

EnvironmentKind - The kind of the environment.

const (
	EnvironmentKindGen1 EnvironmentKind = "Gen1"
	EnvironmentKindGen2 EnvironmentKind = "Gen2"
)

func PossibleEnvironmentKindValues

func PossibleEnvironmentKindValues() []EnvironmentKind

PossibleEnvironmentKindValues returns the possible values for the EnvironmentKind const type.

type EnvironmentListResponse

type EnvironmentListResponse struct {
	// Result of the List Environments operation.
	Value []EnvironmentResourceClassification
}

EnvironmentListResponse - The response of the List Environments operation.

func (EnvironmentListResponse) MarshalJSON added in v1.1.0

func (e EnvironmentListResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentListResponse.

func (*EnvironmentListResponse) UnmarshalJSON

func (e *EnvironmentListResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentListResponse.

type EnvironmentResource

type EnvironmentResource struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentResourceKind

	// REQUIRED; Resource location
	Location *string

	// REQUIRED; The sku determines the type of environment, either Gen1 (S1 or S2) or Gen2 (L1). For Gen1 environments the sku
	// determines the capacity of the environment, the ingress rate, and the billing rate.
	SKU *SKU

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

EnvironmentResource - An environment is a set of time-series data available for query, and is the top level Azure Time Series Insights resource.

func (*EnvironmentResource) GetEnvironmentResource

func (e *EnvironmentResource) GetEnvironmentResource() *EnvironmentResource

GetEnvironmentResource implements the EnvironmentResourceClassification interface for type EnvironmentResource.

func (EnvironmentResource) MarshalJSON added in v1.1.0

func (e EnvironmentResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentResource.

func (*EnvironmentResource) UnmarshalJSON added in v1.1.0

func (e *EnvironmentResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentResource.

type EnvironmentResourceClassification

type EnvironmentResourceClassification interface {
	// GetEnvironmentResource returns the EnvironmentResource content of the underlying type.
	GetEnvironmentResource() *EnvironmentResource
}

EnvironmentResourceClassification provides polymorphic access to related types. Call the interface's GetEnvironmentResource() method to access the common type. Use a type switch to determine the concrete type. The possible types are: - *EnvironmentResource, *Gen1EnvironmentResource, *Gen2EnvironmentResource

type EnvironmentResourceKind

type EnvironmentResourceKind string

EnvironmentResourceKind - The kind of the environment.

const (
	EnvironmentResourceKindGen1 EnvironmentResourceKind = "Gen1"
	EnvironmentResourceKindGen2 EnvironmentResourceKind = "Gen2"
)

func PossibleEnvironmentResourceKindValues

func PossibleEnvironmentResourceKindValues() []EnvironmentResourceKind

PossibleEnvironmentResourceKindValues returns the possible values for the EnvironmentResourceKind const type.

type EnvironmentResourceProperties

type EnvironmentResourceProperties struct {
	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; The fully qualified domain name used to access the environment data, e.g. to query the environment's events
	// or upload reference data for the environment.
	DataAccessFqdn *string

	// READ-ONLY; An id used to access the environment data, e.g. to query the environment's events or upload reference data for
	// the environment.
	DataAccessID *string

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState

	// READ-ONLY; An object that represents the status of the environment, and its internal state in the Time Series Insights
	// service.
	Status *EnvironmentStatus
}

EnvironmentResourceProperties - Properties of the environment.

func (EnvironmentResourceProperties) MarshalJSON

func (e EnvironmentResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentResourceProperties.

func (*EnvironmentResourceProperties) UnmarshalJSON

func (e *EnvironmentResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentResourceProperties.

type EnvironmentStateDetails

type EnvironmentStateDetails struct {
	// Contains the code that represents the reason of an environment being in a particular state. Can be used to programmatically
	// handle specific cases.
	Code *string

	// A message that describes the state in detail.
	Message *string
}

EnvironmentStateDetails - An object that contains the details about an environment's state.

func (EnvironmentStateDetails) MarshalJSON added in v1.1.0

func (e EnvironmentStateDetails) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentStateDetails.

func (*EnvironmentStateDetails) UnmarshalJSON added in v1.1.0

func (e *EnvironmentStateDetails) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentStateDetails.

type EnvironmentStatus

type EnvironmentStatus struct {
	// READ-ONLY; An object that represents the status of ingress on an environment.
	Ingress *IngressEnvironmentStatus

	// READ-ONLY; An object that represents the status of warm storage on an environment.
	WarmStorage *WarmStorageEnvironmentStatus
}

EnvironmentStatus - An object that represents the status of the environment, and its internal state in the Time Series Insights service.

func (EnvironmentStatus) MarshalJSON added in v1.1.0

func (e EnvironmentStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentStatus.

func (*EnvironmentStatus) UnmarshalJSON added in v1.1.0

func (e *EnvironmentStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentStatus.

type EnvironmentUpdateParameters

type EnvironmentUpdateParameters struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentKind

	// Key-value pairs of additional properties for the environment.
	Tags map[string]*string
}

EnvironmentUpdateParameters - Parameters supplied to the Update Environment operation.

func (*EnvironmentUpdateParameters) GetEnvironmentUpdateParameters

func (e *EnvironmentUpdateParameters) GetEnvironmentUpdateParameters() *EnvironmentUpdateParameters

GetEnvironmentUpdateParameters implements the EnvironmentUpdateParametersClassification interface for type EnvironmentUpdateParameters.

func (EnvironmentUpdateParameters) MarshalJSON

func (e EnvironmentUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentUpdateParameters.

func (*EnvironmentUpdateParameters) UnmarshalJSON added in v1.1.0

func (e *EnvironmentUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentUpdateParameters.

type EnvironmentUpdateParametersClassification

type EnvironmentUpdateParametersClassification interface {
	// GetEnvironmentUpdateParameters returns the EnvironmentUpdateParameters content of the underlying type.
	GetEnvironmentUpdateParameters() *EnvironmentUpdateParameters
}

EnvironmentUpdateParametersClassification provides polymorphic access to related types. Call the interface's GetEnvironmentUpdateParameters() method to access the common type. Use a type switch to determine the concrete type. The possible types are: - *EnvironmentUpdateParameters, *Gen1EnvironmentUpdateParameters, *Gen2EnvironmentUpdateParameters

type EnvironmentsClient

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

EnvironmentsClient contains the methods for the Environments group. Don't use this type directly, use NewEnvironmentsClient() instead.

func NewEnvironmentsClient

func NewEnvironmentsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*EnvironmentsClient, error)

NewEnvironmentsClient creates a new instance of EnvironmentsClient with the specified values.

  • subscriptionID - Azure Subscription ID.
  • credential - used to authorize requests. Usually a credential from azidentity.
  • options - pass nil to accept the default values.

func (*EnvironmentsClient) BeginCreateOrUpdate

BeginCreateOrUpdate - Create or update an environment in the specified subscription and resource group. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - Name of the environment
  • parameters - Parameters for creating an environment resource.
  • options - EnvironmentsClientBeginCreateOrUpdateOptions contains the optional parameters for the EnvironmentsClient.BeginCreateOrUpdate method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EnvironmentsCreate.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewEnvironmentsClient().BeginCreateOrUpdate(ctx, "rg1", "env1", &armtimeseriesinsights.Gen1EnvironmentCreateOrUpdateParameters{
		Location: to.Ptr("West US"),
		Kind:     to.Ptr(armtimeseriesinsights.EnvironmentKindGen1),
		SKU: &armtimeseriesinsights.SKU{
			Name:     to.Ptr(armtimeseriesinsights.SKUNameS1),
			Capacity: to.Ptr[int32](1),
		},
		Properties: &armtimeseriesinsights.Gen1EnvironmentCreationProperties{
			DataRetentionTime: to.Ptr("P31D"),
			PartitionKeyProperties: []*armtimeseriesinsights.TimeSeriesIDProperty{
				{
					Name: to.Ptr("DeviceId1"),
					Type: to.Ptr(armtimeseriesinsights.PropertyTypeString),
				}},
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armtimeseriesinsights.EnvironmentsClientCreateOrUpdateResponse{
	// 	                            EnvironmentResourceClassification: &armtimeseriesinsights.Gen1EnvironmentResource{
	// 		Name: to.Ptr("env1"),
	// 		Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments"),
	// 		ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1"),
	// 		Location: to.Ptr("West US"),
	// 		Tags: map[string]*string{
	// 		},
	// 		Kind: to.Ptr(armtimeseriesinsights.EnvironmentResourceKindGen1),
	// 		SKU: &armtimeseriesinsights.SKU{
	// 			Name: to.Ptr(armtimeseriesinsights.SKUNameS1),
	// 			Capacity: to.Ptr[int32](1),
	// 		},
	// 		Properties: &armtimeseriesinsights.Gen1EnvironmentResourceProperties{
	// 			CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 			ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			DataRetentionTime: to.Ptr("P31D"),
	// 		},
	// 	},
	// 	                        }
}
Output:

func (*EnvironmentsClient) BeginUpdate

func (client *EnvironmentsClient) BeginUpdate(ctx context.Context, resourceGroupName string, environmentName string, environmentUpdateParameters EnvironmentUpdateParametersClassification, options *EnvironmentsClientBeginUpdateOptions) (*runtime.Poller[EnvironmentsClientUpdateResponse], error)

BeginUpdate - Updates the environment with the specified name in the specified subscription and resource group. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • environmentUpdateParameters - Request object that contains the updated information for the environment.
  • options - EnvironmentsClientBeginUpdateOptions contains the optional parameters for the EnvironmentsClient.BeginUpdate method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EnvironmentsPatchTags.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewEnvironmentsClient().BeginUpdate(ctx, "rg1", "env1", &armtimeseriesinsights.EnvironmentUpdateParameters{
		Tags: map[string]*string{
			"someTag": to.Ptr("someTagValue"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armtimeseriesinsights.EnvironmentsClientUpdateResponse{
	// 	                            EnvironmentResourceClassification: &armtimeseriesinsights.Gen1EnvironmentResource{
	// 		Name: to.Ptr("env1"),
	// 		Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments"),
	// 		ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1"),
	// 		Location: to.Ptr("West US"),
	// 		Tags: map[string]*string{
	// 			"someTag": to.Ptr("someTagValue"),
	// 		},
	// 		Kind: to.Ptr(armtimeseriesinsights.EnvironmentResourceKindGen1),
	// 		SKU: &armtimeseriesinsights.SKU{
	// 			Name: to.Ptr(armtimeseriesinsights.SKUNameS1),
	// 			Capacity: to.Ptr[int32](10),
	// 		},
	// 		Properties: &armtimeseriesinsights.Gen1EnvironmentResourceProperties{
	// 			CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 			ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			DataRetentionTime: to.Ptr("P31D"),
	// 		},
	// 	},
	// 	                        }
}
Output:

func (*EnvironmentsClient) Delete

func (client *EnvironmentsClient) Delete(ctx context.Context, resourceGroupName string, environmentName string, options *EnvironmentsClientDeleteOptions) (EnvironmentsClientDeleteResponse, error)

Delete - Deletes the environment with the specified name in the specified subscription and resource group. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • options - EnvironmentsClientDeleteOptions contains the optional parameters for the EnvironmentsClient.Delete method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EnvironmentsDelete.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	_, err = clientFactory.NewEnvironmentsClient().Delete(ctx, "rg1", "env1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
}
Output:

func (*EnvironmentsClient) Get

func (client *EnvironmentsClient) Get(ctx context.Context, resourceGroupName string, environmentName string, options *EnvironmentsClientGetOptions) (EnvironmentsClientGetResponse, error)

Get - Gets the environment with the specified name in the specified subscription and resource group. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • options - EnvironmentsClientGetOptions contains the optional parameters for the EnvironmentsClient.Get method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EnvironmentsGet.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEnvironmentsClient().Get(ctx, "rg1", "env1", &armtimeseriesinsights.EnvironmentsClientGetOptions{Expand: nil})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armtimeseriesinsights.EnvironmentsClientGetResponse{
	// 	                            EnvironmentResourceClassification: &armtimeseriesinsights.Gen1EnvironmentResource{
	// 		Name: to.Ptr("env1"),
	// 		Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments"),
	// 		ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1"),
	// 		Location: to.Ptr("West US"),
	// 		Tags: map[string]*string{
	// 		},
	// 		Kind: to.Ptr(armtimeseriesinsights.EnvironmentResourceKindGen1),
	// 		SKU: &armtimeseriesinsights.SKU{
	// 			Name: to.Ptr(armtimeseriesinsights.SKUNameS1),
	// 			Capacity: to.Ptr[int32](1),
	// 		},
	// 		Properties: &armtimeseriesinsights.Gen1EnvironmentResourceProperties{
	// 			CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 			ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			DataRetentionTime: to.Ptr("P31D"),
	// 			PartitionKeyProperties: []*armtimeseriesinsights.TimeSeriesIDProperty{
	// 				{
	// 					Name: to.Ptr("DeviceId1"),
	// 					Type: to.Ptr(armtimeseriesinsights.PropertyTypeString),
	// 			}},
	// 		},
	// 	},
	// 	                        }
}
Output:

func (*EnvironmentsClient) ListByResourceGroup

ListByResourceGroup - Lists all the available environments associated with the subscription and within the specified resource group. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • options - EnvironmentsClientListByResourceGroupOptions contains the optional parameters for the EnvironmentsClient.ListByResourceGroup method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EnvironmentsListByResourceGroup.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEnvironmentsClient().ListByResourceGroup(ctx, "rg1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.EnvironmentListResponse = armtimeseriesinsights.EnvironmentListResponse{
	// 	Value: []armtimeseriesinsights.EnvironmentResourceClassification{
	// 		&armtimeseriesinsights.Gen1EnvironmentResource{
	// 			Name: to.Ptr("env1"),
	// 			Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments"),
	// 			ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1"),
	// 			Location: to.Ptr("West US"),
	// 			Tags: map[string]*string{
	// 			},
	// 			Kind: to.Ptr(armtimeseriesinsights.EnvironmentResourceKindGen1),
	// 			SKU: &armtimeseriesinsights.SKU{
	// 				Name: to.Ptr(armtimeseriesinsights.SKUNameS1),
	// 				Capacity: to.Ptr[int32](1),
	// 			},
	// 			Properties: &armtimeseriesinsights.Gen1EnvironmentResourceProperties{
	// 				CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 				ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 				DataRetentionTime: to.Ptr("P31D"),
	// 			},
	// 	}},
	// }
}
Output:

func (*EnvironmentsClient) ListBySubscription

ListBySubscription - Lists all the available environments within a subscription, irrespective of the resource groups. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • options - EnvironmentsClientListBySubscriptionOptions contains the optional parameters for the EnvironmentsClient.ListBySubscription method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EnvironmentsListBySubscription.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEnvironmentsClient().ListBySubscription(ctx, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.EnvironmentListResponse = armtimeseriesinsights.EnvironmentListResponse{
	// 	Value: []armtimeseriesinsights.EnvironmentResourceClassification{
	// 		&armtimeseriesinsights.Gen1EnvironmentResource{
	// 			Name: to.Ptr("env1"),
	// 			Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments"),
	// 			ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1"),
	// 			Location: to.Ptr("West US"),
	// 			Tags: map[string]*string{
	// 			},
	// 			Kind: to.Ptr(armtimeseriesinsights.EnvironmentResourceKindGen1),
	// 			SKU: &armtimeseriesinsights.SKU{
	// 				Name: to.Ptr(armtimeseriesinsights.SKUNameS1),
	// 				Capacity: to.Ptr[int32](1),
	// 			},
	// 			Properties: &armtimeseriesinsights.Gen1EnvironmentResourceProperties{
	// 				CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 				ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 				DataRetentionTime: to.Ptr("P31D"),
	// 			},
	// 	}},
	// }
}
Output:

type EnvironmentsClientBeginCreateOrUpdateOptions

type EnvironmentsClientBeginCreateOrUpdateOptions struct {
	// Resumes the LRO from the provided token.
	ResumeToken string
}

EnvironmentsClientBeginCreateOrUpdateOptions contains the optional parameters for the EnvironmentsClient.BeginCreateOrUpdate method.

type EnvironmentsClientBeginUpdateOptions

type EnvironmentsClientBeginUpdateOptions struct {
	// Resumes the LRO from the provided token.
	ResumeToken string
}

EnvironmentsClientBeginUpdateOptions contains the optional parameters for the EnvironmentsClient.BeginUpdate method.

type EnvironmentsClientCreateOrUpdateResponse

type EnvironmentsClientCreateOrUpdateResponse struct {
	// An environment is a set of time-series data available for query, and is the top level Azure Time Series Insights resource.
	EnvironmentResourceClassification
}

EnvironmentsClientCreateOrUpdateResponse contains the response from method EnvironmentsClient.BeginCreateOrUpdate.

func (EnvironmentsClientCreateOrUpdateResponse) MarshalJSON added in v1.2.0

MarshalJSON implements the json.Marshaller interface for type EnvironmentsClientCreateOrUpdateResponse.

func (*EnvironmentsClientCreateOrUpdateResponse) UnmarshalJSON

func (e *EnvironmentsClientCreateOrUpdateResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentsClientCreateOrUpdateResponse.

type EnvironmentsClientDeleteOptions

type EnvironmentsClientDeleteOptions struct {
}

EnvironmentsClientDeleteOptions contains the optional parameters for the EnvironmentsClient.Delete method.

type EnvironmentsClientDeleteResponse

type EnvironmentsClientDeleteResponse struct {
}

EnvironmentsClientDeleteResponse contains the response from method EnvironmentsClient.Delete.

type EnvironmentsClientGetOptions

type EnvironmentsClientGetOptions struct {
	// Setting $expand=status will include the status of the internal services of the environment in the Time Series Insights
	// service.
	Expand *string
}

EnvironmentsClientGetOptions contains the optional parameters for the EnvironmentsClient.Get method.

type EnvironmentsClientGetResponse

type EnvironmentsClientGetResponse struct {
	// An environment is a set of time-series data available for query, and is the top level Azure Time Series Insights resource.
	EnvironmentResourceClassification
}

EnvironmentsClientGetResponse contains the response from method EnvironmentsClient.Get.

func (*EnvironmentsClientGetResponse) UnmarshalJSON

func (e *EnvironmentsClientGetResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentsClientGetResponse.

type EnvironmentsClientListByResourceGroupOptions

type EnvironmentsClientListByResourceGroupOptions struct {
}

EnvironmentsClientListByResourceGroupOptions contains the optional parameters for the EnvironmentsClient.ListByResourceGroup method.

type EnvironmentsClientListByResourceGroupResponse

type EnvironmentsClientListByResourceGroupResponse struct {
	// The response of the List Environments operation.
	EnvironmentListResponse
}

EnvironmentsClientListByResourceGroupResponse contains the response from method EnvironmentsClient.ListByResourceGroup.

type EnvironmentsClientListBySubscriptionOptions

type EnvironmentsClientListBySubscriptionOptions struct {
}

EnvironmentsClientListBySubscriptionOptions contains the optional parameters for the EnvironmentsClient.ListBySubscription method.

type EnvironmentsClientListBySubscriptionResponse

type EnvironmentsClientListBySubscriptionResponse struct {
	// The response of the List Environments operation.
	EnvironmentListResponse
}

EnvironmentsClientListBySubscriptionResponse contains the response from method EnvironmentsClient.ListBySubscription.

type EnvironmentsClientUpdateResponse

type EnvironmentsClientUpdateResponse struct {
	// An environment is a set of time-series data available for query, and is the top level Azure Time Series Insights resource.
	EnvironmentResourceClassification
}

EnvironmentsClientUpdateResponse contains the response from method EnvironmentsClient.BeginUpdate.

func (EnvironmentsClientUpdateResponse) MarshalJSON added in v1.2.0

func (e EnvironmentsClientUpdateResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EnvironmentsClientUpdateResponse.

func (*EnvironmentsClientUpdateResponse) UnmarshalJSON

func (e *EnvironmentsClientUpdateResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EnvironmentsClientUpdateResponse.

type EventHubEventSourceCommonProperties

type EventHubEventSourceCommonProperties struct {
	// REQUIRED; The name of the event hub's consumer group that holds the partitions from which events will be read.
	ConsumerGroupName *string

	// REQUIRED; The name of the event hub.
	EventHubName *string

	// REQUIRED; The resource id of the event source in Azure Resource Manager.
	EventSourceResourceID *string

	// REQUIRED; The name of the SAS key that grants the Time Series Insights service access to the event hub. The shared access
	// policies for this key must grant 'Listen' permissions to the event hub.
	KeyName *string

	// REQUIRED; The name of the service bus that contains the event hub.
	ServiceBusNamespace *string

	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

EventHubEventSourceCommonProperties - Properties of the EventHub event source.

func (EventHubEventSourceCommonProperties) MarshalJSON

func (e EventHubEventSourceCommonProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventHubEventSourceCommonProperties.

func (*EventHubEventSourceCommonProperties) UnmarshalJSON

func (e *EventHubEventSourceCommonProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventHubEventSourceCommonProperties.

type EventHubEventSourceCreateOrUpdateParameters

type EventHubEventSourceCreateOrUpdateParameters struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceKind

	// REQUIRED; The location of the resource.
	Location *string

	// REQUIRED; Properties of the EventHub event source that are required on create or update requests.
	Properties *EventHubEventSourceCreationProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

EventHubEventSourceCreateOrUpdateParameters - Parameters supplied to the Create or Update Event Source operation for an EventHub event source.

func (*EventHubEventSourceCreateOrUpdateParameters) GetEventSourceCreateOrUpdateParameters

func (e *EventHubEventSourceCreateOrUpdateParameters) GetEventSourceCreateOrUpdateParameters() *EventSourceCreateOrUpdateParameters

GetEventSourceCreateOrUpdateParameters implements the EventSourceCreateOrUpdateParametersClassification interface for type EventHubEventSourceCreateOrUpdateParameters.

func (EventHubEventSourceCreateOrUpdateParameters) MarshalJSON

MarshalJSON implements the json.Marshaller interface for type EventHubEventSourceCreateOrUpdateParameters.

func (*EventHubEventSourceCreateOrUpdateParameters) UnmarshalJSON

func (e *EventHubEventSourceCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventHubEventSourceCreateOrUpdateParameters.

type EventHubEventSourceCreationProperties

type EventHubEventSourceCreationProperties struct {
	// REQUIRED; The name of the event hub's consumer group that holds the partitions from which events will be read.
	ConsumerGroupName *string

	// REQUIRED; The name of the event hub.
	EventHubName *string

	// REQUIRED; The resource id of the event source in Azure Resource Manager.
	EventSourceResourceID *string

	// REQUIRED; The name of the SAS key that grants the Time Series Insights service access to the event hub. The shared access
	// policies for this key must grant 'Listen' permissions to the event hub.
	KeyName *string

	// REQUIRED; The name of the service bus that contains the event hub.
	ServiceBusNamespace *string

	// REQUIRED; The value of the shared access key that grants the Time Series Insights service read access to the event hub.
	// This property is not shown in event source responses.
	SharedAccessKey *string

	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

EventHubEventSourceCreationProperties - Properties of the EventHub event source that are required on create or update requests.

func (EventHubEventSourceCreationProperties) MarshalJSON

func (e EventHubEventSourceCreationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventHubEventSourceCreationProperties.

func (*EventHubEventSourceCreationProperties) UnmarshalJSON

func (e *EventHubEventSourceCreationProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventHubEventSourceCreationProperties.

type EventHubEventSourceMutableProperties

type EventHubEventSourceMutableProperties struct {
	// The value of the shared access key that grants the Time Series Insights service read access to the event hub. This property
	// is not shown in event source responses.
	SharedAccessKey *string

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string
}

EventHubEventSourceMutableProperties - An object that represents a set of mutable EventHub event source resource properties.

func (EventHubEventSourceMutableProperties) MarshalJSON added in v1.1.0

func (e EventHubEventSourceMutableProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventHubEventSourceMutableProperties.

func (*EventHubEventSourceMutableProperties) UnmarshalJSON added in v1.1.0

func (e *EventHubEventSourceMutableProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventHubEventSourceMutableProperties.

type EventHubEventSourceResource

type EventHubEventSourceResource struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceResourceKind

	// REQUIRED; Resource location
	Location *string

	// REQUIRED; Properties of the EventHub event source resource.
	Properties *EventHubEventSourceResourceProperties

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

EventHubEventSourceResource - An event source that receives its data from an Azure EventHub.

func (*EventHubEventSourceResource) GetEventSourceResource

func (e *EventHubEventSourceResource) GetEventSourceResource() *EventSourceResource

GetEventSourceResource implements the EventSourceResourceClassification interface for type EventHubEventSourceResource.

func (EventHubEventSourceResource) MarshalJSON added in v1.1.0

func (e EventHubEventSourceResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventHubEventSourceResource.

func (*EventHubEventSourceResource) UnmarshalJSON

func (e *EventHubEventSourceResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventHubEventSourceResource.

type EventHubEventSourceResourceProperties

type EventHubEventSourceResourceProperties struct {
	// REQUIRED; The name of the event hub's consumer group that holds the partitions from which events will be read.
	ConsumerGroupName *string

	// REQUIRED; The name of the event hub.
	EventHubName *string

	// REQUIRED; The resource id of the event source in Azure Resource Manager.
	EventSourceResourceID *string

	// REQUIRED; The name of the SAS key that grants the Time Series Insights service access to the event hub. The shared access
	// policies for this key must grant 'Listen' permissions to the event hub.
	KeyName *string

	// REQUIRED; The name of the service bus that contains the event hub.
	ServiceBusNamespace *string

	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

EventHubEventSourceResourceProperties - Properties of the EventHub event source resource.

func (EventHubEventSourceResourceProperties) MarshalJSON

func (e EventHubEventSourceResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventHubEventSourceResourceProperties.

func (*EventHubEventSourceResourceProperties) UnmarshalJSON

func (e *EventHubEventSourceResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventHubEventSourceResourceProperties.

type EventHubEventSourceUpdateParameters

type EventHubEventSourceUpdateParameters struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceKind

	// Properties of the EventHub event source.
	Properties *EventHubEventSourceMutableProperties

	// Key-value pairs of additional properties for the event source.
	Tags map[string]*string
}

EventHubEventSourceUpdateParameters - Parameters supplied to the Update Event Source operation to update an EventHub event source.

func (*EventHubEventSourceUpdateParameters) GetEventSourceUpdateParameters

func (e *EventHubEventSourceUpdateParameters) GetEventSourceUpdateParameters() *EventSourceUpdateParameters

GetEventSourceUpdateParameters implements the EventSourceUpdateParametersClassification interface for type EventHubEventSourceUpdateParameters.

func (EventHubEventSourceUpdateParameters) MarshalJSON

func (e EventHubEventSourceUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventHubEventSourceUpdateParameters.

func (*EventHubEventSourceUpdateParameters) UnmarshalJSON

func (e *EventHubEventSourceUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventHubEventSourceUpdateParameters.

type EventSourceCommonProperties

type EventSourceCommonProperties struct {
	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

EventSourceCommonProperties - Properties of the event source.

func (EventSourceCommonProperties) MarshalJSON

func (e EventSourceCommonProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventSourceCommonProperties.

func (*EventSourceCommonProperties) UnmarshalJSON

func (e *EventSourceCommonProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourceCommonProperties.

type EventSourceCreateOrUpdateParameters

type EventSourceCreateOrUpdateParameters struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceKind

	// REQUIRED; The location of the resource.
	Location *string

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

EventSourceCreateOrUpdateParameters - Parameters supplied to the Create or Update Event Source operation.

func (*EventSourceCreateOrUpdateParameters) GetEventSourceCreateOrUpdateParameters

func (e *EventSourceCreateOrUpdateParameters) GetEventSourceCreateOrUpdateParameters() *EventSourceCreateOrUpdateParameters

GetEventSourceCreateOrUpdateParameters implements the EventSourceCreateOrUpdateParametersClassification interface for type EventSourceCreateOrUpdateParameters.

func (EventSourceCreateOrUpdateParameters) MarshalJSON

func (e EventSourceCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventSourceCreateOrUpdateParameters.

func (*EventSourceCreateOrUpdateParameters) UnmarshalJSON added in v1.1.0

func (e *EventSourceCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourceCreateOrUpdateParameters.

type EventSourceCreateOrUpdateParametersClassification

type EventSourceCreateOrUpdateParametersClassification interface {
	// GetEventSourceCreateOrUpdateParameters returns the EventSourceCreateOrUpdateParameters content of the underlying type.
	GetEventSourceCreateOrUpdateParameters() *EventSourceCreateOrUpdateParameters
}

EventSourceCreateOrUpdateParametersClassification provides polymorphic access to related types. Call the interface's GetEventSourceCreateOrUpdateParameters() method to access the common type. Use a type switch to determine the concrete type. The possible types are: - *EventHubEventSourceCreateOrUpdateParameters, *EventSourceCreateOrUpdateParameters, *IoTHubEventSourceCreateOrUpdateParameters

type EventSourceKind

type EventSourceKind string

EventSourceKind - The kind of the event source.

const (
	EventSourceKindMicrosoftEventHub EventSourceKind = "Microsoft.EventHub"
	EventSourceKindMicrosoftIoTHub   EventSourceKind = "Microsoft.IoTHub"
)

func PossibleEventSourceKindValues

func PossibleEventSourceKindValues() []EventSourceKind

PossibleEventSourceKindValues returns the possible values for the EventSourceKind const type.

type EventSourceListResponse

type EventSourceListResponse struct {
	// Result of the List EventSources operation.
	Value []EventSourceResourceClassification
}

EventSourceListResponse - The response of the List EventSources operation.

func (EventSourceListResponse) MarshalJSON added in v1.1.0

func (e EventSourceListResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventSourceListResponse.

func (*EventSourceListResponse) UnmarshalJSON

func (e *EventSourceListResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourceListResponse.

type EventSourceMutableProperties

type EventSourceMutableProperties struct {
	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string
}

EventSourceMutableProperties - An object that represents a set of mutable event source resource properties.

func (EventSourceMutableProperties) MarshalJSON added in v1.1.0

func (e EventSourceMutableProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventSourceMutableProperties.

func (*EventSourceMutableProperties) UnmarshalJSON added in v1.1.0

func (e *EventSourceMutableProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourceMutableProperties.

type EventSourceResource

type EventSourceResource struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceResourceKind

	// REQUIRED; Resource location
	Location *string

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

EventSourceResource - An environment receives data from one or more event sources. Each event source has associated connection info that allows the Time Series Insights ingress pipeline to connect to and pull data from the event source

func (*EventSourceResource) GetEventSourceResource

func (e *EventSourceResource) GetEventSourceResource() *EventSourceResource

GetEventSourceResource implements the EventSourceResourceClassification interface for type EventSourceResource.

func (EventSourceResource) MarshalJSON added in v1.1.0

func (e EventSourceResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventSourceResource.

func (*EventSourceResource) UnmarshalJSON added in v1.1.0

func (e *EventSourceResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourceResource.

type EventSourceResourceClassification

type EventSourceResourceClassification interface {
	// GetEventSourceResource returns the EventSourceResource content of the underlying type.
	GetEventSourceResource() *EventSourceResource
}

EventSourceResourceClassification provides polymorphic access to related types. Call the interface's GetEventSourceResource() method to access the common type. Use a type switch to determine the concrete type. The possible types are: - *EventHubEventSourceResource, *EventSourceResource, *IoTHubEventSourceResource

type EventSourceResourceKind

type EventSourceResourceKind string

EventSourceResourceKind - The kind of the event source.

const (
	EventSourceResourceKindMicrosoftEventHub EventSourceResourceKind = "Microsoft.EventHub"
	EventSourceResourceKindMicrosoftIoTHub   EventSourceResourceKind = "Microsoft.IoTHub"
)

func PossibleEventSourceResourceKindValues

func PossibleEventSourceResourceKindValues() []EventSourceResourceKind

PossibleEventSourceResourceKindValues returns the possible values for the EventSourceResourceKind const type.

type EventSourceUpdateParameters

type EventSourceUpdateParameters struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceKind

	// Key-value pairs of additional properties for the event source.
	Tags map[string]*string
}

EventSourceUpdateParameters - Parameters supplied to the Update Event Source operation.

func (*EventSourceUpdateParameters) GetEventSourceUpdateParameters

func (e *EventSourceUpdateParameters) GetEventSourceUpdateParameters() *EventSourceUpdateParameters

GetEventSourceUpdateParameters implements the EventSourceUpdateParametersClassification interface for type EventSourceUpdateParameters.

func (EventSourceUpdateParameters) MarshalJSON

func (e EventSourceUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventSourceUpdateParameters.

func (*EventSourceUpdateParameters) UnmarshalJSON added in v1.1.0

func (e *EventSourceUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourceUpdateParameters.

type EventSourceUpdateParametersClassification

type EventSourceUpdateParametersClassification interface {
	// GetEventSourceUpdateParameters returns the EventSourceUpdateParameters content of the underlying type.
	GetEventSourceUpdateParameters() *EventSourceUpdateParameters
}

EventSourceUpdateParametersClassification provides polymorphic access to related types. Call the interface's GetEventSourceUpdateParameters() method to access the common type. Use a type switch to determine the concrete type. The possible types are: - *EventHubEventSourceUpdateParameters, *EventSourceUpdateParameters, *IoTHubEventSourceUpdateParameters

type EventSourcesClient

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

EventSourcesClient contains the methods for the EventSources group. Don't use this type directly, use NewEventSourcesClient() instead.

func NewEventSourcesClient

func NewEventSourcesClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*EventSourcesClient, error)

NewEventSourcesClient creates a new instance of EventSourcesClient with the specified values.

  • subscriptionID - Azure Subscription ID.
  • credential - used to authorize requests. Usually a credential from azidentity.
  • options - pass nil to accept the default values.

func (*EventSourcesClient) CreateOrUpdate

func (client *EventSourcesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, environmentName string, eventSourceName string, parameters EventSourceCreateOrUpdateParametersClassification, options *EventSourcesClientCreateOrUpdateOptions) (EventSourcesClientCreateOrUpdateResponse, error)

CreateOrUpdate - Create or update an event source under the specified environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • eventSourceName - Name of the event source.
  • parameters - Parameters for creating an event source resource.
  • options - EventSourcesClientCreateOrUpdateOptions contains the optional parameters for the EventSourcesClient.CreateOrUpdate method.
Example (CreateEventHubEventSource)

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EventSourcesCreateEventHub.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEventSourcesClient().CreateOrUpdate(ctx, "rg1", "env1", "es1", &armtimeseriesinsights.EventHubEventSourceCreateOrUpdateParameters{
		Location: to.Ptr("West US"),
		Kind:     to.Ptr(armtimeseriesinsights.EventSourceKindMicrosoftEventHub),
		Properties: &armtimeseriesinsights.EventHubEventSourceCreationProperties{
			IngressStartAt: &armtimeseriesinsights.IngressStartAtProperties{
				Type: to.Ptr(armtimeseriesinsights.IngressStartAtTypeEarliestAvailable),
			},
			LocalTimestamp: &armtimeseriesinsights.LocalTimestamp{
				Format: to.Ptr(armtimeseriesinsights.LocalTimestampFormat("TimeSpan")),
				TimeZoneOffset: &armtimeseriesinsights.LocalTimestampTimeZoneOffset{
					PropertyName: to.Ptr("someEventPropertyName"),
				},
			},
			TimestampPropertyName: to.Ptr("someTimestampProperty"),
			EventSourceResourceID: to.Ptr("somePathInArm"),
			ConsumerGroupName:     to.Ptr("cgn"),
			EventHubName:          to.Ptr("ehn"),
			KeyName:               to.Ptr("managementKey"),
			ServiceBusNamespace:   to.Ptr("sbn"),
			SharedAccessKey:       to.Ptr("someSecretvalue"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armtimeseriesinsights.EventSourcesClientCreateOrUpdateResponse{
	// 	                            EventSourceResourceClassification: &armtimeseriesinsights.EventHubEventSourceResource{
	// 		Name: to.Ptr("es1"),
	// 		Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/EventSources"),
	// 		ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/eventSources/es1"),
	// 		Location: to.Ptr("West US"),
	// 		Tags: map[string]*string{
	// 		},
	// 		Kind: to.Ptr(armtimeseriesinsights.EventSourceResourceKindMicrosoftEventHub),
	// 		Properties: &armtimeseriesinsights.EventHubEventSourceResourceProperties{
	// 			CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 			ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			IngressStartAt: &armtimeseriesinsights.IngressStartAtProperties{
	// 				Type: to.Ptr(armtimeseriesinsights.IngressStartAtTypeEarliestAvailable),
	// 			},
	// 			LocalTimestamp: &armtimeseriesinsights.LocalTimestamp{
	// 				Format: to.Ptr(armtimeseriesinsights.LocalTimestampFormat("TimeSpan")),
	// 				TimeZoneOffset: &armtimeseriesinsights.LocalTimestampTimeZoneOffset{
	// 					PropertyName: to.Ptr("someEventPropertyName"),
	// 				},
	// 			},
	// 			EventSourceResourceID: to.Ptr("somePathInArm"),
	// 			ConsumerGroupName: to.Ptr("cgn"),
	// 			EventHubName: to.Ptr("ehn"),
	// 			KeyName: to.Ptr("managementKey"),
	// 			ServiceBusNamespace: to.Ptr("sbn"),
	// 		},
	// 	},
	// 	                        }
}
Output:

Example (EventSourcesCreateEventHubWithCustomEnquedTime)

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EventSourcesCreateEventHubWithCustomEnquedTime.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEventSourcesClient().CreateOrUpdate(ctx, "rg1", "env1", "es1", &armtimeseriesinsights.EventHubEventSourceCreateOrUpdateParameters{
		Location: to.Ptr("West US"),
		Kind:     to.Ptr(armtimeseriesinsights.EventSourceKindMicrosoftEventHub),
		Properties: &armtimeseriesinsights.EventHubEventSourceCreationProperties{
			IngressStartAt: &armtimeseriesinsights.IngressStartAtProperties{
				Type: to.Ptr(armtimeseriesinsights.IngressStartAtTypeCustomEnqueuedTime),
				Time: to.Ptr("2017-04-01T19:20:33.2288820Z"),
			},
			TimestampPropertyName: to.Ptr("someTimestampProperty"),
			EventSourceResourceID: to.Ptr("somePathInArm"),
			ConsumerGroupName:     to.Ptr("cgn"),
			EventHubName:          to.Ptr("ehn"),
			KeyName:               to.Ptr("managementKey"),
			ServiceBusNamespace:   to.Ptr("sbn"),
			SharedAccessKey:       to.Ptr("someSecretvalue"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armtimeseriesinsights.EventSourcesClientCreateOrUpdateResponse{
	// 	                            EventSourceResourceClassification: &armtimeseriesinsights.EventHubEventSourceResource{
	// 		Name: to.Ptr("es1"),
	// 		Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/EventSources"),
	// 		ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/eventSources/es1"),
	// 		Location: to.Ptr("West US"),
	// 		Tags: map[string]*string{
	// 		},
	// 		Kind: to.Ptr(armtimeseriesinsights.EventSourceResourceKindMicrosoftEventHub),
	// 		Properties: &armtimeseriesinsights.EventHubEventSourceResourceProperties{
	// 			CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 			ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			IngressStartAt: &armtimeseriesinsights.IngressStartAtProperties{
	// 				Type: to.Ptr(armtimeseriesinsights.IngressStartAtTypeCustomEnqueuedTime),
	// 				Time: to.Ptr("2017-04-01T19:20:33.2288820Z"),
	// 			},
	// 			EventSourceResourceID: to.Ptr("somePathInArm"),
	// 			ConsumerGroupName: to.Ptr("cgn"),
	// 			EventHubName: to.Ptr("ehn"),
	// 			KeyName: to.Ptr("managementKey"),
	// 			ServiceBusNamespace: to.Ptr("sbn"),
	// 		},
	// 	},
	// 	                        }
}
Output:

func (*EventSourcesClient) Delete

func (client *EventSourcesClient) Delete(ctx context.Context, resourceGroupName string, environmentName string, eventSourceName string, options *EventSourcesClientDeleteOptions) (EventSourcesClientDeleteResponse, error)

Delete - Deletes the event source with the specified name in the specified subscription, resource group, and environment If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • eventSourceName - The name of the Time Series Insights event source associated with the specified environment.
  • options - EventSourcesClientDeleteOptions contains the optional parameters for the EventSourcesClient.Delete method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EventSourcesDelete.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	_, err = clientFactory.NewEventSourcesClient().Delete(ctx, "rg1", "env1", "es1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
}
Output:

func (*EventSourcesClient) Get

func (client *EventSourcesClient) Get(ctx context.Context, resourceGroupName string, environmentName string, eventSourceName string, options *EventSourcesClientGetOptions) (EventSourcesClientGetResponse, error)

Get - Gets the event source with the specified name in the specified environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • eventSourceName - The name of the Time Series Insights event source associated with the specified environment.
  • options - EventSourcesClientGetOptions contains the optional parameters for the EventSourcesClient.Get method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EventSourcesGetEventHub.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEventSourcesClient().Get(ctx, "rg1", "env1", "es1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armtimeseriesinsights.EventSourcesClientGetResponse{
	// 	                            EventSourceResourceClassification: &armtimeseriesinsights.EventHubEventSourceResource{
	// 		Name: to.Ptr("es1"),
	// 		Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/EventSources"),
	// 		ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/eventSources/es1"),
	// 		Location: to.Ptr("West US"),
	// 		Tags: map[string]*string{
	// 		},
	// 		Kind: to.Ptr(armtimeseriesinsights.EventSourceResourceKindMicrosoftEventHub),
	// 		Properties: &armtimeseriesinsights.EventHubEventSourceResourceProperties{
	// 			CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 			ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			IngressStartAt: &armtimeseriesinsights.IngressStartAtProperties{
	// 				Type: to.Ptr(armtimeseriesinsights.IngressStartAtTypeEarliestAvailable),
	// 			},
	// 			LocalTimestamp: &armtimeseriesinsights.LocalTimestamp{
	// 				Format: to.Ptr(armtimeseriesinsights.LocalTimestampFormat("TimeSpan")),
	// 				TimeZoneOffset: &armtimeseriesinsights.LocalTimestampTimeZoneOffset{
	// 					PropertyName: to.Ptr("someEventPropertyName"),
	// 				},
	// 			},
	// 			EventSourceResourceID: to.Ptr("somePathInArm"),
	// 			ConsumerGroupName: to.Ptr("cgn"),
	// 			EventHubName: to.Ptr("ehn"),
	// 			KeyName: to.Ptr("managementKey"),
	// 			ServiceBusNamespace: to.Ptr("sbn"),
	// 		},
	// 	},
	// 	                        }
}
Output:

func (*EventSourcesClient) ListByEnvironment

func (client *EventSourcesClient) ListByEnvironment(ctx context.Context, resourceGroupName string, environmentName string, options *EventSourcesClientListByEnvironmentOptions) (EventSourcesClientListByEnvironmentResponse, error)

ListByEnvironment - Lists all the available event sources associated with the subscription and within the specified resource group and environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • options - EventSourcesClientListByEnvironmentOptions contains the optional parameters for the EventSourcesClient.ListByEnvironment method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EventSourcesListByEnvironment.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEventSourcesClient().ListByEnvironment(ctx, "rg1", "env1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.EventSourceListResponse = armtimeseriesinsights.EventSourceListResponse{
	// 	Value: []armtimeseriesinsights.EventSourceResourceClassification{
	// 		&armtimeseriesinsights.EventHubEventSourceResource{
	// 			Name: to.Ptr("es1"),
	// 			Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/EventSources"),
	// 			ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/eventSources/es1"),
	// 			Location: to.Ptr("West US"),
	// 			Tags: map[string]*string{
	// 			},
	// 			Kind: to.Ptr(armtimeseriesinsights.EventSourceResourceKindMicrosoftEventHub),
	// 			Properties: &armtimeseriesinsights.EventHubEventSourceResourceProperties{
	// 				CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 				ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 				IngressStartAt: &armtimeseriesinsights.IngressStartAtProperties{
	// 					Type: to.Ptr(armtimeseriesinsights.IngressStartAtTypeEarliestAvailable),
	// 				},
	// 				LocalTimestamp: &armtimeseriesinsights.LocalTimestamp{
	// 					Format: to.Ptr(armtimeseriesinsights.LocalTimestampFormat("TimeSpan")),
	// 					TimeZoneOffset: &armtimeseriesinsights.LocalTimestampTimeZoneOffset{
	// 						PropertyName: to.Ptr("someEventPropertyName"),
	// 					},
	// 				},
	// 				EventSourceResourceID: to.Ptr("somePathInArm"),
	// 				ConsumerGroupName: to.Ptr("cgn"),
	// 				EventHubName: to.Ptr("ehn"),
	// 				KeyName: to.Ptr("managementKey"),
	// 				ServiceBusNamespace: to.Ptr("sbn"),
	// 			},
	// 	}},
	// }
}
Output:

func (*EventSourcesClient) Update

func (client *EventSourcesClient) Update(ctx context.Context, resourceGroupName string, environmentName string, eventSourceName string, eventSourceUpdateParameters EventSourceUpdateParametersClassification, options *EventSourcesClientUpdateOptions) (EventSourcesClientUpdateResponse, error)

Update - Updates the event source with the specified name in the specified subscription, resource group, and environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • eventSourceName - The name of the Time Series Insights event source associated with the specified environment.
  • eventSourceUpdateParameters - Request object that contains the updated information for the event source.
  • options - EventSourcesClientUpdateOptions contains the optional parameters for the EventSourcesClient.Update method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/EventSourcesPatchTags.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewEventSourcesClient().Update(ctx, "rg1", "env1", "es1", &armtimeseriesinsights.EventSourceUpdateParameters{
		Tags: map[string]*string{
			"someKey": to.Ptr("someValue"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armtimeseriesinsights.EventSourcesClientUpdateResponse{
	// 	                            EventSourceResourceClassification: &armtimeseriesinsights.EventHubEventSourceResource{
	// 		Name: to.Ptr("es1"),
	// 		Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/EventSources"),
	// 		ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/eventSources/es1"),
	// 		Location: to.Ptr("West US"),
	// 		Tags: map[string]*string{
	// 			"someKey": to.Ptr("someValue"),
	// 		},
	// 		Kind: to.Ptr(armtimeseriesinsights.EventSourceResourceKindMicrosoftEventHub),
	// 		Properties: &armtimeseriesinsights.EventHubEventSourceResourceProperties{
	// 			CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 			ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			IngressStartAt: &armtimeseriesinsights.IngressStartAtProperties{
	// 				Type: to.Ptr(armtimeseriesinsights.IngressStartAtTypeEarliestAvailable),
	// 			},
	// 			LocalTimestamp: &armtimeseriesinsights.LocalTimestamp{
	// 				Format: to.Ptr(armtimeseriesinsights.LocalTimestampFormat("TimeSpan")),
	// 				TimeZoneOffset: &armtimeseriesinsights.LocalTimestampTimeZoneOffset{
	// 					PropertyName: to.Ptr("someEventPropertyName"),
	// 				},
	// 			},
	// 			TimestampPropertyName: to.Ptr("someOtherTimestampProperty"),
	// 			EventSourceResourceID: to.Ptr("somePathInArm"),
	// 			ConsumerGroupName: to.Ptr("cgn"),
	// 			EventHubName: to.Ptr("ehn"),
	// 			KeyName: to.Ptr("managementKey"),
	// 			ServiceBusNamespace: to.Ptr("sbn"),
	// 		},
	// 	},
	// 	                        }
}
Output:

type EventSourcesClientCreateOrUpdateOptions

type EventSourcesClientCreateOrUpdateOptions struct {
}

EventSourcesClientCreateOrUpdateOptions contains the optional parameters for the EventSourcesClient.CreateOrUpdate method.

type EventSourcesClientCreateOrUpdateResponse

type EventSourcesClientCreateOrUpdateResponse struct {
	// An environment receives data from one or more event sources. Each event source has associated connection info that allows
	// the Time Series Insights ingress pipeline to connect to and pull data from the event source
	EventSourceResourceClassification
}

EventSourcesClientCreateOrUpdateResponse contains the response from method EventSourcesClient.CreateOrUpdate.

func (*EventSourcesClientCreateOrUpdateResponse) UnmarshalJSON

func (e *EventSourcesClientCreateOrUpdateResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourcesClientCreateOrUpdateResponse.

type EventSourcesClientDeleteOptions

type EventSourcesClientDeleteOptions struct {
}

EventSourcesClientDeleteOptions contains the optional parameters for the EventSourcesClient.Delete method.

type EventSourcesClientDeleteResponse

type EventSourcesClientDeleteResponse struct {
}

EventSourcesClientDeleteResponse contains the response from method EventSourcesClient.Delete.

type EventSourcesClientGetOptions

type EventSourcesClientGetOptions struct {
}

EventSourcesClientGetOptions contains the optional parameters for the EventSourcesClient.Get method.

type EventSourcesClientGetResponse

type EventSourcesClientGetResponse struct {
	// An environment receives data from one or more event sources. Each event source has associated connection info that allows
	// the Time Series Insights ingress pipeline to connect to and pull data from the event source
	EventSourceResourceClassification
}

EventSourcesClientGetResponse contains the response from method EventSourcesClient.Get.

func (*EventSourcesClientGetResponse) UnmarshalJSON

func (e *EventSourcesClientGetResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourcesClientGetResponse.

type EventSourcesClientListByEnvironmentOptions

type EventSourcesClientListByEnvironmentOptions struct {
}

EventSourcesClientListByEnvironmentOptions contains the optional parameters for the EventSourcesClient.ListByEnvironment method.

type EventSourcesClientListByEnvironmentResponse

type EventSourcesClientListByEnvironmentResponse struct {
	// The response of the List EventSources operation.
	EventSourceListResponse
}

EventSourcesClientListByEnvironmentResponse contains the response from method EventSourcesClient.ListByEnvironment.

type EventSourcesClientUpdateOptions

type EventSourcesClientUpdateOptions struct {
}

EventSourcesClientUpdateOptions contains the optional parameters for the EventSourcesClient.Update method.

type EventSourcesClientUpdateResponse

type EventSourcesClientUpdateResponse struct {
	// An environment receives data from one or more event sources. Each event source has associated connection info that allows
	// the Time Series Insights ingress pipeline to connect to and pull data from the event source
	EventSourceResourceClassification
}

EventSourcesClientUpdateResponse contains the response from method EventSourcesClient.Update.

func (*EventSourcesClientUpdateResponse) UnmarshalJSON

func (e *EventSourcesClientUpdateResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventSourcesClientUpdateResponse.

type Gen1EnvironmentCreateOrUpdateParameters

type Gen1EnvironmentCreateOrUpdateParameters struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentKind

	// REQUIRED; The location of the resource.
	Location *string

	// REQUIRED; Properties used to create a Gen1 environment.
	Properties *Gen1EnvironmentCreationProperties

	// REQUIRED; The sku determines the type of environment, either Gen1 (S1 or S2) or Gen2 (L1). For Gen1 environments the sku
	// determines the capacity of the environment, the ingress rate, and the billing rate.
	SKU *SKU

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

Gen1EnvironmentCreateOrUpdateParameters - Parameters supplied to the Create or Update Environment operation for a Gen1 environment.

func (*Gen1EnvironmentCreateOrUpdateParameters) GetEnvironmentCreateOrUpdateParameters

func (g *Gen1EnvironmentCreateOrUpdateParameters) GetEnvironmentCreateOrUpdateParameters() *EnvironmentCreateOrUpdateParameters

GetEnvironmentCreateOrUpdateParameters implements the EnvironmentCreateOrUpdateParametersClassification interface for type Gen1EnvironmentCreateOrUpdateParameters.

func (Gen1EnvironmentCreateOrUpdateParameters) MarshalJSON

func (g Gen1EnvironmentCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen1EnvironmentCreateOrUpdateParameters.

func (*Gen1EnvironmentCreateOrUpdateParameters) UnmarshalJSON

func (g *Gen1EnvironmentCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen1EnvironmentCreateOrUpdateParameters.

type Gen1EnvironmentCreationProperties

type Gen1EnvironmentCreationProperties struct {
	// REQUIRED; ISO8601 timespan specifying the minimum number of days the environment's events will be available for query.
	DataRetentionTime *string

	// The list of event properties which will be used to partition data in the environment. Currently, only a single partition
	// key property is supported.
	PartitionKeyProperties []*TimeSeriesIDProperty

	// The behavior the Time Series Insights service should take when the environment's capacity has been exceeded. If "PauseIngress"
	// is specified, new events will not be read from the event source. If
	// "PurgeOldData" is specified, new events will continue to be read and old events will be deleted from the environment. The
	// default behavior is PurgeOldData.
	StorageLimitExceededBehavior *StorageLimitExceededBehavior
}

Gen1EnvironmentCreationProperties - Properties used to create a Gen1 environment.

func (Gen1EnvironmentCreationProperties) MarshalJSON

func (g Gen1EnvironmentCreationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen1EnvironmentCreationProperties.

func (*Gen1EnvironmentCreationProperties) UnmarshalJSON added in v1.1.0

func (g *Gen1EnvironmentCreationProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen1EnvironmentCreationProperties.

type Gen1EnvironmentMutableProperties

type Gen1EnvironmentMutableProperties struct {
	// ISO8601 timespan specifying the minimum number of days the environment's events will be available for query.
	DataRetentionTime *string

	// The behavior the Time Series Insights service should take when the environment's capacity has been exceeded. If "PauseIngress"
	// is specified, new events will not be read from the event source. If
	// "PurgeOldData" is specified, new events will continue to be read and old events will be deleted from the environment. The
	// default behavior is PurgeOldData.
	StorageLimitExceededBehavior *StorageLimitExceededBehavior
}

Gen1EnvironmentMutableProperties - An object that represents a set of mutable Gen1 environment resource properties.

func (Gen1EnvironmentMutableProperties) MarshalJSON added in v1.1.0

func (g Gen1EnvironmentMutableProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen1EnvironmentMutableProperties.

func (*Gen1EnvironmentMutableProperties) UnmarshalJSON added in v1.1.0

func (g *Gen1EnvironmentMutableProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen1EnvironmentMutableProperties.

type Gen1EnvironmentResource

type Gen1EnvironmentResource struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentResourceKind

	// REQUIRED; Resource location
	Location *string

	// REQUIRED; Properties of the Gen1 environment.
	Properties *Gen1EnvironmentResourceProperties

	// REQUIRED; The sku determines the type of environment, either Gen1 (S1 or S2) or Gen2 (L1). For Gen1 environments the sku
	// determines the capacity of the environment, the ingress rate, and the billing rate.
	SKU *SKU

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

Gen1EnvironmentResource - An environment is a set of time-series data available for query, and is the top level Azure Time Series Insights resource. Gen1 environments have data retention limits.

func (*Gen1EnvironmentResource) GetEnvironmentResource

func (g *Gen1EnvironmentResource) GetEnvironmentResource() *EnvironmentResource

GetEnvironmentResource implements the EnvironmentResourceClassification interface for type Gen1EnvironmentResource.

func (Gen1EnvironmentResource) MarshalJSON added in v1.1.0

func (g Gen1EnvironmentResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen1EnvironmentResource.

func (*Gen1EnvironmentResource) UnmarshalJSON

func (g *Gen1EnvironmentResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen1EnvironmentResource.

type Gen1EnvironmentResourceProperties

type Gen1EnvironmentResourceProperties struct {
	// REQUIRED; ISO8601 timespan specifying the minimum number of days the environment's events will be available for query.
	DataRetentionTime *string

	// The list of event properties which will be used to partition data in the environment. Currently, only a single partition
	// key property is supported.
	PartitionKeyProperties []*TimeSeriesIDProperty

	// The behavior the Time Series Insights service should take when the environment's capacity has been exceeded. If "PauseIngress"
	// is specified, new events will not be read from the event source. If
	// "PurgeOldData" is specified, new events will continue to be read and old events will be deleted from the environment. The
	// default behavior is PurgeOldData.
	StorageLimitExceededBehavior *StorageLimitExceededBehavior

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; The fully qualified domain name used to access the environment data, e.g. to query the environment's events
	// or upload reference data for the environment.
	DataAccessFqdn *string

	// READ-ONLY; An id used to access the environment data, e.g. to query the environment's events or upload reference data for
	// the environment.
	DataAccessID *string

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState

	// READ-ONLY; An object that represents the status of the environment, and its internal state in the Time Series Insights
	// service.
	Status *EnvironmentStatus
}

Gen1EnvironmentResourceProperties - Properties of the Gen1 environment.

func (Gen1EnvironmentResourceProperties) MarshalJSON

func (g Gen1EnvironmentResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen1EnvironmentResourceProperties.

func (*Gen1EnvironmentResourceProperties) UnmarshalJSON

func (g *Gen1EnvironmentResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen1EnvironmentResourceProperties.

type Gen1EnvironmentUpdateParameters

type Gen1EnvironmentUpdateParameters struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentKind

	// Properties of the Gen1 environment.
	Properties *Gen1EnvironmentMutableProperties

	// The sku of the environment.
	SKU *SKU

	// Key-value pairs of additional properties for the environment.
	Tags map[string]*string
}

Gen1EnvironmentUpdateParameters - Parameters supplied to the Update Environment operation to update a Gen1 environment.

func (*Gen1EnvironmentUpdateParameters) GetEnvironmentUpdateParameters

func (g *Gen1EnvironmentUpdateParameters) GetEnvironmentUpdateParameters() *EnvironmentUpdateParameters

GetEnvironmentUpdateParameters implements the EnvironmentUpdateParametersClassification interface for type Gen1EnvironmentUpdateParameters.

func (Gen1EnvironmentUpdateParameters) MarshalJSON

func (g Gen1EnvironmentUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen1EnvironmentUpdateParameters.

func (*Gen1EnvironmentUpdateParameters) UnmarshalJSON

func (g *Gen1EnvironmentUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen1EnvironmentUpdateParameters.

type Gen2EnvironmentCreateOrUpdateParameters

type Gen2EnvironmentCreateOrUpdateParameters struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentKind

	// REQUIRED; The location of the resource.
	Location *string

	// REQUIRED; Properties used to create a Gen2 environment.
	Properties *Gen2EnvironmentCreationProperties

	// REQUIRED; The sku determines the type of environment, either Gen1 (S1 or S2) or Gen2 (L1). For Gen1 environments the sku
	// determines the capacity of the environment, the ingress rate, and the billing rate.
	SKU *SKU

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

Gen2EnvironmentCreateOrUpdateParameters - Parameters supplied to the Create or Update Environment operation for a Gen2 environment.

func (*Gen2EnvironmentCreateOrUpdateParameters) GetEnvironmentCreateOrUpdateParameters

func (g *Gen2EnvironmentCreateOrUpdateParameters) GetEnvironmentCreateOrUpdateParameters() *EnvironmentCreateOrUpdateParameters

GetEnvironmentCreateOrUpdateParameters implements the EnvironmentCreateOrUpdateParametersClassification interface for type Gen2EnvironmentCreateOrUpdateParameters.

func (Gen2EnvironmentCreateOrUpdateParameters) MarshalJSON

func (g Gen2EnvironmentCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2EnvironmentCreateOrUpdateParameters.

func (*Gen2EnvironmentCreateOrUpdateParameters) UnmarshalJSON

func (g *Gen2EnvironmentCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2EnvironmentCreateOrUpdateParameters.

type Gen2EnvironmentCreationProperties

type Gen2EnvironmentCreationProperties struct {
	// REQUIRED; The storage configuration provides the connection details that allows the Time Series Insights service to connect
	// to the customer storage account that is used to store the environment's data.
	StorageConfiguration *Gen2StorageConfigurationInput

	// REQUIRED; The list of event properties which will be used to define the environment's time series id.
	TimeSeriesIDProperties []*TimeSeriesIDProperty

	// The warm store configuration provides the details to create a warm store cache that will retain a copy of the environment's
	// data available for faster query.
	WarmStoreConfiguration *WarmStoreConfigurationProperties
}

Gen2EnvironmentCreationProperties - Properties used to create a Gen2 environment.

func (Gen2EnvironmentCreationProperties) MarshalJSON

func (g Gen2EnvironmentCreationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2EnvironmentCreationProperties.

func (*Gen2EnvironmentCreationProperties) UnmarshalJSON added in v1.1.0

func (g *Gen2EnvironmentCreationProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2EnvironmentCreationProperties.

type Gen2EnvironmentMutableProperties

type Gen2EnvironmentMutableProperties struct {
	// The storage configuration provides the connection details that allows the Time Series Insights service to connect to the
	// customer storage account that is used to store the environment's data.
	StorageConfiguration *Gen2StorageConfigurationMutableProperties

	// The warm store configuration provides the details to create a warm store cache that will retain a copy of the environment's
	// data available for faster query.
	WarmStoreConfiguration *WarmStoreConfigurationProperties
}

Gen2EnvironmentMutableProperties - An object that represents a set of mutable Gen2 environment resource properties.

func (Gen2EnvironmentMutableProperties) MarshalJSON added in v1.1.0

func (g Gen2EnvironmentMutableProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2EnvironmentMutableProperties.

func (*Gen2EnvironmentMutableProperties) UnmarshalJSON added in v1.1.0

func (g *Gen2EnvironmentMutableProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2EnvironmentMutableProperties.

type Gen2EnvironmentResource

type Gen2EnvironmentResource struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentResourceKind

	// REQUIRED; Resource location
	Location *string

	// REQUIRED; Properties of the Gen2 environment.
	Properties *Gen2EnvironmentResourceProperties

	// REQUIRED; The sku determines the type of environment, either Gen1 (S1 or S2) or Gen2 (L1). For Gen1 environments the sku
	// determines the capacity of the environment, the ingress rate, and the billing rate.
	SKU *SKU

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

Gen2EnvironmentResource - An environment is a set of time-series data available for query, and is the top level Azure Time Series Insights resource. Gen2 environments do not have set data retention limits.

func (*Gen2EnvironmentResource) GetEnvironmentResource

func (g *Gen2EnvironmentResource) GetEnvironmentResource() *EnvironmentResource

GetEnvironmentResource implements the EnvironmentResourceClassification interface for type Gen2EnvironmentResource.

func (Gen2EnvironmentResource) MarshalJSON added in v1.1.0

func (g Gen2EnvironmentResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2EnvironmentResource.

func (*Gen2EnvironmentResource) UnmarshalJSON

func (g *Gen2EnvironmentResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2EnvironmentResource.

type Gen2EnvironmentResourceProperties

type Gen2EnvironmentResourceProperties struct {
	// REQUIRED; The storage configuration provides the connection details that allows the Time Series Insights service to connect
	// to the customer storage account that is used to store the environment's data.
	StorageConfiguration *Gen2StorageConfigurationOutput

	// REQUIRED; The list of event properties which will be used to define the environment's time series id.
	TimeSeriesIDProperties []*TimeSeriesIDProperty

	// The warm store configuration provides the details to create a warm store cache that will retain a copy of the environment's
	// data available for faster query.
	WarmStoreConfiguration *WarmStoreConfigurationProperties

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; The fully qualified domain name used to access the environment data, e.g. to query the environment's events
	// or upload reference data for the environment.
	DataAccessFqdn *string

	// READ-ONLY; An id used to access the environment data, e.g. to query the environment's events or upload reference data for
	// the environment.
	DataAccessID *string

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState

	// READ-ONLY; An object that represents the status of the environment, and its internal state in the Time Series Insights
	// service.
	Status *EnvironmentStatus
}

Gen2EnvironmentResourceProperties - Properties of the Gen2 environment.

func (Gen2EnvironmentResourceProperties) MarshalJSON

func (g Gen2EnvironmentResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2EnvironmentResourceProperties.

func (*Gen2EnvironmentResourceProperties) UnmarshalJSON

func (g *Gen2EnvironmentResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2EnvironmentResourceProperties.

type Gen2EnvironmentUpdateParameters

type Gen2EnvironmentUpdateParameters struct {
	// REQUIRED; The kind of the environment.
	Kind *EnvironmentKind

	// Properties of the Gen2 environment.
	Properties *Gen2EnvironmentMutableProperties

	// Key-value pairs of additional properties for the environment.
	Tags map[string]*string
}

Gen2EnvironmentUpdateParameters - Parameters supplied to the Update Environment operation to update a Gen2 environment.

func (*Gen2EnvironmentUpdateParameters) GetEnvironmentUpdateParameters

func (g *Gen2EnvironmentUpdateParameters) GetEnvironmentUpdateParameters() *EnvironmentUpdateParameters

GetEnvironmentUpdateParameters implements the EnvironmentUpdateParametersClassification interface for type Gen2EnvironmentUpdateParameters.

func (Gen2EnvironmentUpdateParameters) MarshalJSON

func (g Gen2EnvironmentUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2EnvironmentUpdateParameters.

func (*Gen2EnvironmentUpdateParameters) UnmarshalJSON

func (g *Gen2EnvironmentUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2EnvironmentUpdateParameters.

type Gen2StorageConfigurationInput

type Gen2StorageConfigurationInput struct {
	// REQUIRED; The name of the storage account that will hold the environment's Gen2 data.
	AccountName *string

	// REQUIRED; The value of the management key that grants the Time Series Insights service write access to the storage account.
	// This property is not shown in environment responses.
	ManagementKey *string
}

Gen2StorageConfigurationInput - The storage configuration provides the connection details that allows the Time Series Insights service to connect to the customer storage account that is used to store the environment's data.

func (Gen2StorageConfigurationInput) MarshalJSON added in v1.1.0

func (g Gen2StorageConfigurationInput) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2StorageConfigurationInput.

func (*Gen2StorageConfigurationInput) UnmarshalJSON added in v1.1.0

func (g *Gen2StorageConfigurationInput) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2StorageConfigurationInput.

type Gen2StorageConfigurationMutableProperties

type Gen2StorageConfigurationMutableProperties struct {
	// REQUIRED; The value of the management key that grants the Time Series Insights service write access to the storage account.
	// This property is not shown in environment responses.
	ManagementKey *string
}

Gen2StorageConfigurationMutableProperties - The storage configuration provides the connection details that allows the Time Series Insights service to connect to the customer storage account that is used to store the environment's data.

func (Gen2StorageConfigurationMutableProperties) MarshalJSON added in v1.1.0

MarshalJSON implements the json.Marshaller interface for type Gen2StorageConfigurationMutableProperties.

func (*Gen2StorageConfigurationMutableProperties) UnmarshalJSON added in v1.1.0

func (g *Gen2StorageConfigurationMutableProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2StorageConfigurationMutableProperties.

type Gen2StorageConfigurationOutput

type Gen2StorageConfigurationOutput struct {
	// REQUIRED; The name of the storage account that will hold the environment's Gen2 data.
	AccountName *string
}

Gen2StorageConfigurationOutput - The storage configuration provides the non-secret connection details about the customer storage account that is used to store the environment's data.

func (Gen2StorageConfigurationOutput) MarshalJSON added in v1.1.0

func (g Gen2StorageConfigurationOutput) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Gen2StorageConfigurationOutput.

func (*Gen2StorageConfigurationOutput) UnmarshalJSON added in v1.1.0

func (g *Gen2StorageConfigurationOutput) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Gen2StorageConfigurationOutput.

type IngressEnvironmentStatus

type IngressEnvironmentStatus struct {
	// This string represents the state of ingress operations on an environment. It can be "Disabled", "Ready", "Running", "Paused"
	// or "Unknown"
	State *IngressState

	// READ-ONLY; An object that contains the details about an environment's state.
	StateDetails *EnvironmentStateDetails
}

IngressEnvironmentStatus - An object that represents the status of ingress on an environment.

func (IngressEnvironmentStatus) MarshalJSON added in v1.1.0

func (i IngressEnvironmentStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IngressEnvironmentStatus.

func (*IngressEnvironmentStatus) UnmarshalJSON added in v1.1.0

func (i *IngressEnvironmentStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IngressEnvironmentStatus.

type IngressStartAtProperties

type IngressStartAtProperties struct {
	// ISO8601 UTC datetime with seconds precision (milliseconds are optional), specifying the date and time that will be the
	// starting point for Events to be consumed.
	Time *string

	// The type of the ingressStartAt, It can be "EarliestAvailable", "EventSourceCreationTime", "CustomEnqueuedTime".
	Type *IngressStartAtType
}

IngressStartAtProperties - An object that contains the details about the starting point in time to ingest events.

func (IngressStartAtProperties) MarshalJSON added in v1.1.0

func (i IngressStartAtProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IngressStartAtProperties.

func (*IngressStartAtProperties) UnmarshalJSON added in v1.1.0

func (i *IngressStartAtProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IngressStartAtProperties.

type IngressStartAtType

type IngressStartAtType string

IngressStartAtType - The type of the ingressStartAt, It can be "EarliestAvailable", "EventSourceCreationTime", "CustomEnqueuedTime".

const (
	IngressStartAtTypeCustomEnqueuedTime      IngressStartAtType = "CustomEnqueuedTime"
	IngressStartAtTypeEarliestAvailable       IngressStartAtType = "EarliestAvailable"
	IngressStartAtTypeEventSourceCreationTime IngressStartAtType = "EventSourceCreationTime"
)

func PossibleIngressStartAtTypeValues

func PossibleIngressStartAtTypeValues() []IngressStartAtType

PossibleIngressStartAtTypeValues returns the possible values for the IngressStartAtType const type.

type IngressState

type IngressState string

IngressState - This string represents the state of ingress operations on an environment. It can be "Disabled", "Ready", "Running", "Paused" or "Unknown"

const (
	IngressStateDisabled IngressState = "Disabled"
	IngressStatePaused   IngressState = "Paused"
	IngressStateReady    IngressState = "Ready"
	IngressStateRunning  IngressState = "Running"
	IngressStateUnknown  IngressState = "Unknown"
)

func PossibleIngressStateValues

func PossibleIngressStateValues() []IngressState

PossibleIngressStateValues returns the possible values for the IngressState const type.

type IoTHubEventSourceCommonProperties

type IoTHubEventSourceCommonProperties struct {
	// REQUIRED; The name of the iot hub's consumer group that holds the partitions from which events will be read.
	ConsumerGroupName *string

	// REQUIRED; The resource id of the event source in Azure Resource Manager.
	EventSourceResourceID *string

	// REQUIRED; The name of the iot hub.
	IotHubName *string

	// REQUIRED; The name of the Shared Access Policy key that grants the Time Series Insights service access to the iot hub.
	// This shared access policy key must grant 'service connect' permissions to the iot hub.
	KeyName *string

	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

IoTHubEventSourceCommonProperties - Properties of the IoTHub event source.

func (IoTHubEventSourceCommonProperties) MarshalJSON

func (i IoTHubEventSourceCommonProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IoTHubEventSourceCommonProperties.

func (*IoTHubEventSourceCommonProperties) UnmarshalJSON

func (i *IoTHubEventSourceCommonProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IoTHubEventSourceCommonProperties.

type IoTHubEventSourceCreateOrUpdateParameters

type IoTHubEventSourceCreateOrUpdateParameters struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceKind

	// REQUIRED; The location of the resource.
	Location *string

	// REQUIRED; Properties of the IoTHub event source that are required on create or update requests.
	Properties *IoTHubEventSourceCreationProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

IoTHubEventSourceCreateOrUpdateParameters - Parameters supplied to the Create or Update Event Source operation for an IoTHub event source.

func (*IoTHubEventSourceCreateOrUpdateParameters) GetEventSourceCreateOrUpdateParameters

func (i *IoTHubEventSourceCreateOrUpdateParameters) GetEventSourceCreateOrUpdateParameters() *EventSourceCreateOrUpdateParameters

GetEventSourceCreateOrUpdateParameters implements the EventSourceCreateOrUpdateParametersClassification interface for type IoTHubEventSourceCreateOrUpdateParameters.

func (IoTHubEventSourceCreateOrUpdateParameters) MarshalJSON

MarshalJSON implements the json.Marshaller interface for type IoTHubEventSourceCreateOrUpdateParameters.

func (*IoTHubEventSourceCreateOrUpdateParameters) UnmarshalJSON

func (i *IoTHubEventSourceCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IoTHubEventSourceCreateOrUpdateParameters.

type IoTHubEventSourceCreationProperties

type IoTHubEventSourceCreationProperties struct {
	// REQUIRED; The name of the iot hub's consumer group that holds the partitions from which events will be read.
	ConsumerGroupName *string

	// REQUIRED; The resource id of the event source in Azure Resource Manager.
	EventSourceResourceID *string

	// REQUIRED; The name of the iot hub.
	IotHubName *string

	// REQUIRED; The name of the Shared Access Policy key that grants the Time Series Insights service access to the iot hub.
	// This shared access policy key must grant 'service connect' permissions to the iot hub.
	KeyName *string

	// REQUIRED; The value of the Shared Access Policy key that grants the Time Series Insights service read access to the iot
	// hub. This property is not shown in event source responses.
	SharedAccessKey *string

	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

IoTHubEventSourceCreationProperties - Properties of the IoTHub event source that are required on create or update requests.

func (IoTHubEventSourceCreationProperties) MarshalJSON

func (i IoTHubEventSourceCreationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IoTHubEventSourceCreationProperties.

func (*IoTHubEventSourceCreationProperties) UnmarshalJSON

func (i *IoTHubEventSourceCreationProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IoTHubEventSourceCreationProperties.

type IoTHubEventSourceMutableProperties

type IoTHubEventSourceMutableProperties struct {
	// The value of the shared access key that grants the Time Series Insights service read access to the iot hub. This property
	// is not shown in event source responses.
	SharedAccessKey *string

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string
}

IoTHubEventSourceMutableProperties - An object that represents a set of mutable IoTHub event source resource properties.

func (IoTHubEventSourceMutableProperties) MarshalJSON added in v1.1.0

func (i IoTHubEventSourceMutableProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IoTHubEventSourceMutableProperties.

func (*IoTHubEventSourceMutableProperties) UnmarshalJSON added in v1.1.0

func (i *IoTHubEventSourceMutableProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IoTHubEventSourceMutableProperties.

type IoTHubEventSourceResource

type IoTHubEventSourceResource struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceResourceKind

	// REQUIRED; Resource location
	Location *string

	// REQUIRED; Properties of the IoTHub event source resource.
	Properties *IoTHubEventSourceResourceProperties

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

IoTHubEventSourceResource - An event source that receives its data from an Azure IoTHub.

func (*IoTHubEventSourceResource) GetEventSourceResource

func (i *IoTHubEventSourceResource) GetEventSourceResource() *EventSourceResource

GetEventSourceResource implements the EventSourceResourceClassification interface for type IoTHubEventSourceResource.

func (IoTHubEventSourceResource) MarshalJSON added in v1.1.0

func (i IoTHubEventSourceResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IoTHubEventSourceResource.

func (*IoTHubEventSourceResource) UnmarshalJSON

func (i *IoTHubEventSourceResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IoTHubEventSourceResource.

type IoTHubEventSourceResourceProperties

type IoTHubEventSourceResourceProperties struct {
	// REQUIRED; The name of the iot hub's consumer group that holds the partitions from which events will be read.
	ConsumerGroupName *string

	// REQUIRED; The resource id of the event source in Azure Resource Manager.
	EventSourceResourceID *string

	// REQUIRED; The name of the iot hub.
	IotHubName *string

	// REQUIRED; The name of the Shared Access Policy key that grants the Time Series Insights service access to the iot hub.
	// This shared access policy key must grant 'service connect' permissions to the iot hub.
	KeyName *string

	// An object that contains the details about the starting point in time to ingest events.
	IngressStartAt *IngressStartAtProperties

	// An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used
	// and the corresponding timezone offset information. If a value isn't specified
	// for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.
	LocalTimestamp *LocalTimestamp

	// The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName,
	// or if null or empty-string is specified, the event creation time will be
	// used.
	TimestampPropertyName *string

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

IoTHubEventSourceResourceProperties - Properties of the IoTHub event source resource.

func (IoTHubEventSourceResourceProperties) MarshalJSON

func (i IoTHubEventSourceResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IoTHubEventSourceResourceProperties.

func (*IoTHubEventSourceResourceProperties) UnmarshalJSON

func (i *IoTHubEventSourceResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IoTHubEventSourceResourceProperties.

type IoTHubEventSourceUpdateParameters

type IoTHubEventSourceUpdateParameters struct {
	// REQUIRED; The kind of the event source.
	Kind *EventSourceKind

	// Properties of the IoTHub event source.
	Properties *IoTHubEventSourceMutableProperties

	// Key-value pairs of additional properties for the event source.
	Tags map[string]*string
}

IoTHubEventSourceUpdateParameters - Parameters supplied to the Update Event Source operation to update an IoTHub event source.

func (*IoTHubEventSourceUpdateParameters) GetEventSourceUpdateParameters

func (i *IoTHubEventSourceUpdateParameters) GetEventSourceUpdateParameters() *EventSourceUpdateParameters

GetEventSourceUpdateParameters implements the EventSourceUpdateParametersClassification interface for type IoTHubEventSourceUpdateParameters.

func (IoTHubEventSourceUpdateParameters) MarshalJSON

func (i IoTHubEventSourceUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type IoTHubEventSourceUpdateParameters.

func (*IoTHubEventSourceUpdateParameters) UnmarshalJSON

func (i *IoTHubEventSourceUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type IoTHubEventSourceUpdateParameters.

type LocalTimestamp

type LocalTimestamp struct {
	// An enum that represents the format of the local timestamp property that needs to be set.
	Format *LocalTimestampFormat

	// An object that represents the offset information for the local timestamp format specified. Should not be specified for
	// LocalTimestampFormat - Embedded.
	TimeZoneOffset *LocalTimestampTimeZoneOffset
}

LocalTimestamp - An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used and the corresponding timezone offset information. If a value isn't specified for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.

func (LocalTimestamp) MarshalJSON added in v1.1.0

func (l LocalTimestamp) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type LocalTimestamp.

func (*LocalTimestamp) UnmarshalJSON added in v1.1.0

func (l *LocalTimestamp) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type LocalTimestamp.

type LocalTimestampFormat

type LocalTimestampFormat string

LocalTimestampFormat - An enum that represents the format of the local timestamp property that needs to be set.

const (
	LocalTimestampFormatEmbedded LocalTimestampFormat = "Embedded"
)

func PossibleLocalTimestampFormatValues

func PossibleLocalTimestampFormatValues() []LocalTimestampFormat

PossibleLocalTimestampFormatValues returns the possible values for the LocalTimestampFormat const type.

type LocalTimestampTimeZoneOffset

type LocalTimestampTimeZoneOffset struct {
	// The event property that will be contain the offset information to calculate the local timestamp. When the LocalTimestampFormat
	// is Iana, the property name will contain the name of the column which
	// contains IANA Timezone Name (eg: Americas/Los Angeles). When LocalTimestampFormat is Timespan, it contains the name of
	// property which contains values representing the offset (eg: P1D or 1.00:00:00)
	PropertyName *string
}

LocalTimestampTimeZoneOffset - An object that represents the offset information for the local timestamp format specified. Should not be specified for LocalTimestampFormat - Embedded.

func (LocalTimestampTimeZoneOffset) MarshalJSON added in v1.1.0

func (l LocalTimestampTimeZoneOffset) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type LocalTimestampTimeZoneOffset.

func (*LocalTimestampTimeZoneOffset) UnmarshalJSON added in v1.1.0

func (l *LocalTimestampTimeZoneOffset) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type LocalTimestampTimeZoneOffset.

type LogSpecification

type LogSpecification struct {
	// Log display name.
	DisplayName *string

	// Log name.
	Name *string
}

LogSpecification - The specification of an Azure Monitoring log.

func (LogSpecification) MarshalJSON added in v1.1.0

func (l LogSpecification) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type LogSpecification.

func (*LogSpecification) UnmarshalJSON added in v1.1.0

func (l *LogSpecification) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type LogSpecification.

type MetricAvailability

type MetricAvailability struct {
	BlobDuration *string
	TimeGrain    *string
}

MetricAvailability - Retention policy of a resource metric.

func (MetricAvailability) MarshalJSON added in v1.1.0

func (m MetricAvailability) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type MetricAvailability.

func (*MetricAvailability) UnmarshalJSON added in v1.1.0

func (m *MetricAvailability) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type MetricAvailability.

type MetricSpecification

type MetricSpecification struct {
	// Aggregation type could be Average.
	AggregationType *string

	// Retention policies of a resource metric.
	Availabilities []*MetricAvailability

	// The category this metric specification belong to, could be Capacity.
	Category *string

	// Dimensions of blobs, including blob type and access tier.
	Dimensions []*Dimension

	// Display description of metric specification.
	DisplayDescription *string

	// Display name of metric specification.
	DisplayName *string

	// Name of metric specification.
	Name *string

	// Account Resource Id.
	ResourceIDDimensionNameOverride *string

	// Unit could be Bytes or Count.
	Unit *string
}

MetricSpecification - Metric specification of operation.

func (MetricSpecification) MarshalJSON added in v1.1.0

func (m MetricSpecification) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type MetricSpecification.

func (*MetricSpecification) UnmarshalJSON added in v1.1.0

func (m *MetricSpecification) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type MetricSpecification.

type Operation

type Operation struct {
	// Properties of operation, include metric specifications.
	OperationProperties *OperationProperties

	// The intended executor of the operation.
	Origin *string

	// READ-ONLY; Contains the localized display information for this particular operation / action.
	Display *OperationDisplay

	// READ-ONLY; The name of the operation being performed on this particular object.
	Name *string
}

Operation - A Time Series Insights REST API operation

func (Operation) MarshalJSON added in v1.1.0

func (o Operation) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Operation.

func (*Operation) UnmarshalJSON added in v1.1.0

func (o *Operation) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Operation.

type OperationDisplay

type OperationDisplay struct {
	// READ-ONLY; The localized friendly description for the operation.
	Description *string

	// READ-ONLY; The localized friendly name for the operation.
	Operation *string

	// READ-ONLY; The localized friendly form of the resource provider name.
	Provider *string

	// READ-ONLY; The localized friendly form of the resource type related to this action/operation.
	Resource *string
}

OperationDisplay - Contains the localized display information for this particular operation / action.

func (OperationDisplay) MarshalJSON added in v1.1.0

func (o OperationDisplay) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type OperationDisplay.

func (*OperationDisplay) UnmarshalJSON added in v1.1.0

func (o *OperationDisplay) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type OperationDisplay.

type OperationListResult

type OperationListResult struct {
	// READ-ONLY; URL to get the next set of operation list results if there are any.
	NextLink *string

	// READ-ONLY; List of Time Series Insights operations supported by the Microsoft.TimeSeriesInsights resource provider.
	Value []*Operation
}

OperationListResult - Result of the request to list Time Series Insights operations. It contains a list of operations and a URL link to get the next set of results.

func (OperationListResult) MarshalJSON added in v1.1.0

func (o OperationListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type OperationListResult.

func (*OperationListResult) UnmarshalJSON added in v1.1.0

func (o *OperationListResult) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type OperationListResult.

type OperationProperties

type OperationProperties struct {
	// One property of operation, include metric specifications.
	ServiceSpecification *ServiceSpecification
}

OperationProperties - Properties of operation, include metric specifications.

func (OperationProperties) MarshalJSON added in v1.1.0

func (o OperationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type OperationProperties.

func (*OperationProperties) UnmarshalJSON added in v1.1.0

func (o *OperationProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type OperationProperties.

type OperationsClient

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

OperationsClient contains the methods for the Operations group. Don't use this type directly, use NewOperationsClient() instead.

func NewOperationsClient

func NewOperationsClient(credential azcore.TokenCredential, options *arm.ClientOptions) (*OperationsClient, error)

NewOperationsClient creates a new instance of OperationsClient with the specified values.

  • credential - used to authorize requests. Usually a credential from azidentity.
  • options - pass nil to accept the default values.

func (*OperationsClient) NewListPager

NewListPager - Lists all of the available Time Series Insights related operations.

Generated from API version 2020-05-15

  • options - OperationsClientListOptions contains the optional parameters for the OperationsClient.NewListPager method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/Operation_List.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	pager := clientFactory.NewOperationsClient().NewListPager(nil)
	for pager.More() {
		page, err := pager.NextPage(ctx)
		if err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		for _, v := range page.Value {
			// You could use page here. We use blank identifier for just demo purposes.
			_ = v
		}
		// If the HTTP response code is 200 as defined in example definition, your page structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
		// page.OperationListResult = armtimeseriesinsights.OperationListResult{
		// 	Value: []*armtimeseriesinsights.Operation{
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/register/action"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Registers the subscription for the Time Series Insights resource provider and enables the creation of Time Series Insights environments."),
		// 				Operation: to.Ptr("Registers the Time Series Insights Resource Provider"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Time Series Insights Resource Provider"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/providers/Microsoft.Insights/metricDefinitions/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Gets the available metrics for environments"),
		// 				Operation: to.Ptr("Read environments metric definitions"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("The metrics definition of environments"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 			OperationProperties: &armtimeseriesinsights.OperationProperties{
		// 				ServiceSpecification: &armtimeseriesinsights.ServiceSpecification{
		// 					MetricSpecifications: []*armtimeseriesinsights.MetricSpecification{
		// 						{
		// 							Name: to.Ptr("IngressReceivedMessages"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of messages read from all Event hub or IoT hub event sources"),
		// 							DisplayName: to.Ptr("Ingress Received Messages"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedInvalidMessages"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of invalid messages read from all Event hub or IoT hub event sources"),
		// 							DisplayName: to.Ptr("Ingress Received Invalid Messages"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedBytes"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of bytes read from all event sources"),
		// 							DisplayName: to.Ptr("Ingress Received Bytes"),
		// 							Unit: to.Ptr("Bytes"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressStoredBytes"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Total size of events successfully processed and available for query"),
		// 							DisplayName: to.Ptr("Ingress Stored Bytes"),
		// 							Unit: to.Ptr("Bytes"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressStoredEvents"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of flattened events successfully processed and available for query"),
		// 							DisplayName: to.Ptr("Ingress Stored Events"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedMessagesTimeLag"),
		// 							AggregationType: to.Ptr("Maximum"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Difference between the time that the message is enqueued in the event source and the time it is processed in Ingress"),
		// 							DisplayName: to.Ptr("Ingress Received Messages Time Lag"),
		// 							Unit: to.Ptr("Seconds"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedMessagesCountLag"),
		// 							AggregationType: to.Ptr("Average"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Difference between the sequence number of last enqueued message in the event source partition and sequence number of messages being processed in Ingress"),
		// 							DisplayName: to.Ptr("Ingress Received Messages Count Lag"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("WarmStorageMaxProperties"),
		// 							AggregationType: to.Ptr("Maximum"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Maximum number of properties used allowed by the environment for S1/S2 SKU and maximum number of properties allowed by Warm Store for PAYG SKU"),
		// 							DisplayName: to.Ptr("Warm Storage Max Properties"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("WarmStorageUsedProperties"),
		// 							AggregationType: to.Ptr("Maximum"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Number of properties used by the environment for S1/S2 SKU and number of properties used by Warm Store for PAYG SKU"),
		// 							DisplayName: to.Ptr("Warm Storage Used Properties "),
		// 							Unit: to.Ptr("Count"),
		// 					}},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/providers/Microsoft.Insights/diagnosticSettings/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Gets the diagnostic setting for the resource"),
		// 				Operation: to.Ptr("Read diagnostic setting."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("environments"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/providers/Microsoft.Insights/diagnosticSettings/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates or updates the diagnostic setting for the resource"),
		// 				Operation: to.Ptr("Write diagnostic setting."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("environments"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/providers/Microsoft.Insights/logDefinitions/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Gets the available logs for environments"),
		// 				Operation: to.Ptr("Read environments log definitions"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("environments"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 			OperationProperties: &armtimeseriesinsights.OperationProperties{
		// 				ServiceSpecification: &armtimeseriesinsights.ServiceSpecification{
		// 					LogSpecifications: []*armtimeseriesinsights.LogSpecification{
		// 						{
		// 							Name: to.Ptr("Ingress"),
		// 							DisplayName: to.Ptr("Ingress"),
		// 						},
		// 						{
		// 							Name: to.Ptr("Management"),
		// 							DisplayName: to.Ptr("Management"),
		// 					}},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/eventsources/providers/Microsoft.Insights/logDefinitions/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Gets the available logs for the event source"),
		// 				Operation: to.Ptr("Read event source log definitions"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Event Source"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 			OperationProperties: &armtimeseriesinsights.OperationProperties{
		// 				ServiceSpecification: &armtimeseriesinsights.ServiceSpecification{
		// 					LogSpecifications: []*armtimeseriesinsights.LogSpecification{
		// 						{
		// 							Name: to.Ptr("Ingress"),
		// 							DisplayName: to.Ptr("Ingress"),
		// 						},
		// 						{
		// 							Name: to.Ptr("Management"),
		// 							DisplayName: to.Ptr("Management"),
		// 					}},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/eventsources/providers/Microsoft.Insights/metricDefinitions/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Gets the available metrics for eventsources"),
		// 				Operation: to.Ptr("Read eventsources metric definitions"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("The metrics definition of environments/eventsources"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 			OperationProperties: &armtimeseriesinsights.OperationProperties{
		// 				ServiceSpecification: &armtimeseriesinsights.ServiceSpecification{
		// 					MetricSpecifications: []*armtimeseriesinsights.MetricSpecification{
		// 						{
		// 							Name: to.Ptr("IngressReceivedMessages"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of messages read from the event source"),
		// 							DisplayName: to.Ptr("Ingress Received Messages"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedInvalidMessages"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of invalid messages read from the event source"),
		// 							DisplayName: to.Ptr("Ingress Received Invalid Messages"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedBytes"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of bytes read from the event source"),
		// 							DisplayName: to.Ptr("Ingress Received Bytes"),
		// 							Unit: to.Ptr("Bytes"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressStoredBytes"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Total size of events successfully processed and available for query"),
		// 							DisplayName: to.Ptr("Ingress Stored Bytes"),
		// 							Unit: to.Ptr("Bytes"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressStoredEvents"),
		// 							AggregationType: to.Ptr("Total"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Count of flattened events successfully processed and available for query"),
		// 							DisplayName: to.Ptr("Ingress Stored Events"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedMessagesTimeLag"),
		// 							AggregationType: to.Ptr("Maximum"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Difference between the time that the message is enqueued in the event source and the time it is processed in Ingress"),
		// 							DisplayName: to.Ptr("Ingress Received Messages Time Lag"),
		// 							Unit: to.Ptr("Seconds"),
		// 						},
		// 						{
		// 							Name: to.Ptr("IngressReceivedMessagesCountLag"),
		// 							AggregationType: to.Ptr("Average"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Difference between the sequence number of last enqueued message in the event source partition and sequence number of messages being processed in Ingress"),
		// 							DisplayName: to.Ptr("Ingress Received Messages Count Lag"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("WarmStorageMaxProperties"),
		// 							AggregationType: to.Ptr("Maximum"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Maximum number of properties used allowed by the environment for S1/S2 SKU and maximum number of properties allowed by Warm Store for PAYG SKU"),
		// 							DisplayName: to.Ptr("Warm Storage Max Properties"),
		// 							Unit: to.Ptr("Count"),
		// 						},
		// 						{
		// 							Name: to.Ptr("WarmStorageUsedProperties"),
		// 							AggregationType: to.Ptr("Maximum"),
		// 							Availabilities: []*armtimeseriesinsights.MetricAvailability{
		// 								{
		// 									BlobDuration: to.Ptr("PT1H"),
		// 									TimeGrain: to.Ptr("PT1M"),
		// 							}},
		// 							DisplayDescription: to.Ptr("Number of properties used by the environment for S1/S2 SKU and number of properties used by Warm Store for PAYG SKU"),
		// 							DisplayName: to.Ptr("Warm Storage Used Properties "),
		// 							Unit: to.Ptr("Count"),
		// 					}},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/eventsources/providers/Microsoft.Insights/diagnosticSettings/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Gets the diagnostic setting for the resource"),
		// 				Operation: to.Ptr("Read diagnostic setting."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("environments/eventsources"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/eventsources/providers/Microsoft.Insights/diagnosticSettings/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates or updates the diagnostic setting for the resource"),
		// 				Operation: to.Ptr("Write diagnostic setting."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("environments/eventsources"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Get the properties of an environment."),
		// 				Operation: to.Ptr("Read Environment"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Environment"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates a new environment, or updates an existing environment."),
		// 				Operation: to.Ptr("Create or Update Environment"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Environment"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/delete"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Deletes the environment."),
		// 				Operation: to.Ptr("Delete Environment"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Environment"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/status/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Get the status of the environment, state of its associated operations like ingress."),
		// 				Operation: to.Ptr("Read Environment status"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Environment"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/eventsources/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Get the properties of an event source."),
		// 				Operation: to.Ptr("Read Event Source"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Event Source"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/eventsources/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates a new event source for an environment, or updates an existing event source."),
		// 				Operation: to.Ptr("Create or Update Event Source"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Event Source"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/eventsources/delete"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Deletes the event source."),
		// 				Operation: to.Ptr("Delete Event Source"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Event Source"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/referencedatasets/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Get the properties of a reference data set."),
		// 				Operation: to.Ptr("Read Reference Data Set"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Reference Data Set"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/referencedatasets/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates a new reference data set for an environment, or updates an existing reference data set."),
		// 				Operation: to.Ptr("Create or Update Reference Data Set"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Reference Data Set"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/referencedatasets/delete"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Deletes the reference data set."),
		// 				Operation: to.Ptr("Delete Reference Data Set"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Reference Data Set"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/accesspolicies/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Get the properties of an access policy."),
		// 				Operation: to.Ptr("Read Access Policy"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Access Policy"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/accesspolicies/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates a new access policy for an environment, or updates an existing access policy."),
		// 				Operation: to.Ptr("Create or Update Access Policy"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Access Policy"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/accesspolicies/delete"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Deletes the access policy."),
		// 				Operation: to.Ptr("Delete Access Policy"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Access Policy"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateEndpointConnectionProxies/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Get the properties of a private endpoint connection proxy."),
		// 				Operation: to.Ptr("Read private endpoint connection proxy"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection proxy"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateEndpointConnectionProxies/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates a new private endpoint connection proxy for an environment, or updates an existing connection proxy."),
		// 				Operation: to.Ptr("Create or Update private endpoint connection proxy"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection proxy"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateEndpointConnectionProxies/delete"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Deletes the private endpoint connection proxy."),
		// 				Operation: to.Ptr("Delete the private endpoint connection proxy"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection proxy"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateEndpointConnectionProxies/validate/action"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Validate the private endpoint connection proxy object before creation."),
		// 				Operation: to.Ptr("Validate the private endpoint connection proxy."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection proxy"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateEndpointConnectionProxies/operationresults/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Validate the private endpoint connection proxy operation status."),
		// 				Operation: to.Ptr("Get private endpoint connection proxy operation status."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection proxy"),
		// 			},
		// 			Origin: to.Ptr("system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateendpointConnections/read"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Get the properties of a private endpoint connection."),
		// 				Operation: to.Ptr("Read private endpoint connection."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection."),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateendpointConnections/write"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Creates a new private endpoint connection for an environment, or updates an existing connection."),
		// 				Operation: to.Ptr("Create or Update private endpoint connection."),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection."),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 		},
		// 		{
		// 			Name: to.Ptr("Microsoft.TimeSeriesInsights/environments/privateendpointConnections/delete"),
		// 			Display: &armtimeseriesinsights.OperationDisplay{
		// 				Description: to.Ptr("Deletes the private endpoint connection."),
		// 				Operation: to.Ptr("Delete the private endpoint connection"),
		// 				Provider: to.Ptr("Microsoft Time Series Insights"),
		// 				Resource: to.Ptr("Private endpoint connection"),
		// 			},
		// 			Origin: to.Ptr("user,system"),
		// 	}},
		// }
	}
}
Output:

type OperationsClientListOptions

type OperationsClientListOptions struct {
}

OperationsClientListOptions contains the optional parameters for the OperationsClient.NewListPager method.

type OperationsClientListResponse

type OperationsClientListResponse struct {
	// Result of the request to list Time Series Insights operations. It contains a list of operations and a URL link to get the
	// next set of results.
	OperationListResult
}

OperationsClientListResponse contains the response from method OperationsClient.NewListPager.

type PropertyType

type PropertyType string

PropertyType - The type of the property.

const (
	PropertyTypeString PropertyType = "String"
)

func PossiblePropertyTypeValues

func PossiblePropertyTypeValues() []PropertyType

PossiblePropertyTypeValues returns the possible values for the PropertyType const type.

type ProvisioningState

type ProvisioningState string

ProvisioningState - Provisioning state of the resource.

const (
	ProvisioningStateAccepted  ProvisioningState = "Accepted"
	ProvisioningStateCreating  ProvisioningState = "Creating"
	ProvisioningStateDeleting  ProvisioningState = "Deleting"
	ProvisioningStateFailed    ProvisioningState = "Failed"
	ProvisioningStateSucceeded ProvisioningState = "Succeeded"
	ProvisioningStateUpdating  ProvisioningState = "Updating"
)

func PossibleProvisioningStateValues

func PossibleProvisioningStateValues() []ProvisioningState

PossibleProvisioningStateValues returns the possible values for the ProvisioningState const type.

type ReferenceDataKeyPropertyType

type ReferenceDataKeyPropertyType string

ReferenceDataKeyPropertyType - The type of the key property.

const (
	ReferenceDataKeyPropertyTypeBool     ReferenceDataKeyPropertyType = "Bool"
	ReferenceDataKeyPropertyTypeDateTime ReferenceDataKeyPropertyType = "DateTime"
	ReferenceDataKeyPropertyTypeDouble   ReferenceDataKeyPropertyType = "Double"
	ReferenceDataKeyPropertyTypeString   ReferenceDataKeyPropertyType = "String"
)

func PossibleReferenceDataKeyPropertyTypeValues

func PossibleReferenceDataKeyPropertyTypeValues() []ReferenceDataKeyPropertyType

PossibleReferenceDataKeyPropertyTypeValues returns the possible values for the ReferenceDataKeyPropertyType const type.

type ReferenceDataSetCreateOrUpdateParameters

type ReferenceDataSetCreateOrUpdateParameters struct {
	// REQUIRED; The location of the resource.
	Location *string

	// REQUIRED; Properties used to create a reference data set.
	Properties *ReferenceDataSetCreationProperties

	// Key-value pairs of additional properties for the resource.
	Tags map[string]*string
}

func (ReferenceDataSetCreateOrUpdateParameters) MarshalJSON

MarshalJSON implements the json.Marshaller interface for type ReferenceDataSetCreateOrUpdateParameters.

func (*ReferenceDataSetCreateOrUpdateParameters) UnmarshalJSON added in v1.1.0

func (r *ReferenceDataSetCreateOrUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ReferenceDataSetCreateOrUpdateParameters.

type ReferenceDataSetCreationProperties

type ReferenceDataSetCreationProperties struct {
	// REQUIRED; The list of key properties for the reference data set.
	KeyProperties []*ReferenceDataSetKeyProperty

	// The reference data set key comparison behavior can be set using this property. By default, the value is 'Ordinal' - which
	// means case sensitive key comparison will be performed while joining reference
	// data with events or while adding new reference data. When 'OrdinalIgnoreCase' is set, case insensitive comparison will
	// be used.
	DataStringComparisonBehavior *DataStringComparisonBehavior
}

ReferenceDataSetCreationProperties - Properties used to create a reference data set.

func (ReferenceDataSetCreationProperties) MarshalJSON

func (r ReferenceDataSetCreationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ReferenceDataSetCreationProperties.

func (*ReferenceDataSetCreationProperties) UnmarshalJSON added in v1.1.0

func (r *ReferenceDataSetCreationProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ReferenceDataSetCreationProperties.

type ReferenceDataSetKeyProperty

type ReferenceDataSetKeyProperty struct {
	// The name of the key property.
	Name *string

	// The type of the key property.
	Type *ReferenceDataKeyPropertyType
}

ReferenceDataSetKeyProperty - A key property for the reference data set. A reference data set can have multiple key properties.

func (ReferenceDataSetKeyProperty) MarshalJSON added in v1.1.0

func (r ReferenceDataSetKeyProperty) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ReferenceDataSetKeyProperty.

func (*ReferenceDataSetKeyProperty) UnmarshalJSON added in v1.1.0

func (r *ReferenceDataSetKeyProperty) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ReferenceDataSetKeyProperty.

type ReferenceDataSetListResponse

type ReferenceDataSetListResponse struct {
	// Result of the List Reference Data Sets operation.
	Value []*ReferenceDataSetResource
}

ReferenceDataSetListResponse - The response of the List Reference Data Sets operation.

func (ReferenceDataSetListResponse) MarshalJSON added in v1.1.0

func (r ReferenceDataSetListResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ReferenceDataSetListResponse.

func (*ReferenceDataSetListResponse) UnmarshalJSON added in v1.1.0

func (r *ReferenceDataSetListResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ReferenceDataSetListResponse.

type ReferenceDataSetResource

type ReferenceDataSetResource struct {
	// REQUIRED; Resource location
	Location *string

	// Properties of the reference data set.
	Properties *ReferenceDataSetResourceProperties

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

ReferenceDataSetResource - A reference data set provides metadata about the events in an environment. Metadata in the reference data set will be joined with events as they are read from event sources. The metadata that makes up the reference data set is uploaded or modified through the Time Series Insights data plane APIs.

func (ReferenceDataSetResource) MarshalJSON added in v1.1.0

func (r ReferenceDataSetResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ReferenceDataSetResource.

func (*ReferenceDataSetResource) UnmarshalJSON added in v1.1.0

func (r *ReferenceDataSetResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ReferenceDataSetResource.

type ReferenceDataSetResourceProperties

type ReferenceDataSetResourceProperties struct {
	// REQUIRED; The list of key properties for the reference data set.
	KeyProperties []*ReferenceDataSetKeyProperty

	// The reference data set key comparison behavior can be set using this property. By default, the value is 'Ordinal' - which
	// means case sensitive key comparison will be performed while joining reference
	// data with events or while adding new reference data. When 'OrdinalIgnoreCase' is set, case insensitive comparison will
	// be used.
	DataStringComparisonBehavior *DataStringComparisonBehavior

	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

ReferenceDataSetResourceProperties - Properties of the reference data set.

func (ReferenceDataSetResourceProperties) MarshalJSON

func (r ReferenceDataSetResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ReferenceDataSetResourceProperties.

func (*ReferenceDataSetResourceProperties) UnmarshalJSON

func (r *ReferenceDataSetResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ReferenceDataSetResourceProperties.

type ReferenceDataSetUpdateParameters

type ReferenceDataSetUpdateParameters struct {
	// Key-value pairs of additional properties for the reference data set.
	Tags map[string]*string
}

ReferenceDataSetUpdateParameters - Parameters supplied to the Update Reference Data Set operation.

func (ReferenceDataSetUpdateParameters) MarshalJSON

func (r ReferenceDataSetUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ReferenceDataSetUpdateParameters.

func (*ReferenceDataSetUpdateParameters) UnmarshalJSON added in v1.1.0

func (r *ReferenceDataSetUpdateParameters) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ReferenceDataSetUpdateParameters.

type ReferenceDataSetsClient

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

ReferenceDataSetsClient contains the methods for the ReferenceDataSets group. Don't use this type directly, use NewReferenceDataSetsClient() instead.

func NewReferenceDataSetsClient

func NewReferenceDataSetsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*ReferenceDataSetsClient, error)

NewReferenceDataSetsClient creates a new instance of ReferenceDataSetsClient with the specified values.

  • subscriptionID - Azure Subscription ID.
  • credential - used to authorize requests. Usually a credential from azidentity.
  • options - pass nil to accept the default values.

func (*ReferenceDataSetsClient) CreateOrUpdate

func (client *ReferenceDataSetsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, environmentName string, referenceDataSetName string, parameters ReferenceDataSetCreateOrUpdateParameters, options *ReferenceDataSetsClientCreateOrUpdateOptions) (ReferenceDataSetsClientCreateOrUpdateResponse, error)

CreateOrUpdate - Create or update a reference data set in the specified environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • referenceDataSetName - Name of the reference data set.
  • parameters - Parameters for creating a reference data set.
  • options - ReferenceDataSetsClientCreateOrUpdateOptions contains the optional parameters for the ReferenceDataSetsClient.CreateOrUpdate method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/ReferenceDataSetsCreate.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewReferenceDataSetsClient().CreateOrUpdate(ctx, "rg1", "env1", "rds1", armtimeseriesinsights.ReferenceDataSetCreateOrUpdateParameters{
		Location: to.Ptr("West US"),
		Properties: &armtimeseriesinsights.ReferenceDataSetCreationProperties{
			KeyProperties: []*armtimeseriesinsights.ReferenceDataSetKeyProperty{
				{
					Name: to.Ptr("DeviceId1"),
					Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeString),
				},
				{
					Name: to.Ptr("DeviceFloor"),
					Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeDouble),
				}},
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.ReferenceDataSetResource = armtimeseriesinsights.ReferenceDataSetResource{
	// 	Name: to.Ptr("rds1"),
	// 	Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/ReferenceDataSets"),
	// 	ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/referenceDataSets/rds1"),
	// 	Location: to.Ptr("West US"),
	// 	Tags: map[string]*string{
	// 	},
	// 	Properties: &armtimeseriesinsights.ReferenceDataSetResourceProperties{
	// 		KeyProperties: []*armtimeseriesinsights.ReferenceDataSetKeyProperty{
	// 			{
	// 				Name: to.Ptr("DeviceId1"),
	// 				Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeString),
	// 			},
	// 			{
	// 				Name: to.Ptr("DeviceFloor"),
	// 				Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeDouble),
	// 		}},
	// 		CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 		ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 	},
	// }
}
Output:

func (*ReferenceDataSetsClient) Delete

func (client *ReferenceDataSetsClient) Delete(ctx context.Context, resourceGroupName string, environmentName string, referenceDataSetName string, options *ReferenceDataSetsClientDeleteOptions) (ReferenceDataSetsClientDeleteResponse, error)

Delete - Deletes the reference data set with the specified name in the specified subscription, resource group, and environment If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • referenceDataSetName - The name of the Time Series Insights reference data set associated with the specified environment.
  • options - ReferenceDataSetsClientDeleteOptions contains the optional parameters for the ReferenceDataSetsClient.Delete method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/ReferenceDataSetsDelete.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	_, err = clientFactory.NewReferenceDataSetsClient().Delete(ctx, "rg1", "env1", "rds1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
}
Output:

func (*ReferenceDataSetsClient) Get

func (client *ReferenceDataSetsClient) Get(ctx context.Context, resourceGroupName string, environmentName string, referenceDataSetName string, options *ReferenceDataSetsClientGetOptions) (ReferenceDataSetsClientGetResponse, error)

Get - Gets the reference data set with the specified name in the specified environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • referenceDataSetName - The name of the Time Series Insights reference data set associated with the specified environment.
  • options - ReferenceDataSetsClientGetOptions contains the optional parameters for the ReferenceDataSetsClient.Get method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/ReferenceDataSetsGet.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewReferenceDataSetsClient().Get(ctx, "rg1", "env1", "rds1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.ReferenceDataSetResource = armtimeseriesinsights.ReferenceDataSetResource{
	// 	Name: to.Ptr("rds1"),
	// 	Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/ReferenceDataSets"),
	// 	ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/referenceDataSets/rds1"),
	// 	Location: to.Ptr("West US"),
	// 	Tags: map[string]*string{
	// 	},
	// 	Properties: &armtimeseriesinsights.ReferenceDataSetResourceProperties{
	// 		KeyProperties: []*armtimeseriesinsights.ReferenceDataSetKeyProperty{
	// 			{
	// 				Name: to.Ptr("DeviceId1"),
	// 				Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeString),
	// 			},
	// 			{
	// 				Name: to.Ptr("DeviceFloor"),
	// 				Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeDouble),
	// 		}},
	// 		CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 		ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 	},
	// }
}
Output:

func (*ReferenceDataSetsClient) ListByEnvironment

ListByEnvironment - Lists all the available reference data sets associated with the subscription and within the specified resource group and environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • options - ReferenceDataSetsClientListByEnvironmentOptions contains the optional parameters for the ReferenceDataSetsClient.ListByEnvironment method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/ReferenceDataSetsListByEnvironment.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewReferenceDataSetsClient().ListByEnvironment(ctx, "rg1", "env1", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.ReferenceDataSetListResponse = armtimeseriesinsights.ReferenceDataSetListResponse{
	// 	Value: []*armtimeseriesinsights.ReferenceDataSetResource{
	// 		{
	// 			Name: to.Ptr("rds1"),
	// 			Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/ReferenceDataSets"),
	// 			ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/referenceDataSets/rds1"),
	// 			Location: to.Ptr("West US"),
	// 			Tags: map[string]*string{
	// 			},
	// 			Properties: &armtimeseriesinsights.ReferenceDataSetResourceProperties{
	// 				KeyProperties: []*armtimeseriesinsights.ReferenceDataSetKeyProperty{
	// 					{
	// 						Name: to.Ptr("DeviceId1"),
	// 						Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeString),
	// 					},
	// 					{
	// 						Name: to.Ptr("DeviceFloor"),
	// 						Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeDouble),
	// 				}},
	// 				CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 				ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 			},
	// 	}},
	// }
}
Output:

func (*ReferenceDataSetsClient) Update

func (client *ReferenceDataSetsClient) Update(ctx context.Context, resourceGroupName string, environmentName string, referenceDataSetName string, referenceDataSetUpdateParameters ReferenceDataSetUpdateParameters, options *ReferenceDataSetsClientUpdateOptions) (ReferenceDataSetsClientUpdateResponse, error)

Update - Updates the reference data set with the specified name in the specified subscription, resource group, and environment. If the operation fails it returns an *azcore.ResponseError type.

Generated from API version 2020-05-15

  • resourceGroupName - Name of an Azure Resource group.
  • environmentName - The name of the Time Series Insights environment associated with the specified resource group.
  • referenceDataSetName - The name of the Time Series Insights reference data set associated with the specified environment.
  • referenceDataSetUpdateParameters - Request object that contains the updated information for the reference data set.
  • options - ReferenceDataSetsClientUpdateOptions contains the optional parameters for the ReferenceDataSetsClient.Update method.
Example

Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/163e27c0ca7570bc39e00a46f255740d9b3ba3cb/specification/timeseriesinsights/resource-manager/Microsoft.TimeSeriesInsights/stable/2020-05-15/examples/ReferenceDataSetsPatchTags.json

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/timeseriesinsights/armtimeseriesinsights"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armtimeseriesinsights.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewReferenceDataSetsClient().Update(ctx, "rg1", "env1", "rds1", armtimeseriesinsights.ReferenceDataSetUpdateParameters{
		Tags: map[string]*string{
			"someKey": to.Ptr("someValue"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.ReferenceDataSetResource = armtimeseriesinsights.ReferenceDataSetResource{
	// 	Name: to.Ptr("rds1"),
	// 	Type: to.Ptr("Microsoft.TimeSeriesInsights/Environments/ReferenceDataSets"),
	// 	ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/referenceDataSets/rds1"),
	// 	Location: to.Ptr("West US"),
	// 	Tags: map[string]*string{
	// 		"someKey": to.Ptr("someValue"),
	// 	},
	// 	Properties: &armtimeseriesinsights.ReferenceDataSetResourceProperties{
	// 		KeyProperties: []*armtimeseriesinsights.ReferenceDataSetKeyProperty{
	// 			{
	// 				Name: to.Ptr("DeviceId1"),
	// 				Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeString),
	// 			},
	// 			{
	// 				Name: to.Ptr("DeviceFloor"),
	// 				Type: to.Ptr(armtimeseriesinsights.ReferenceDataKeyPropertyTypeDouble),
	// 		}},
	// 		CreationTime: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-04-18T19:20:33.228Z"); return t}()),
	// 		ProvisioningState: to.Ptr(armtimeseriesinsights.ProvisioningStateSucceeded),
	// 	},
	// }
}
Output:

type ReferenceDataSetsClientCreateOrUpdateOptions

type ReferenceDataSetsClientCreateOrUpdateOptions struct {
}

ReferenceDataSetsClientCreateOrUpdateOptions contains the optional parameters for the ReferenceDataSetsClient.CreateOrUpdate method.

type ReferenceDataSetsClientCreateOrUpdateResponse

type ReferenceDataSetsClientCreateOrUpdateResponse struct {
	// A reference data set provides metadata about the events in an environment. Metadata in the reference data set will be joined
	// with events as they are read from event sources. The metadata that makes up the reference data set is uploaded or modified
	// through the Time Series Insights data plane APIs.
	ReferenceDataSetResource
}

ReferenceDataSetsClientCreateOrUpdateResponse contains the response from method ReferenceDataSetsClient.CreateOrUpdate.

type ReferenceDataSetsClientDeleteOptions

type ReferenceDataSetsClientDeleteOptions struct {
}

ReferenceDataSetsClientDeleteOptions contains the optional parameters for the ReferenceDataSetsClient.Delete method.

type ReferenceDataSetsClientDeleteResponse

type ReferenceDataSetsClientDeleteResponse struct {
}

ReferenceDataSetsClientDeleteResponse contains the response from method ReferenceDataSetsClient.Delete.

type ReferenceDataSetsClientGetOptions

type ReferenceDataSetsClientGetOptions struct {
}

ReferenceDataSetsClientGetOptions contains the optional parameters for the ReferenceDataSetsClient.Get method.

type ReferenceDataSetsClientGetResponse

type ReferenceDataSetsClientGetResponse struct {
	// A reference data set provides metadata about the events in an environment. Metadata in the reference data set will be joined
	// with events as they are read from event sources. The metadata that makes up the reference data set is uploaded or modified
	// through the Time Series Insights data plane APIs.
	ReferenceDataSetResource
}

ReferenceDataSetsClientGetResponse contains the response from method ReferenceDataSetsClient.Get.

type ReferenceDataSetsClientListByEnvironmentOptions

type ReferenceDataSetsClientListByEnvironmentOptions struct {
}

ReferenceDataSetsClientListByEnvironmentOptions contains the optional parameters for the ReferenceDataSetsClient.ListByEnvironment method.

type ReferenceDataSetsClientListByEnvironmentResponse

type ReferenceDataSetsClientListByEnvironmentResponse struct {
	// The response of the List Reference Data Sets operation.
	ReferenceDataSetListResponse
}

ReferenceDataSetsClientListByEnvironmentResponse contains the response from method ReferenceDataSetsClient.ListByEnvironment.

type ReferenceDataSetsClientUpdateOptions

type ReferenceDataSetsClientUpdateOptions struct {
}

ReferenceDataSetsClientUpdateOptions contains the optional parameters for the ReferenceDataSetsClient.Update method.

type ReferenceDataSetsClientUpdateResponse

type ReferenceDataSetsClientUpdateResponse struct {
	// A reference data set provides metadata about the events in an environment. Metadata in the reference data set will be joined
	// with events as they are read from event sources. The metadata that makes up the reference data set is uploaded or modified
	// through the Time Series Insights data plane APIs.
	ReferenceDataSetResource
}

ReferenceDataSetsClientUpdateResponse contains the response from method ReferenceDataSetsClient.Update.

type Resource

type Resource struct {
	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

Resource - Time Series Insights resource

func (Resource) MarshalJSON added in v1.1.0

func (r Resource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Resource.

func (*Resource) UnmarshalJSON added in v1.1.0

func (r *Resource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type Resource.

type ResourceProperties

type ResourceProperties struct {
	// READ-ONLY; The time the resource was created.
	CreationTime *time.Time

	// READ-ONLY; Provisioning state of the resource.
	ProvisioningState *ProvisioningState
}

ResourceProperties - Properties that are common to all tracked resources.

func (ResourceProperties) MarshalJSON

func (r ResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ResourceProperties.

func (*ResourceProperties) UnmarshalJSON

func (r *ResourceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ResourceProperties.

type SKU

type SKU struct {
	// REQUIRED; The capacity of the sku. For Gen1 environments, this value can be changed to support scale out of environments
	// after they have been created.
	Capacity *int32

	// REQUIRED; The name of this SKU.
	Name *SKUName
}

SKU - The sku determines the type of environment, either Gen1 (S1 or S2) or Gen2 (L1). For Gen1 environments the sku determines the capacity of the environment, the ingress rate, and the billing rate.

func (SKU) MarshalJSON added in v1.1.0

func (s SKU) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type SKU.

func (*SKU) UnmarshalJSON added in v1.1.0

func (s *SKU) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type SKU.

type SKUName

type SKUName string

SKUName - The name of this SKU.

const (
	SKUNameL1 SKUName = "L1"
	SKUNameP1 SKUName = "P1"
	SKUNameS1 SKUName = "S1"
	SKUNameS2 SKUName = "S2"
)

func PossibleSKUNameValues

func PossibleSKUNameValues() []SKUName

PossibleSKUNameValues returns the possible values for the SKUName const type.

type ServiceSpecification

type ServiceSpecification struct {
	// A list of Azure Monitoring log definitions.
	LogSpecifications []*LogSpecification

	// Metric specifications of operation.
	MetricSpecifications []*MetricSpecification
}

ServiceSpecification - One property of operation, include metric specifications.

func (ServiceSpecification) MarshalJSON added in v1.1.0

func (s ServiceSpecification) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ServiceSpecification.

func (*ServiceSpecification) UnmarshalJSON added in v1.1.0

func (s *ServiceSpecification) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ServiceSpecification.

type StorageLimitExceededBehavior

type StorageLimitExceededBehavior string

StorageLimitExceededBehavior - The behavior the Time Series Insights service should take when the environment's capacity has been exceeded. If "PauseIngress" is specified, new events will not be read from the event source. If "PurgeOldData" is specified, new events will continue to be read and old events will be deleted from the environment. The default behavior is PurgeOldData.

const (
	StorageLimitExceededBehaviorPauseIngress StorageLimitExceededBehavior = "PauseIngress"
	StorageLimitExceededBehaviorPurgeOldData StorageLimitExceededBehavior = "PurgeOldData"
)

func PossibleStorageLimitExceededBehaviorValues

func PossibleStorageLimitExceededBehaviorValues() []StorageLimitExceededBehavior

PossibleStorageLimitExceededBehaviorValues returns the possible values for the StorageLimitExceededBehavior const type.

type TimeSeriesIDProperty

type TimeSeriesIDProperty struct {
	// The name of the property.
	Name *string

	// The type of the property.
	Type *PropertyType
}

TimeSeriesIDProperty - The structure of the property that a time series id can have. An environment can have multiple such properties.

func (TimeSeriesIDProperty) MarshalJSON added in v1.1.0

func (t TimeSeriesIDProperty) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type TimeSeriesIDProperty.

func (*TimeSeriesIDProperty) UnmarshalJSON added in v1.1.0

func (t *TimeSeriesIDProperty) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type TimeSeriesIDProperty.

type TrackedResource

type TrackedResource struct {
	// REQUIRED; Resource location
	Location *string

	// Resource tags
	Tags map[string]*string

	// READ-ONLY; Resource Id
	ID *string

	// READ-ONLY; Resource name
	Name *string

	// READ-ONLY; Resource type
	Type *string
}

TrackedResource - Time Series Insights resource that is tracked by Azure Resource Manager.

func (TrackedResource) MarshalJSON added in v1.1.0

func (t TrackedResource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type TrackedResource.

func (*TrackedResource) UnmarshalJSON added in v1.1.0

func (t *TrackedResource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type TrackedResource.

type WarmStorageEnvironmentStatus

type WarmStorageEnvironmentStatus struct {
	// READ-ONLY; An object that contains the status of warm storage properties usage.
	PropertiesUsage *WarmStoragePropertiesUsage
}

WarmStorageEnvironmentStatus - An object that represents the status of warm storage on an environment.

func (WarmStorageEnvironmentStatus) MarshalJSON added in v1.1.0

func (w WarmStorageEnvironmentStatus) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type WarmStorageEnvironmentStatus.

func (*WarmStorageEnvironmentStatus) UnmarshalJSON added in v1.1.0

func (w *WarmStorageEnvironmentStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type WarmStorageEnvironmentStatus.

type WarmStoragePropertiesState

type WarmStoragePropertiesState string

WarmStoragePropertiesState - This string represents the state of warm storage properties usage. It can be "Ok", "Error", "Unknown".

const (
	WarmStoragePropertiesStateError   WarmStoragePropertiesState = "Error"
	WarmStoragePropertiesStateOk      WarmStoragePropertiesState = "Ok"
	WarmStoragePropertiesStateUnknown WarmStoragePropertiesState = "Unknown"
)

func PossibleWarmStoragePropertiesStateValues

func PossibleWarmStoragePropertiesStateValues() []WarmStoragePropertiesState

PossibleWarmStoragePropertiesStateValues returns the possible values for the WarmStoragePropertiesState const type.

type WarmStoragePropertiesUsage

type WarmStoragePropertiesUsage struct {
	// This string represents the state of warm storage properties usage. It can be "Ok", "Error", "Unknown".
	State *WarmStoragePropertiesState

	// READ-ONLY; An object that contains the details about warm storage properties usage state.
	StateDetails *WarmStoragePropertiesUsageStateDetails
}

WarmStoragePropertiesUsage - An object that contains the status of warm storage properties usage.

func (WarmStoragePropertiesUsage) MarshalJSON added in v1.1.0

func (w WarmStoragePropertiesUsage) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type WarmStoragePropertiesUsage.

func (*WarmStoragePropertiesUsage) UnmarshalJSON added in v1.1.0

func (w *WarmStoragePropertiesUsage) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type WarmStoragePropertiesUsage.

type WarmStoragePropertiesUsageStateDetails

type WarmStoragePropertiesUsageStateDetails struct {
	// A value that represents the number of properties used by the environment for S1/S2 SKU and number of properties used by
	// Warm Store for PAYG SKU
	CurrentCount *int32

	// A value that represents the maximum number of properties used allowed by the environment for S1/S2 SKU and maximum number
	// of properties allowed by Warm Store for PAYG SKU.
	MaxCount *int32
}

WarmStoragePropertiesUsageStateDetails - An object that contains the details about warm storage properties usage state.

func (WarmStoragePropertiesUsageStateDetails) MarshalJSON added in v1.1.0

func (w WarmStoragePropertiesUsageStateDetails) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type WarmStoragePropertiesUsageStateDetails.

func (*WarmStoragePropertiesUsageStateDetails) UnmarshalJSON added in v1.1.0

func (w *WarmStoragePropertiesUsageStateDetails) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type WarmStoragePropertiesUsageStateDetails.

type WarmStoreConfigurationProperties

type WarmStoreConfigurationProperties struct {
	// REQUIRED; ISO8601 timespan specifying the number of days the environment's events will be available for query from the
	// warm store.
	DataRetention *string
}

WarmStoreConfigurationProperties - The warm store configuration provides the details to create a warm store cache that will retain a copy of the environment's data available for faster query.

func (WarmStoreConfigurationProperties) MarshalJSON added in v1.1.0

func (w WarmStoreConfigurationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type WarmStoreConfigurationProperties.

func (*WarmStoreConfigurationProperties) UnmarshalJSON added in v1.1.0

func (w *WarmStoreConfigurationProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type WarmStoreConfigurationProperties.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL