armhdinsight

package module
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2022 License: MIT Imports: 14 Imported by: 2

README

Azure HDInsight Module for Go

PkgGoDev

The armhdinsight module provides operations for working with Azure HDInsight.

Source code

Getting started

Prerequisites

Install the package

This project uses Go modules for versioning and dependency management.

Install the Azure HDInsight module:

go get github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight

Authorization

When creating a client, you will need to provide a credential for authenticating with Azure HDInsight. 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.

Clients

Azure HDInsight modules consist of one or more clients. A client groups a set of related APIs, providing access to its functionality within the specified subscription. Create one or more clients to access the APIs you require using your credential.

client := armhdinsight.NewApplicationsClient(<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{
    Host: arm.AzureChina,
}
client := armhdinsight.NewApplicationsClient(<subscription ID>, cred, &options)

Provide Feedback

If you encounter bugs or have suggestions, please open an issue and assign the HDInsight 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 AaddsResourceDetails 

type AaddsResourceDetails struct {
	// The Azure active directory domain service name.
	DomainName *string `json:"domainName,omitempty"`

	// This indicates whether initial sync complete or not.
	InitialSyncComplete *bool `json:"initialSyncComplete,omitempty"`

	// This indicates whether enable ldaps or not.
	LdapsEnabled *bool `json:"ldapsEnabled,omitempty"`

	// The base 64 format string of public ldap certificate.
	LdapsPublicCertificateInBase64 *string `json:"ldapsPublicCertificateInBase64,omitempty"`

	// The resource id of azure active directory domain service.
	ResourceID *string `json:"resourceId,omitempty"`

	// The subnet resource id.
	SubnetID *string `json:"subnetId,omitempty"`

	// The tenant id of azure active directory domain service .
	TenantID *string `json:"tenantId,omitempty"`
}

AaddsResourceDetails - The Azure active directory domain service resource details.

type Application 

type Application struct {
	// The ETag for the application
	Etag *string `json:"etag,omitempty"`

	// The properties of the application.
	Properties *ApplicationProperties `json:"properties,omitempty"`

	// The tags for the application.
	Tags map[string]*string `json:"tags,omitempty"`

	// READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; Metadata pertaining to creation and last modification of the resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`

	// READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty" azure:"ro"`
}

Application - The HDInsight cluster application

func (Application) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type Application.

type ApplicationGetEndpoint 

type ApplicationGetEndpoint struct {
	// The destination port to connect to.
	DestinationPort *int32 `json:"destinationPort,omitempty"`

	// The location of the endpoint.
	Location *string `json:"location,omitempty"`

	// The private ip address of the endpoint.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`

	// The public port to connect to.
	PublicPort *int32 `json:"publicPort,omitempty"`
}

ApplicationGetEndpoint - Gets the application SSH endpoint

type ApplicationGetHTTPSEndpoint 

type ApplicationGetHTTPSEndpoint struct {
	// The list of access modes for the application.
	AccessModes []*string `json:"accessModes,omitempty"`

	// The destination port to connect to.
	DestinationPort *int32 `json:"destinationPort,omitempty"`

	// The value indicates whether to disable GatewayAuth.
	DisableGatewayAuth *bool `json:"disableGatewayAuth,omitempty"`

	// The private ip address of the endpoint.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`

	// The subdomain suffix of the application.
	SubDomainSuffix *string `json:"subDomainSuffix,omitempty"`

	// READ-ONLY; The location of the endpoint.
	Location *string `json:"location,omitempty" azure:"ro"`

	// READ-ONLY; The public port to connect to.
	PublicPort *int32 `json:"publicPort,omitempty" azure:"ro"`
}

ApplicationGetHTTPSEndpoint - Gets the application HTTP endpoints.

func (ApplicationGetHTTPSEndpoint) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ApplicationGetHTTPSEndpoint.

type ApplicationListResult 

type ApplicationListResult struct {
	// The list of HDInsight applications installed on HDInsight cluster.
	Value []*Application `json:"value,omitempty"`

	// READ-ONLY; The URL to get the next set of operation list results if there are any.
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`
}

ApplicationListResult - Result of the request to list cluster Applications. It contains a list of operations and a URL link to get the next set of results.

func (ApplicationListResult) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ApplicationListResult.

type ApplicationProperties 

type ApplicationProperties struct {
	// The application type.
	ApplicationType *string `json:"applicationType,omitempty"`

	// The list of roles in the cluster.
	ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"`

	// The list of errors.
	Errors []*Errors `json:"errors,omitempty"`

	// The list of application HTTPS endpoints.
	HTTPSEndpoints []*ApplicationGetHTTPSEndpoint `json:"httpsEndpoints,omitempty"`

	// The list of install script actions.
	InstallScriptActions []*RuntimeScriptAction `json:"installScriptActions,omitempty"`

	// The private link configurations.
	PrivateLinkConfigurations []*PrivateLinkConfiguration `json:"privateLinkConfigurations,omitempty"`

	// The list of application SSH endpoints.
	SSHEndpoints []*ApplicationGetEndpoint `json:"sshEndpoints,omitempty"`

	// The list of uninstall script actions.
	UninstallScriptActions []*RuntimeScriptAction `json:"uninstallScriptActions,omitempty"`

	// READ-ONLY; The application state.
	ApplicationState *string `json:"applicationState,omitempty" azure:"ro"`

	// READ-ONLY; The application create date time.
	CreatedDate *string `json:"createdDate,omitempty" azure:"ro"`

	// READ-ONLY; The marketplace identifier.
	MarketplaceIdentifier *string `json:"marketplaceIdentifier,omitempty" azure:"ro"`

	// READ-ONLY; The provisioning state of the application.
	ProvisioningState *string `json:"provisioningState,omitempty" azure:"ro"`
}

ApplicationProperties - The HDInsight cluster application GET response.

func (ApplicationProperties) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ApplicationProperties.

type ApplicationsClient 

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

ApplicationsClient contains the methods for the Applications group. Don't use this type directly, use NewApplicationsClient() instead.

func NewApplicationsClient 

func NewApplicationsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ApplicationsClient

NewApplicationsClient creates a new instance of ApplicationsClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*ApplicationsClient) BeginCreate 

func (client *ApplicationsClient) BeginCreate(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, parameters Application, options *ApplicationsClientBeginCreateOptions) (ApplicationsClientCreatePollerResponse, error)

BeginCreate - Creates applications for the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. applicationName - The constant value for the application name. parameters - The application create request. options - ApplicationsClientBeginCreateOptions contains the optional parameters for the ApplicationsClient.BeginCreate method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/CreateApplication.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewApplicationsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginCreate(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<application-name>",
		armhdinsight.Application{
			Properties: &armhdinsight.ApplicationProperties{
				ApplicationType: to.StringPtr("<application-type>"),
				ComputeProfile: &armhdinsight.ComputeProfile{
					Roles: []*armhdinsight.Role{
						{
							Name: to.StringPtr("<name>"),
							HardwareProfile: &armhdinsight.HardwareProfile{
								VMSize: to.StringPtr("<vmsize>"),
							},
							TargetInstanceCount: to.Int32Ptr(1),
						}},
				},
				Errors: []*armhdinsight.Errors{},
				HTTPSEndpoints: []*armhdinsight.ApplicationGetHTTPSEndpoint{
					{
						AccessModes: []*string{
							to.StringPtr("WebPage")},
						DestinationPort: to.Int32Ptr(20000),
						SubDomainSuffix: to.StringPtr("<sub-domain-suffix>"),
					}},
				InstallScriptActions: []*armhdinsight.RuntimeScriptAction{
					{
						Name:       to.StringPtr("<name>"),
						Parameters: to.StringPtr("<parameters>"),
						Roles: []*string{
							to.StringPtr("edgenode")},
						URI: to.StringPtr("<uri>"),
					}},
				UninstallScriptActions: []*armhdinsight.RuntimeScriptAction{},
			},
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	res, err := poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ApplicationsClientCreateResult)
}

Output:

func (*ApplicationsClient) BeginDelete 

func (client *ApplicationsClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, options *ApplicationsClientBeginDeleteOptions) (ApplicationsClientDeletePollerResponse, error)

BeginDelete - Deletes the specified application on the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. applicationName - The constant value for the application name. options - ApplicationsClientBeginDeleteOptions contains the optional parameters for the ApplicationsClient.BeginDelete method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DeleteApplication.json 

package main

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewApplicationsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginDelete(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<application-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ApplicationsClient) Get 

func (client *ApplicationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, options *ApplicationsClientGetOptions) (ApplicationsClientGetResponse, error)

Get - Gets properties of the specified application. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. applicationName - The constant value for the application name. options - ApplicationsClientGetOptions contains the optional parameters for the ApplicationsClient.Get method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetApplicationInProgress.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewApplicationsClient("<subscription-id>", cred, nil)
	res, err := client.Get(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<application-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ApplicationsClientGetResult)
}

Output:

func (*ApplicationsClient) GetAzureAsyncOperationStatus 

func (client *ApplicationsClient) GetAzureAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, operationID string, options *ApplicationsClientGetAzureAsyncOperationStatusOptions) (ApplicationsClientGetAzureAsyncOperationStatusResponse, error)

GetAzureAsyncOperationStatus - Gets the async operation status. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. applicationName - The constant value for the application name. operationID - The long running operation id. options - ApplicationsClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the ApplicationsClient.GetAzureAsyncOperationStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetApplicationCreationAsyncOperationStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewApplicationsClient("<subscription-id>", cred, nil)
	res, err := client.GetAzureAsyncOperationStatus(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<application-name>",
		"<operation-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ApplicationsClientGetAzureAsyncOperationStatusResult)
}

Output:

func (*ApplicationsClient) ListByCluster 

func (client *ApplicationsClient) ListByCluster(resourceGroupName string, clusterName string, options *ApplicationsClientListByClusterOptions) *ApplicationsClientListByClusterPager

ListByCluster - Lists all of the applications for the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ApplicationsClientListByClusterOptions contains the optional parameters for the ApplicationsClient.ListByCluster method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetAllApplications.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewApplicationsClient("<subscription-id>", cred, nil)
	pager := client.ListByCluster("<resource-group-name>",
		"<cluster-name>",
		nil)
	for {
		nextResult := pager.NextPage(ctx)
		if err := pager.Err(); err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		if !nextResult {
			break
		}
		for _, v := range pager.PageResponse().Value {
			log.Printf("Pager result: %#v\n", v)
		}
	}
}

Output:

type ApplicationsClientBeginCreateOptions added in v0.2.0 

type ApplicationsClientBeginCreateOptions struct {
}

ApplicationsClientBeginCreateOptions contains the optional parameters for the ApplicationsClient.BeginCreate method.

type ApplicationsClientBeginDeleteOptions added in v0.2.0 

type ApplicationsClientBeginDeleteOptions struct {
}

ApplicationsClientBeginDeleteOptions contains the optional parameters for the ApplicationsClient.BeginDelete method.

type ApplicationsClientCreatePoller added in v0.2.0 

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

ApplicationsClientCreatePoller provides polling facilities until the operation reaches a terminal state.

func (*ApplicationsClientCreatePoller) Done added in v0.2.0 

func (p *ApplicationsClientCreatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ApplicationsClientCreatePoller) FinalResponse added in v0.2.0 

func (p *ApplicationsClientCreatePoller) FinalResponse(ctx context.Context) (ApplicationsClientCreateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ApplicationsClientCreateResponse will be returned.

func (*ApplicationsClientCreatePoller) Poll added in v0.2.0 

func (p *ApplicationsClientCreatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ApplicationsClientCreatePoller) ResumeToken added in v0.2.0 

func (p *ApplicationsClientCreatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ApplicationsClientCreatePollerResponse added in v0.2.0 

type ApplicationsClientCreatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ApplicationsClientCreatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ApplicationsClientCreatePollerResponse contains the response from method ApplicationsClient.Create.

func (ApplicationsClientCreatePollerResponse) PollUntilDone added in v0.2.0 

func (l ApplicationsClientCreatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ApplicationsClientCreateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ApplicationsClientCreatePollerResponse) Resume added in v0.2.0 

func (l *ApplicationsClientCreatePollerResponse) Resume(ctx context.Context, client *ApplicationsClient, token string) error

Resume rehydrates a ApplicationsClientCreatePollerResponse from the provided client and resume token.

type ApplicationsClientCreateResponse added in v0.2.0 

type ApplicationsClientCreateResponse struct {
	ApplicationsClientCreateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ApplicationsClientCreateResponse contains the response from method ApplicationsClient.Create.

type ApplicationsClientCreateResult added in v0.2.0 

type ApplicationsClientCreateResult struct {
	Application
}

ApplicationsClientCreateResult contains the result from method ApplicationsClient.Create.

type ApplicationsClientDeletePoller added in v0.2.0 

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

ApplicationsClientDeletePoller provides polling facilities until the operation reaches a terminal state.

func (*ApplicationsClientDeletePoller) Done added in v0.2.0 

func (p *ApplicationsClientDeletePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ApplicationsClientDeletePoller) FinalResponse added in v0.2.0 

func (p *ApplicationsClientDeletePoller) FinalResponse(ctx context.Context) (ApplicationsClientDeleteResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ApplicationsClientDeleteResponse will be returned.

func (*ApplicationsClientDeletePoller) Poll added in v0.2.0 

func (p *ApplicationsClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ApplicationsClientDeletePoller) ResumeToken added in v0.2.0 

func (p *ApplicationsClientDeletePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ApplicationsClientDeletePollerResponse added in v0.2.0 

type ApplicationsClientDeletePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ApplicationsClientDeletePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ApplicationsClientDeletePollerResponse contains the response from method ApplicationsClient.Delete.

func (ApplicationsClientDeletePollerResponse) PollUntilDone added in v0.2.0 

func (l ApplicationsClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ApplicationsClientDeleteResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ApplicationsClientDeletePollerResponse) Resume added in v0.2.0 

func (l *ApplicationsClientDeletePollerResponse) Resume(ctx context.Context, client *ApplicationsClient, token string) error

Resume rehydrates a ApplicationsClientDeletePollerResponse from the provided client and resume token.

type ApplicationsClientDeleteResponse added in v0.2.0 

type ApplicationsClientDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ApplicationsClientDeleteResponse contains the response from method ApplicationsClient.Delete.

type ApplicationsClientGetAzureAsyncOperationStatusOptions added in v0.2.0 

type ApplicationsClientGetAzureAsyncOperationStatusOptions struct {
}

ApplicationsClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the ApplicationsClient.GetAzureAsyncOperationStatus method.

type ApplicationsClientGetAzureAsyncOperationStatusResponse added in v0.2.0 

type ApplicationsClientGetAzureAsyncOperationStatusResponse struct {
	ApplicationsClientGetAzureAsyncOperationStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ApplicationsClientGetAzureAsyncOperationStatusResponse contains the response from method ApplicationsClient.GetAzureAsyncOperationStatus.

type ApplicationsClientGetAzureAsyncOperationStatusResult added in v0.2.0 

type ApplicationsClientGetAzureAsyncOperationStatusResult struct {
	AsyncOperationResult
}

ApplicationsClientGetAzureAsyncOperationStatusResult contains the result from method ApplicationsClient.GetAzureAsyncOperationStatus.

type ApplicationsClientGetOptions added in v0.2.0 

type ApplicationsClientGetOptions struct {
}

ApplicationsClientGetOptions contains the optional parameters for the ApplicationsClient.Get method.

type ApplicationsClientGetResponse added in v0.2.0 

type ApplicationsClientGetResponse struct {
	ApplicationsClientGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ApplicationsClientGetResponse contains the response from method ApplicationsClient.Get.

type ApplicationsClientGetResult added in v0.2.0 

type ApplicationsClientGetResult struct {
	Application
}

ApplicationsClientGetResult contains the result from method ApplicationsClient.Get.

type ApplicationsClientListByClusterOptions added in v0.2.0 

type ApplicationsClientListByClusterOptions struct {
}

ApplicationsClientListByClusterOptions contains the optional parameters for the ApplicationsClient.ListByCluster method.

type ApplicationsClientListByClusterPager added in v0.2.0 

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

ApplicationsClientListByClusterPager provides operations for iterating over paged responses.

func (*ApplicationsClientListByClusterPager) Err added in v0.2.0 

func (p *ApplicationsClientListByClusterPager) Err() error

Err returns the last error encountered while paging.

func (*ApplicationsClientListByClusterPager) NextPage added in v0.2.0 

func (p *ApplicationsClientListByClusterPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ApplicationsClientListByClusterPager) PageResponse added in v0.2.0 

func (p *ApplicationsClientListByClusterPager) PageResponse() ApplicationsClientListByClusterResponse

PageResponse returns the current ApplicationsClientListByClusterResponse page.

type ApplicationsClientListByClusterResponse added in v0.2.0 

type ApplicationsClientListByClusterResponse struct {
	ApplicationsClientListByClusterResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ApplicationsClientListByClusterResponse contains the response from method ApplicationsClient.ListByCluster.

type ApplicationsClientListByClusterResult added in v0.2.0 

type ApplicationsClientListByClusterResult struct {
	ApplicationListResult
}

ApplicationsClientListByClusterResult contains the result from method ApplicationsClient.ListByCluster.

type AsyncOperationResult 

type AsyncOperationResult struct {
	// The operation error information.
	Error *Errors `json:"error,omitempty"`

	// The async operation state.
	Status *AsyncOperationState `json:"status,omitempty"`
}

AsyncOperationResult - The azure async operation response.

type AsyncOperationState 

type AsyncOperationState string

AsyncOperationState - The async operation state. 

const (
	AsyncOperationStateFailed     AsyncOperationState = "Failed"
	AsyncOperationStateInProgress AsyncOperationState = "InProgress"
	AsyncOperationStateSucceeded  AsyncOperationState = "Succeeded"
)

func PossibleAsyncOperationStateValues 

func PossibleAsyncOperationStateValues() []AsyncOperationState

PossibleAsyncOperationStateValues returns the possible values for the AsyncOperationState const type.

func (AsyncOperationState) ToPtr 

func (c AsyncOperationState) ToPtr() *AsyncOperationState

ToPtr returns a *AsyncOperationState pointing to the current value.

type Autoscale 

type Autoscale struct {
	// Parameters for load-based autoscale
	Capacity *AutoscaleCapacity `json:"capacity,omitempty"`

	// Parameters for schedule-based autoscale
	Recurrence *AutoscaleRecurrence `json:"recurrence,omitempty"`
}

Autoscale - The autoscale request parameters

type AutoscaleCapacity 

type AutoscaleCapacity struct {
	// The maximum instance count of the cluster
	MaxInstanceCount *int32 `json:"maxInstanceCount,omitempty"`

	// The minimum instance count of the cluster
	MinInstanceCount *int32 `json:"minInstanceCount,omitempty"`
}

AutoscaleCapacity - The load-based autoscale request parameters

type AutoscaleConfigurationUpdateParameter 

type AutoscaleConfigurationUpdateParameter struct {
	// The autoscale configuration.
	Autoscale *Autoscale `json:"autoscale,omitempty"`
}

AutoscaleConfigurationUpdateParameter - The autoscale configuration update parameter.

type AutoscaleRecurrence 

type AutoscaleRecurrence struct {
	// Array of schedule-based autoscale rules
	Schedule []*AutoscaleSchedule `json:"schedule,omitempty"`

	// The time zone for the autoscale schedule times
	TimeZone *string `json:"timeZone,omitempty"`
}

AutoscaleRecurrence - Schedule-based autoscale request parameters

func (AutoscaleRecurrence) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type AutoscaleRecurrence.

type AutoscaleSchedule 

type AutoscaleSchedule struct {
	// Days of the week for a schedule-based autoscale rule
	Days []*DaysOfWeek `json:"days,omitempty"`

	// Time and capacity for a schedule-based autoscale rule
	TimeAndCapacity *AutoscaleTimeAndCapacity `json:"timeAndCapacity,omitempty"`
}

AutoscaleSchedule - Parameters for a schedule-based autoscale rule, consisting of an array of days + a time and capacity

func (AutoscaleSchedule) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type AutoscaleSchedule.

type AutoscaleTimeAndCapacity 

type AutoscaleTimeAndCapacity struct {
	// The maximum instance count of the cluster
	MaxInstanceCount *int32 `json:"maxInstanceCount,omitempty"`

	// The minimum instance count of the cluster
	MinInstanceCount *int32 `json:"minInstanceCount,omitempty"`

	// 24-hour time in the form xx:xx
	Time *string `json:"time,omitempty"`
}

AutoscaleTimeAndCapacity - Time and capacity request parameters

type AzureMonitorRequest 

type AzureMonitorRequest struct {
	// The Log Analytics workspace key.
	PrimaryKey *string `json:"primaryKey,omitempty"`

	// The selected configurations.
	SelectedConfigurations *AzureMonitorSelectedConfigurations `json:"selectedConfigurations,omitempty"`

	// The Log Analytics workspace ID.
	WorkspaceID *string `json:"workspaceId,omitempty"`
}

AzureMonitorRequest - The azure monitor parameters.

type AzureMonitorResponse 

type AzureMonitorResponse struct {
	// The status of the monitor on the HDInsight cluster.
	ClusterMonitoringEnabled *bool `json:"clusterMonitoringEnabled,omitempty"`

	// The selected configurations.
	SelectedConfigurations *AzureMonitorSelectedConfigurations `json:"selectedConfigurations,omitempty"`

	// The workspace ID of the monitor on the HDInsight cluster.
	WorkspaceID *string `json:"workspaceId,omitempty"`
}

AzureMonitorResponse - The azure monitor status response.

type AzureMonitorSelectedConfigurations 

type AzureMonitorSelectedConfigurations struct {
	// The configuration version.
	ConfigurationVersion *string `json:"configurationVersion,omitempty"`

	// The global configurations of selected configurations.
	GlobalConfigurations map[string]*string `json:"globalConfigurations,omitempty"`

	// The table list.
	TableList []*AzureMonitorTableConfiguration `json:"tableList,omitempty"`
}

AzureMonitorSelectedConfigurations - The selected configurations for azure monitor.

func (AzureMonitorSelectedConfigurations) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type AzureMonitorSelectedConfigurations.

type AzureMonitorTableConfiguration 

type AzureMonitorTableConfiguration struct {
	// The name.
	Name *string `json:"name,omitempty"`
}

AzureMonitorTableConfiguration - The table configuration for the Log Analytics integration.

type BillingMeters 

type BillingMeters struct {
	// The HDInsight meter guid.
	Meter *string `json:"meter,omitempty"`

	// The virtual machine sizes.
	MeterParameter *string `json:"meterParameter,omitempty"`

	// The unit of meter, VMHours or CoreHours.
	Unit *string `json:"unit,omitempty"`
}

BillingMeters - The billing meters.

type BillingResources 

type BillingResources struct {
	// The billing meter information.
	BillingMeters []*BillingMeters `json:"billingMeters,omitempty"`

	// The managed disk billing information.
	DiskBillingMeters []*DiskBillingMeters `json:"diskBillingMeters,omitempty"`

	// The region or location.
	Region *string `json:"region,omitempty"`
}

BillingResources - The billing resources.

func (BillingResources) MarshalJSON 

func (b BillingResources) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type BillingResources.

type BillingResponseListResult 

type BillingResponseListResult struct {
	// The billing and managed disk billing resources for a region.
	BillingResources []*BillingResources `json:"billingResources,omitempty"`

	// The virtual machine filtering mode. Effectively this can enabling or disabling the virtual machine sizes in a particular
	// set.
	VMSizeFilters []*VMSizeCompatibilityFilterV2 `json:"vmSizeFilters,omitempty"`

	// The virtual machine sizes to include or exclude.
	VMSizes []*string `json:"vmSizes,omitempty"`

	// The vm sizes which enable encryption at host.
	VMSizesWithEncryptionAtHost []*string `json:"vmSizesWithEncryptionAtHost,omitempty"`

	// READ-ONLY; The vm size properties.
	VMSizeProperties []*VMSizeProperty `json:"vmSizeProperties,omitempty" azure:"ro"`
}

BillingResponseListResult - The response for the operation to get regional billingSpecs for a subscription.

func (BillingResponseListResult) MarshalJSON 

func (b BillingResponseListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type BillingResponseListResult.

type CapabilitiesResult 

type CapabilitiesResult struct {
	// The capability features.
	Features []*string `json:"features,omitempty"`

	// The virtual machine size compatibility features.
	Regions map[string]*RegionsCapability `json:"regions,omitempty"`

	// The version capability.
	Versions map[string]*VersionsCapability `json:"versions,omitempty"`

	// READ-ONLY; The quota capability.
	Quota *QuotaCapability `json:"quota,omitempty" azure:"ro"`
}

CapabilitiesResult - The Get Capabilities operation response.

func (CapabilitiesResult) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type CapabilitiesResult.

type ClientGroupInfo 

type ClientGroupInfo struct {
	// The AAD security group id.
	GroupID *string `json:"groupId,omitempty"`

	// The AAD security group name.
	GroupName *string `json:"groupName,omitempty"`
}

ClientGroupInfo - The information of AAD security group.

type Cluster 

type Cluster struct {
	// REQUIRED; The geo-location where the resource lives
	Location *string `json:"location,omitempty"`

	// The ETag for the resource
	Etag *string `json:"etag,omitempty"`

	// The identity of the cluster, if configured.
	Identity *ClusterIdentity `json:"identity,omitempty"`

	// The properties of the cluster.
	Properties *ClusterGetProperties `json:"properties,omitempty"`

	// Resource tags.
	Tags map[string]*string `json:"tags,omitempty"`

	// The availability zones.
	Zones []*string `json:"zones,omitempty"`

	// READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; Metadata pertaining to creation and last modification of the resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`

	// READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty" azure:"ro"`
}

Cluster - The HDInsight cluster.

func (Cluster) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type Cluster.

type ClusterConfigurations 

type ClusterConfigurations struct {
	// The configuration object for the specified configuration for the specified cluster.
	Configurations map[string]map[string]*string `json:"configurations,omitempty"`
}

ClusterConfigurations - The configuration object for the specified cluster.

func (ClusterConfigurations) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterConfigurations.

type ClusterCreateParametersExtended 

type ClusterCreateParametersExtended struct {
	// The identity of the cluster, if configured.
	Identity *ClusterIdentity `json:"identity,omitempty"`

	// The location of the cluster.
	Location *string `json:"location,omitempty"`

	// The cluster create parameters.
	Properties *ClusterCreateProperties `json:"properties,omitempty"`

	// The resource tags.
	Tags map[string]*string `json:"tags,omitempty"`

	// The availability zones.
	Zones []*string `json:"zones,omitempty"`
}

ClusterCreateParametersExtended - The CreateCluster request parameters.

func (ClusterCreateParametersExtended) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterCreateParametersExtended.

type ClusterCreateProperties 

type ClusterCreateProperties struct {
	// The cluster definition.
	ClusterDefinition *ClusterDefinition `json:"clusterDefinition,omitempty"`

	// The version of the cluster.
	ClusterVersion *string `json:"clusterVersion,omitempty"`

	// The compute isolation properties.
	ComputeIsolationProperties *ComputeIsolationProperties `json:"computeIsolationProperties,omitempty"`

	// The compute profile.
	ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"`

	// The disk encryption properties.
	DiskEncryptionProperties *DiskEncryptionProperties `json:"diskEncryptionProperties,omitempty"`

	// The encryption-in-transit properties.
	EncryptionInTransitProperties *EncryptionInTransitProperties `json:"encryptionInTransitProperties,omitempty"`

	// The cluster kafka rest proxy configuration.
	KafkaRestProperties *KafkaRestProperties `json:"kafkaRestProperties,omitempty"`

	// The minimal supported tls version.
	MinSupportedTLSVersion *string `json:"minSupportedTlsVersion,omitempty"`

	// The network properties.
	NetworkProperties *NetworkProperties `json:"networkProperties,omitempty"`

	// The type of operating system.
	OSType *OSType `json:"osType,omitempty"`

	// The private link configurations.
	PrivateLinkConfigurations []*PrivateLinkConfiguration `json:"privateLinkConfigurations,omitempty"`

	// The security profile.
	SecurityProfile *SecurityProfile `json:"securityProfile,omitempty"`

	// The storage profile.
	StorageProfile *StorageProfile `json:"storageProfile,omitempty"`

	// The cluster tier.
	Tier *Tier `json:"tier,omitempty"`
}

ClusterCreateProperties - The cluster create parameters.

func (ClusterCreateProperties) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterCreateProperties.

type ClusterCreateRequestValidationParameters 

type ClusterCreateRequestValidationParameters struct {
	// This indicates whether fetch Aadds resource or not.
	FetchAaddsResource *bool `json:"fetchAaddsResource,omitempty"`

	// The identity of the cluster, if configured.
	Identity *ClusterIdentity `json:"identity,omitempty"`

	// The location of the cluster.
	Location *string `json:"location,omitempty"`

	// The cluster name.
	Name *string `json:"name,omitempty"`

	// The cluster create parameters.
	Properties *ClusterCreateProperties `json:"properties,omitempty"`

	// The resource tags.
	Tags map[string]*string `json:"tags,omitempty"`

	// The tenant id.
	TenantID *string `json:"tenantId,omitempty"`

	// The resource type.
	Type *string `json:"type,omitempty"`

	// The availability zones.
	Zones []*string `json:"zones,omitempty"`
}

ClusterCreateRequestValidationParameters - The cluster create request specification.

func (ClusterCreateRequestValidationParameters) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterCreateRequestValidationParameters.

type ClusterCreateValidationResult 

type ClusterCreateValidationResult struct {
	// The Azure active directory domain service resource details.
	AaddsResourcesDetails []*AaddsResourceDetails `json:"aaddsResourcesDetails,omitempty"`

	// The estimated creation duration.
	EstimatedCreationDuration *string `json:"estimatedCreationDuration,omitempty"`

	// The validation errors.
	ValidationErrors []*ValidationErrorInfo `json:"validationErrors,omitempty"`

	// The validation warnings.
	ValidationWarnings []*ValidationErrorInfo `json:"validationWarnings,omitempty"`
}

ClusterCreateValidationResult - The response of cluster create request validation.

func (ClusterCreateValidationResult) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterCreateValidationResult.

type ClusterDefinition 

type ClusterDefinition struct {
	// The link to the blueprint.
	Blueprint *string `json:"blueprint,omitempty"`

	// The versions of different services in the cluster.
	ComponentVersion map[string]*string `json:"componentVersion,omitempty"`

	// The cluster configurations.
	Configurations map[string]interface{} `json:"configurations,omitempty"`

	// The type of cluster.
	Kind *string `json:"kind,omitempty"`
}

ClusterDefinition - The cluster definition.

func (ClusterDefinition) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterDefinition.

type ClusterDiskEncryptionParameters 

type ClusterDiskEncryptionParameters struct {
	// Key name that is used for enabling disk encryption.
	KeyName *string `json:"keyName,omitempty"`

	// Specific key version that is used for enabling disk encryption.
	KeyVersion *string `json:"keyVersion,omitempty"`

	// Base key vault URI where the customers key is located eg. https://myvault.vault.azure.net
	VaultURI *string `json:"vaultUri,omitempty"`
}

ClusterDiskEncryptionParameters - The Disk Encryption Cluster request parameters.

type ClusterGetProperties 

type ClusterGetProperties struct {
	// REQUIRED; The cluster definition.
	ClusterDefinition *ClusterDefinition `json:"clusterDefinition,omitempty"`

	// The hdp version of the cluster.
	ClusterHdpVersion *string `json:"clusterHdpVersion,omitempty"`

	// The cluster id.
	ClusterID *string `json:"clusterId,omitempty"`

	// The state of the cluster.
	ClusterState *string `json:"clusterState,omitempty"`

	// The version of the cluster.
	ClusterVersion *string `json:"clusterVersion,omitempty"`

	// The compute isolation properties.
	ComputeIsolationProperties *ComputeIsolationProperties `json:"computeIsolationProperties,omitempty"`

	// The compute profile.
	ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"`

	// The list of connectivity endpoints.
	ConnectivityEndpoints []*ConnectivityEndpoint `json:"connectivityEndpoints,omitempty"`

	// The date on which the cluster was created.
	CreatedDate *string `json:"createdDate,omitempty"`

	// The disk encryption properties.
	DiskEncryptionProperties *DiskEncryptionProperties `json:"diskEncryptionProperties,omitempty"`

	// The encryption-in-transit properties.
	EncryptionInTransitProperties *EncryptionInTransitProperties `json:"encryptionInTransitProperties,omitempty"`

	// The list of errors.
	Errors []*Errors `json:"errors,omitempty"`

	// The excluded services config.
	ExcludedServicesConfig *ExcludedServicesConfig `json:"excludedServicesConfig,omitempty"`

	// The cluster kafka rest proxy configuration.
	KafkaRestProperties *KafkaRestProperties `json:"kafkaRestProperties,omitempty"`

	// The minimal supported tls version.
	MinSupportedTLSVersion *string `json:"minSupportedTlsVersion,omitempty"`

	// The network properties.
	NetworkProperties *NetworkProperties `json:"networkProperties,omitempty"`

	// The type of operating system.
	OSType *OSType `json:"osType,omitempty"`

	// The private link configurations.
	PrivateLinkConfigurations []*PrivateLinkConfiguration `json:"privateLinkConfigurations,omitempty"`

	// The provisioning state, which only appears in the response.
	ProvisioningState *HDInsightClusterProvisioningState `json:"provisioningState,omitempty"`

	// The quota information.
	QuotaInfo *QuotaInfo `json:"quotaInfo,omitempty"`

	// The security profile.
	SecurityProfile *SecurityProfile `json:"securityProfile,omitempty"`

	// The storage profile.
	StorageProfile *StorageProfile `json:"storageProfile,omitempty"`

	// The cluster tier.
	Tier *Tier `json:"tier,omitempty"`

	// READ-ONLY; The list of private endpoint connections.
	PrivateEndpointConnections []*PrivateEndpointConnection `json:"privateEndpointConnections,omitempty" azure:"ro"`
}

ClusterGetProperties - The properties of cluster.

func (ClusterGetProperties) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterGetProperties.

type ClusterIdentity 

type ClusterIdentity struct {
	// The type of identity used for the cluster. The type 'SystemAssigned, UserAssigned' includes both an implicitly created
	// identity and a set of user assigned identities.
	Type *ResourceIdentityType `json:"type,omitempty"`

	// The list of user identities associated with the cluster. The user identity dictionary key references will be ARM resource
	// ids in the form:
	// '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ManagedIdentity/userAssignedIdentities/{identityName}'.
	UserAssignedIdentities map[string]*UserAssignedIdentity `json:"userAssignedIdentities,omitempty"`

	// READ-ONLY; The principal id of cluster identity. This property will only be provided for a system assigned identity.
	PrincipalID *string `json:"principalId,omitempty" azure:"ro"`

	// READ-ONLY; The tenant id associated with the cluster. This property will only be provided for a system assigned identity.
	TenantID *string `json:"tenantId,omitempty" azure:"ro"`
}

ClusterIdentity - Identity for the cluster.

func (ClusterIdentity) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterIdentity.

type ClusterListPersistedScriptActionsResult 

type ClusterListPersistedScriptActionsResult struct {
	// The list of Persisted Script Actions.
	Value []*RuntimeScriptAction `json:"value,omitempty"`

	// READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`
}

ClusterListPersistedScriptActionsResult - The ListPersistedScriptActions operation response.

func (ClusterListPersistedScriptActionsResult) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterListPersistedScriptActionsResult.

type ClusterListResult 

type ClusterListResult struct {
	// The list of Clusters.
	Value []*Cluster `json:"value,omitempty"`

	// READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`
}

ClusterListResult - The List Cluster operation response.

func (ClusterListResult) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterListResult.

type ClusterMonitoringRequest 

type ClusterMonitoringRequest struct {
	// The cluster monitor workspace key.
	PrimaryKey *string `json:"primaryKey,omitempty"`

	// The cluster monitor workspace ID.
	WorkspaceID *string `json:"workspaceId,omitempty"`
}

ClusterMonitoringRequest - The cluster monitor parameters.

type ClusterMonitoringResponse 

type ClusterMonitoringResponse struct {
	// The status of the monitor on the HDInsight cluster.
	ClusterMonitoringEnabled *bool `json:"clusterMonitoringEnabled,omitempty"`

	// The workspace ID of the monitor on the HDInsight cluster.
	WorkspaceID *string `json:"workspaceId,omitempty"`
}

ClusterMonitoringResponse - The cluster monitoring status response.

type ClusterPatchParameters 

type ClusterPatchParameters struct {
	// The resource tags.
	Tags map[string]*string `json:"tags,omitempty"`
}

ClusterPatchParameters - The PatchCluster request parameters

func (ClusterPatchParameters) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ClusterPatchParameters.

type ClusterResizeParameters 

type ClusterResizeParameters struct {
	// The target instance count for the operation.
	TargetInstanceCount *int32 `json:"targetInstanceCount,omitempty"`
}

ClusterResizeParameters - The Resize Cluster request parameters.

type ClustersClient 

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

ClustersClient contains the methods for the Clusters group. Don't use this type directly, use NewClustersClient() instead.

func NewClustersClient 

func NewClustersClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ClustersClient

NewClustersClient creates a new instance of ClustersClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*ClustersClient) BeginCreate 

func (client *ClustersClient) BeginCreate(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterCreateParametersExtended, options *ClustersClientBeginCreateOptions) (ClustersClientCreatePollerResponse, error)

BeginCreate - Creates a new HDInsight cluster with the specified parameters. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The cluster create request. options - ClustersClientBeginCreateOptions contains the optional parameters for the ClustersClient.BeginCreate method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/CreateHDInsightClusterWithAutoscaleConfig.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginCreate(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.ClusterCreateParametersExtended{
			Properties: &armhdinsight.ClusterCreateProperties{
				ClusterDefinition: &armhdinsight.ClusterDefinition{
					ComponentVersion: map[string]*string{
						"Hadoop": to.StringPtr("2.7"),
					},
					Configurations: map[string]interface{}{
						"gateway": map[string]interface{}{
							"restAuthCredential.isEnabled": true,
							"restAuthCredential.password":  "**********",
							"restAuthCredential.username":  "admin",
						},
					},
					Kind: to.StringPtr("<kind>"),
				},
				ClusterVersion: to.StringPtr("<cluster-version>"),
				ComputeProfile: &armhdinsight.ComputeProfile{
					Roles: []*armhdinsight.Role{
						{
							Name: to.StringPtr("<name>"),
							AutoscaleConfiguration: &armhdinsight.Autoscale{
								Recurrence: &armhdinsight.AutoscaleRecurrence{
									Schedule: []*armhdinsight.AutoscaleSchedule{
										{
											Days: []*armhdinsight.DaysOfWeek{
												armhdinsight.DaysOfWeek("Monday").ToPtr(),
												armhdinsight.DaysOfWeek("Tuesday").ToPtr(),
												armhdinsight.DaysOfWeek("Wednesday").ToPtr(),
												armhdinsight.DaysOfWeek("Thursday").ToPtr(),
												armhdinsight.DaysOfWeek("Friday").ToPtr()},
											TimeAndCapacity: &armhdinsight.AutoscaleTimeAndCapacity{
												MaxInstanceCount: to.Int32Ptr(3),
												MinInstanceCount: to.Int32Ptr(3),
												Time:             to.StringPtr("<time>"),
											},
										},
										{
											Days: []*armhdinsight.DaysOfWeek{
												armhdinsight.DaysOfWeek("Monday").ToPtr(),
												armhdinsight.DaysOfWeek("Tuesday").ToPtr(),
												armhdinsight.DaysOfWeek("Wednesday").ToPtr(),
												armhdinsight.DaysOfWeek("Thursday").ToPtr(),
												armhdinsight.DaysOfWeek("Friday").ToPtr()},
											TimeAndCapacity: &armhdinsight.AutoscaleTimeAndCapacity{
												MaxInstanceCount: to.Int32Ptr(6),
												MinInstanceCount: to.Int32Ptr(6),
												Time:             to.StringPtr("<time>"),
											},
										},
										{
											Days: []*armhdinsight.DaysOfWeek{
												armhdinsight.DaysOfWeek("Saturday").ToPtr(),
												armhdinsight.DaysOfWeek("Sunday").ToPtr()},
											TimeAndCapacity: &armhdinsight.AutoscaleTimeAndCapacity{
												MaxInstanceCount: to.Int32Ptr(2),
												MinInstanceCount: to.Int32Ptr(2),
												Time:             to.StringPtr("<time>"),
											},
										},
										{
											Days: []*armhdinsight.DaysOfWeek{
												armhdinsight.DaysOfWeek("Saturday").ToPtr(),
												armhdinsight.DaysOfWeek("Sunday").ToPtr()},
											TimeAndCapacity: &armhdinsight.AutoscaleTimeAndCapacity{
												MaxInstanceCount: to.Int32Ptr(4),
												MinInstanceCount: to.Int32Ptr(4),
												Time:             to.StringPtr("<time>"),
											},
										}},
									TimeZone: to.StringPtr("<time-zone>"),
								},
							},
							HardwareProfile: &armhdinsight.HardwareProfile{
								VMSize: to.StringPtr("<vmsize>"),
							},
							OSProfile: &armhdinsight.OsProfile{
								LinuxOperatingSystemProfile: &armhdinsight.LinuxOperatingSystemProfile{
									Password: to.StringPtr("<password>"),
									Username: to.StringPtr("<username>"),
								},
							},
							ScriptActions:       []*armhdinsight.ScriptAction{},
							TargetInstanceCount: to.Int32Ptr(4),
						}},
				},
				OSType: armhdinsight.OSType("Linux").ToPtr(),
				StorageProfile: &armhdinsight.StorageProfile{
					Storageaccounts: []*armhdinsight.StorageAccount{
						{
							Name:      to.StringPtr("<name>"),
							Container: to.StringPtr("<container>"),
							IsDefault: to.BoolPtr(true),
							Key:       to.StringPtr("<key>"),
						}},
				},
				Tier: armhdinsight.Tier("Standard").ToPtr(),
			},
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	res, err := poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ClustersClientCreateResult)
}

Output:

func (*ClustersClient) BeginDelete 

func (client *ClustersClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientBeginDeleteOptions) (ClustersClientDeletePollerResponse, error)

BeginDelete - Deletes the specified HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ClustersClientBeginDeleteOptions contains the optional parameters for the ClustersClient.BeginDelete method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DeleteLinuxHadoopCluster.json 

package main

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginDelete(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ClustersClient) BeginExecuteScriptActions 

func (client *ClustersClient) BeginExecuteScriptActions(ctx context.Context, resourceGroupName string, clusterName string, parameters ExecuteScriptActionParameters, options *ClustersClientBeginExecuteScriptActionsOptions) (ClustersClientExecuteScriptActionsPollerResponse, error)

BeginExecuteScriptActions - Executes script actions on the specified HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The parameters for executing script actions. options - ClustersClientBeginExecuteScriptActionsOptions contains the optional parameters for the ClustersClient.BeginExecuteScriptActions method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/PostExecuteScriptAction.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginExecuteScriptActions(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.ExecuteScriptActionParameters{
			PersistOnSuccess: to.BoolPtr(false),
			ScriptActions: []*armhdinsight.RuntimeScriptAction{
				{
					Name:       to.StringPtr("<name>"),
					Parameters: to.StringPtr("<parameters>"),
					Roles: []*string{
						to.StringPtr("headnode"),
						to.StringPtr("workernode")},
					URI: to.StringPtr("<uri>"),
				}},
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ClustersClient) BeginResize 

func (client *ClustersClient) BeginResize(ctx context.Context, resourceGroupName string, clusterName string, roleName RoleName, parameters ClusterResizeParameters, options *ClustersClientBeginResizeOptions) (ClustersClientResizePollerResponse, error)

BeginResize - Resizes the specified HDInsight cluster to the specified size. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. roleName - The constant value for the roleName parameters - The parameters for the resize operation. options - ClustersClientBeginResizeOptions contains the optional parameters for the ClustersClient.BeginResize method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/ResizeLinuxHadoopCluster.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginResize(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.RoleName("workernode"),
		armhdinsight.ClusterResizeParameters{
			TargetInstanceCount: to.Int32Ptr(10),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ClustersClient) BeginRotateDiskEncryptionKey 

func (client *ClustersClient) BeginRotateDiskEncryptionKey(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterDiskEncryptionParameters, options *ClustersClientBeginRotateDiskEncryptionKeyOptions) (ClustersClientRotateDiskEncryptionKeyPollerResponse, error)

BeginRotateDiskEncryptionKey - Rotate disk encryption key of the specified HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The parameters for the disk encryption operation. options - ClustersClientBeginRotateDiskEncryptionKeyOptions contains the optional parameters for the ClustersClient.BeginRotateDiskEncryptionKey method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/RotateLinuxHadoopClusterDiskEncryptionKey.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginRotateDiskEncryptionKey(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.ClusterDiskEncryptionParameters{
			KeyName:    to.StringPtr("<key-name>"),
			KeyVersion: to.StringPtr("<key-version>"),
			VaultURI:   to.StringPtr("<vault-uri>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ClustersClient) BeginUpdateAutoScaleConfiguration 

func (client *ClustersClient) BeginUpdateAutoScaleConfiguration(ctx context.Context, resourceGroupName string, clusterName string, roleName RoleName, parameters AutoscaleConfigurationUpdateParameter, options *ClustersClientBeginUpdateAutoScaleConfigurationOptions) (ClustersClientUpdateAutoScaleConfigurationPollerResponse, error)

BeginUpdateAutoScaleConfiguration - Updates the Autoscale Configuration for HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. roleName - The constant value for the roleName parameters - The parameters for the update autoscale configuration operation. options - ClustersClientBeginUpdateAutoScaleConfigurationOptions contains the optional parameters for the ClustersClient.BeginUpdateAutoScaleConfiguration method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DisableClusterAutoScale.json 

package main

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginUpdateAutoScaleConfiguration(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.RoleName("workernode"),
		armhdinsight.AutoscaleConfigurationUpdateParameter{},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ClustersClient) BeginUpdateGatewaySettings 

func (client *ClustersClient) BeginUpdateGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateGatewaySettingsParameters, options *ClustersClientBeginUpdateGatewaySettingsOptions) (ClustersClientUpdateGatewaySettingsPollerResponse, error)

BeginUpdateGatewaySettings - Configures the gateway settings on the specified cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The cluster configurations. options - ClustersClientBeginUpdateGatewaySettingsOptions contains the optional parameters for the ClustersClient.BeginUpdateGatewaySettings method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Clusters_UpdateGatewaySettings_Enable.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginUpdateGatewaySettings(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.UpdateGatewaySettingsParameters{
			IsCredentialEnabled: to.BoolPtr(true),
			Password:            to.StringPtr("<password>"),
			UserName:            to.StringPtr("<user-name>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ClustersClient) BeginUpdateIdentityCertificate 

func (client *ClustersClient) BeginUpdateIdentityCertificate(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateClusterIdentityCertificateParameters, options *ClustersClientBeginUpdateIdentityCertificateOptions) (ClustersClientUpdateIdentityCertificatePollerResponse, error)

BeginUpdateIdentityCertificate - Updates the cluster identity certificate. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The cluster configurations. options - ClustersClientBeginUpdateIdentityCertificateOptions contains the optional parameters for the ClustersClient.BeginUpdateIdentityCertificate method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Clusters_UpdateClusterIdentityCertificate.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	poller, err := client.BeginUpdateIdentityCertificate(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.UpdateClusterIdentityCertificateParameters{
			ApplicationID:       to.StringPtr("<application-id>"),
			Certificate:         to.StringPtr("<certificate>"),
			CertificatePassword: to.StringPtr("<certificate-password>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ClustersClient) Get 

func (client *ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientGetOptions) (ClustersClientGetResponse, error)

Get - Gets the specified cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ClustersClientGetOptions contains the optional parameters for the ClustersClient.Get method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetLinuxHadoopCluster.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	res, err := client.Get(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ClustersClientGetResult)
}

Output:

func (*ClustersClient) GetAzureAsyncOperationStatus 

func (client *ClustersClient) GetAzureAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, operationID string, options *ClustersClientGetAzureAsyncOperationStatusOptions) (ClustersClientGetAzureAsyncOperationStatusResponse, error)

GetAzureAsyncOperationStatus - The the async operation status. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. operationID - The long running operation id. options - ClustersClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the ClustersClient.GetAzureAsyncOperationStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetClusterCreatingAsyncOperationStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	res, err := client.GetAzureAsyncOperationStatus(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<operation-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ClustersClientGetAzureAsyncOperationStatusResult)
}

Output:

func (*ClustersClient) GetGatewaySettings 

func (client *ClustersClient) GetGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientGetGatewaySettingsOptions) (ClustersClientGetGatewaySettingsResponse, error)

GetGatewaySettings - Gets the gateway settings for the specified cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ClustersClientGetGatewaySettingsOptions contains the optional parameters for the ClustersClient.GetGatewaySettings method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Clusters_GetGatewaySettings.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	res, err := client.GetGatewaySettings(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ClustersClientGetGatewaySettingsResult)
}

Output:

func (*ClustersClient) List 

func (client *ClustersClient) List(options *ClustersClientListOptions) *ClustersClientListPager

List - Lists all the HDInsight clusters under the subscription. If the operation fails it returns an *azcore.ResponseError type. options - ClustersClientListOptions contains the optional parameters for the ClustersClient.List method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetLinuxHadoopAllClusters.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	pager := client.List(nil)
	for {
		nextResult := pager.NextPage(ctx)
		if err := pager.Err(); err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		if !nextResult {
			break
		}
		for _, v := range pager.PageResponse().Value {
			log.Printf("Pager result: %#v\n", v)
		}
	}
}

Output:

func (*ClustersClient) ListByResourceGroup 

func (client *ClustersClient) ListByResourceGroup(resourceGroupName string, options *ClustersClientListByResourceGroupOptions) *ClustersClientListByResourceGroupPager

ListByResourceGroup - Lists the HDInsight clusters in a resource group. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. options - ClustersClientListByResourceGroupOptions contains the optional parameters for the ClustersClient.ListByResourceGroup method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetLinuxHadoopAllClustersInResourceGroup.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	pager := client.ListByResourceGroup("<resource-group-name>",
		nil)
	for {
		nextResult := pager.NextPage(ctx)
		if err := pager.Err(); err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		if !nextResult {
			break
		}
		for _, v := range pager.PageResponse().Value {
			log.Printf("Pager result: %#v\n", v)
		}
	}
}

Output:

func (*ClustersClient) Update 

func (client *ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterPatchParameters, options *ClustersClientUpdateOptions) (ClustersClientUpdateResponse, error)

Update - Patch HDInsight cluster with the specified parameters. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The cluster patch request. options - ClustersClientUpdateOptions contains the optional parameters for the ClustersClient.Update method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/PatchLinuxHadoopCluster.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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewClustersClient("<subscription-id>", cred, nil)
	res, err := client.Update(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.ClusterPatchParameters{
			Tags: map[string]*string{
				"key1": to.StringPtr("val1"),
				"key2": to.StringPtr("val2"),
			},
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ClustersClientUpdateResult)
}

Output:

type ClustersClientBeginCreateOptions added in v0.2.0 

type ClustersClientBeginCreateOptions struct {
}

ClustersClientBeginCreateOptions contains the optional parameters for the ClustersClient.BeginCreate method.

type ClustersClientBeginDeleteOptions added in v0.2.0 

type ClustersClientBeginDeleteOptions struct {
}

ClustersClientBeginDeleteOptions contains the optional parameters for the ClustersClient.BeginDelete method.

type ClustersClientBeginExecuteScriptActionsOptions added in v0.2.0 

type ClustersClientBeginExecuteScriptActionsOptions struct {
}

ClustersClientBeginExecuteScriptActionsOptions contains the optional parameters for the ClustersClient.BeginExecuteScriptActions method.

type ClustersClientBeginResizeOptions added in v0.2.0 

type ClustersClientBeginResizeOptions struct {
}

ClustersClientBeginResizeOptions contains the optional parameters for the ClustersClient.BeginResize method.

type ClustersClientBeginRotateDiskEncryptionKeyOptions added in v0.2.0 

type ClustersClientBeginRotateDiskEncryptionKeyOptions struct {
}

ClustersClientBeginRotateDiskEncryptionKeyOptions contains the optional parameters for the ClustersClient.BeginRotateDiskEncryptionKey method.

type ClustersClientBeginUpdateAutoScaleConfigurationOptions added in v0.2.0 

type ClustersClientBeginUpdateAutoScaleConfigurationOptions struct {
}

ClustersClientBeginUpdateAutoScaleConfigurationOptions contains the optional parameters for the ClustersClient.BeginUpdateAutoScaleConfiguration method.

type ClustersClientBeginUpdateGatewaySettingsOptions added in v0.2.0 

type ClustersClientBeginUpdateGatewaySettingsOptions struct {
}

ClustersClientBeginUpdateGatewaySettingsOptions contains the optional parameters for the ClustersClient.BeginUpdateGatewaySettings method.

type ClustersClientBeginUpdateIdentityCertificateOptions added in v0.2.0 

type ClustersClientBeginUpdateIdentityCertificateOptions struct {
}

ClustersClientBeginUpdateIdentityCertificateOptions contains the optional parameters for the ClustersClient.BeginUpdateIdentityCertificate method.

type ClustersClientCreatePoller added in v0.2.0 

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

ClustersClientCreatePoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientCreatePoller) Done added in v0.2.0 

func (p *ClustersClientCreatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientCreatePoller) FinalResponse added in v0.2.0 

func (p *ClustersClientCreatePoller) FinalResponse(ctx context.Context) (ClustersClientCreateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientCreateResponse will be returned.

func (*ClustersClientCreatePoller) Poll added in v0.2.0 

func (p *ClustersClientCreatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientCreatePoller) ResumeToken added in v0.2.0 

func (p *ClustersClientCreatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientCreatePollerResponse added in v0.2.0 

type ClustersClientCreatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientCreatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientCreatePollerResponse contains the response from method ClustersClient.Create.

func (ClustersClientCreatePollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientCreatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientCreateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientCreatePollerResponse) Resume added in v0.2.0 

func (l *ClustersClientCreatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientCreatePollerResponse from the provided client and resume token.

type ClustersClientCreateResponse added in v0.2.0 

type ClustersClientCreateResponse struct {
	ClustersClientCreateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientCreateResponse contains the response from method ClustersClient.Create.

type ClustersClientCreateResult added in v0.2.0 

type ClustersClientCreateResult struct {
	Cluster
}

ClustersClientCreateResult contains the result from method ClustersClient.Create.

type ClustersClientDeletePoller added in v0.2.0 

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

ClustersClientDeletePoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientDeletePoller) Done added in v0.2.0 

func (p *ClustersClientDeletePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientDeletePoller) FinalResponse added in v0.2.0 

func (p *ClustersClientDeletePoller) FinalResponse(ctx context.Context) (ClustersClientDeleteResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientDeleteResponse will be returned.

func (*ClustersClientDeletePoller) Poll added in v0.2.0 

func (p *ClustersClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientDeletePoller) ResumeToken added in v0.2.0 

func (p *ClustersClientDeletePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientDeletePollerResponse added in v0.2.0 

type ClustersClientDeletePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientDeletePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientDeletePollerResponse contains the response from method ClustersClient.Delete.

func (ClustersClientDeletePollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientDeleteResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientDeletePollerResponse) Resume added in v0.2.0 

func (l *ClustersClientDeletePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientDeletePollerResponse from the provided client and resume token.

type ClustersClientDeleteResponse added in v0.2.0 

type ClustersClientDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientDeleteResponse contains the response from method ClustersClient.Delete.

type ClustersClientExecuteScriptActionsPoller added in v0.2.0 

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

ClustersClientExecuteScriptActionsPoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientExecuteScriptActionsPoller) Done added in v0.2.0 

func (p *ClustersClientExecuteScriptActionsPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientExecuteScriptActionsPoller) FinalResponse added in v0.2.0 

func (p *ClustersClientExecuteScriptActionsPoller) FinalResponse(ctx context.Context) (ClustersClientExecuteScriptActionsResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientExecuteScriptActionsResponse will be returned.

func (*ClustersClientExecuteScriptActionsPoller) Poll added in v0.2.0 

func (p *ClustersClientExecuteScriptActionsPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientExecuteScriptActionsPoller) ResumeToken added in v0.2.0 

func (p *ClustersClientExecuteScriptActionsPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientExecuteScriptActionsPollerResponse added in v0.2.0 

type ClustersClientExecuteScriptActionsPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientExecuteScriptActionsPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientExecuteScriptActionsPollerResponse contains the response from method ClustersClient.ExecuteScriptActions.

func (ClustersClientExecuteScriptActionsPollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientExecuteScriptActionsPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientExecuteScriptActionsResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientExecuteScriptActionsPollerResponse) Resume added in v0.2.0 

func (l *ClustersClientExecuteScriptActionsPollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientExecuteScriptActionsPollerResponse from the provided client and resume token.

type ClustersClientExecuteScriptActionsResponse added in v0.2.0 

type ClustersClientExecuteScriptActionsResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientExecuteScriptActionsResponse contains the response from method ClustersClient.ExecuteScriptActions.

type ClustersClientGetAzureAsyncOperationStatusOptions added in v0.2.0 

type ClustersClientGetAzureAsyncOperationStatusOptions struct {
}

ClustersClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the ClustersClient.GetAzureAsyncOperationStatus method.

type ClustersClientGetAzureAsyncOperationStatusResponse added in v0.2.0 

type ClustersClientGetAzureAsyncOperationStatusResponse struct {
	ClustersClientGetAzureAsyncOperationStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientGetAzureAsyncOperationStatusResponse contains the response from method ClustersClient.GetAzureAsyncOperationStatus.

type ClustersClientGetAzureAsyncOperationStatusResult added in v0.2.0 

type ClustersClientGetAzureAsyncOperationStatusResult struct {
	AsyncOperationResult
}

ClustersClientGetAzureAsyncOperationStatusResult contains the result from method ClustersClient.GetAzureAsyncOperationStatus.

type ClustersClientGetGatewaySettingsOptions added in v0.2.0 

type ClustersClientGetGatewaySettingsOptions struct {
}

ClustersClientGetGatewaySettingsOptions contains the optional parameters for the ClustersClient.GetGatewaySettings method.

type ClustersClientGetGatewaySettingsResponse added in v0.2.0 

type ClustersClientGetGatewaySettingsResponse struct {
	ClustersClientGetGatewaySettingsResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientGetGatewaySettingsResponse contains the response from method ClustersClient.GetGatewaySettings.

type ClustersClientGetGatewaySettingsResult added in v0.2.0 

type ClustersClientGetGatewaySettingsResult struct {
	GatewaySettings
}

ClustersClientGetGatewaySettingsResult contains the result from method ClustersClient.GetGatewaySettings.

type ClustersClientGetOptions added in v0.2.0 

type ClustersClientGetOptions struct {
}

ClustersClientGetOptions contains the optional parameters for the ClustersClient.Get method.

type ClustersClientGetResponse added in v0.2.0 

type ClustersClientGetResponse struct {
	ClustersClientGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientGetResponse contains the response from method ClustersClient.Get.

type ClustersClientGetResult added in v0.2.0 

type ClustersClientGetResult struct {
	Cluster
}

ClustersClientGetResult contains the result from method ClustersClient.Get.

type ClustersClientListByResourceGroupOptions added in v0.2.0 

type ClustersClientListByResourceGroupOptions struct {
}

ClustersClientListByResourceGroupOptions contains the optional parameters for the ClustersClient.ListByResourceGroup method.

type ClustersClientListByResourceGroupPager added in v0.2.0 

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

ClustersClientListByResourceGroupPager provides operations for iterating over paged responses.

func (*ClustersClientListByResourceGroupPager) Err added in v0.2.0 

func (p *ClustersClientListByResourceGroupPager) Err() error

Err returns the last error encountered while paging.

func (*ClustersClientListByResourceGroupPager) NextPage added in v0.2.0 

func (p *ClustersClientListByResourceGroupPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ClustersClientListByResourceGroupPager) PageResponse added in v0.2.0 

func (p *ClustersClientListByResourceGroupPager) PageResponse() ClustersClientListByResourceGroupResponse

PageResponse returns the current ClustersClientListByResourceGroupResponse page.

type ClustersClientListByResourceGroupResponse added in v0.2.0 

type ClustersClientListByResourceGroupResponse struct {
	ClustersClientListByResourceGroupResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientListByResourceGroupResponse contains the response from method ClustersClient.ListByResourceGroup.

type ClustersClientListByResourceGroupResult added in v0.2.0 

type ClustersClientListByResourceGroupResult struct {
	ClusterListResult
}

ClustersClientListByResourceGroupResult contains the result from method ClustersClient.ListByResourceGroup.

type ClustersClientListOptions added in v0.2.0 

type ClustersClientListOptions struct {
}

ClustersClientListOptions contains the optional parameters for the ClustersClient.List method.

type ClustersClientListPager added in v0.2.0 

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

ClustersClientListPager provides operations for iterating over paged responses.

func (*ClustersClientListPager) Err added in v0.2.0 

func (p *ClustersClientListPager) Err() error

Err returns the last error encountered while paging.

func (*ClustersClientListPager) NextPage added in v0.2.0 

func (p *ClustersClientListPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ClustersClientListPager) PageResponse added in v0.2.0 

func (p *ClustersClientListPager) PageResponse() ClustersClientListResponse

PageResponse returns the current ClustersClientListResponse page.

type ClustersClientListResponse added in v0.2.0 

type ClustersClientListResponse struct {
	ClustersClientListResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientListResponse contains the response from method ClustersClient.List.

type ClustersClientListResult added in v0.2.0 

type ClustersClientListResult struct {
	ClusterListResult
}

ClustersClientListResult contains the result from method ClustersClient.List.

type ClustersClientResizePoller added in v0.2.0 

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

ClustersClientResizePoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientResizePoller) Done added in v0.2.0 

func (p *ClustersClientResizePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientResizePoller) FinalResponse added in v0.2.0 

func (p *ClustersClientResizePoller) FinalResponse(ctx context.Context) (ClustersClientResizeResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientResizeResponse will be returned.

func (*ClustersClientResizePoller) Poll added in v0.2.0 

func (p *ClustersClientResizePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientResizePoller) ResumeToken added in v0.2.0 

func (p *ClustersClientResizePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientResizePollerResponse added in v0.2.0 

type ClustersClientResizePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientResizePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientResizePollerResponse contains the response from method ClustersClient.Resize.

func (ClustersClientResizePollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientResizePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientResizeResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientResizePollerResponse) Resume added in v0.2.0 

func (l *ClustersClientResizePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientResizePollerResponse from the provided client and resume token.

type ClustersClientResizeResponse added in v0.2.0 

type ClustersClientResizeResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientResizeResponse contains the response from method ClustersClient.Resize.

type ClustersClientRotateDiskEncryptionKeyPoller added in v0.2.0 

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

ClustersClientRotateDiskEncryptionKeyPoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientRotateDiskEncryptionKeyPoller) Done added in v0.2.0 

func (p *ClustersClientRotateDiskEncryptionKeyPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientRotateDiskEncryptionKeyPoller) FinalResponse added in v0.2.0 

func (p *ClustersClientRotateDiskEncryptionKeyPoller) FinalResponse(ctx context.Context) (ClustersClientRotateDiskEncryptionKeyResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientRotateDiskEncryptionKeyResponse will be returned.

func (*ClustersClientRotateDiskEncryptionKeyPoller) Poll added in v0.2.0 

func (p *ClustersClientRotateDiskEncryptionKeyPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientRotateDiskEncryptionKeyPoller) ResumeToken added in v0.2.0 

func (p *ClustersClientRotateDiskEncryptionKeyPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientRotateDiskEncryptionKeyPollerResponse added in v0.2.0 

type ClustersClientRotateDiskEncryptionKeyPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientRotateDiskEncryptionKeyPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientRotateDiskEncryptionKeyPollerResponse contains the response from method ClustersClient.RotateDiskEncryptionKey.

func (ClustersClientRotateDiskEncryptionKeyPollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientRotateDiskEncryptionKeyPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientRotateDiskEncryptionKeyResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientRotateDiskEncryptionKeyPollerResponse) Resume added in v0.2.0 

func (l *ClustersClientRotateDiskEncryptionKeyPollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientRotateDiskEncryptionKeyPollerResponse from the provided client and resume token.

type ClustersClientRotateDiskEncryptionKeyResponse added in v0.2.0 

type ClustersClientRotateDiskEncryptionKeyResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientRotateDiskEncryptionKeyResponse contains the response from method ClustersClient.RotateDiskEncryptionKey.

type ClustersClientUpdateAutoScaleConfigurationPoller added in v0.2.0 

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

ClustersClientUpdateAutoScaleConfigurationPoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientUpdateAutoScaleConfigurationPoller) Done added in v0.2.0 

func (p *ClustersClientUpdateAutoScaleConfigurationPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientUpdateAutoScaleConfigurationPoller) FinalResponse added in v0.2.0 

func (p *ClustersClientUpdateAutoScaleConfigurationPoller) FinalResponse(ctx context.Context) (ClustersClientUpdateAutoScaleConfigurationResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientUpdateAutoScaleConfigurationResponse will be returned.

func (*ClustersClientUpdateAutoScaleConfigurationPoller) Poll added in v0.2.0 

func (p *ClustersClientUpdateAutoScaleConfigurationPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientUpdateAutoScaleConfigurationPoller) ResumeToken added in v0.2.0 

func (p *ClustersClientUpdateAutoScaleConfigurationPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientUpdateAutoScaleConfigurationPollerResponse added in v0.2.0 

type ClustersClientUpdateAutoScaleConfigurationPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientUpdateAutoScaleConfigurationPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientUpdateAutoScaleConfigurationPollerResponse contains the response from method ClustersClient.UpdateAutoScaleConfiguration.

func (ClustersClientUpdateAutoScaleConfigurationPollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientUpdateAutoScaleConfigurationPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientUpdateAutoScaleConfigurationResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientUpdateAutoScaleConfigurationPollerResponse) Resume added in v0.2.0 

func (l *ClustersClientUpdateAutoScaleConfigurationPollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientUpdateAutoScaleConfigurationPollerResponse from the provided client and resume token.

type ClustersClientUpdateAutoScaleConfigurationResponse added in v0.2.0 

type ClustersClientUpdateAutoScaleConfigurationResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientUpdateAutoScaleConfigurationResponse contains the response from method ClustersClient.UpdateAutoScaleConfiguration.

type ClustersClientUpdateGatewaySettingsPoller added in v0.2.0 

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

ClustersClientUpdateGatewaySettingsPoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientUpdateGatewaySettingsPoller) Done added in v0.2.0 

func (p *ClustersClientUpdateGatewaySettingsPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientUpdateGatewaySettingsPoller) FinalResponse added in v0.2.0 

func (p *ClustersClientUpdateGatewaySettingsPoller) FinalResponse(ctx context.Context) (ClustersClientUpdateGatewaySettingsResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientUpdateGatewaySettingsResponse will be returned.

func (*ClustersClientUpdateGatewaySettingsPoller) Poll added in v0.2.0 

func (p *ClustersClientUpdateGatewaySettingsPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientUpdateGatewaySettingsPoller) ResumeToken added in v0.2.0 

func (p *ClustersClientUpdateGatewaySettingsPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientUpdateGatewaySettingsPollerResponse added in v0.2.0 

type ClustersClientUpdateGatewaySettingsPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientUpdateGatewaySettingsPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientUpdateGatewaySettingsPollerResponse contains the response from method ClustersClient.UpdateGatewaySettings.

func (ClustersClientUpdateGatewaySettingsPollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientUpdateGatewaySettingsPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientUpdateGatewaySettingsResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientUpdateGatewaySettingsPollerResponse) Resume added in v0.2.0 

func (l *ClustersClientUpdateGatewaySettingsPollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientUpdateGatewaySettingsPollerResponse from the provided client and resume token.

type ClustersClientUpdateGatewaySettingsResponse added in v0.2.0 

type ClustersClientUpdateGatewaySettingsResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientUpdateGatewaySettingsResponse contains the response from method ClustersClient.UpdateGatewaySettings.

type ClustersClientUpdateIdentityCertificatePoller added in v0.2.0 

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

ClustersClientUpdateIdentityCertificatePoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersClientUpdateIdentityCertificatePoller) Done added in v0.2.0 

func (p *ClustersClientUpdateIdentityCertificatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersClientUpdateIdentityCertificatePoller) FinalResponse added in v0.2.0 

func (p *ClustersClientUpdateIdentityCertificatePoller) FinalResponse(ctx context.Context) (ClustersClientUpdateIdentityCertificateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersClientUpdateIdentityCertificateResponse will be returned.

func (*ClustersClientUpdateIdentityCertificatePoller) Poll added in v0.2.0 

func (p *ClustersClientUpdateIdentityCertificatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersClientUpdateIdentityCertificatePoller) ResumeToken added in v0.2.0 

func (p *ClustersClientUpdateIdentityCertificatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersClientUpdateIdentityCertificatePollerResponse added in v0.2.0 

type ClustersClientUpdateIdentityCertificatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersClientUpdateIdentityCertificatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientUpdateIdentityCertificatePollerResponse contains the response from method ClustersClient.UpdateIdentityCertificate.

func (ClustersClientUpdateIdentityCertificatePollerResponse) PollUntilDone added in v0.2.0 

func (l ClustersClientUpdateIdentityCertificatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientUpdateIdentityCertificateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ClustersClientUpdateIdentityCertificatePollerResponse) Resume added in v0.2.0 

func (l *ClustersClientUpdateIdentityCertificatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersClientUpdateIdentityCertificatePollerResponse from the provided client and resume token.

type ClustersClientUpdateIdentityCertificateResponse added in v0.2.0 

type ClustersClientUpdateIdentityCertificateResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientUpdateIdentityCertificateResponse contains the response from method ClustersClient.UpdateIdentityCertificate.

type ClustersClientUpdateOptions added in v0.2.0 

type ClustersClientUpdateOptions struct {
}

ClustersClientUpdateOptions contains the optional parameters for the ClustersClient.Update method.

type ClustersClientUpdateResponse added in v0.2.0 

type ClustersClientUpdateResponse struct {
	ClustersClientUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersClientUpdateResponse contains the response from method ClustersClient.Update.

type ClustersClientUpdateResult added in v0.2.0 

type ClustersClientUpdateResult struct {
	Cluster
}

ClustersClientUpdateResult contains the result from method ClustersClient.Update.

type ComputeIsolationProperties 

type ComputeIsolationProperties struct {
	// The flag indicates whether enable compute isolation or not.
	EnableComputeIsolation *bool `json:"enableComputeIsolation,omitempty"`

	// The host sku.
	HostSKU *string `json:"hostSku,omitempty"`
}

ComputeIsolationProperties - The compute isolation properties.

type ComputeProfile 

type ComputeProfile struct {
	// The list of roles in the cluster.
	Roles []*Role `json:"roles,omitempty"`
}

ComputeProfile - Describes the compute profile.

func (ComputeProfile) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ComputeProfile.

type ConfigurationsClient 

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

ConfigurationsClient contains the methods for the Configurations group. Don't use this type directly, use NewConfigurationsClient() instead.

func NewConfigurationsClient 

func NewConfigurationsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ConfigurationsClient

NewConfigurationsClient creates a new instance of ConfigurationsClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*ConfigurationsClient) BeginUpdate 

func (client *ConfigurationsClient) BeginUpdate(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, parameters map[string]*string, options *ConfigurationsClientBeginUpdateOptions) (ConfigurationsClientUpdatePollerResponse, error)

BeginUpdate - Configures the HTTP settings on the specified cluster. This API is deprecated, please use UpdateGatewaySettings in cluster endpoint instead. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. configurationName - The name of the cluster configuration. parameters - The cluster configurations. options - ConfigurationsClientBeginUpdateOptions contains the optional parameters for the ConfigurationsClient.BeginUpdate method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/ChangeHttpConnectivityDisable.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewConfigurationsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginUpdate(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<configuration-name>",
		map[string]*string{
			"restAuthCredential.isEnabled": to.StringPtr("false"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ConfigurationsClient) Get 

func (client *ConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, options *ConfigurationsClientGetOptions) (ConfigurationsClientGetResponse, error)

Get - The configuration object for the specified cluster. This API is not recommended and might be removed in the future. Please consider using List configurations API instead. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. configurationName - The name of the cluster configuration. options - ConfigurationsClientGetOptions contains the optional parameters for the ConfigurationsClient.Get method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Configurations_Get.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewConfigurationsClient("<subscription-id>", cred, nil)
	res, err := client.Get(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<configuration-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ConfigurationsClientGetResult)
}

Output:

func (*ConfigurationsClient) List 

func (client *ConfigurationsClient) List(ctx context.Context, resourceGroupName string, clusterName string, options *ConfigurationsClientListOptions) (ConfigurationsClientListResponse, error)

List - Gets all configuration information for an HDI cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ConfigurationsClientListOptions contains the optional parameters for the ConfigurationsClient.List method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Configurations_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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewConfigurationsClient("<subscription-id>", cred, nil)
	res, err := client.List(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ConfigurationsClientListResult)
}

Output:

type ConfigurationsClientBeginUpdateOptions added in v0.2.0 

type ConfigurationsClientBeginUpdateOptions struct {
}

ConfigurationsClientBeginUpdateOptions contains the optional parameters for the ConfigurationsClient.BeginUpdate method.

type ConfigurationsClientGetOptions added in v0.2.0 

type ConfigurationsClientGetOptions struct {
}

ConfigurationsClientGetOptions contains the optional parameters for the ConfigurationsClient.Get method.

type ConfigurationsClientGetResponse added in v0.2.0 

type ConfigurationsClientGetResponse struct {
	ConfigurationsClientGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConfigurationsClientGetResponse contains the response from method ConfigurationsClient.Get.

type ConfigurationsClientGetResult added in v0.2.0 

type ConfigurationsClientGetResult struct {
	// The configuration object for the specified configuration for the specified cluster.
	Value map[string]*string
}

ConfigurationsClientGetResult contains the result from method ConfigurationsClient.Get.

type ConfigurationsClientListOptions added in v0.2.0 

type ConfigurationsClientListOptions struct {
}

ConfigurationsClientListOptions contains the optional parameters for the ConfigurationsClient.List method.

type ConfigurationsClientListResponse added in v0.2.0 

type ConfigurationsClientListResponse struct {
	ConfigurationsClientListResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConfigurationsClientListResponse contains the response from method ConfigurationsClient.List.

type ConfigurationsClientListResult added in v0.2.0 

type ConfigurationsClientListResult struct {
	ClusterConfigurations
}

ConfigurationsClientListResult contains the result from method ConfigurationsClient.List.

type ConfigurationsClientUpdatePoller added in v0.2.0 

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

ConfigurationsClientUpdatePoller provides polling facilities until the operation reaches a terminal state.

func (*ConfigurationsClientUpdatePoller) Done added in v0.2.0 

func (p *ConfigurationsClientUpdatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ConfigurationsClientUpdatePoller) FinalResponse added in v0.2.0 

func (p *ConfigurationsClientUpdatePoller) FinalResponse(ctx context.Context) (ConfigurationsClientUpdateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ConfigurationsClientUpdateResponse will be returned.

func (*ConfigurationsClientUpdatePoller) Poll added in v0.2.0 

func (p *ConfigurationsClientUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ConfigurationsClientUpdatePoller) ResumeToken added in v0.2.0 

func (p *ConfigurationsClientUpdatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ConfigurationsClientUpdatePollerResponse added in v0.2.0 

type ConfigurationsClientUpdatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ConfigurationsClientUpdatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConfigurationsClientUpdatePollerResponse contains the response from method ConfigurationsClient.Update.

func (ConfigurationsClientUpdatePollerResponse) PollUntilDone added in v0.2.0 

func (l ConfigurationsClientUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ConfigurationsClientUpdateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ConfigurationsClientUpdatePollerResponse) Resume added in v0.2.0 

func (l *ConfigurationsClientUpdatePollerResponse) Resume(ctx context.Context, client *ConfigurationsClient, token string) error

Resume rehydrates a ConfigurationsClientUpdatePollerResponse from the provided client and resume token.

type ConfigurationsClientUpdateResponse added in v0.2.0 

type ConfigurationsClientUpdateResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConfigurationsClientUpdateResponse contains the response from method ConfigurationsClient.Update.

type ConnectivityEndpoint 

type ConnectivityEndpoint struct {
	// The location of the endpoint.
	Location *string `json:"location,omitempty"`

	// The name of the endpoint.
	Name *string `json:"name,omitempty"`

	// The port to connect to.
	Port *int32 `json:"port,omitempty"`

	// The private ip address of the endpoint.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`

	// The protocol of the endpoint.
	Protocol *string `json:"protocol,omitempty"`
}

ConnectivityEndpoint - The connectivity properties

type CreatedByType 

type CreatedByType string

CreatedByType - The type of identity that created the resource. 

const (
	CreatedByTypeApplication     CreatedByType = "Application"
	CreatedByTypeKey             CreatedByType = "Key"
	CreatedByTypeManagedIdentity CreatedByType = "ManagedIdentity"
	CreatedByTypeUser            CreatedByType = "User"
)

func PossibleCreatedByTypeValues 

func PossibleCreatedByTypeValues() []CreatedByType

PossibleCreatedByTypeValues returns the possible values for the CreatedByType const type.

func (CreatedByType) ToPtr 

func (c CreatedByType) ToPtr() *CreatedByType

ToPtr returns a *CreatedByType pointing to the current value.

type DataDisksGroups 

type DataDisksGroups struct {
	// The number of disks per node.
	DisksPerNode *int32 `json:"disksPerNode,omitempty"`

	// READ-ONLY; ReadOnly. The DiskSize in GB. Do not set this value.
	DiskSizeGB *int32 `json:"diskSizeGB,omitempty" azure:"ro"`

	// READ-ONLY; ReadOnly. The storage account type. Do not set this value.
	StorageAccountType *string `json:"storageAccountType,omitempty" azure:"ro"`
}

DataDisksGroups - The data disks groups for the role.

type DaysOfWeek 

type DaysOfWeek string
const (
	DaysOfWeekFriday    DaysOfWeek = "Friday"
	DaysOfWeekMonday    DaysOfWeek = "Monday"
	DaysOfWeekSaturday  DaysOfWeek = "Saturday"
	DaysOfWeekSunday    DaysOfWeek = "Sunday"
	DaysOfWeekThursday  DaysOfWeek = "Thursday"
	DaysOfWeekTuesday   DaysOfWeek = "Tuesday"
	DaysOfWeekWednesday DaysOfWeek = "Wednesday"
)

func PossibleDaysOfWeekValues 

func PossibleDaysOfWeekValues() []DaysOfWeek

PossibleDaysOfWeekValues returns the possible values for the DaysOfWeek const type.

func (DaysOfWeek) ToPtr 

func (c DaysOfWeek) ToPtr() *DaysOfWeek

ToPtr returns a *DaysOfWeek pointing to the current value.

type Dimension 

type Dimension struct {
	// The display name of the dimension.
	DisplayName *string `json:"displayName,omitempty"`

	// The display name of the dimension.
	InternalName *string `json:"internalName,omitempty"`

	// The name of the dimension.
	Name *string `json:"name,omitempty"`

	// The flag indicates whether the metric will be exported for shoebox or not.
	ToBeExportedForShoebox *bool `json:"toBeExportedForShoebox,omitempty"`
}

Dimension - The definition of Dimension.

type DirectoryType 

type DirectoryType string

DirectoryType - The directory type. 

const (
	DirectoryTypeActiveDirectory DirectoryType = "ActiveDirectory"
)

func PossibleDirectoryTypeValues 

func PossibleDirectoryTypeValues() []DirectoryType

PossibleDirectoryTypeValues returns the possible values for the DirectoryType const type.

func (DirectoryType) ToPtr 

func (c DirectoryType) ToPtr() *DirectoryType

ToPtr returns a *DirectoryType pointing to the current value.

type DiskBillingMeters 

type DiskBillingMeters struct {
	// The managed disk meter guid.
	DiskRpMeter *string `json:"diskRpMeter,omitempty"`

	// The managed disk billing sku, P30 or S30.
	SKU *string `json:"sku,omitempty"`

	// The managed disk billing tier, Standard or Premium.
	Tier *Tier `json:"tier,omitempty"`
}

DiskBillingMeters - The disk billing meters.

type DiskEncryptionProperties 

type DiskEncryptionProperties struct {
	// Algorithm identifier for encryption, default RSA-OAEP.
	EncryptionAlgorithm *JSONWebKeyEncryptionAlgorithm `json:"encryptionAlgorithm,omitempty"`

	// Indicates whether or not resource disk encryption is enabled.
	EncryptionAtHost *bool `json:"encryptionAtHost,omitempty"`

	// Key name that is used for enabling disk encryption.
	KeyName *string `json:"keyName,omitempty"`

	// Specific key version that is used for enabling disk encryption.
	KeyVersion *string `json:"keyVersion,omitempty"`

	// Resource ID of Managed Identity that is used to access the key vault.
	MsiResourceID *string `json:"msiResourceId,omitempty"`

	// Base key vault URI where the customers key is located eg. https://myvault.vault.azure.net
	VaultURI *string `json:"vaultUri,omitempty"`
}

DiskEncryptionProperties - The disk encryption properties

type EncryptionInTransitProperties 

type EncryptionInTransitProperties struct {
	// Indicates whether or not inter cluster node communication is encrypted in transit.
	IsEncryptionInTransitEnabled *bool `json:"isEncryptionInTransitEnabled,omitempty"`
}

EncryptionInTransitProperties - The encryption-in-transit properties.

type ErrorResponse 

type ErrorResponse struct {
	// Error code
	Code *string `json:"code,omitempty"`

	// Error message indicating why the operation failed.
	Message *string `json:"message,omitempty"`
}

ErrorResponse - Describes the format of Error response.

type Errors 

type Errors struct {
	// The error code.
	Code *string `json:"code,omitempty"`

	// The error message.
	Message *string `json:"message,omitempty"`
}

Errors - The error message associated with the cluster creation.

type ExcludedServicesConfig 

type ExcludedServicesConfig struct {
	// The config id of excluded services.
	ExcludedServicesConfigID *string `json:"excludedServicesConfigId,omitempty"`

	// The list of excluded services.
	ExcludedServicesList *string `json:"excludedServicesList,omitempty"`
}

ExcludedServicesConfig - The configuration that services will be excluded when creating cluster.

type ExecuteScriptActionParameters 

type ExecuteScriptActionParameters struct {
	// REQUIRED; Gets or sets if the scripts needs to be persisted.
	PersistOnSuccess *bool `json:"persistOnSuccess,omitempty"`

	// The list of run time script actions.
	ScriptActions []*RuntimeScriptAction `json:"scriptActions,omitempty"`
}

ExecuteScriptActionParameters - The parameters for the script actions to execute on a running cluster.

func (ExecuteScriptActionParameters) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ExecuteScriptActionParameters.

type Extension 

type Extension struct {
	// The certificate for the cluster monitoring extensions.
	PrimaryKey *string `json:"primaryKey,omitempty"`

	// The workspace ID for the cluster monitoring extension.
	WorkspaceID *string `json:"workspaceId,omitempty"`
}

Extension - Cluster monitoring extensions.

type ExtensionsClient 

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

ExtensionsClient contains the methods for the Extensions group. Don't use this type directly, use NewExtensionsClient() instead.

func NewExtensionsClient 

func NewExtensionsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ExtensionsClient

NewExtensionsClient creates a new instance of ExtensionsClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*ExtensionsClient) BeginCreate 

func (client *ExtensionsClient) BeginCreate(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, parameters Extension, options *ExtensionsClientBeginCreateOptions) (ExtensionsClientCreatePollerResponse, error)

BeginCreate - Creates an HDInsight cluster extension. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. extensionName - The name of the cluster extension. parameters - The cluster extensions create request. options - ExtensionsClientBeginCreateOptions contains the optional parameters for the ExtensionsClient.BeginCreate method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/CreateExtension.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginCreate(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<extension-name>",
		armhdinsight.Extension{
			PrimaryKey:  to.StringPtr("<primary-key>"),
			WorkspaceID: to.StringPtr("<workspace-id>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ExtensionsClient) BeginDelete 

func (client *ExtensionsClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, options *ExtensionsClientBeginDeleteOptions) (ExtensionsClientDeletePollerResponse, error)

BeginDelete - Deletes the specified extension for HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. extensionName - The name of the cluster extension. options - ExtensionsClientBeginDeleteOptions contains the optional parameters for the ExtensionsClient.BeginDelete method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DeleteExtension.json 

package main

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginDelete(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<extension-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ExtensionsClient) BeginDisableAzureMonitor 

func (client *ExtensionsClient) BeginDisableAzureMonitor(ctx context.Context, resourceGroupName string, clusterName string, options *ExtensionsClientBeginDisableAzureMonitorOptions) (ExtensionsClientDisableAzureMonitorPollerResponse, error)

BeginDisableAzureMonitor - Disables the Azure Monitor on the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ExtensionsClientBeginDisableAzureMonitorOptions contains the optional parameters for the ExtensionsClient.BeginDisableAzureMonitor method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DisableLinuxClusterAzureMonitor.json 

package main

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginDisableAzureMonitor(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ExtensionsClient) BeginDisableMonitoring 

func (client *ExtensionsClient) BeginDisableMonitoring(ctx context.Context, resourceGroupName string, clusterName string, options *ExtensionsClientBeginDisableMonitoringOptions) (ExtensionsClientDisableMonitoringPollerResponse, error)

BeginDisableMonitoring - Disables the Operations Management Suite (OMS) on the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ExtensionsClientBeginDisableMonitoringOptions contains the optional parameters for the ExtensionsClient.BeginDisableMonitoring method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DisableLinuxClusterMonitoring.json 

package main

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginDisableMonitoring(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ExtensionsClient) BeginEnableAzureMonitor 

func (client *ExtensionsClient) BeginEnableAzureMonitor(ctx context.Context, resourceGroupName string, clusterName string, parameters AzureMonitorRequest, options *ExtensionsClientBeginEnableAzureMonitorOptions) (ExtensionsClientEnableAzureMonitorPollerResponse, error)

BeginEnableAzureMonitor - Enables the Azure Monitor on the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The Log Analytics workspace parameters. options - ExtensionsClientBeginEnableAzureMonitorOptions contains the optional parameters for the ExtensionsClient.BeginEnableAzureMonitor method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/EnableLinuxClusterAzureMonitor.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginEnableAzureMonitor(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.AzureMonitorRequest{
			PrimaryKey:  to.StringPtr("<primary-key>"),
			WorkspaceID: to.StringPtr("<workspace-id>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ExtensionsClient) BeginEnableMonitoring 

func (client *ExtensionsClient) BeginEnableMonitoring(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterMonitoringRequest, options *ExtensionsClientBeginEnableMonitoringOptions) (ExtensionsClientEnableMonitoringPollerResponse, error)

BeginEnableMonitoring - Enables the Operations Management Suite (OMS) on the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. parameters - The Operations Management Suite (OMS) workspace parameters. options - ExtensionsClientBeginEnableMonitoringOptions contains the optional parameters for the ExtensionsClient.BeginEnableMonitoring method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/EnableLinuxClusterMonitoring.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginEnableMonitoring(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		armhdinsight.ClusterMonitoringRequest{
			PrimaryKey:  to.StringPtr("<primary-key>"),
			WorkspaceID: to.StringPtr("<workspace-id>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ExtensionsClient) Get 

func (client *ExtensionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, options *ExtensionsClientGetOptions) (ExtensionsClientGetResponse, error)

Get - Gets the extension properties for the specified HDInsight cluster extension. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. extensionName - The name of the cluster extension. options - ExtensionsClientGetOptions contains the optional parameters for the ExtensionsClient.Get method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetExtension.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	res, err := client.Get(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<extension-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ExtensionsClientGetResult)
}

Output:

func (*ExtensionsClient) GetAzureAsyncOperationStatus 

func (client *ExtensionsClient) GetAzureAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, operationID string, options *ExtensionsClientGetAzureAsyncOperationStatusOptions) (ExtensionsClientGetAzureAsyncOperationStatusResponse, error)

GetAzureAsyncOperationStatus - Gets the async operation status. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. extensionName - The name of the cluster extension. operationID - The long running operation id. options - ExtensionsClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the ExtensionsClient.GetAzureAsyncOperationStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetExtensionCreationAsyncOperationStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	res, err := client.GetAzureAsyncOperationStatus(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<extension-name>",
		"<operation-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ExtensionsClientGetAzureAsyncOperationStatusResult)
}

Output:

func (*ExtensionsClient) GetAzureMonitorStatus 

func (client *ExtensionsClient) GetAzureMonitorStatus(ctx context.Context, resourceGroupName string, clusterName string, options *ExtensionsClientGetAzureMonitorStatusOptions) (ExtensionsClientGetAzureMonitorStatusResponse, error)

GetAzureMonitorStatus - Gets the status of Azure Monitor on the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ExtensionsClientGetAzureMonitorStatusOptions contains the optional parameters for the ExtensionsClient.GetAzureMonitorStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetLinuxClusterAzureMonitorStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	res, err := client.GetAzureMonitorStatus(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ExtensionsClientGetAzureMonitorStatusResult)
}

Output:

func (*ExtensionsClient) GetMonitoringStatus 

func (client *ExtensionsClient) GetMonitoringStatus(ctx context.Context, resourceGroupName string, clusterName string, options *ExtensionsClientGetMonitoringStatusOptions) (ExtensionsClientGetMonitoringStatusResponse, error)

GetMonitoringStatus - Gets the status of Operations Management Suite (OMS) on the HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ExtensionsClientGetMonitoringStatusOptions contains the optional parameters for the ExtensionsClient.GetMonitoringStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetLinuxClusterMonitoringStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewExtensionsClient("<subscription-id>", cred, nil)
	res, err := client.GetMonitoringStatus(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ExtensionsClientGetMonitoringStatusResult)
}

Output:

type ExtensionsClientBeginCreateOptions added in v0.2.0 

type ExtensionsClientBeginCreateOptions struct {
}

ExtensionsClientBeginCreateOptions contains the optional parameters for the ExtensionsClient.BeginCreate method.

type ExtensionsClientBeginDeleteOptions added in v0.2.0 

type ExtensionsClientBeginDeleteOptions struct {
}

ExtensionsClientBeginDeleteOptions contains the optional parameters for the ExtensionsClient.BeginDelete method.

type ExtensionsClientBeginDisableAzureMonitorOptions added in v0.2.0 

type ExtensionsClientBeginDisableAzureMonitorOptions struct {
}

ExtensionsClientBeginDisableAzureMonitorOptions contains the optional parameters for the ExtensionsClient.BeginDisableAzureMonitor method.

type ExtensionsClientBeginDisableMonitoringOptions added in v0.2.0 

type ExtensionsClientBeginDisableMonitoringOptions struct {
}

ExtensionsClientBeginDisableMonitoringOptions contains the optional parameters for the ExtensionsClient.BeginDisableMonitoring method.

type ExtensionsClientBeginEnableAzureMonitorOptions added in v0.2.0 

type ExtensionsClientBeginEnableAzureMonitorOptions struct {
}

ExtensionsClientBeginEnableAzureMonitorOptions contains the optional parameters for the ExtensionsClient.BeginEnableAzureMonitor method.

type ExtensionsClientBeginEnableMonitoringOptions added in v0.2.0 

type ExtensionsClientBeginEnableMonitoringOptions struct {
}

ExtensionsClientBeginEnableMonitoringOptions contains the optional parameters for the ExtensionsClient.BeginEnableMonitoring method.

type ExtensionsClientCreatePoller added in v0.2.0 

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

ExtensionsClientCreatePoller provides polling facilities until the operation reaches a terminal state.

func (*ExtensionsClientCreatePoller) Done added in v0.2.0 

func (p *ExtensionsClientCreatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ExtensionsClientCreatePoller) FinalResponse added in v0.2.0 

func (p *ExtensionsClientCreatePoller) FinalResponse(ctx context.Context) (ExtensionsClientCreateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ExtensionsClientCreateResponse will be returned.

func (*ExtensionsClientCreatePoller) Poll added in v0.2.0 

func (p *ExtensionsClientCreatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ExtensionsClientCreatePoller) ResumeToken added in v0.2.0 

func (p *ExtensionsClientCreatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ExtensionsClientCreatePollerResponse added in v0.2.0 

type ExtensionsClientCreatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ExtensionsClientCreatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientCreatePollerResponse contains the response from method ExtensionsClient.Create.

func (ExtensionsClientCreatePollerResponse) PollUntilDone added in v0.2.0 

func (l ExtensionsClientCreatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ExtensionsClientCreateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ExtensionsClientCreatePollerResponse) Resume added in v0.2.0 

func (l *ExtensionsClientCreatePollerResponse) Resume(ctx context.Context, client *ExtensionsClient, token string) error

Resume rehydrates a ExtensionsClientCreatePollerResponse from the provided client and resume token.

type ExtensionsClientCreateResponse added in v0.2.0 

type ExtensionsClientCreateResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientCreateResponse contains the response from method ExtensionsClient.Create.

type ExtensionsClientDeletePoller added in v0.2.0 

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

ExtensionsClientDeletePoller provides polling facilities until the operation reaches a terminal state.

func (*ExtensionsClientDeletePoller) Done added in v0.2.0 

func (p *ExtensionsClientDeletePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ExtensionsClientDeletePoller) FinalResponse added in v0.2.0 

func (p *ExtensionsClientDeletePoller) FinalResponse(ctx context.Context) (ExtensionsClientDeleteResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ExtensionsClientDeleteResponse will be returned.

func (*ExtensionsClientDeletePoller) Poll added in v0.2.0 

func (p *ExtensionsClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ExtensionsClientDeletePoller) ResumeToken added in v0.2.0 

func (p *ExtensionsClientDeletePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ExtensionsClientDeletePollerResponse added in v0.2.0 

type ExtensionsClientDeletePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ExtensionsClientDeletePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientDeletePollerResponse contains the response from method ExtensionsClient.Delete.

func (ExtensionsClientDeletePollerResponse) PollUntilDone added in v0.2.0 

func (l ExtensionsClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ExtensionsClientDeleteResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ExtensionsClientDeletePollerResponse) Resume added in v0.2.0 

func (l *ExtensionsClientDeletePollerResponse) Resume(ctx context.Context, client *ExtensionsClient, token string) error

Resume rehydrates a ExtensionsClientDeletePollerResponse from the provided client and resume token.

type ExtensionsClientDeleteResponse added in v0.2.0 

type ExtensionsClientDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientDeleteResponse contains the response from method ExtensionsClient.Delete.

type ExtensionsClientDisableAzureMonitorPoller added in v0.2.0 

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

ExtensionsClientDisableAzureMonitorPoller provides polling facilities until the operation reaches a terminal state.

func (*ExtensionsClientDisableAzureMonitorPoller) Done added in v0.2.0 

func (p *ExtensionsClientDisableAzureMonitorPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ExtensionsClientDisableAzureMonitorPoller) FinalResponse added in v0.2.0 

func (p *ExtensionsClientDisableAzureMonitorPoller) FinalResponse(ctx context.Context) (ExtensionsClientDisableAzureMonitorResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ExtensionsClientDisableAzureMonitorResponse will be returned.

func (*ExtensionsClientDisableAzureMonitorPoller) Poll added in v0.2.0 

func (p *ExtensionsClientDisableAzureMonitorPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ExtensionsClientDisableAzureMonitorPoller) ResumeToken added in v0.2.0 

func (p *ExtensionsClientDisableAzureMonitorPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ExtensionsClientDisableAzureMonitorPollerResponse added in v0.2.0 

type ExtensionsClientDisableAzureMonitorPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ExtensionsClientDisableAzureMonitorPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientDisableAzureMonitorPollerResponse contains the response from method ExtensionsClient.DisableAzureMonitor.

func (ExtensionsClientDisableAzureMonitorPollerResponse) PollUntilDone added in v0.2.0 

func (l ExtensionsClientDisableAzureMonitorPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ExtensionsClientDisableAzureMonitorResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ExtensionsClientDisableAzureMonitorPollerResponse) Resume added in v0.2.0 

func (l *ExtensionsClientDisableAzureMonitorPollerResponse) Resume(ctx context.Context, client *ExtensionsClient, token string) error

Resume rehydrates a ExtensionsClientDisableAzureMonitorPollerResponse from the provided client and resume token.

type ExtensionsClientDisableAzureMonitorResponse added in v0.2.0 

type ExtensionsClientDisableAzureMonitorResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientDisableAzureMonitorResponse contains the response from method ExtensionsClient.DisableAzureMonitor.

type ExtensionsClientDisableMonitoringPoller added in v0.2.0 

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

ExtensionsClientDisableMonitoringPoller provides polling facilities until the operation reaches a terminal state.

func (*ExtensionsClientDisableMonitoringPoller) Done added in v0.2.0 

func (p *ExtensionsClientDisableMonitoringPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ExtensionsClientDisableMonitoringPoller) FinalResponse added in v0.2.0 

func (p *ExtensionsClientDisableMonitoringPoller) FinalResponse(ctx context.Context) (ExtensionsClientDisableMonitoringResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ExtensionsClientDisableMonitoringResponse will be returned.

func (*ExtensionsClientDisableMonitoringPoller) Poll added in v0.2.0 

func (p *ExtensionsClientDisableMonitoringPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ExtensionsClientDisableMonitoringPoller) ResumeToken added in v0.2.0 

func (p *ExtensionsClientDisableMonitoringPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ExtensionsClientDisableMonitoringPollerResponse added in v0.2.0 

type ExtensionsClientDisableMonitoringPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ExtensionsClientDisableMonitoringPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientDisableMonitoringPollerResponse contains the response from method ExtensionsClient.DisableMonitoring.

func (ExtensionsClientDisableMonitoringPollerResponse) PollUntilDone added in v0.2.0 

func (l ExtensionsClientDisableMonitoringPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ExtensionsClientDisableMonitoringResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ExtensionsClientDisableMonitoringPollerResponse) Resume added in v0.2.0 

func (l *ExtensionsClientDisableMonitoringPollerResponse) Resume(ctx context.Context, client *ExtensionsClient, token string) error

Resume rehydrates a ExtensionsClientDisableMonitoringPollerResponse from the provided client and resume token.

type ExtensionsClientDisableMonitoringResponse added in v0.2.0 

type ExtensionsClientDisableMonitoringResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientDisableMonitoringResponse contains the response from method ExtensionsClient.DisableMonitoring.

type ExtensionsClientEnableAzureMonitorPoller added in v0.2.0 

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

ExtensionsClientEnableAzureMonitorPoller provides polling facilities until the operation reaches a terminal state.

func (*ExtensionsClientEnableAzureMonitorPoller) Done added in v0.2.0 

func (p *ExtensionsClientEnableAzureMonitorPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ExtensionsClientEnableAzureMonitorPoller) FinalResponse added in v0.2.0 

func (p *ExtensionsClientEnableAzureMonitorPoller) FinalResponse(ctx context.Context) (ExtensionsClientEnableAzureMonitorResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ExtensionsClientEnableAzureMonitorResponse will be returned.

func (*ExtensionsClientEnableAzureMonitorPoller) Poll added in v0.2.0 

func (p *ExtensionsClientEnableAzureMonitorPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ExtensionsClientEnableAzureMonitorPoller) ResumeToken added in v0.2.0 

func (p *ExtensionsClientEnableAzureMonitorPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ExtensionsClientEnableAzureMonitorPollerResponse added in v0.2.0 

type ExtensionsClientEnableAzureMonitorPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ExtensionsClientEnableAzureMonitorPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientEnableAzureMonitorPollerResponse contains the response from method ExtensionsClient.EnableAzureMonitor.

func (ExtensionsClientEnableAzureMonitorPollerResponse) PollUntilDone added in v0.2.0 

func (l ExtensionsClientEnableAzureMonitorPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ExtensionsClientEnableAzureMonitorResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ExtensionsClientEnableAzureMonitorPollerResponse) Resume added in v0.2.0 

func (l *ExtensionsClientEnableAzureMonitorPollerResponse) Resume(ctx context.Context, client *ExtensionsClient, token string) error

Resume rehydrates a ExtensionsClientEnableAzureMonitorPollerResponse from the provided client and resume token.

type ExtensionsClientEnableAzureMonitorResponse added in v0.2.0 

type ExtensionsClientEnableAzureMonitorResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientEnableAzureMonitorResponse contains the response from method ExtensionsClient.EnableAzureMonitor.

type ExtensionsClientEnableMonitoringPoller added in v0.2.0 

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

ExtensionsClientEnableMonitoringPoller provides polling facilities until the operation reaches a terminal state.

func (*ExtensionsClientEnableMonitoringPoller) Done added in v0.2.0 

func (p *ExtensionsClientEnableMonitoringPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ExtensionsClientEnableMonitoringPoller) FinalResponse added in v0.2.0 

func (p *ExtensionsClientEnableMonitoringPoller) FinalResponse(ctx context.Context) (ExtensionsClientEnableMonitoringResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ExtensionsClientEnableMonitoringResponse will be returned.

func (*ExtensionsClientEnableMonitoringPoller) Poll added in v0.2.0 

func (p *ExtensionsClientEnableMonitoringPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ExtensionsClientEnableMonitoringPoller) ResumeToken added in v0.2.0 

func (p *ExtensionsClientEnableMonitoringPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ExtensionsClientEnableMonitoringPollerResponse added in v0.2.0 

type ExtensionsClientEnableMonitoringPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ExtensionsClientEnableMonitoringPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientEnableMonitoringPollerResponse contains the response from method ExtensionsClient.EnableMonitoring.

func (ExtensionsClientEnableMonitoringPollerResponse) PollUntilDone added in v0.2.0 

func (l ExtensionsClientEnableMonitoringPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ExtensionsClientEnableMonitoringResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*ExtensionsClientEnableMonitoringPollerResponse) Resume added in v0.2.0 

func (l *ExtensionsClientEnableMonitoringPollerResponse) Resume(ctx context.Context, client *ExtensionsClient, token string) error

Resume rehydrates a ExtensionsClientEnableMonitoringPollerResponse from the provided client and resume token.

type ExtensionsClientEnableMonitoringResponse added in v0.2.0 

type ExtensionsClientEnableMonitoringResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientEnableMonitoringResponse contains the response from method ExtensionsClient.EnableMonitoring.

type ExtensionsClientGetAzureAsyncOperationStatusOptions added in v0.2.0 

type ExtensionsClientGetAzureAsyncOperationStatusOptions struct {
}

ExtensionsClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the ExtensionsClient.GetAzureAsyncOperationStatus method.

type ExtensionsClientGetAzureAsyncOperationStatusResponse added in v0.2.0 

type ExtensionsClientGetAzureAsyncOperationStatusResponse struct {
	ExtensionsClientGetAzureAsyncOperationStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientGetAzureAsyncOperationStatusResponse contains the response from method ExtensionsClient.GetAzureAsyncOperationStatus.

type ExtensionsClientGetAzureAsyncOperationStatusResult added in v0.2.0 

type ExtensionsClientGetAzureAsyncOperationStatusResult struct {
	AsyncOperationResult
}

ExtensionsClientGetAzureAsyncOperationStatusResult contains the result from method ExtensionsClient.GetAzureAsyncOperationStatus.

type ExtensionsClientGetAzureMonitorStatusOptions added in v0.2.0 

type ExtensionsClientGetAzureMonitorStatusOptions struct {
}

ExtensionsClientGetAzureMonitorStatusOptions contains the optional parameters for the ExtensionsClient.GetAzureMonitorStatus method.

type ExtensionsClientGetAzureMonitorStatusResponse added in v0.2.0 

type ExtensionsClientGetAzureMonitorStatusResponse struct {
	ExtensionsClientGetAzureMonitorStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientGetAzureMonitorStatusResponse contains the response from method ExtensionsClient.GetAzureMonitorStatus.

type ExtensionsClientGetAzureMonitorStatusResult added in v0.2.0 

type ExtensionsClientGetAzureMonitorStatusResult struct {
	AzureMonitorResponse
}

ExtensionsClientGetAzureMonitorStatusResult contains the result from method ExtensionsClient.GetAzureMonitorStatus.

type ExtensionsClientGetMonitoringStatusOptions added in v0.2.0 

type ExtensionsClientGetMonitoringStatusOptions struct {
}

ExtensionsClientGetMonitoringStatusOptions contains the optional parameters for the ExtensionsClient.GetMonitoringStatus method.

type ExtensionsClientGetMonitoringStatusResponse added in v0.2.0 

type ExtensionsClientGetMonitoringStatusResponse struct {
	ExtensionsClientGetMonitoringStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientGetMonitoringStatusResponse contains the response from method ExtensionsClient.GetMonitoringStatus.

type ExtensionsClientGetMonitoringStatusResult added in v0.2.0 

type ExtensionsClientGetMonitoringStatusResult struct {
	ClusterMonitoringResponse
}

ExtensionsClientGetMonitoringStatusResult contains the result from method ExtensionsClient.GetMonitoringStatus.

type ExtensionsClientGetOptions added in v0.2.0 

type ExtensionsClientGetOptions struct {
}

ExtensionsClientGetOptions contains the optional parameters for the ExtensionsClient.Get method.

type ExtensionsClientGetResponse added in v0.2.0 

type ExtensionsClientGetResponse struct {
	ExtensionsClientGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ExtensionsClientGetResponse contains the response from method ExtensionsClient.Get.

type ExtensionsClientGetResult added in v0.2.0 

type ExtensionsClientGetResult struct {
	ClusterMonitoringResponse
}

ExtensionsClientGetResult contains the result from method ExtensionsClient.Get.

type FilterMode 

type FilterMode string

FilterMode - The filtering mode. Effectively this can enabling or disabling the VM sizes in a particular set. 

const (
	FilterModeDefault   FilterMode = "Default"
	FilterModeExclude   FilterMode = "Exclude"
	FilterModeInclude   FilterMode = "Include"
	FilterModeRecommend FilterMode = "Recommend"
)

func PossibleFilterModeValues 

func PossibleFilterModeValues() []FilterMode

PossibleFilterModeValues returns the possible values for the FilterMode const type.

func (FilterMode) ToPtr 

func (c FilterMode) ToPtr() *FilterMode

ToPtr returns a *FilterMode pointing to the current value.

type GatewaySettings 

type GatewaySettings struct {
	// READ-ONLY; Indicates whether or not the gateway settings based authorization is enabled.
	IsCredentialEnabled *string `json:"restAuthCredential.isEnabled,omitempty" azure:"ro"`

	// READ-ONLY; The gateway settings user password.
	Password *string `json:"restAuthCredential.password,omitempty" azure:"ro"`

	// READ-ONLY; The gateway settings user name.
	UserName *string `json:"restAuthCredential.username,omitempty" azure:"ro"`
}

GatewaySettings - Gateway settings.

type HDInsightClusterProvisioningState 

type HDInsightClusterProvisioningState string

HDInsightClusterProvisioningState - The provisioning state, which only appears in the response. 

const (
	HDInsightClusterProvisioningStateCanceled   HDInsightClusterProvisioningState = "Canceled"
	HDInsightClusterProvisioningStateDeleting   HDInsightClusterProvisioningState = "Deleting"
	HDInsightClusterProvisioningStateFailed     HDInsightClusterProvisioningState = "Failed"
	HDInsightClusterProvisioningStateInProgress HDInsightClusterProvisioningState = "InProgress"
	HDInsightClusterProvisioningStateSucceeded  HDInsightClusterProvisioningState = "Succeeded"
)

func PossibleHDInsightClusterProvisioningStateValues 

func PossibleHDInsightClusterProvisioningStateValues() []HDInsightClusterProvisioningState

PossibleHDInsightClusterProvisioningStateValues returns the possible values for the HDInsightClusterProvisioningState const type.

func (HDInsightClusterProvisioningState) ToPtr 

func (c HDInsightClusterProvisioningState) ToPtr() *HDInsightClusterProvisioningState

ToPtr returns a *HDInsightClusterProvisioningState pointing to the current value.

type HardwareProfile 

type HardwareProfile struct {
	// The size of the VM
	VMSize *string `json:"vmSize,omitempty"`
}

HardwareProfile - The hardware profile.

type HostInfo 

type HostInfo struct {
	// The effective disk encryption key URL used by the host
	EffectiveDiskEncryptionKeyURL *string `json:"effectiveDiskEncryptionKeyUrl,omitempty"`

	// The Fully Qualified Domain Name of host
	Fqdn *string `json:"fqdn,omitempty"`

	// The host name
	Name *string `json:"name,omitempty"`
}

HostInfo - The cluster host information.

type IPConfiguration 

type IPConfiguration struct {
	// REQUIRED; The name of private link IP configuration.
	Name *string `json:"name,omitempty"`

	// The private link ip configuration properties.
	Properties *IPConfigurationProperties `json:"properties,omitempty"`

	// READ-ONLY; The private link IP configuration id.
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The type of the private link IP configuration.
	Type *string `json:"type,omitempty" azure:"ro"`
}

IPConfiguration - The ip configurations for the private link service.

type IPConfigurationProperties 

type IPConfigurationProperties struct {
	// Indicates whether this IP configuration is primary for the corresponding NIC.
	Primary *bool `json:"primary,omitempty"`

	// The IP address.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`

	// The method that private IP address is allocated.
	PrivateIPAllocationMethod *PrivateIPAllocationMethod `json:"privateIPAllocationMethod,omitempty"`

	// The subnet resource id.
	Subnet *ResourceID `json:"subnet,omitempty"`

	// READ-ONLY; The private link configuration provisioning state, which only appears in the response.
	ProvisioningState *PrivateLinkConfigurationProvisioningState `json:"provisioningState,omitempty" azure:"ro"`
}

IPConfigurationProperties - The private link ip configuration properties.

type JSONWebKeyEncryptionAlgorithm 

type JSONWebKeyEncryptionAlgorithm string

JSONWebKeyEncryptionAlgorithm - Algorithm identifier for encryption, default RSA-OAEP. 

const (
	JSONWebKeyEncryptionAlgorithmRSA15      JSONWebKeyEncryptionAlgorithm = "RSA1_5"
	JSONWebKeyEncryptionAlgorithmRSAOAEP    JSONWebKeyEncryptionAlgorithm = "RSA-OAEP"
	JSONWebKeyEncryptionAlgorithmRSAOAEP256 JSONWebKeyEncryptionAlgorithm = "RSA-OAEP-256"
)

func PossibleJSONWebKeyEncryptionAlgorithmValues 

func PossibleJSONWebKeyEncryptionAlgorithmValues() []JSONWebKeyEncryptionAlgorithm

PossibleJSONWebKeyEncryptionAlgorithmValues returns the possible values for the JSONWebKeyEncryptionAlgorithm const type.

func (JSONWebKeyEncryptionAlgorithm) ToPtr 

func (c JSONWebKeyEncryptionAlgorithm) ToPtr() *JSONWebKeyEncryptionAlgorithm

ToPtr returns a *JSONWebKeyEncryptionAlgorithm pointing to the current value.

type KafkaRestProperties 

type KafkaRestProperties struct {
	// The information of AAD security group.
	ClientGroupInfo *ClientGroupInfo `json:"clientGroupInfo,omitempty"`

	// The configurations that need to be overriden.
	ConfigurationOverride map[string]*string `json:"configurationOverride,omitempty"`
}

KafkaRestProperties - The kafka rest proxy configuration which contains AAD security group information.

func (KafkaRestProperties) MarshalJSON 

func (k KafkaRestProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type KafkaRestProperties.

type LinuxOperatingSystemProfile 

type LinuxOperatingSystemProfile struct {
	// The password.
	Password *string `json:"password,omitempty"`

	// The SSH profile.
	SSHProfile *SSHProfile `json:"sshProfile,omitempty"`

	// The username.
	Username *string `json:"username,omitempty"`
}

LinuxOperatingSystemProfile - The ssh username, password, and ssh public key.

type LocalizedName 

type LocalizedName struct {
	// The localized name of the used resource.
	LocalizedValue *string `json:"localizedValue,omitempty"`

	// The name of the used resource.
	Value *string `json:"value,omitempty"`
}

LocalizedName - The details about the localizable name of a type of usage.

type LocationsClient 

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

LocationsClient contains the methods for the Locations group. Don't use this type directly, use NewLocationsClient() instead.

func NewLocationsClient 

func NewLocationsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *LocationsClient

NewLocationsClient creates a new instance of LocationsClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*LocationsClient) CheckNameAvailability 

func (client *LocationsClient) CheckNameAvailability(ctx context.Context, location string, parameters NameAvailabilityCheckRequestParameters, options *LocationsClientCheckNameAvailabilityOptions) (LocationsClientCheckNameAvailabilityResponse, error)

CheckNameAvailability - Check the cluster name is available or not. If the operation fails it returns an *azcore.ResponseError type. location - The Azure location (region) for which to make the request. options - LocationsClientCheckNameAvailabilityOptions contains the optional parameters for the LocationsClient.CheckNameAvailability method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Locations_CheckClusterNameAvailability.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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewLocationsClient("<subscription-id>", cred, nil)
	res, err := client.CheckNameAvailability(ctx,
		"<location>",
		armhdinsight.NameAvailabilityCheckRequestParameters{
			Name: to.StringPtr("<name>"),
			Type: to.StringPtr("<type>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.LocationsClientCheckNameAvailabilityResult)
}

Output:

func (*LocationsClient) GetAzureAsyncOperationStatus 

func (client *LocationsClient) GetAzureAsyncOperationStatus(ctx context.Context, location string, operationID string, options *LocationsClientGetAzureAsyncOperationStatusOptions) (LocationsClientGetAzureAsyncOperationStatusResponse, error)

GetAzureAsyncOperationStatus - Get the async operation status. If the operation fails it returns an *azcore.ResponseError type. location - The Azure location (region) for which to make the request. operationID - The long running operation id. options - LocationsClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the LocationsClient.GetAzureAsyncOperationStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Locations_GetAsyncOperationStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewLocationsClient("<subscription-id>", cred, nil)
	res, err := client.GetAzureAsyncOperationStatus(ctx,
		"<location>",
		"<operation-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.LocationsClientGetAzureAsyncOperationStatusResult)
}

Output:

func (*LocationsClient) GetCapabilities 

func (client *LocationsClient) GetCapabilities(ctx context.Context, location string, options *LocationsClientGetCapabilitiesOptions) (LocationsClientGetCapabilitiesResponse, error)

GetCapabilities - Gets the capabilities for the specified location. If the operation fails it returns an *azcore.ResponseError type. location - The Azure location (region) for which to make the request. options - LocationsClientGetCapabilitiesOptions contains the optional parameters for the LocationsClient.GetCapabilities method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetHDInsightCapabilities.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewLocationsClient("<subscription-id>", cred, nil)
	res, err := client.GetCapabilities(ctx,
		"<location>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.LocationsClientGetCapabilitiesResult)
}

Output:

func (*LocationsClient) ListBillingSpecs 

func (client *LocationsClient) ListBillingSpecs(ctx context.Context, location string, options *LocationsClientListBillingSpecsOptions) (LocationsClientListBillingSpecsResponse, error)

ListBillingSpecs - Lists the billingSpecs for the specified subscription and location. If the operation fails it returns an *azcore.ResponseError type. location - The Azure location (region) for which to make the request. options - LocationsClientListBillingSpecsOptions contains the optional parameters for the LocationsClient.ListBillingSpecs method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Locations_ListBillingSpecs.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewLocationsClient("<subscription-id>", cred, nil)
	res, err := client.ListBillingSpecs(ctx,
		"<location>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.LocationsClientListBillingSpecsResult)
}

Output:

func (*LocationsClient) ListUsages 

func (client *LocationsClient) ListUsages(ctx context.Context, location string, options *LocationsClientListUsagesOptions) (LocationsClientListUsagesResponse, error)

ListUsages - Lists the usages for the specified location. If the operation fails it returns an *azcore.ResponseError type. location - The Azure location (region) for which to make the request. options - LocationsClientListUsagesOptions contains the optional parameters for the LocationsClient.ListUsages method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetHDInsightUsages.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewLocationsClient("<subscription-id>", cred, nil)
	res, err := client.ListUsages(ctx,
		"<location>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.LocationsClientListUsagesResult)
}

Output:

func (*LocationsClient) ValidateClusterCreateRequest 

func (client *LocationsClient) ValidateClusterCreateRequest(ctx context.Context, location string, parameters ClusterCreateRequestValidationParameters, options *LocationsClientValidateClusterCreateRequestOptions) (LocationsClientValidateClusterCreateRequestResponse, error)

ValidateClusterCreateRequest - Validate the cluster create request spec is valid or not. If the operation fails it returns an *azcore.ResponseError type. location - The Azure location (region) for which to make the request. options - LocationsClientValidateClusterCreateRequestOptions contains the optional parameters for the LocationsClient.ValidateClusterCreateRequest method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/HDI_Locations_ValidateClusterCreateRequest.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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewLocationsClient("<subscription-id>", cred, nil)
	res, err := client.ValidateClusterCreateRequest(ctx,
		"<location>",
		armhdinsight.ClusterCreateRequestValidationParameters{
			Location: to.StringPtr("<location>"),
			Properties: &armhdinsight.ClusterCreateProperties{
				ClusterDefinition: &armhdinsight.ClusterDefinition{
					ComponentVersion: map[string]*string{
						"Spark": to.StringPtr("2.4"),
					},
					Configurations: map[string]interface{}{
						"gateway": map[string]interface{}{
							"restAuthCredential.isEnabled": true,
							"restAuthCredential.password":  "**********",
							"restAuthCredential.username":  "admin",
						},
					},
					Kind: to.StringPtr("<kind>"),
				},
				ClusterVersion: to.StringPtr("<cluster-version>"),
				ComputeProfile: &armhdinsight.ComputeProfile{
					Roles: []*armhdinsight.Role{
						{
							Name: to.StringPtr("<name>"),
							HardwareProfile: &armhdinsight.HardwareProfile{
								VMSize: to.StringPtr("<vmsize>"),
							},
							MinInstanceCount: to.Int32Ptr(1),
							OSProfile: &armhdinsight.OsProfile{
								LinuxOperatingSystemProfile: &armhdinsight.LinuxOperatingSystemProfile{
									Password: to.StringPtr("<password>"),
									Username: to.StringPtr("<username>"),
								},
							},
							ScriptActions:       []*armhdinsight.ScriptAction{},
							TargetInstanceCount: to.Int32Ptr(2),
						},
						{
							Name: to.StringPtr("<name>"),
							HardwareProfile: &armhdinsight.HardwareProfile{
								VMSize: to.StringPtr("<vmsize>"),
							},
							OSProfile: &armhdinsight.OsProfile{
								LinuxOperatingSystemProfile: &armhdinsight.LinuxOperatingSystemProfile{
									Password: to.StringPtr("<password>"),
									Username: to.StringPtr("<username>"),
								},
							},
							ScriptActions:       []*armhdinsight.ScriptAction{},
							TargetInstanceCount: to.Int32Ptr(4),
						},
						{
							Name: to.StringPtr("<name>"),
							HardwareProfile: &armhdinsight.HardwareProfile{
								VMSize: to.StringPtr("<vmsize>"),
							},
							MinInstanceCount: to.Int32Ptr(1),
							OSProfile: &armhdinsight.OsProfile{
								LinuxOperatingSystemProfile: &armhdinsight.LinuxOperatingSystemProfile{
									Password: to.StringPtr("<password>"),
									Username: to.StringPtr("<username>"),
								},
							},
							ScriptActions:       []*armhdinsight.ScriptAction{},
							TargetInstanceCount: to.Int32Ptr(3),
						}},
				},
				MinSupportedTLSVersion: to.StringPtr("<min-supported-tlsversion>"),
				OSType:                 armhdinsight.OSType("Linux").ToPtr(),
				StorageProfile: &armhdinsight.StorageProfile{
					Storageaccounts: []*armhdinsight.StorageAccount{
						{
							Name:       to.StringPtr("<name>"),
							Container:  to.StringPtr("<container>"),
							IsDefault:  to.BoolPtr(true),
							Key:        to.StringPtr("<key>"),
							ResourceID: to.StringPtr("<resource-id>"),
						}},
				},
				Tier: armhdinsight.Tier("Standard").ToPtr(),
			},
			Tags:               map[string]*string{},
			Name:               to.StringPtr("<name>"),
			Type:               to.StringPtr("<type>"),
			FetchAaddsResource: to.BoolPtr(false),
			TenantID:           to.StringPtr("<tenant-id>"),
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.LocationsClientValidateClusterCreateRequestResult)
}

Output:

type LocationsClientCheckNameAvailabilityOptions added in v0.2.0 

type LocationsClientCheckNameAvailabilityOptions struct {
}

LocationsClientCheckNameAvailabilityOptions contains the optional parameters for the LocationsClient.CheckNameAvailability method.

type LocationsClientCheckNameAvailabilityResponse added in v0.2.0 

type LocationsClientCheckNameAvailabilityResponse struct {
	LocationsClientCheckNameAvailabilityResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

LocationsClientCheckNameAvailabilityResponse contains the response from method LocationsClient.CheckNameAvailability.

type LocationsClientCheckNameAvailabilityResult added in v0.2.0 

type LocationsClientCheckNameAvailabilityResult struct {
	NameAvailabilityCheckResult
}

LocationsClientCheckNameAvailabilityResult contains the result from method LocationsClient.CheckNameAvailability.

type LocationsClientGetAzureAsyncOperationStatusOptions added in v0.2.0 

type LocationsClientGetAzureAsyncOperationStatusOptions struct {
}

LocationsClientGetAzureAsyncOperationStatusOptions contains the optional parameters for the LocationsClient.GetAzureAsyncOperationStatus method.

type LocationsClientGetAzureAsyncOperationStatusResponse added in v0.2.0 

type LocationsClientGetAzureAsyncOperationStatusResponse struct {
	LocationsClientGetAzureAsyncOperationStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

LocationsClientGetAzureAsyncOperationStatusResponse contains the response from method LocationsClient.GetAzureAsyncOperationStatus.

type LocationsClientGetAzureAsyncOperationStatusResult added in v0.2.0 

type LocationsClientGetAzureAsyncOperationStatusResult struct {
	AsyncOperationResult
}

LocationsClientGetAzureAsyncOperationStatusResult contains the result from method LocationsClient.GetAzureAsyncOperationStatus.

type LocationsClientGetCapabilitiesOptions added in v0.2.0 

type LocationsClientGetCapabilitiesOptions struct {
}

LocationsClientGetCapabilitiesOptions contains the optional parameters for the LocationsClient.GetCapabilities method.

type LocationsClientGetCapabilitiesResponse added in v0.2.0 

type LocationsClientGetCapabilitiesResponse struct {
	LocationsClientGetCapabilitiesResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

LocationsClientGetCapabilitiesResponse contains the response from method LocationsClient.GetCapabilities.

type LocationsClientGetCapabilitiesResult added in v0.2.0 

type LocationsClientGetCapabilitiesResult struct {
	CapabilitiesResult
}

LocationsClientGetCapabilitiesResult contains the result from method LocationsClient.GetCapabilities.

type LocationsClientListBillingSpecsOptions added in v0.2.0 

type LocationsClientListBillingSpecsOptions struct {
}

LocationsClientListBillingSpecsOptions contains the optional parameters for the LocationsClient.ListBillingSpecs method.

type LocationsClientListBillingSpecsResponse added in v0.2.0 

type LocationsClientListBillingSpecsResponse struct {
	LocationsClientListBillingSpecsResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

LocationsClientListBillingSpecsResponse contains the response from method LocationsClient.ListBillingSpecs.

type LocationsClientListBillingSpecsResult added in v0.2.0 

type LocationsClientListBillingSpecsResult struct {
	BillingResponseListResult
}

LocationsClientListBillingSpecsResult contains the result from method LocationsClient.ListBillingSpecs.

type LocationsClientListUsagesOptions added in v0.2.0 

type LocationsClientListUsagesOptions struct {
}

LocationsClientListUsagesOptions contains the optional parameters for the LocationsClient.ListUsages method.

type LocationsClientListUsagesResponse added in v0.2.0 

type LocationsClientListUsagesResponse struct {
	LocationsClientListUsagesResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

LocationsClientListUsagesResponse contains the response from method LocationsClient.ListUsages.

type LocationsClientListUsagesResult added in v0.2.0 

type LocationsClientListUsagesResult struct {
	UsagesListResult
}

LocationsClientListUsagesResult contains the result from method LocationsClient.ListUsages.

type LocationsClientValidateClusterCreateRequestOptions added in v0.2.0 

type LocationsClientValidateClusterCreateRequestOptions struct {
}

LocationsClientValidateClusterCreateRequestOptions contains the optional parameters for the LocationsClient.ValidateClusterCreateRequest method.

type LocationsClientValidateClusterCreateRequestResponse added in v0.2.0 

type LocationsClientValidateClusterCreateRequestResponse struct {
	LocationsClientValidateClusterCreateRequestResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

LocationsClientValidateClusterCreateRequestResponse contains the response from method LocationsClient.ValidateClusterCreateRequest.

type LocationsClientValidateClusterCreateRequestResult added in v0.2.0 

type LocationsClientValidateClusterCreateRequestResult struct {
	ClusterCreateValidationResult
}

LocationsClientValidateClusterCreateRequestResult contains the result from method LocationsClient.ValidateClusterCreateRequest.

type MetricSpecifications 

type MetricSpecifications struct {
	// The aggregation type of the metric specification.
	AggregationType *string `json:"aggregationType,omitempty"`

	// The category of the metric.
	Category *string `json:"category,omitempty"`

	// The override name of delegate metric.
	DelegateMetricNameOverride *string `json:"delegateMetricNameOverride,omitempty"`

	// The dimensions of the metric specification.
	Dimensions []*Dimension `json:"dimensions,omitempty"`

	// The display description of the metric specification.
	DisplayDescription *string `json:"displayDescription,omitempty"`

	// The display name of the metric specification.
	DisplayName *string `json:"displayName,omitempty"`

	// The flag indicates whether enable regional mdm account or not.
	EnableRegionalMdmAccount *bool `json:"enableRegionalMdmAccount,omitempty"`

	// The flag indicates whether filling gap with zero.
	FillGapWithZero *bool `json:"fillGapWithZero,omitempty"`

	// The flag indicates whether the metric is internal or not.
	IsInternal *bool `json:"isInternal,omitempty"`

	// The metric filter pattern.
	MetricFilterPattern *string `json:"metricFilterPattern,omitempty"`

	// The name of the metric specification.
	Name *string `json:"name,omitempty"`

	// The override name of resource id dimension name.
	ResourceIDDimensionNameOverride *string `json:"resourceIdDimensionNameOverride,omitempty"`

	// The source mdm account.
	SourceMdmAccount *string `json:"sourceMdmAccount,omitempty"`

	// The source mdm namespace.
	SourceMdmNamespace *string `json:"sourceMdmNamespace,omitempty"`

	// The supported aggregation types of the metric specification.
	SupportedAggregationTypes []*string `json:"supportedAggregationTypes,omitempty"`

	// The supported time grain types of the metric specification.
	SupportedTimeGrainTypes []*string `json:"supportedTimeGrainTypes,omitempty"`

	// The unit of the metric specification.
	Unit *string `json:"unit,omitempty"`
}

MetricSpecifications - The details of metric specifications.

func (MetricSpecifications) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type MetricSpecifications.

type NameAvailabilityCheckRequestParameters 

type NameAvailabilityCheckRequestParameters struct {
	// The resource name.
	Name *string `json:"name,omitempty"`

	// The resource type
	Type *string `json:"type,omitempty"`
}

NameAvailabilityCheckRequestParameters - The request spec of checking name availability.

type NameAvailabilityCheckResult 

type NameAvailabilityCheckResult struct {
	// This indicates whether the name is available.
	NameAvailable *bool `json:"nameAvailable,omitempty"`

	// READ-ONLY; The related message.
	Message *string `json:"message,omitempty" azure:"ro"`

	// READ-ONLY; The reason of the result.
	Reason *string `json:"reason,omitempty" azure:"ro"`
}

NameAvailabilityCheckResult - The response spec of checking name availability.

type NetworkProperties 

type NetworkProperties struct {
	// Indicates whether or not private link is enabled.
	PrivateLink *PrivateLink `json:"privateLink,omitempty"`

	// The direction for the resource provider connection.
	ResourceProviderConnection *ResourceProviderConnection `json:"resourceProviderConnection,omitempty"`
}

NetworkProperties - The network properties.

type OSType 

type OSType string

OSType - The type of operating system. 

const (
	OSTypeLinux   OSType = "Linux"
	OSTypeWindows OSType = "Windows"
)

func PossibleOSTypeValues 

func PossibleOSTypeValues() []OSType

PossibleOSTypeValues returns the possible values for the OSType const type.

func (OSType) ToPtr 

func (c OSType) ToPtr() *OSType

ToPtr returns a *OSType pointing to the current value.

type Operation 

type Operation struct {
	// The display of operation.
	Display *OperationDisplay `json:"display,omitempty"`

	// The operation name: {provider}/{resource}/{operation}
	Name *string `json:"name,omitempty"`

	// The operation properties.
	Properties *OperationProperties `json:"properties,omitempty"`
}

Operation - The HDInsight REST API operation.

type OperationDisplay 

type OperationDisplay struct {
	// Localized friendly description for the operation
	Description *string `json:"description,omitempty"`

	// The operation type: read, write, delete, etc.
	Operation *string `json:"operation,omitempty"`

	// The service provider: Microsoft.HDInsight
	Provider *string `json:"provider,omitempty"`

	// The resource on which the operation is performed: Cluster, Applications, etc.
	Resource *string `json:"resource,omitempty"`
}

OperationDisplay - The object that represents the operation.

type OperationListResult 

type OperationListResult struct {
	// The URL to get the next set of operation list results if there are any.
	NextLink *string `json:"nextLink,omitempty"`

	// The list of HDInsight operations supported by the HDInsight resource provider.
	Value []*Operation `json:"value,omitempty"`
}

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

func (OperationListResult) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type OperationListResult.

type OperationProperties 

type OperationProperties struct {
	// The specification of the service.
	ServiceSpecification *ServiceSpecification `json:"serviceSpecification,omitempty"`
}

OperationProperties - The details of operation.

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

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) List 

func (client *OperationsClient) List(options *OperationsClientListOptions) *OperationsClientListPager

List - Lists all of the available HDInsight REST API operations. If the operation fails it returns an *azcore.ResponseError type. options - OperationsClientListOptions contains the optional parameters for the OperationsClient.List method.

type OperationsClientListOptions added in v0.2.0 

type OperationsClientListOptions struct {
}

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

type OperationsClientListPager added in v0.2.0 

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

OperationsClientListPager provides operations for iterating over paged responses.

func (*OperationsClientListPager) Err added in v0.2.0 

func (p *OperationsClientListPager) Err() error

Err returns the last error encountered while paging.

func (*OperationsClientListPager) NextPage added in v0.2.0 

func (p *OperationsClientListPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*OperationsClientListPager) PageResponse added in v0.2.0 

func (p *OperationsClientListPager) PageResponse() OperationsClientListResponse

PageResponse returns the current OperationsClientListResponse page.

type OperationsClientListResponse added in v0.2.0 

type OperationsClientListResponse struct {
	OperationsClientListResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

OperationsClientListResponse contains the response from method OperationsClient.List.

type OperationsClientListResult added in v0.2.0 

type OperationsClientListResult struct {
	OperationListResult
}

OperationsClientListResult contains the result from method OperationsClient.List.

type OsProfile 

type OsProfile struct {
	// The Linux OS profile.
	LinuxOperatingSystemProfile *LinuxOperatingSystemProfile `json:"linuxOperatingSystemProfile,omitempty"`
}

OsProfile - The Linux operation systems profile.

type PrivateEndpoint 

type PrivateEndpoint struct {
	// The private endpoint id.
	ID *string `json:"id,omitempty"`
}

PrivateEndpoint - The private endpoint.

type PrivateEndpointConnection 

type PrivateEndpointConnection struct {
	// REQUIRED; The private endpoint connection properties.
	Properties *PrivateEndpointConnectionProperties `json:"properties,omitempty"`

	// READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; Metadata pertaining to creation and last modification of the resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`

	// READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty" azure:"ro"`
}

PrivateEndpointConnection - The private endpoint connection.

type PrivateEndpointConnectionListResult 

type PrivateEndpointConnectionListResult struct {
	// The list of private endpoint connections.
	Value []*PrivateEndpointConnection `json:"value,omitempty"`

	// READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`
}

PrivateEndpointConnectionListResult - The list private endpoint connections response.

func (PrivateEndpointConnectionListResult) MarshalJSON 

func (p PrivateEndpointConnectionListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateEndpointConnectionListResult.

type PrivateEndpointConnectionProperties 

type PrivateEndpointConnectionProperties struct {
	// REQUIRED; The private link service connection state.
	PrivateLinkServiceConnectionState *PrivateLinkServiceConnectionState `json:"privateLinkServiceConnectionState,omitempty"`

	// READ-ONLY; The link identifier.
	LinkIdentifier *string `json:"linkIdentifier,omitempty" azure:"ro"`

	// READ-ONLY; The private endpoint of the private endpoint connection
	PrivateEndpoint *PrivateEndpoint `json:"privateEndpoint,omitempty" azure:"ro"`

	// READ-ONLY; The provisioning state, which only appears in the response.
	ProvisioningState *PrivateEndpointConnectionProvisioningState `json:"provisioningState,omitempty" azure:"ro"`
}

PrivateEndpointConnectionProperties - The private endpoint connection properties.

type PrivateEndpointConnectionProvisioningState 

type PrivateEndpointConnectionProvisioningState string

PrivateEndpointConnectionProvisioningState - The provisioning state, which only appears in the response. 

const (
	PrivateEndpointConnectionProvisioningStateCanceled   PrivateEndpointConnectionProvisioningState = "Canceled"
	PrivateEndpointConnectionProvisioningStateDeleting   PrivateEndpointConnectionProvisioningState = "Deleting"
	PrivateEndpointConnectionProvisioningStateFailed     PrivateEndpointConnectionProvisioningState = "Failed"
	PrivateEndpointConnectionProvisioningStateInProgress PrivateEndpointConnectionProvisioningState = "InProgress"
	PrivateEndpointConnectionProvisioningStateSucceeded  PrivateEndpointConnectionProvisioningState = "Succeeded"
	PrivateEndpointConnectionProvisioningStateUpdating   PrivateEndpointConnectionProvisioningState = "Updating"
)

func PossiblePrivateEndpointConnectionProvisioningStateValues 

func PossiblePrivateEndpointConnectionProvisioningStateValues() []PrivateEndpointConnectionProvisioningState

PossiblePrivateEndpointConnectionProvisioningStateValues returns the possible values for the PrivateEndpointConnectionProvisioningState const type.

func (PrivateEndpointConnectionProvisioningState) ToPtr 

func (c PrivateEndpointConnectionProvisioningState) ToPtr() *PrivateEndpointConnectionProvisioningState

ToPtr returns a *PrivateEndpointConnectionProvisioningState pointing to the current value.

type PrivateEndpointConnectionsClient 

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

PrivateEndpointConnectionsClient contains the methods for the PrivateEndpointConnections group. Don't use this type directly, use NewPrivateEndpointConnectionsClient() instead.

func NewPrivateEndpointConnectionsClient 

func NewPrivateEndpointConnectionsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *PrivateEndpointConnectionsClient

NewPrivateEndpointConnectionsClient creates a new instance of PrivateEndpointConnectionsClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*PrivateEndpointConnectionsClient) BeginCreateOrUpdate 

func (client *PrivateEndpointConnectionsClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection, options *PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions) (PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse, error)

BeginCreateOrUpdate - Approve or reject a private endpoint connection manually. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. privateEndpointConnectionName - The name of the private endpoint connection. parameters - The private endpoint connection create or update request. options - PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginCreateOrUpdate method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/ApprovePrivateEndpointConnection.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginCreateOrUpdate(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<private-endpoint-connection-name>",
		armhdinsight.PrivateEndpointConnection{
			Properties: &armhdinsight.PrivateEndpointConnectionProperties{
				PrivateLinkServiceConnectionState: &armhdinsight.PrivateLinkServiceConnectionState{
					Description:     to.StringPtr("<description>"),
					ActionsRequired: to.StringPtr("<actions-required>"),
					Status:          armhdinsight.PrivateLinkServiceConnectionStatus("Approved").ToPtr(),
				},
			},
		},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	res, err := poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.PrivateEndpointConnectionsClientCreateOrUpdateResult)
}

Output:

func (*PrivateEndpointConnectionsClient) BeginDelete 

func (client *PrivateEndpointConnectionsClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsClientBeginDeleteOptions) (PrivateEndpointConnectionsClientDeletePollerResponse, error)

BeginDelete - Deletes the specific private endpoint connection. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. privateEndpointConnectionName - The name of the private endpoint connection. options - PrivateEndpointConnectionsClientBeginDeleteOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginDelete method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DeletePrivateEndpointConnection.json 

package main

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil)
	poller, err := client.BeginDelete(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<private-endpoint-connection-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*PrivateEndpointConnectionsClient) Get 

func (client *PrivateEndpointConnectionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsClientGetOptions) (PrivateEndpointConnectionsClientGetResponse, error)

Get - Gets the specific private endpoint connection. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. privateEndpointConnectionName - The name of the private endpoint connection. options - PrivateEndpointConnectionsClientGetOptions contains the optional parameters for the PrivateEndpointConnectionsClient.Get method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetPrivateEndpointConnection.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil)
	res, err := client.Get(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<private-endpoint-connection-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.PrivateEndpointConnectionsClientGetResult)
}

Output:

func (*PrivateEndpointConnectionsClient) ListByCluster 

func (client *PrivateEndpointConnectionsClient) ListByCluster(resourceGroupName string, clusterName string, options *PrivateEndpointConnectionsClientListByClusterOptions) *PrivateEndpointConnectionsClientListByClusterPager

ListByCluster - Lists the private endpoint connections for a HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - PrivateEndpointConnectionsClientListByClusterOptions contains the optional parameters for the PrivateEndpointConnectionsClient.ListByCluster method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetAllPrivateEndpointConnectionsInCluster.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil)
	pager := client.ListByCluster("<resource-group-name>",
		"<cluster-name>",
		nil)
	for {
		nextResult := pager.NextPage(ctx)
		if err := pager.Err(); err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		if !nextResult {
			break
		}
		for _, v := range pager.PageResponse().Value {
			log.Printf("Pager result: %#v\n", v)
		}
	}
}

Output:

type PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions added in v0.2.0 

type PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions struct {
}

PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginCreateOrUpdate method.

type PrivateEndpointConnectionsClientBeginDeleteOptions added in v0.2.0 

type PrivateEndpointConnectionsClientBeginDeleteOptions struct {
}

PrivateEndpointConnectionsClientBeginDeleteOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginDelete method.

type PrivateEndpointConnectionsClientCreateOrUpdatePoller added in v0.2.0 

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

PrivateEndpointConnectionsClientCreateOrUpdatePoller provides polling facilities until the operation reaches a terminal state.

func (*PrivateEndpointConnectionsClientCreateOrUpdatePoller) Done added in v0.2.0 

func (p *PrivateEndpointConnectionsClientCreateOrUpdatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*PrivateEndpointConnectionsClientCreateOrUpdatePoller) FinalResponse added in v0.2.0 

func (p *PrivateEndpointConnectionsClientCreateOrUpdatePoller) FinalResponse(ctx context.Context) (PrivateEndpointConnectionsClientCreateOrUpdateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final PrivateEndpointConnectionsClientCreateOrUpdateResponse will be returned.

func (*PrivateEndpointConnectionsClientCreateOrUpdatePoller) Poll added in v0.2.0 

func (p *PrivateEndpointConnectionsClientCreateOrUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*PrivateEndpointConnectionsClientCreateOrUpdatePoller) ResumeToken added in v0.2.0 

func (p *PrivateEndpointConnectionsClientCreateOrUpdatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse added in v0.2.0 

type PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *PrivateEndpointConnectionsClientCreateOrUpdatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse contains the response from method PrivateEndpointConnectionsClient.CreateOrUpdate.

func (PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse) PollUntilDone added in v0.2.0 

func (l PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (PrivateEndpointConnectionsClientCreateOrUpdateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse) Resume added in v0.2.0 

func (l *PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse) Resume(ctx context.Context, client *PrivateEndpointConnectionsClient, token string) error

Resume rehydrates a PrivateEndpointConnectionsClientCreateOrUpdatePollerResponse from the provided client and resume token.

type PrivateEndpointConnectionsClientCreateOrUpdateResponse added in v0.2.0 

type PrivateEndpointConnectionsClientCreateOrUpdateResponse struct {
	PrivateEndpointConnectionsClientCreateOrUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsClientCreateOrUpdateResponse contains the response from method PrivateEndpointConnectionsClient.CreateOrUpdate.

type PrivateEndpointConnectionsClientCreateOrUpdateResult added in v0.2.0 

type PrivateEndpointConnectionsClientCreateOrUpdateResult struct {
	PrivateEndpointConnection
}

PrivateEndpointConnectionsClientCreateOrUpdateResult contains the result from method PrivateEndpointConnectionsClient.CreateOrUpdate.

type PrivateEndpointConnectionsClientDeletePoller added in v0.2.0 

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

PrivateEndpointConnectionsClientDeletePoller provides polling facilities until the operation reaches a terminal state.

func (*PrivateEndpointConnectionsClientDeletePoller) Done added in v0.2.0 

func (p *PrivateEndpointConnectionsClientDeletePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*PrivateEndpointConnectionsClientDeletePoller) FinalResponse added in v0.2.0 

func (p *PrivateEndpointConnectionsClientDeletePoller) FinalResponse(ctx context.Context) (PrivateEndpointConnectionsClientDeleteResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final PrivateEndpointConnectionsClientDeleteResponse will be returned.

func (*PrivateEndpointConnectionsClientDeletePoller) Poll added in v0.2.0 

func (p *PrivateEndpointConnectionsClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*PrivateEndpointConnectionsClientDeletePoller) ResumeToken added in v0.2.0 

func (p *PrivateEndpointConnectionsClientDeletePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type PrivateEndpointConnectionsClientDeletePollerResponse added in v0.2.0 

type PrivateEndpointConnectionsClientDeletePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *PrivateEndpointConnectionsClientDeletePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsClientDeletePollerResponse contains the response from method PrivateEndpointConnectionsClient.Delete.

func (PrivateEndpointConnectionsClientDeletePollerResponse) PollUntilDone added in v0.2.0 

func (l PrivateEndpointConnectionsClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (PrivateEndpointConnectionsClientDeleteResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*PrivateEndpointConnectionsClientDeletePollerResponse) Resume added in v0.2.0 

func (l *PrivateEndpointConnectionsClientDeletePollerResponse) Resume(ctx context.Context, client *PrivateEndpointConnectionsClient, token string) error

Resume rehydrates a PrivateEndpointConnectionsClientDeletePollerResponse from the provided client and resume token.

type PrivateEndpointConnectionsClientDeleteResponse added in v0.2.0 

type PrivateEndpointConnectionsClientDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsClientDeleteResponse contains the response from method PrivateEndpointConnectionsClient.Delete.

type PrivateEndpointConnectionsClientGetOptions added in v0.2.0 

type PrivateEndpointConnectionsClientGetOptions struct {
}

PrivateEndpointConnectionsClientGetOptions contains the optional parameters for the PrivateEndpointConnectionsClient.Get method.

type PrivateEndpointConnectionsClientGetResponse added in v0.2.0 

type PrivateEndpointConnectionsClientGetResponse struct {
	PrivateEndpointConnectionsClientGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsClientGetResponse contains the response from method PrivateEndpointConnectionsClient.Get.

type PrivateEndpointConnectionsClientGetResult added in v0.2.0 

type PrivateEndpointConnectionsClientGetResult struct {
	PrivateEndpointConnection
}

PrivateEndpointConnectionsClientGetResult contains the result from method PrivateEndpointConnectionsClient.Get.

type PrivateEndpointConnectionsClientListByClusterOptions added in v0.2.0 

type PrivateEndpointConnectionsClientListByClusterOptions struct {
}

PrivateEndpointConnectionsClientListByClusterOptions contains the optional parameters for the PrivateEndpointConnectionsClient.ListByCluster method.

type PrivateEndpointConnectionsClientListByClusterPager added in v0.2.0 

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

PrivateEndpointConnectionsClientListByClusterPager provides operations for iterating over paged responses.

func (*PrivateEndpointConnectionsClientListByClusterPager) Err added in v0.2.0 

func (p *PrivateEndpointConnectionsClientListByClusterPager) Err() error

Err returns the last error encountered while paging.

func (*PrivateEndpointConnectionsClientListByClusterPager) NextPage added in v0.2.0 

func (p *PrivateEndpointConnectionsClientListByClusterPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*PrivateEndpointConnectionsClientListByClusterPager) PageResponse added in v0.2.0 

func (p *PrivateEndpointConnectionsClientListByClusterPager) PageResponse() PrivateEndpointConnectionsClientListByClusterResponse

PageResponse returns the current PrivateEndpointConnectionsClientListByClusterResponse page.

type PrivateEndpointConnectionsClientListByClusterResponse added in v0.2.0 

type PrivateEndpointConnectionsClientListByClusterResponse struct {
	PrivateEndpointConnectionsClientListByClusterResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsClientListByClusterResponse contains the response from method PrivateEndpointConnectionsClient.ListByCluster.

type PrivateEndpointConnectionsClientListByClusterResult added in v0.2.0 

type PrivateEndpointConnectionsClientListByClusterResult struct {
	PrivateEndpointConnectionListResult
}

PrivateEndpointConnectionsClientListByClusterResult contains the result from method PrivateEndpointConnectionsClient.ListByCluster.

type PrivateIPAllocationMethod 

type PrivateIPAllocationMethod string

PrivateIPAllocationMethod - The method that private IP address is allocated. 

const (
	PrivateIPAllocationMethodDynamic PrivateIPAllocationMethod = "dynamic"
	PrivateIPAllocationMethodStatic  PrivateIPAllocationMethod = "static"
)

func PossiblePrivateIPAllocationMethodValues 

func PossiblePrivateIPAllocationMethodValues() []PrivateIPAllocationMethod

PossiblePrivateIPAllocationMethodValues returns the possible values for the PrivateIPAllocationMethod const type.

func (PrivateIPAllocationMethod) ToPtr 

func (c PrivateIPAllocationMethod) ToPtr() *PrivateIPAllocationMethod

ToPtr returns a *PrivateIPAllocationMethod pointing to the current value. 

type PrivateLink string

PrivateLink - Indicates whether or not private link is enabled. 

const (
	PrivateLinkDisabled PrivateLink = "Disabled"
	PrivateLinkEnabled  PrivateLink = "Enabled"
)

func PossiblePrivateLinkValues 

func PossiblePrivateLinkValues() []PrivateLink

PossiblePrivateLinkValues returns the possible values for the PrivateLink const type.

func (PrivateLink) ToPtr 

func (c PrivateLink) ToPtr() *PrivateLink

ToPtr returns a *PrivateLink pointing to the current value.

type PrivateLinkConfiguration 

type PrivateLinkConfiguration struct {
	// REQUIRED; The name of private link configuration.
	Name *string `json:"name,omitempty"`

	// REQUIRED; The private link configuration properties.
	Properties *PrivateLinkConfigurationProperties `json:"properties,omitempty"`

	// READ-ONLY; The private link configuration id.
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The type of the private link configuration.
	Type *string `json:"type,omitempty" azure:"ro"`
}

PrivateLinkConfiguration - The private link configuration.

type PrivateLinkConfigurationProperties 

type PrivateLinkConfigurationProperties struct {
	// REQUIRED; The HDInsight private linkable sub-resource name to apply the private link configuration to. For example, 'headnode',
	// 'gateway', 'edgenode'.
	GroupID *string `json:"groupId,omitempty"`

	// REQUIRED; The IP configurations for the private link service.
	IPConfigurations []*IPConfiguration `json:"ipConfigurations,omitempty"`

	// READ-ONLY; The private link configuration provisioning state, which only appears in the response.
	ProvisioningState *PrivateLinkConfigurationProvisioningState `json:"provisioningState,omitempty" azure:"ro"`
}

PrivateLinkConfigurationProperties - The private link configuration properties.

func (PrivateLinkConfigurationProperties) MarshalJSON 

func (p PrivateLinkConfigurationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateLinkConfigurationProperties.

type PrivateLinkConfigurationProvisioningState 

type PrivateLinkConfigurationProvisioningState string

PrivateLinkConfigurationProvisioningState - The private link configuration provisioning state, which only appears in the response. 

const (
	PrivateLinkConfigurationProvisioningStateCanceled   PrivateLinkConfigurationProvisioningState = "Canceled"
	PrivateLinkConfigurationProvisioningStateDeleting   PrivateLinkConfigurationProvisioningState = "Deleting"
	PrivateLinkConfigurationProvisioningStateFailed     PrivateLinkConfigurationProvisioningState = "Failed"
	PrivateLinkConfigurationProvisioningStateInProgress PrivateLinkConfigurationProvisioningState = "InProgress"
	PrivateLinkConfigurationProvisioningStateSucceeded  PrivateLinkConfigurationProvisioningState = "Succeeded"
)

func PossiblePrivateLinkConfigurationProvisioningStateValues 

func PossiblePrivateLinkConfigurationProvisioningStateValues() []PrivateLinkConfigurationProvisioningState

PossiblePrivateLinkConfigurationProvisioningStateValues returns the possible values for the PrivateLinkConfigurationProvisioningState const type.

func (PrivateLinkConfigurationProvisioningState) ToPtr 

func (c PrivateLinkConfigurationProvisioningState) ToPtr() *PrivateLinkConfigurationProvisioningState

ToPtr returns a *PrivateLinkConfigurationProvisioningState pointing to the current value.

type PrivateLinkResource 

type PrivateLinkResource struct {
	// Resource properties.
	Properties *PrivateLinkResourceProperties `json:"properties,omitempty"`

	// READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; Metadata pertaining to creation and last modification of the resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`

	// READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty" azure:"ro"`
}

PrivateLinkResource - A private link resource

type PrivateLinkResourceListResult 

type PrivateLinkResourceListResult struct {
	// Array of private link resources
	Value []*PrivateLinkResource `json:"value,omitempty"`
}

PrivateLinkResourceListResult - A list of private link resources

func (PrivateLinkResourceListResult) MarshalJSON 

func (p PrivateLinkResourceListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateLinkResourceListResult.

type PrivateLinkResourceProperties 

type PrivateLinkResourceProperties struct {
	// The private link resource Private link DNS zone name.
	RequiredZoneNames []*string `json:"requiredZoneNames,omitempty"`

	// READ-ONLY; The private link resource group id.
	GroupID *string `json:"groupId,omitempty" azure:"ro"`

	// READ-ONLY; The private link resource required member names.
	RequiredMembers []*string `json:"requiredMembers,omitempty" azure:"ro"`
}

PrivateLinkResourceProperties - Properties of a private link resource.

func (PrivateLinkResourceProperties) MarshalJSON 

func (p PrivateLinkResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateLinkResourceProperties.

type PrivateLinkResourcesClient 

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

PrivateLinkResourcesClient contains the methods for the PrivateLinkResources group. Don't use this type directly, use NewPrivateLinkResourcesClient() instead.

func NewPrivateLinkResourcesClient 

func NewPrivateLinkResourcesClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *PrivateLinkResourcesClient

NewPrivateLinkResourcesClient creates a new instance of PrivateLinkResourcesClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*PrivateLinkResourcesClient) Get 

func (client *PrivateLinkResourcesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateLinkResourceName string, options *PrivateLinkResourcesClientGetOptions) (PrivateLinkResourcesClientGetResponse, error)

Get - Gets the specific private link resource. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. privateLinkResourceName - The name of the private link resource. options - PrivateLinkResourcesClientGetOptions contains the optional parameters for the PrivateLinkResourcesClient.Get method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetPrivateLinkResource.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewPrivateLinkResourcesClient("<subscription-id>", cred, nil)
	res, err := client.Get(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<private-link-resource-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.PrivateLinkResourcesClientGetResult)
}

Output:

func (*PrivateLinkResourcesClient) ListByCluster 

func (client *PrivateLinkResourcesClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string, options *PrivateLinkResourcesClientListByClusterOptions) (PrivateLinkResourcesClientListByClusterResponse, error)

ListByCluster - Lists the private link resources in a HDInsight cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - PrivateLinkResourcesClientListByClusterOptions contains the optional parameters for the PrivateLinkResourcesClient.ListByCluster method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetAllPrivateLinkResourcesInCluster.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewPrivateLinkResourcesClient("<subscription-id>", cred, nil)
	res, err := client.ListByCluster(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.PrivateLinkResourcesClientListByClusterResult)
}

Output:

type PrivateLinkResourcesClientGetOptions added in v0.2.0 

type PrivateLinkResourcesClientGetOptions struct {
}

PrivateLinkResourcesClientGetOptions contains the optional parameters for the PrivateLinkResourcesClient.Get method.

type PrivateLinkResourcesClientGetResponse added in v0.2.0 

type PrivateLinkResourcesClientGetResponse struct {
	PrivateLinkResourcesClientGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateLinkResourcesClientGetResponse contains the response from method PrivateLinkResourcesClient.Get.

type PrivateLinkResourcesClientGetResult added in v0.2.0 

type PrivateLinkResourcesClientGetResult struct {
	PrivateLinkResource
}

PrivateLinkResourcesClientGetResult contains the result from method PrivateLinkResourcesClient.Get.

type PrivateLinkResourcesClientListByClusterOptions added in v0.2.0 

type PrivateLinkResourcesClientListByClusterOptions struct {
}

PrivateLinkResourcesClientListByClusterOptions contains the optional parameters for the PrivateLinkResourcesClient.ListByCluster method.

type PrivateLinkResourcesClientListByClusterResponse added in v0.2.0 

type PrivateLinkResourcesClientListByClusterResponse struct {
	PrivateLinkResourcesClientListByClusterResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateLinkResourcesClientListByClusterResponse contains the response from method PrivateLinkResourcesClient.ListByCluster.

type PrivateLinkResourcesClientListByClusterResult added in v0.2.0 

type PrivateLinkResourcesClientListByClusterResult struct {
	PrivateLinkResourceListResult
}

PrivateLinkResourcesClientListByClusterResult contains the result from method PrivateLinkResourcesClient.ListByCluster.

type PrivateLinkServiceConnectionState 

type PrivateLinkServiceConnectionState struct {
	// REQUIRED; The concrete private link service connection.
	Status *PrivateLinkServiceConnectionStatus `json:"status,omitempty"`

	// Whether there is further actions.
	ActionsRequired *string `json:"actionsRequired,omitempty"`

	// The optional description of the status.
	Description *string `json:"description,omitempty"`
}

PrivateLinkServiceConnectionState - The private link service connection state.

type PrivateLinkServiceConnectionStatus 

type PrivateLinkServiceConnectionStatus string

PrivateLinkServiceConnectionStatus - The concrete private link service connection. 

const (
	PrivateLinkServiceConnectionStatusApproved PrivateLinkServiceConnectionStatus = "Approved"
	PrivateLinkServiceConnectionStatusPending  PrivateLinkServiceConnectionStatus = "Pending"
	PrivateLinkServiceConnectionStatusRejected PrivateLinkServiceConnectionStatus = "Rejected"
	PrivateLinkServiceConnectionStatusRemoved  PrivateLinkServiceConnectionStatus = "Removed"
)

func PossiblePrivateLinkServiceConnectionStatusValues 

func PossiblePrivateLinkServiceConnectionStatusValues() []PrivateLinkServiceConnectionStatus

PossiblePrivateLinkServiceConnectionStatusValues returns the possible values for the PrivateLinkServiceConnectionStatus const type.

func (PrivateLinkServiceConnectionStatus) ToPtr 

func (c PrivateLinkServiceConnectionStatus) ToPtr() *PrivateLinkServiceConnectionStatus

ToPtr returns a *PrivateLinkServiceConnectionStatus pointing to the current value.

type ProxyResource 

type ProxyResource struct {
	// READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty" azure:"ro"`
}

ProxyResource - The resource model definition for a Azure Resource Manager proxy resource. It will not have tags and a location

type QuotaCapability 

type QuotaCapability struct {
	// The number of cores used in the subscription.
	CoresUsed *int64 `json:"coresUsed,omitempty"`

	// The number of cores that the subscription allowed.
	MaxCoresAllowed *int64 `json:"maxCoresAllowed,omitempty"`

	// The list of region quota capabilities.
	RegionalQuotas []*RegionalQuotaCapability `json:"regionalQuotas,omitempty"`
}

QuotaCapability - The regional quota capability.

func (QuotaCapability) MarshalJSON 

func (q QuotaCapability) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type QuotaCapability.

type QuotaInfo 

type QuotaInfo struct {
	// The cores used by the cluster.
	CoresUsed *int32 `json:"coresUsed,omitempty"`
}

QuotaInfo - The quota properties for the cluster.

type RegionalQuotaCapability 

type RegionalQuotaCapability struct {
	// The number of cores available in the region.
	CoresAvailable *int64 `json:"coresAvailable,omitempty"`

	// The number of cores used in the region.
	CoresUsed *int64 `json:"coresUsed,omitempty"`

	// The region name.
	RegionName *string `json:"regionName,omitempty"`
}

RegionalQuotaCapability - The regional quota capacity.

type RegionsCapability 

type RegionsCapability struct {
	// The list of region capabilities.
	Available []*string `json:"available,omitempty"`
}

RegionsCapability - The regions capability.

func (RegionsCapability) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type RegionsCapability.

type Resource 

type Resource struct {
	// READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty" azure:"ro"`
}

Resource - Common fields that are returned in the response for all Azure Resource Manager resources

type ResourceID 

type ResourceID struct {
	// The azure resource id.
	ID *string `json:"id,omitempty"`
}

ResourceID - The azure resource id.

type ResourceIdentityType 

type ResourceIdentityType string

ResourceIdentityType - The type of identity used for the cluster. The type 'SystemAssigned, UserAssigned' includes both an implicitly created identity and a set of user assigned identities. 

const (
	ResourceIdentityTypeNone                       ResourceIdentityType = "None"
	ResourceIdentityTypeSystemAssigned             ResourceIdentityType = "SystemAssigned"
	ResourceIdentityTypeSystemAssignedUserAssigned ResourceIdentityType = "SystemAssigned, UserAssigned"
	ResourceIdentityTypeUserAssigned               ResourceIdentityType = "UserAssigned"
)

func PossibleResourceIdentityTypeValues 

func PossibleResourceIdentityTypeValues() []ResourceIdentityType

PossibleResourceIdentityTypeValues returns the possible values for the ResourceIdentityType const type.

func (ResourceIdentityType) ToPtr 

func (c ResourceIdentityType) ToPtr() *ResourceIdentityType

ToPtr returns a *ResourceIdentityType pointing to the current value.

type ResourceProviderConnection 

type ResourceProviderConnection string

ResourceProviderConnection - The direction for the resource provider connection. 

const (
	ResourceProviderConnectionInbound  ResourceProviderConnection = "Inbound"
	ResourceProviderConnectionOutbound ResourceProviderConnection = "Outbound"
)

func PossibleResourceProviderConnectionValues 

func PossibleResourceProviderConnectionValues() []ResourceProviderConnection

PossibleResourceProviderConnectionValues returns the possible values for the ResourceProviderConnection const type.

func (ResourceProviderConnection) ToPtr 

func (c ResourceProviderConnection) ToPtr() *ResourceProviderConnection

ToPtr returns a *ResourceProviderConnection pointing to the current value.

type Role 

type Role struct {
	// The autoscale configurations.
	AutoscaleConfiguration *Autoscale `json:"autoscale,omitempty"`

	// The data disks groups for the role.
	DataDisksGroups []*DataDisksGroups `json:"dataDisksGroups,omitempty"`

	// Indicates whether encrypt the data disks.
	EncryptDataDisks *bool `json:"encryptDataDisks,omitempty"`

	// The hardware profile.
	HardwareProfile *HardwareProfile `json:"hardwareProfile,omitempty"`

	// The minimum instance count of the cluster.
	MinInstanceCount *int32 `json:"minInstanceCount,omitempty"`

	// The name of the role.
	Name *string `json:"name,omitempty"`

	// The operating system profile.
	OSProfile *OsProfile `json:"osProfile,omitempty"`

	// The list of script actions on the role.
	ScriptActions []*ScriptAction `json:"scriptActions,omitempty"`

	// The instance count of the cluster.
	TargetInstanceCount *int32 `json:"targetInstanceCount,omitempty"`

	// The name of the virtual machine group.
	VMGroupName *string `json:"VMGroupName,omitempty"`

	// The virtual network profile.
	VirtualNetworkProfile *VirtualNetworkProfile `json:"virtualNetworkProfile,omitempty"`
}

Role - Describes a role on the cluster.

func (Role) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type Role.

type RoleName 

type RoleName string
const (
	RoleNameWorkernode RoleName = "workernode"
)

func PossibleRoleNameValues 

func PossibleRoleNameValues() []RoleName

PossibleRoleNameValues returns the possible values for the RoleName const type.

func (RoleName) ToPtr 

func (c RoleName) ToPtr() *RoleName

ToPtr returns a *RoleName pointing to the current value.

type RuntimeScriptAction 

type RuntimeScriptAction struct {
	// REQUIRED; The name of the script action.
	Name *string `json:"name,omitempty"`

	// REQUIRED; The list of roles where script will be executed.
	Roles []*string `json:"roles,omitempty"`

	// REQUIRED; The URI to the script.
	URI *string `json:"uri,omitempty"`

	// The parameters for the script
	Parameters *string `json:"parameters,omitempty"`

	// READ-ONLY; The application name of the script action, if any.
	ApplicationName *string `json:"applicationName,omitempty" azure:"ro"`
}

RuntimeScriptAction - Describes a script action on a running cluster.

func (RuntimeScriptAction) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type RuntimeScriptAction.

type RuntimeScriptActionDetail 

type RuntimeScriptActionDetail struct {
	// REQUIRED; The name of the script action.
	Name *string `json:"name,omitempty"`

	// REQUIRED; The list of roles where script will be executed.
	Roles []*string `json:"roles,omitempty"`

	// REQUIRED; The URI to the script.
	URI *string `json:"uri,omitempty"`

	// The parameters for the script
	Parameters *string `json:"parameters,omitempty"`

	// READ-ONLY; The application name of the script action, if any.
	ApplicationName *string `json:"applicationName,omitempty" azure:"ro"`

	// READ-ONLY; The script action execution debug information.
	DebugInformation *string `json:"debugInformation,omitempty" azure:"ro"`

	// READ-ONLY; The end time of script action execution.
	EndTime *string `json:"endTime,omitempty" azure:"ro"`

	// READ-ONLY; The summary of script action execution result.
	ExecutionSummary []*ScriptActionExecutionSummary `json:"executionSummary,omitempty" azure:"ro"`

	// READ-ONLY; The reason why the script action was executed.
	Operation *string `json:"operation,omitempty" azure:"ro"`

	// READ-ONLY; The execution id of the script action.
	ScriptExecutionID *int64 `json:"scriptExecutionId,omitempty" azure:"ro"`

	// READ-ONLY; The start time of script action execution.
	StartTime *string `json:"startTime,omitempty" azure:"ro"`

	// READ-ONLY; The current execution status of the script action.
	Status *string `json:"status,omitempty" azure:"ro"`
}

RuntimeScriptActionDetail - The execution details of a script action.

func (RuntimeScriptActionDetail) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type RuntimeScriptActionDetail.

type SSHProfile 

type SSHProfile struct {
	// The list of SSH public keys.
	PublicKeys []*SSHPublicKey `json:"publicKeys,omitempty"`
}

SSHProfile - The list of SSH public keys.

func (SSHProfile) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type SSHProfile.

type SSHPublicKey 

type SSHPublicKey struct {
	// The certificate for SSH.
	CertificateData *string `json:"certificateData,omitempty"`
}

SSHPublicKey - The SSH public key for the cluster nodes.

type ScriptAction 

type ScriptAction struct {
	// REQUIRED; The name of the script action.
	Name *string `json:"name,omitempty"`

	// REQUIRED; The parameters for the script provided.
	Parameters *string `json:"parameters,omitempty"`

	// REQUIRED; The URI to the script.
	URI *string `json:"uri,omitempty"`
}

ScriptAction - Describes a script action on role on the cluster.

type ScriptActionExecutionHistoryList 

type ScriptActionExecutionHistoryList struct {
	// READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`

	// READ-ONLY; The list of persisted script action details for the cluster.
	Value []*RuntimeScriptActionDetail `json:"value,omitempty" azure:"ro"`
}

ScriptActionExecutionHistoryList - The list script execution history response.

func (ScriptActionExecutionHistoryList) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ScriptActionExecutionHistoryList.

type ScriptActionExecutionSummary 

type ScriptActionExecutionSummary struct {
	// READ-ONLY; The instance count for a given script action execution status.
	InstanceCount *int32 `json:"instanceCount,omitempty" azure:"ro"`

	// READ-ONLY; The status of script action execution.
	Status *string `json:"status,omitempty" azure:"ro"`
}

ScriptActionExecutionSummary - The execution summary of a script action.

type ScriptActionPersistedGetResponseSpec 

type ScriptActionPersistedGetResponseSpec struct {
	// The application name for the script action.
	ApplicationName *string `json:"applicationName,omitempty"`

	// The name of script action.
	Name *string `json:"name,omitempty"`

	// The parameters for the script provided.
	Parameters *string `json:"parameters,omitempty"`

	// The list of roles where script will be executed.
	Roles []*string `json:"roles,omitempty"`

	// The URI to the script.
	URI *string `json:"uri,omitempty"`
}

ScriptActionPersistedGetResponseSpec - The persisted script action for cluster.

func (ScriptActionPersistedGetResponseSpec) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ScriptActionPersistedGetResponseSpec.

type ScriptActionsClient 

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

ScriptActionsClient contains the methods for the ScriptActions group. Don't use this type directly, use NewScriptActionsClient() instead.

func NewScriptActionsClient 

func NewScriptActionsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ScriptActionsClient

NewScriptActionsClient creates a new instance of ScriptActionsClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*ScriptActionsClient) Delete 

func (client *ScriptActionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, scriptName string, options *ScriptActionsClientDeleteOptions) (ScriptActionsClientDeleteResponse, error)

Delete - Deletes a specified persisted script action of the cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. scriptName - The name of the script. options - ScriptActionsClientDeleteOptions contains the optional parameters for the ScriptActionsClient.Delete method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/DeleteScriptAction.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewScriptActionsClient("<subscription-id>", cred, nil)
	_, err = client.Delete(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<script-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*ScriptActionsClient) GetExecutionAsyncOperationStatus 

func (client *ScriptActionsClient) GetExecutionAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, operationID string, options *ScriptActionsClientGetExecutionAsyncOperationStatusOptions) (ScriptActionsClientGetExecutionAsyncOperationStatusResponse, error)

GetExecutionAsyncOperationStatus - Gets the async operation status of execution operation. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. operationID - The long running operation id. options - ScriptActionsClientGetExecutionAsyncOperationStatusOptions contains the optional parameters for the ScriptActionsClient.GetExecutionAsyncOperationStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetScriptExecutionAsyncOperationStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewScriptActionsClient("<subscription-id>", cred, nil)
	res, err := client.GetExecutionAsyncOperationStatus(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<operation-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ScriptActionsClientGetExecutionAsyncOperationStatusResult)
}

Output:

func (*ScriptActionsClient) GetExecutionDetail 

func (client *ScriptActionsClient) GetExecutionDetail(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string, options *ScriptActionsClientGetExecutionDetailOptions) (ScriptActionsClientGetExecutionDetailResponse, error)

GetExecutionDetail - Gets the script execution detail for the given script execution ID. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. scriptExecutionID - The script execution Id options - ScriptActionsClientGetExecutionDetailOptions contains the optional parameters for the ScriptActionsClient.GetExecutionDetail method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetScriptActionById.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewScriptActionsClient("<subscription-id>", cred, nil)
	res, err := client.GetExecutionDetail(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<script-execution-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.ScriptActionsClientGetExecutionDetailResult)
}

Output:

func (*ScriptActionsClient) ListByCluster 

func (client *ScriptActionsClient) ListByCluster(resourceGroupName string, clusterName string, options *ScriptActionsClientListByClusterOptions) *ScriptActionsClientListByClusterPager

ListByCluster - Lists all the persisted script actions for the specified cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ScriptActionsClientListByClusterOptions contains the optional parameters for the ScriptActionsClient.ListByCluster method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetLinuxHadoopScriptAction.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewScriptActionsClient("<subscription-id>", cred, nil)
	pager := client.ListByCluster("<resource-group-name>",
		"<cluster-name>",
		nil)
	for {
		nextResult := pager.NextPage(ctx)
		if err := pager.Err(); err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		if !nextResult {
			break
		}
		for _, v := range pager.PageResponse().Value {
			log.Printf("Pager result: %#v\n", v)
		}
	}
}

Output:

type ScriptActionsClientDeleteOptions added in v0.2.0 

type ScriptActionsClientDeleteOptions struct {
}

ScriptActionsClientDeleteOptions contains the optional parameters for the ScriptActionsClient.Delete method.

type ScriptActionsClientDeleteResponse added in v0.2.0 

type ScriptActionsClientDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ScriptActionsClientDeleteResponse contains the response from method ScriptActionsClient.Delete.

type ScriptActionsClientGetExecutionAsyncOperationStatusOptions added in v0.2.0 

type ScriptActionsClientGetExecutionAsyncOperationStatusOptions struct {
}

ScriptActionsClientGetExecutionAsyncOperationStatusOptions contains the optional parameters for the ScriptActionsClient.GetExecutionAsyncOperationStatus method.

type ScriptActionsClientGetExecutionAsyncOperationStatusResponse added in v0.2.0 

type ScriptActionsClientGetExecutionAsyncOperationStatusResponse struct {
	ScriptActionsClientGetExecutionAsyncOperationStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ScriptActionsClientGetExecutionAsyncOperationStatusResponse contains the response from method ScriptActionsClient.GetExecutionAsyncOperationStatus.

type ScriptActionsClientGetExecutionAsyncOperationStatusResult added in v0.2.0 

type ScriptActionsClientGetExecutionAsyncOperationStatusResult struct {
	AsyncOperationResult
}

ScriptActionsClientGetExecutionAsyncOperationStatusResult contains the result from method ScriptActionsClient.GetExecutionAsyncOperationStatus.

type ScriptActionsClientGetExecutionDetailOptions added in v0.2.0 

type ScriptActionsClientGetExecutionDetailOptions struct {
}

ScriptActionsClientGetExecutionDetailOptions contains the optional parameters for the ScriptActionsClient.GetExecutionDetail method.

type ScriptActionsClientGetExecutionDetailResponse added in v0.2.0 

type ScriptActionsClientGetExecutionDetailResponse struct {
	ScriptActionsClientGetExecutionDetailResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ScriptActionsClientGetExecutionDetailResponse contains the response from method ScriptActionsClient.GetExecutionDetail.

type ScriptActionsClientGetExecutionDetailResult added in v0.2.0 

type ScriptActionsClientGetExecutionDetailResult struct {
	RuntimeScriptActionDetail
}

ScriptActionsClientGetExecutionDetailResult contains the result from method ScriptActionsClient.GetExecutionDetail.

type ScriptActionsClientListByClusterOptions added in v0.2.0 

type ScriptActionsClientListByClusterOptions struct {
}

ScriptActionsClientListByClusterOptions contains the optional parameters for the ScriptActionsClient.ListByCluster method.

type ScriptActionsClientListByClusterPager added in v0.2.0 

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

ScriptActionsClientListByClusterPager provides operations for iterating over paged responses.

func (*ScriptActionsClientListByClusterPager) Err added in v0.2.0 

func (p *ScriptActionsClientListByClusterPager) Err() error

Err returns the last error encountered while paging.

func (*ScriptActionsClientListByClusterPager) NextPage added in v0.2.0 

func (p *ScriptActionsClientListByClusterPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ScriptActionsClientListByClusterPager) PageResponse added in v0.2.0 

func (p *ScriptActionsClientListByClusterPager) PageResponse() ScriptActionsClientListByClusterResponse

PageResponse returns the current ScriptActionsClientListByClusterResponse page.

type ScriptActionsClientListByClusterResponse added in v0.2.0 

type ScriptActionsClientListByClusterResponse struct {
	ScriptActionsClientListByClusterResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ScriptActionsClientListByClusterResponse contains the response from method ScriptActionsClient.ListByCluster.

type ScriptActionsClientListByClusterResult added in v0.2.0 

type ScriptActionsClientListByClusterResult struct {
	ScriptActionsList
}

ScriptActionsClientListByClusterResult contains the result from method ScriptActionsClient.ListByCluster.

type ScriptActionsList 

type ScriptActionsList struct {
	// The list of persisted script action details for the cluster.
	Value []*RuntimeScriptActionDetail `json:"value,omitempty"`

	// READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`
}

ScriptActionsList - The persisted script action for the cluster.

func (ScriptActionsList) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ScriptActionsList.

type ScriptExecutionHistoryClient 

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

ScriptExecutionHistoryClient contains the methods for the ScriptExecutionHistory group. Don't use this type directly, use NewScriptExecutionHistoryClient() instead.

func NewScriptExecutionHistoryClient 

func NewScriptExecutionHistoryClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ScriptExecutionHistoryClient

NewScriptExecutionHistoryClient creates a new instance of ScriptExecutionHistoryClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*ScriptExecutionHistoryClient) ListByCluster 

func (client *ScriptExecutionHistoryClient) ListByCluster(resourceGroupName string, clusterName string, options *ScriptExecutionHistoryClientListByClusterOptions) *ScriptExecutionHistoryClientListByClusterPager

ListByCluster - Lists all scripts' execution history for the specified cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - ScriptExecutionHistoryClientListByClusterOptions contains the optional parameters for the ScriptExecutionHistoryClient.ListByCluster method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetScriptExecutionHistory.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewScriptExecutionHistoryClient("<subscription-id>", cred, nil)
	pager := client.ListByCluster("<resource-group-name>",
		"<cluster-name>",
		nil)
	for {
		nextResult := pager.NextPage(ctx)
		if err := pager.Err(); err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		if !nextResult {
			break
		}
		for _, v := range pager.PageResponse().Value {
			log.Printf("Pager result: %#v\n", v)
		}
	}
}

Output:

func (*ScriptExecutionHistoryClient) Promote 

func (client *ScriptExecutionHistoryClient) Promote(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string, options *ScriptExecutionHistoryClientPromoteOptions) (ScriptExecutionHistoryClientPromoteResponse, error)

Promote - Promotes the specified ad-hoc script execution to a persisted script. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. scriptExecutionID - The script execution Id options - ScriptExecutionHistoryClientPromoteOptions contains the optional parameters for the ScriptExecutionHistoryClient.Promote method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/PromoteLinuxHadoopScriptAction.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewScriptExecutionHistoryClient("<subscription-id>", cred, nil)
	_, err = client.Promote(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<script-execution-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

type ScriptExecutionHistoryClientListByClusterOptions added in v0.2.0 

type ScriptExecutionHistoryClientListByClusterOptions struct {
}

ScriptExecutionHistoryClientListByClusterOptions contains the optional parameters for the ScriptExecutionHistoryClient.ListByCluster method.

type ScriptExecutionHistoryClientListByClusterPager added in v0.2.0 

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

ScriptExecutionHistoryClientListByClusterPager provides operations for iterating over paged responses.

func (*ScriptExecutionHistoryClientListByClusterPager) Err added in v0.2.0 

func (p *ScriptExecutionHistoryClientListByClusterPager) Err() error

Err returns the last error encountered while paging.

func (*ScriptExecutionHistoryClientListByClusterPager) NextPage added in v0.2.0 

func (p *ScriptExecutionHistoryClientListByClusterPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ScriptExecutionHistoryClientListByClusterPager) PageResponse added in v0.2.0 

func (p *ScriptExecutionHistoryClientListByClusterPager) PageResponse() ScriptExecutionHistoryClientListByClusterResponse

PageResponse returns the current ScriptExecutionHistoryClientListByClusterResponse page.

type ScriptExecutionHistoryClientListByClusterResponse added in v0.2.0 

type ScriptExecutionHistoryClientListByClusterResponse struct {
	ScriptExecutionHistoryClientListByClusterResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ScriptExecutionHistoryClientListByClusterResponse contains the response from method ScriptExecutionHistoryClient.ListByCluster.

type ScriptExecutionHistoryClientListByClusterResult added in v0.2.0 

type ScriptExecutionHistoryClientListByClusterResult struct {
	ScriptActionExecutionHistoryList
}

ScriptExecutionHistoryClientListByClusterResult contains the result from method ScriptExecutionHistoryClient.ListByCluster.

type ScriptExecutionHistoryClientPromoteOptions added in v0.2.0 

type ScriptExecutionHistoryClientPromoteOptions struct {
}

ScriptExecutionHistoryClientPromoteOptions contains the optional parameters for the ScriptExecutionHistoryClient.Promote method.

type ScriptExecutionHistoryClientPromoteResponse added in v0.2.0 

type ScriptExecutionHistoryClientPromoteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ScriptExecutionHistoryClientPromoteResponse contains the response from method ScriptExecutionHistoryClient.Promote.

type SecurityProfile 

type SecurityProfile struct {
	// The resource ID of the user's Azure Active Directory Domain Service.
	AaddsResourceID *string `json:"aaddsResourceId,omitempty"`

	// Optional. The Distinguished Names for cluster user groups
	ClusterUsersGroupDNs []*string `json:"clusterUsersGroupDNs,omitempty"`

	// The directory type.
	DirectoryType *DirectoryType `json:"directoryType,omitempty"`

	// The organization's active directory domain.
	Domain *string `json:"domain,omitempty"`

	// The domain admin password.
	DomainUserPassword *string `json:"domainUserPassword,omitempty"`

	// The domain user account that will have admin privileges on the cluster.
	DomainUsername *string `json:"domainUsername,omitempty"`

	// The LDAPS protocol URLs to communicate with the Active Directory.
	LdapsUrls []*string `json:"ldapsUrls,omitempty"`

	// User assigned identity that has permissions to read and create cluster-related artifacts in the user's AADDS.
	MsiResourceID *string `json:"msiResourceId,omitempty"`

	// The organizational unit within the Active Directory to place the cluster and service accounts.
	OrganizationalUnitDN *string `json:"organizationalUnitDN,omitempty"`
}

SecurityProfile - The security profile which contains Ssh public key for the HDInsight cluster.

func (SecurityProfile) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type SecurityProfile.

type ServiceSpecification 

type ServiceSpecification struct {
	// The metric specifications.
	MetricSpecifications []*MetricSpecifications `json:"metricSpecifications,omitempty"`
}

ServiceSpecification - The specification of the service.

func (ServiceSpecification) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type ServiceSpecification.

type StorageAccount 

type StorageAccount struct {
	// The container in the storage account, only to be specified for WASB storage accounts.
	Container *string `json:"container,omitempty"`

	// The filesystem, only to be specified for Azure Data Lake Storage Gen 2.
	FileSystem *string `json:"fileSystem,omitempty"`

	// The file share name.
	Fileshare *string `json:"fileshare,omitempty"`

	// Whether or not the storage account is the default storage account.
	IsDefault *bool `json:"isDefault,omitempty"`

	// The storage account access key.
	Key *string `json:"key,omitempty"`

	// The managed identity (MSI) that is allowed to access the storage account, only to be specified for Azure Data Lake Storage
	// Gen 2.
	MsiResourceID *string `json:"msiResourceId,omitempty"`

	// The name of the storage account.
	Name *string `json:"name,omitempty"`

	// The resource ID of storage account, only to be specified for Azure Data Lake Storage Gen 2.
	ResourceID *string `json:"resourceId,omitempty"`

	// The shared access signature key.
	Saskey *string `json:"saskey,omitempty"`
}

StorageAccount - The storage Account.

type StorageProfile 

type StorageProfile struct {
	// The list of storage accounts in the cluster.
	Storageaccounts []*StorageAccount `json:"storageaccounts,omitempty"`
}

StorageProfile - The storage profile.

func (StorageProfile) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type StorageProfile.

type SystemData 

type SystemData struct {
	// The timestamp of resource creation (UTC).
	CreatedAt *time.Time `json:"createdAt,omitempty"`

	// The identity that created the resource.
	CreatedBy *string `json:"createdBy,omitempty"`

	// The type of identity that created the resource.
	CreatedByType *CreatedByType `json:"createdByType,omitempty"`

	// The timestamp of resource last modification (UTC)
	LastModifiedAt *time.Time `json:"lastModifiedAt,omitempty"`

	// The identity that last modified the resource.
	LastModifiedBy *string `json:"lastModifiedBy,omitempty"`

	// The type of identity that last modified the resource.
	LastModifiedByType *CreatedByType `json:"lastModifiedByType,omitempty"`
}

SystemData - Metadata pertaining to creation and last modification of the resource.

func (SystemData) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type SystemData.

func (*SystemData) UnmarshalJSON 

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

UnmarshalJSON implements the json.Unmarshaller interface for type SystemData.

type Tier 

type Tier string

Tier - The cluster tier. 

const (
	TierPremium  Tier = "Premium"
	TierStandard Tier = "Standard"
)

func PossibleTierValues 

func PossibleTierValues() []Tier

PossibleTierValues returns the possible values for the Tier const type.

func (Tier) ToPtr 

func (c Tier) ToPtr() *Tier

ToPtr returns a *Tier pointing to the current value.

type TrackedResource 

type TrackedResource struct {
	// REQUIRED; The geo-location where the resource lives
	Location *string `json:"location,omitempty"`

	// Resource tags.
	Tags map[string]*string `json:"tags,omitempty"`

	// READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty" azure:"ro"`
}

TrackedResource - The resource model definition for an Azure Resource Manager tracked top level resource which has 'tags' and a 'location'

func (TrackedResource) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type TrackedResource.

type UpdateClusterIdentityCertificateParameters 

type UpdateClusterIdentityCertificateParameters struct {
	// The application id.
	ApplicationID *string `json:"applicationId,omitempty"`

	// The certificate in base64 encoded format.
	Certificate *string `json:"certificate,omitempty"`

	// The password of the certificate.
	CertificatePassword *string `json:"certificatePassword,omitempty"`
}

UpdateClusterIdentityCertificateParameters - The update cluster identity certificate request parameters.

type UpdateGatewaySettingsParameters 

type UpdateGatewaySettingsParameters struct {
	// Indicates whether or not the gateway settings based authorization is enabled.
	IsCredentialEnabled *bool `json:"restAuthCredential.isEnabled,omitempty"`

	// The gateway settings user password.
	Password *string `json:"restAuthCredential.password,omitempty"`

	// The gateway settings user name.
	UserName *string `json:"restAuthCredential.username,omitempty"`
}

UpdateGatewaySettingsParameters - The update gateway settings request parameters.

type Usage 

type Usage struct {
	// The current usage.
	CurrentValue *int64 `json:"currentValue,omitempty"`

	// The maximum allowed usage.
	Limit *int64 `json:"limit,omitempty"`

	// The type of measurement for usage.
	Unit *string `json:"unit,omitempty"`

	// READ-ONLY; The details about the localizable name of the used resource.
	Name *LocalizedName `json:"name,omitempty" azure:"ro"`
}

Usage - The details about the usage of a particular limited resource.

type UsagesListResult 

type UsagesListResult struct {
	// The list of usages.
	Value []*Usage `json:"value,omitempty"`
}

UsagesListResult - The response for the operation to get regional usages for a subscription.

func (UsagesListResult) MarshalJSON 

func (u UsagesListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type UsagesListResult.

type UserAssignedIdentity 

type UserAssignedIdentity struct {
	// The tenant id of user assigned identity.
	TenantID *string `json:"tenantId,omitempty"`

	// READ-ONLY; The client id of user assigned identity.
	ClientID *string `json:"clientId,omitempty" azure:"ro"`

	// READ-ONLY; The principal id of user assigned identity.
	PrincipalID *string `json:"principalId,omitempty" azure:"ro"`
}

UserAssignedIdentity - The User Assigned Identity

type VMSizeCompatibilityFilterV2 

type VMSizeCompatibilityFilterV2 struct {
	// The list of cluster flavors under the effect of the filter.
	ClusterFlavors []*string `json:"clusterFlavors,omitempty"`

	// The list of cluster versions affected in Major.Minor format.
	ClusterVersions []*string `json:"clusterVersions,omitempty"`

	// Whether support compute isolation. 'true' means only for ComputeIsolationEnabled, 'false' means only for regular cluster.
	ComputeIsolationSupported *string `json:"computeIsolationSupported,omitempty"`

	// Whether apply for ESP cluster. 'true' means only for ESP, 'false' means only for non-ESP, null or empty string or others
	// mean for both.
	EspApplied *string `json:"espApplied,omitempty"`

	// The filtering mode. Effectively this can enabling or disabling the VM sizes in a particular set.
	FilterMode *FilterMode `json:"filterMode,omitempty"`

	// The list of node types affected by the filter.
	NodeTypes []*string `json:"nodeTypes,omitempty"`

	// The OSType affected, Windows or Linux.
	OSType []*OSType `json:"osType,omitempty"`

	// The list of regions under the effect of the filter.
	Regions []*string `json:"regions,omitempty"`

	// The list of virtual machine sizes to include or exclude.
	VMSizes []*string `json:"vmSizes,omitempty"`
}

VMSizeCompatibilityFilterV2 - This class represent a single filter object that defines a multidimensional set. The dimensions of this set are Regions, ClusterFlavors, NodeTypes and ClusterVersions. The constraint should be defined based on the following: FilterMode (Exclude vs Include), VMSizes (the vm sizes in affect of exclusion/inclusion) and the ordering of the Filters. Later filters override previous settings if conflicted.

func (VMSizeCompatibilityFilterV2) MarshalJSON 

func (v VMSizeCompatibilityFilterV2) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type VMSizeCompatibilityFilterV2.

type VMSizeProperty 

type VMSizeProperty struct {
	// The number of cores that the vm size has.
	Cores *int32 `json:"cores,omitempty"`

	// The data disk storage tier of the vm size.
	DataDiskStorageTier *string `json:"dataDiskStorageTier,omitempty"`

	// The label of the vm size.
	Label *string `json:"label,omitempty"`

	// The max data disk count of the vm size.
	MaxDataDiskCount *int64 `json:"maxDataDiskCount,omitempty"`

	// The memory whose unit is MB of the vm size.
	MemoryInMb *int64 `json:"memoryInMb,omitempty"`

	// The vm size name.
	Name *string `json:"name,omitempty"`

	// This indicates this vm size is supported by virtual machines or not
	SupportedByVirtualMachines *bool `json:"supportedByVirtualMachines,omitempty"`

	// The indicates this vm size is supported by web worker roles or not
	SupportedByWebWorkerRoles *bool `json:"supportedByWebWorkerRoles,omitempty"`

	// The virtual machine resource disk size whose unit is MB of the vm size.
	VirtualMachineResourceDiskSizeInMb *int64 `json:"virtualMachineResourceDiskSizeInMb,omitempty"`

	// The web worker resource disk size whose unit is MB of the vm size.
	WebWorkerResourceDiskSizeInMb *int64 `json:"webWorkerResourceDiskSizeInMb,omitempty"`
}

VMSizeProperty - The vm size property

type ValidationErrorInfo 

type ValidationErrorInfo struct {
	// The error code.
	Code *string `json:"code,omitempty"`

	// The error resource.
	ErrorResource *string `json:"errorResource,omitempty"`

	// The error message.
	Message *string `json:"message,omitempty"`

	// The message arguments
	MessageArguments []*string `json:"messageArguments,omitempty"`
}

ValidationErrorInfo - The validation error information.

func (ValidationErrorInfo) MarshalJSON 

func (v ValidationErrorInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ValidationErrorInfo.

type VersionSpec 

type VersionSpec struct {
	// The component version property.
	ComponentVersions map[string]*string `json:"componentVersions,omitempty"`

	// The display name
	DisplayName *string `json:"displayName,omitempty"`

	// The friendly name
	FriendlyName *string `json:"friendlyName,omitempty"`

	// Whether or not the version is the default version.
	IsDefault *bool `json:"isDefault,omitempty"`
}

VersionSpec - The version properties.

func (VersionSpec) MarshalJSON 

func (v VersionSpec) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type VersionSpec.

type VersionsCapability 

type VersionsCapability struct {
	// The list of version capabilities.
	Available []*VersionSpec `json:"available,omitempty"`
}

VersionsCapability - The version capability.

func (VersionsCapability) MarshalJSON 

func (v VersionsCapability) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type VersionsCapability.

type VirtualMachinesClient 

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

VirtualMachinesClient contains the methods for the VirtualMachines group. Don't use this type directly, use NewVirtualMachinesClient() instead.

func NewVirtualMachinesClient 

func NewVirtualMachinesClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *VirtualMachinesClient

NewVirtualMachinesClient creates a new instance of VirtualMachinesClient with the specified values. subscriptionID - The subscription credentials which uniquely identify Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.

func (*VirtualMachinesClient) BeginRestartHosts 

func (client *VirtualMachinesClient) BeginRestartHosts(ctx context.Context, resourceGroupName string, clusterName string, hosts []*string, options *VirtualMachinesClientBeginRestartHostsOptions) (VirtualMachinesClientRestartHostsPollerResponse, error)

BeginRestartHosts - Restarts the specified HDInsight cluster hosts. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. hosts - The list of hosts to restart options - VirtualMachinesClientBeginRestartHostsOptions contains the optional parameters for the VirtualMachinesClient.BeginRestartHosts method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/RestartVirtualMachinesOperation.json 

package main

import (
	"context"
	"log"

	"time"

	"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/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewVirtualMachinesClient("<subscription-id>", cred, nil)
	poller, err := client.BeginRestartHosts(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		[]*string{
			to.StringPtr("gateway1"),
			to.StringPtr("gateway3")},
		nil)
	if err != nil {
		log.Fatal(err)
	}
	_, err = poller.PollUntilDone(ctx, 30*time.Second)
	if err != nil {
		log.Fatal(err)
	}
}

Output:

func (*VirtualMachinesClient) GetAsyncOperationStatus 

func (client *VirtualMachinesClient) GetAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, operationID string, options *VirtualMachinesClientGetAsyncOperationStatusOptions) (VirtualMachinesClientGetAsyncOperationStatusResponse, error)

GetAsyncOperationStatus - Gets the async operation status. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. operationID - The long running operation id. options - VirtualMachinesClientGetAsyncOperationStatusOptions contains the optional parameters for the VirtualMachinesClient.GetAsyncOperationStatus method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetRestartHostsAsyncOperationStatus.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewVirtualMachinesClient("<subscription-id>", cred, nil)
	res, err := client.GetAsyncOperationStatus(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		"<operation-id>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.VirtualMachinesClientGetAsyncOperationStatusResult)
}

Output:

func (*VirtualMachinesClient) ListHosts 

func (client *VirtualMachinesClient) ListHosts(ctx context.Context, resourceGroupName string, clusterName string, options *VirtualMachinesClientListHostsOptions) (VirtualMachinesClientListHostsResponse, error)

ListHosts - Lists the HDInsight clusters hosts If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - The name of the resource group. clusterName - The name of the cluster. options - VirtualMachinesClientListHostsOptions contains the optional parameters for the VirtualMachinesClient.ListHosts method.

Example

x-ms-original-file: specification/hdinsight/resource-manager/Microsoft.HDInsight/stable/2021-06-01/examples/GetClusterVirtualMachines.json 

package main

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hdinsight/armhdinsight"
)

func main() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client := armhdinsight.NewVirtualMachinesClient("<subscription-id>", cred, nil)
	res, err := client.ListHosts(ctx,
		"<resource-group-name>",
		"<cluster-name>",
		nil)
	if err != nil {
		log.Fatal(err)
	}
	log.Printf("Response result: %#v\n", res.VirtualMachinesClientListHostsResult)
}

Output:

type VirtualMachinesClientBeginRestartHostsOptions added in v0.2.0 

type VirtualMachinesClientBeginRestartHostsOptions struct {
}

VirtualMachinesClientBeginRestartHostsOptions contains the optional parameters for the VirtualMachinesClient.BeginRestartHosts method.

type VirtualMachinesClientGetAsyncOperationStatusOptions added in v0.2.0 

type VirtualMachinesClientGetAsyncOperationStatusOptions struct {
}

VirtualMachinesClientGetAsyncOperationStatusOptions contains the optional parameters for the VirtualMachinesClient.GetAsyncOperationStatus method.

type VirtualMachinesClientGetAsyncOperationStatusResponse added in v0.2.0 

type VirtualMachinesClientGetAsyncOperationStatusResponse struct {
	VirtualMachinesClientGetAsyncOperationStatusResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

VirtualMachinesClientGetAsyncOperationStatusResponse contains the response from method VirtualMachinesClient.GetAsyncOperationStatus.

type VirtualMachinesClientGetAsyncOperationStatusResult added in v0.2.0 

type VirtualMachinesClientGetAsyncOperationStatusResult struct {
	AsyncOperationResult
}

VirtualMachinesClientGetAsyncOperationStatusResult contains the result from method VirtualMachinesClient.GetAsyncOperationStatus.

type VirtualMachinesClientListHostsOptions added in v0.2.0 

type VirtualMachinesClientListHostsOptions struct {
}

VirtualMachinesClientListHostsOptions contains the optional parameters for the VirtualMachinesClient.ListHosts method.

type VirtualMachinesClientListHostsResponse added in v0.2.0 

type VirtualMachinesClientListHostsResponse struct {
	VirtualMachinesClientListHostsResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

VirtualMachinesClientListHostsResponse contains the response from method VirtualMachinesClient.ListHosts.

type VirtualMachinesClientListHostsResult added in v0.2.0 

type VirtualMachinesClientListHostsResult struct {
	// Result of the request to list cluster hosts
	HostInfoArray []*HostInfo
}

VirtualMachinesClientListHostsResult contains the result from method VirtualMachinesClient.ListHosts.

type VirtualMachinesClientRestartHostsPoller added in v0.2.0 

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

VirtualMachinesClientRestartHostsPoller provides polling facilities until the operation reaches a terminal state.

func (*VirtualMachinesClientRestartHostsPoller) Done added in v0.2.0 

func (p *VirtualMachinesClientRestartHostsPoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*VirtualMachinesClientRestartHostsPoller) FinalResponse added in v0.2.0 

func (p *VirtualMachinesClientRestartHostsPoller) FinalResponse(ctx context.Context) (VirtualMachinesClientRestartHostsResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final VirtualMachinesClientRestartHostsResponse will be returned.

func (*VirtualMachinesClientRestartHostsPoller) Poll added in v0.2.0 

func (p *VirtualMachinesClientRestartHostsPoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*VirtualMachinesClientRestartHostsPoller) ResumeToken added in v0.2.0 

func (p *VirtualMachinesClientRestartHostsPoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type VirtualMachinesClientRestartHostsPollerResponse added in v0.2.0 

type VirtualMachinesClientRestartHostsPollerResponse struct {
	// Poller contains an initialized poller.
	Poller *VirtualMachinesClientRestartHostsPoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

VirtualMachinesClientRestartHostsPollerResponse contains the response from method VirtualMachinesClient.RestartHosts.

func (VirtualMachinesClientRestartHostsPollerResponse) PollUntilDone added in v0.2.0 

func (l VirtualMachinesClientRestartHostsPollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (VirtualMachinesClientRestartHostsResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.

func (*VirtualMachinesClientRestartHostsPollerResponse) Resume added in v0.2.0 

func (l *VirtualMachinesClientRestartHostsPollerResponse) Resume(ctx context.Context, client *VirtualMachinesClient, token string) error

Resume rehydrates a VirtualMachinesClientRestartHostsPollerResponse from the provided client and resume token.

type VirtualMachinesClientRestartHostsResponse added in v0.2.0 

type VirtualMachinesClientRestartHostsResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

VirtualMachinesClientRestartHostsResponse contains the response from method VirtualMachinesClient.RestartHosts.

type VirtualNetworkProfile 

type VirtualNetworkProfile struct {
	// The ID of the virtual network.
	ID *string `json:"id,omitempty"`

	// The name of the subnet.
	Subnet *string `json:"subnet,omitempty"`
}

VirtualNetworkProfile - The virtual network properties.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.