hdinsight

package
v61.4.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 29, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Package hdinsight implements the Azure ARM Hdinsight service API version 2021-06-01.

HDInsight Management Client

Index

Constants

View Source
const (
	// DefaultBaseURI is the default URI used for the service Hdinsight
	DefaultBaseURI = "https://management.azure.com"
)

Variables

This section is empty.

Functions

func UserAgent

func UserAgent() string

UserAgent returns the UserAgent string to use when sending http.Requests.

func Version

func Version() string

Version returns the semantic version (see http://semver.org) of the client.

Types

type AaddsResourceDetails

type AaddsResourceDetails struct {
	// DomainName - The Azure active directory domain service name.
	DomainName *string `json:"domainName,omitempty"`
	// InitialSyncComplete - This indicates whether initial sync complete or not.
	InitialSyncComplete *bool `json:"initialSyncComplete,omitempty"`
	// LdapsEnabled - This indicates whether enable ldaps or not.
	LdapsEnabled *bool `json:"ldapsEnabled,omitempty"`
	// LdapsPublicCertificateInBase64 - The base 64 format string of public ldap certificate.
	LdapsPublicCertificateInBase64 *string `json:"ldapsPublicCertificateInBase64,omitempty"`
	// ResourceID - The resource id of azure active directory domain service.
	ResourceID *string `json:"resourceId,omitempty"`
	// SubnetID - The subnet resource id.
	SubnetID *string `json:"subnetId,omitempty"`
	// TenantID - 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 {
	autorest.Response `json:"-"`
	// Etag - The ETag for the application
	Etag *string `json:"etag,omitempty"`
	// Tags - The tags for the application.
	Tags map[string]*string `json:"tags"`
	// Properties - The properties of the application.
	Properties *ApplicationProperties `json:"properties,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

Application the HDInsight cluster application

func (Application) MarshalJSON

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

MarshalJSON is the custom marshaler for Application.

type ApplicationGetEndpoint

type ApplicationGetEndpoint struct {
	// Location - The location of the endpoint.
	Location *string `json:"location,omitempty"`
	// DestinationPort - The destination port to connect to.
	DestinationPort *int32 `json:"destinationPort,omitempty"`
	// PublicPort - The public port to connect to.
	PublicPort *int32 `json:"publicPort,omitempty"`
	// PrivateIPAddress - The private ip address of the endpoint.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`
}

ApplicationGetEndpoint gets the application SSH endpoint

type ApplicationGetHTTPSEndpoint

type ApplicationGetHTTPSEndpoint struct {
	// AccessModes - The list of access modes for the application.
	AccessModes *[]string `json:"accessModes,omitempty"`
	// Location - READ-ONLY; The location of the endpoint.
	Location *string `json:"location,omitempty"`
	// DestinationPort - The destination port to connect to.
	DestinationPort *int32 `json:"destinationPort,omitempty"`
	// PublicPort - READ-ONLY; The public port to connect to.
	PublicPort *int32 `json:"publicPort,omitempty"`
	// PrivateIPAddress - The private ip address of the endpoint.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`
	// SubDomainSuffix - The subdomain suffix of the application.
	SubDomainSuffix *string `json:"subDomainSuffix,omitempty"`
	// DisableGatewayAuth - The value indicates whether to disable GatewayAuth.
	DisableGatewayAuth *bool `json:"disableGatewayAuth,omitempty"`
}

ApplicationGetHTTPSEndpoint gets the application HTTP endpoints.

func (ApplicationGetHTTPSEndpoint) MarshalJSON

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

MarshalJSON is the custom marshaler for ApplicationGetHTTPSEndpoint.

type ApplicationListResult

type ApplicationListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of HDInsight applications installed on HDInsight cluster.
	Value *[]Application `json:"value,omitempty"`
	// NextLink - READ-ONLY; The URL to get the next set of operation list results if there are any.
	NextLink *string `json:"nextLink,omitempty"`
}

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) IsEmpty

func (alr ApplicationListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (ApplicationListResult) MarshalJSON

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

MarshalJSON is the custom marshaler for ApplicationListResult.

type ApplicationListResultIterator

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

ApplicationListResultIterator provides access to a complete listing of Application values.

func NewApplicationListResultIterator

func NewApplicationListResultIterator(page ApplicationListResultPage) ApplicationListResultIterator

Creates a new instance of the ApplicationListResultIterator type.

func (*ApplicationListResultIterator) Next

func (iter *ApplicationListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ApplicationListResultIterator) NextWithContext

func (iter *ApplicationListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (ApplicationListResultIterator) NotDone

func (iter ApplicationListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (ApplicationListResultIterator) Response

Response returns the raw server response from the last page request.

func (ApplicationListResultIterator) Value

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type ApplicationListResultPage

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

ApplicationListResultPage contains a page of Application values.

func NewApplicationListResultPage

Creates a new instance of the ApplicationListResultPage type.

func (*ApplicationListResultPage) Next

func (page *ApplicationListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ApplicationListResultPage) NextWithContext

func (page *ApplicationListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (ApplicationListResultPage) NotDone

func (page ApplicationListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (ApplicationListResultPage) Response

Response returns the raw server response from the last page request.

func (ApplicationListResultPage) Values

func (page ApplicationListResultPage) Values() []Application

Values returns the slice of values for the current page or nil if there are no values.

type ApplicationProperties

type ApplicationProperties struct {
	// ComputeProfile - The list of roles in the cluster.
	ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"`
	// InstallScriptActions - The list of install script actions.
	InstallScriptActions *[]RuntimeScriptAction `json:"installScriptActions,omitempty"`
	// UninstallScriptActions - The list of uninstall script actions.
	UninstallScriptActions *[]RuntimeScriptAction `json:"uninstallScriptActions,omitempty"`
	// HTTPSEndpoints - The list of application HTTPS endpoints.
	HTTPSEndpoints *[]ApplicationGetHTTPSEndpoint `json:"httpsEndpoints,omitempty"`
	// SSHEndpoints - The list of application SSH endpoints.
	SSHEndpoints *[]ApplicationGetEndpoint `json:"sshEndpoints,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioning state of the application.
	ProvisioningState *string `json:"provisioningState,omitempty"`
	// ApplicationType - The application type.
	ApplicationType *string `json:"applicationType,omitempty"`
	// ApplicationState - READ-ONLY; The application state.
	ApplicationState *string `json:"applicationState,omitempty"`
	// Errors - The list of errors.
	Errors *[]Errors `json:"errors,omitempty"`
	// CreatedDate - READ-ONLY; The application create date time.
	CreatedDate *string `json:"createdDate,omitempty"`
	// MarketplaceIdentifier - READ-ONLY; The marketplace identifier.
	MarketplaceIdentifier *string `json:"marketplaceIdentifier,omitempty"`
	// PrivateLinkConfigurations - The private link configurations.
	PrivateLinkConfigurations *[]PrivateLinkConfiguration `json:"privateLinkConfigurations,omitempty"`
}

ApplicationProperties the HDInsight cluster application GET response.

func (ApplicationProperties) MarshalJSON

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

MarshalJSON is the custom marshaler for ApplicationProperties.

type ApplicationsClient

type ApplicationsClient struct {
	BaseClient
}

ApplicationsClient is the hDInsight Management Client

func NewApplicationsClient

func NewApplicationsClient(subscriptionID string) ApplicationsClient

NewApplicationsClient creates an instance of the ApplicationsClient client.

func NewApplicationsClientWithBaseURI

func NewApplicationsClientWithBaseURI(baseURI string, subscriptionID string) ApplicationsClient

NewApplicationsClientWithBaseURI creates an instance of the ApplicationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ApplicationsClient) Create

func (client ApplicationsClient) Create(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, parameters Application) (result ApplicationsCreateFuture, err error)

Create creates applications for the HDInsight cluster. Parameters: 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.

func (ApplicationsClient) CreatePreparer

func (client ApplicationsClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, parameters Application) (*http.Request, error)

CreatePreparer prepares the Create request.

func (ApplicationsClient) CreateResponder

func (client ApplicationsClient) CreateResponder(resp *http.Response) (result Application, err error)

CreateResponder handles the response to the Create request. The method always closes the http.Response Body.

func (ApplicationsClient) CreateSender

func (client ApplicationsClient) CreateSender(req *http.Request) (future ApplicationsCreateFuture, err error)

CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.

func (ApplicationsClient) Delete

func (client ApplicationsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, applicationName string) (result ApplicationsDeleteFuture, err error)

Delete deletes the specified application on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. applicationName - the constant value for the application name.

func (ApplicationsClient) DeletePreparer

func (client ApplicationsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, applicationName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ApplicationsClient) DeleteResponder

func (client ApplicationsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (ApplicationsClient) DeleteSender

func (client ApplicationsClient) DeleteSender(req *http.Request) (future ApplicationsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ApplicationsClient) Get

func (client ApplicationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, applicationName string) (result Application, err error)

Get gets properties of the specified application. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. applicationName - the constant value for the application name.

func (ApplicationsClient) GetAzureAsyncOperationStatus

func (client ApplicationsClient) GetAzureAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, operationID string) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatus gets the async operation status. Parameters: 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.

func (ApplicationsClient) GetAzureAsyncOperationStatusPreparer

func (client ApplicationsClient) GetAzureAsyncOperationStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, operationID string) (*http.Request, error)

GetAzureAsyncOperationStatusPreparer prepares the GetAzureAsyncOperationStatus request.

func (ApplicationsClient) GetAzureAsyncOperationStatusResponder

func (client ApplicationsClient) GetAzureAsyncOperationStatusResponder(resp *http.Response) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatusResponder handles the response to the GetAzureAsyncOperationStatus request. The method always closes the http.Response Body.

func (ApplicationsClient) GetAzureAsyncOperationStatusSender

func (client ApplicationsClient) GetAzureAsyncOperationStatusSender(req *http.Request) (*http.Response, error)

GetAzureAsyncOperationStatusSender sends the GetAzureAsyncOperationStatus request. The method will close the http.Response Body if it receives an error.

func (ApplicationsClient) GetPreparer

func (client ApplicationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, applicationName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ApplicationsClient) GetResponder

func (client ApplicationsClient) GetResponder(resp *http.Response) (result Application, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ApplicationsClient) GetSender

func (client ApplicationsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (ApplicationsClient) ListByCluster

func (client ApplicationsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result ApplicationListResultPage, err error)

ListByCluster lists all of the applications for the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ApplicationsClient) ListByClusterComplete

func (client ApplicationsClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ApplicationListResultIterator, err error)

ListByClusterComplete enumerates all values, automatically crossing page boundaries as required.

func (ApplicationsClient) ListByClusterPreparer

func (client ApplicationsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListByClusterPreparer prepares the ListByCluster request.

func (ApplicationsClient) ListByClusterResponder

func (client ApplicationsClient) ListByClusterResponder(resp *http.Response) (result ApplicationListResult, err error)

ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.

func (ApplicationsClient) ListByClusterSender

func (client ApplicationsClient) ListByClusterSender(req *http.Request) (*http.Response, error)

ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.

type ApplicationsCreateFuture

type ApplicationsCreateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ApplicationsClient) (Application, error)
}

ApplicationsCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ApplicationsCreateFuture) UnmarshalJSON

func (future *ApplicationsCreateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ApplicationsDeleteFuture

type ApplicationsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ApplicationsClient) (autorest.Response, error)
}

ApplicationsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ApplicationsDeleteFuture) UnmarshalJSON

func (future *ApplicationsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type AsyncOperationResult

type AsyncOperationResult struct {
	autorest.Response `json:"-"`
	// Status - The async operation state. Possible values include: 'AsyncOperationStateInProgress', 'AsyncOperationStateSucceeded', 'AsyncOperationStateFailed'
	Status AsyncOperationState `json:"status,omitempty"`
	// Error - The operation error information.
	Error *Errors `json:"error,omitempty"`
}

AsyncOperationResult the azure async operation response.

type AsyncOperationState

type AsyncOperationState string

AsyncOperationState enumerates the values for async operation state.

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

func PossibleAsyncOperationStateValues

func PossibleAsyncOperationStateValues() []AsyncOperationState

PossibleAsyncOperationStateValues returns an array of possible values for the AsyncOperationState const type.

type Autoscale

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

Autoscale the autoscale request parameters

type AutoscaleCapacity

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

AutoscaleCapacity the load-based autoscale request parameters

type AutoscaleConfigurationUpdateParameter

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

AutoscaleConfigurationUpdateParameter the autoscale configuration update parameter.

type AutoscaleRecurrence

type AutoscaleRecurrence struct {
	// TimeZone - The time zone for the autoscale schedule times
	TimeZone *string `json:"timeZone,omitempty"`
	// Schedule - Array of schedule-based autoscale rules
	Schedule *[]AutoscaleSchedule `json:"schedule,omitempty"`
}

AutoscaleRecurrence schedule-based autoscale request parameters

type AutoscaleSchedule

type AutoscaleSchedule struct {
	// Days - Days of the week for a schedule-based autoscale rule
	Days *[]DaysOfWeek `json:"days,omitempty"`
	// TimeAndCapacity - 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

type AutoscaleTimeAndCapacity

type AutoscaleTimeAndCapacity struct {
	// Time - 24-hour time in the form xx:xx
	Time *string `json:"time,omitempty"`
	// MinInstanceCount - The minimum instance count of the cluster
	MinInstanceCount *int32 `json:"minInstanceCount,omitempty"`
	// MaxInstanceCount - The maximum instance count of the cluster
	MaxInstanceCount *int32 `json:"maxInstanceCount,omitempty"`
}

AutoscaleTimeAndCapacity time and capacity request parameters

type AzureEntityResource

type AzureEntityResource struct {
	// Etag - READ-ONLY; Resource Etag.
	Etag *string `json:"etag,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

AzureEntityResource the resource model definition for an Azure Resource Manager resource with an etag.

func (AzureEntityResource) MarshalJSON

func (aer AzureEntityResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureEntityResource.

type AzureMonitorRequest

type AzureMonitorRequest struct {
	// WorkspaceID - The Log Analytics workspace ID.
	WorkspaceID *string `json:"workspaceId,omitempty"`
	// PrimaryKey - The Log Analytics workspace key.
	PrimaryKey *string `json:"primaryKey,omitempty"`
	// SelectedConfigurations - The selected configurations.
	SelectedConfigurations *AzureMonitorSelectedConfigurations `json:"selectedConfigurations,omitempty"`
}

AzureMonitorRequest the azure monitor parameters.

type AzureMonitorResponse

type AzureMonitorResponse struct {
	autorest.Response `json:"-"`
	// ClusterMonitoringEnabled - The status of the monitor on the HDInsight cluster.
	ClusterMonitoringEnabled *bool `json:"clusterMonitoringEnabled,omitempty"`
	// WorkspaceID - The workspace ID of the monitor on the HDInsight cluster.
	WorkspaceID *string `json:"workspaceId,omitempty"`
	// SelectedConfigurations - The selected configurations.
	SelectedConfigurations *AzureMonitorSelectedConfigurations `json:"selectedConfigurations,omitempty"`
}

AzureMonitorResponse the azure monitor status response.

type AzureMonitorSelectedConfigurations

type AzureMonitorSelectedConfigurations struct {
	// ConfigurationVersion - The configuration version.
	ConfigurationVersion *string `json:"configurationVersion,omitempty"`
	// GlobalConfigurations - The global configurations of selected configurations.
	GlobalConfigurations map[string]*string `json:"globalConfigurations"`
	// TableList - The table list.
	TableList *[]AzureMonitorTableConfiguration `json:"tableList,omitempty"`
}

AzureMonitorSelectedConfigurations the selected configurations for azure monitor.

func (AzureMonitorSelectedConfigurations) MarshalJSON

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

MarshalJSON is the custom marshaler for AzureMonitorSelectedConfigurations.

type AzureMonitorTableConfiguration

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

AzureMonitorTableConfiguration the table configuration for the Log Analytics integration.

type BaseClient

type BaseClient struct {
	autorest.Client
	BaseURI        string
	SubscriptionID string
}

BaseClient is the base client for Hdinsight.

func New

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

type BillingMeters

type BillingMeters struct {
	// MeterParameter - The virtual machine sizes.
	MeterParameter *string `json:"meterParameter,omitempty"`
	// Meter - The HDInsight meter guid.
	Meter *string `json:"meter,omitempty"`
	// Unit - The unit of meter, VMHours or CoreHours.
	Unit *string `json:"unit,omitempty"`
}

BillingMeters the billing meters.

type BillingResources

type BillingResources struct {
	// Region - The region or location.
	Region *string `json:"region,omitempty"`
	// BillingMeters - The billing meter information.
	BillingMeters *[]BillingMeters `json:"billingMeters,omitempty"`
	// DiskBillingMeters - The managed disk billing information.
	DiskBillingMeters *[]DiskBillingMeters `json:"diskBillingMeters,omitempty"`
}

BillingResources the billing resources.

type BillingResponseListResult

type BillingResponseListResult struct {
	autorest.Response `json:"-"`
	// VMSizes - The virtual machine sizes to include or exclude.
	VMSizes *[]string `json:"vmSizes,omitempty"`
	// VMSizesWithEncryptionAtHost - The vm sizes which enable encryption at host.
	VMSizesWithEncryptionAtHost *[]string `json:"vmSizesWithEncryptionAtHost,omitempty"`
	// VMSizeFilters - The virtual machine filtering mode. Effectively this can enabling or disabling the virtual machine sizes in a particular set.
	VMSizeFilters *[]VMSizeCompatibilityFilterV2 `json:"vmSizeFilters,omitempty"`
	// VMSizeProperties - READ-ONLY; The vm size properties.
	VMSizeProperties *[]VMSizeProperty `json:"vmSizeProperties,omitempty"`
	// BillingResources - The billing and managed disk billing resources for a region.
	BillingResources *[]BillingResources `json:"billingResources,omitempty"`
}

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

func (BillingResponseListResult) MarshalJSON

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

MarshalJSON is the custom marshaler for BillingResponseListResult.

type CapabilitiesResult

type CapabilitiesResult struct {
	autorest.Response `json:"-"`
	// Versions - The version capability.
	Versions map[string]*VersionsCapability `json:"versions"`
	// Regions - The virtual machine size compatibility features.
	Regions map[string]*RegionsCapability `json:"regions"`
	// Features - The capability features.
	Features *[]string `json:"features,omitempty"`
	// Quota - The quota capability.
	Quota *QuotaCapability `json:"quota,omitempty"`
}

CapabilitiesResult the Get Capabilities operation response.

func (CapabilitiesResult) MarshalJSON

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

MarshalJSON is the custom marshaler for CapabilitiesResult.

type ClientGroupInfo

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

ClientGroupInfo the information of AAD security group.

type Cluster

type Cluster struct {
	autorest.Response `json:"-"`
	// Etag - The ETag for the resource
	Etag *string `json:"etag,omitempty"`
	// Zones - The availability zones.
	Zones *[]string `json:"zones,omitempty"`
	// Properties - The properties of the cluster.
	Properties *ClusterGetProperties `json:"properties,omitempty"`
	// Identity - The identity of the cluster, if configured.
	Identity *ClusterIdentity `json:"identity,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - The geo-location where the resource lives
	Location *string `json:"location,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

Cluster the HDInsight cluster.

func (Cluster) MarshalJSON

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

MarshalJSON is the custom marshaler for Cluster.

type ClusterConfigurations

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

ClusterConfigurations the configuration object for the specified cluster.

func (ClusterConfigurations) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterConfigurations.

type ClusterCreateParametersExtended

type ClusterCreateParametersExtended struct {
	// Location - The location of the cluster.
	Location *string `json:"location,omitempty"`
	// Tags - The resource tags.
	Tags map[string]*string `json:"tags"`
	// Zones - The availability zones.
	Zones *[]string `json:"zones,omitempty"`
	// Properties - The cluster create parameters.
	Properties *ClusterCreateProperties `json:"properties,omitempty"`
	// Identity - The identity of the cluster, if configured.
	Identity *ClusterIdentity `json:"identity,omitempty"`
}

ClusterCreateParametersExtended the CreateCluster request parameters.

func (ClusterCreateParametersExtended) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterCreateParametersExtended.

type ClusterCreateProperties

type ClusterCreateProperties struct {
	// ClusterVersion - The version of the cluster.
	ClusterVersion *string `json:"clusterVersion,omitempty"`
	// OsType - The type of operating system. Possible values include: 'OSTypeWindows', 'OSTypeLinux'
	OsType OSType `json:"osType,omitempty"`
	// Tier - The cluster tier. Possible values include: 'TierStandard', 'TierPremium'
	Tier Tier `json:"tier,omitempty"`
	// ClusterDefinition - The cluster definition.
	ClusterDefinition *ClusterDefinition `json:"clusterDefinition,omitempty"`
	// KafkaRestProperties - The cluster kafka rest proxy configuration.
	KafkaRestProperties *KafkaRestProperties `json:"kafkaRestProperties,omitempty"`
	// SecurityProfile - The security profile.
	SecurityProfile *SecurityProfile `json:"securityProfile,omitempty"`
	// ComputeProfile - The compute profile.
	ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"`
	// StorageProfile - The storage profile.
	StorageProfile *StorageProfile `json:"storageProfile,omitempty"`
	// DiskEncryptionProperties - The disk encryption properties.
	DiskEncryptionProperties *DiskEncryptionProperties `json:"diskEncryptionProperties,omitempty"`
	// EncryptionInTransitProperties - The encryption-in-transit properties.
	EncryptionInTransitProperties *EncryptionInTransitProperties `json:"encryptionInTransitProperties,omitempty"`
	// MinSupportedTLSVersion - The minimal supported tls version.
	MinSupportedTLSVersion *string `json:"minSupportedTlsVersion,omitempty"`
	// NetworkProperties - The network properties.
	NetworkProperties *NetworkProperties `json:"networkProperties,omitempty"`
	// ComputeIsolationProperties - The compute isolation properties.
	ComputeIsolationProperties *ComputeIsolationProperties `json:"computeIsolationProperties,omitempty"`
	// PrivateLinkConfigurations - The private link configurations.
	PrivateLinkConfigurations *[]PrivateLinkConfiguration `json:"privateLinkConfigurations,omitempty"`
}

ClusterCreateProperties the cluster create parameters.

type ClusterCreateRequestValidationParameters

type ClusterCreateRequestValidationParameters struct {
	// Name - The cluster name.
	Name *string `json:"name,omitempty"`
	// Type - The resource type.
	Type *string `json:"type,omitempty"`
	// TenantID - The tenant id.
	TenantID *string `json:"tenantId,omitempty"`
	// FetchAaddsResource - This indicates whether fetch Aadds resource or not.
	FetchAaddsResource *bool `json:"fetchAaddsResource,omitempty"`
	// Location - The location of the cluster.
	Location *string `json:"location,omitempty"`
	// Tags - The resource tags.
	Tags map[string]*string `json:"tags"`
	// Zones - The availability zones.
	Zones *[]string `json:"zones,omitempty"`
	// Properties - The cluster create parameters.
	Properties *ClusterCreateProperties `json:"properties,omitempty"`
	// Identity - The identity of the cluster, if configured.
	Identity *ClusterIdentity `json:"identity,omitempty"`
}

ClusterCreateRequestValidationParameters the cluster create request specification.

func (ClusterCreateRequestValidationParameters) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterCreateRequestValidationParameters.

type ClusterCreateValidationResult

type ClusterCreateValidationResult struct {
	autorest.Response `json:"-"`
	// ValidationErrors - The validation errors.
	ValidationErrors *[]ValidationErrorInfo `json:"validationErrors,omitempty"`
	// ValidationWarnings - The validation warnings.
	ValidationWarnings *[]ValidationErrorInfo `json:"validationWarnings,omitempty"`
	// EstimatedCreationDuration - The estimated creation duration.
	EstimatedCreationDuration *string `json:"estimatedCreationDuration,omitempty"`
	// AaddsResourcesDetails - The Azure active directory domain service resource details.
	AaddsResourcesDetails *[]AaddsResourceDetails `json:"aaddsResourcesDetails,omitempty"`
}

ClusterCreateValidationResult the response of cluster create request validation.

type ClusterDefinition

type ClusterDefinition struct {
	// Blueprint - The link to the blueprint.
	Blueprint *string `json:"blueprint,omitempty"`
	// Kind - The type of cluster.
	Kind *string `json:"kind,omitempty"`
	// ComponentVersion - The versions of different services in the cluster.
	ComponentVersion map[string]*string `json:"componentVersion"`
	// Configurations - The cluster configurations.
	Configurations interface{} `json:"configurations,omitempty"`
}

ClusterDefinition the cluster definition.

func (ClusterDefinition) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterDefinition.

type ClusterDiskEncryptionParameters

type ClusterDiskEncryptionParameters struct {
	// VaultURI - Base key vault URI where the customers key is located eg. https://myvault.vault.azure.net
	VaultURI *string `json:"vaultUri,omitempty"`
	// KeyName - Key name that is used for enabling disk encryption.
	KeyName *string `json:"keyName,omitempty"`
	// KeyVersion - Specific key version that is used for enabling disk encryption.
	KeyVersion *string `json:"keyVersion,omitempty"`
}

ClusterDiskEncryptionParameters the Disk Encryption Cluster request parameters.

type ClusterGetProperties

type ClusterGetProperties struct {
	// ClusterVersion - The version of the cluster.
	ClusterVersion *string `json:"clusterVersion,omitempty"`
	// ClusterHdpVersion - The hdp version of the cluster.
	ClusterHdpVersion *string `json:"clusterHdpVersion,omitempty"`
	// OsType - The type of operating system. Possible values include: 'OSTypeWindows', 'OSTypeLinux'
	OsType OSType `json:"osType,omitempty"`
	// Tier - The cluster tier. Possible values include: 'TierStandard', 'TierPremium'
	Tier Tier `json:"tier,omitempty"`
	// ClusterID - The cluster id.
	ClusterID *string `json:"clusterId,omitempty"`
	// ClusterDefinition - The cluster definition.
	ClusterDefinition *ClusterDefinition `json:"clusterDefinition,omitempty"`
	// KafkaRestProperties - The cluster kafka rest proxy configuration.
	KafkaRestProperties *KafkaRestProperties `json:"kafkaRestProperties,omitempty"`
	// SecurityProfile - The security profile.
	SecurityProfile *SecurityProfile `json:"securityProfile,omitempty"`
	// ComputeProfile - The compute profile.
	ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"`
	// ProvisioningState - The provisioning state, which only appears in the response. Possible values include: 'ClusterProvisioningStateInProgress', 'ClusterProvisioningStateFailed', 'ClusterProvisioningStateSucceeded', 'ClusterProvisioningStateCanceled', 'ClusterProvisioningStateDeleting'
	ProvisioningState ClusterProvisioningState `json:"provisioningState,omitempty"`
	// CreatedDate - The date on which the cluster was created.
	CreatedDate *string `json:"createdDate,omitempty"`
	// ClusterState - The state of the cluster.
	ClusterState *string `json:"clusterState,omitempty"`
	// QuotaInfo - The quota information.
	QuotaInfo *QuotaInfo `json:"quotaInfo,omitempty"`
	// Errors - The list of errors.
	Errors *[]Errors `json:"errors,omitempty"`
	// ConnectivityEndpoints - The list of connectivity endpoints.
	ConnectivityEndpoints *[]ConnectivityEndpoint `json:"connectivityEndpoints,omitempty"`
	// DiskEncryptionProperties - The disk encryption properties.
	DiskEncryptionProperties *DiskEncryptionProperties `json:"diskEncryptionProperties,omitempty"`
	// EncryptionInTransitProperties - The encryption-in-transit properties.
	EncryptionInTransitProperties *EncryptionInTransitProperties `json:"encryptionInTransitProperties,omitempty"`
	// StorageProfile - The storage profile.
	StorageProfile *StorageProfile `json:"storageProfile,omitempty"`
	// MinSupportedTLSVersion - The minimal supported tls version.
	MinSupportedTLSVersion *string `json:"minSupportedTlsVersion,omitempty"`
	// ExcludedServicesConfig - The excluded services config.
	ExcludedServicesConfig *ExcludedServicesConfig `json:"excludedServicesConfig,omitempty"`
	// NetworkProperties - The network properties.
	NetworkProperties *NetworkProperties `json:"networkProperties,omitempty"`
	// ComputeIsolationProperties - The compute isolation properties.
	ComputeIsolationProperties *ComputeIsolationProperties `json:"computeIsolationProperties,omitempty"`
	// PrivateLinkConfigurations - The private link configurations.
	PrivateLinkConfigurations *[]PrivateLinkConfiguration `json:"privateLinkConfigurations,omitempty"`
	// PrivateEndpointConnections - READ-ONLY; The list of private endpoint connections.
	PrivateEndpointConnections *[]PrivateEndpointConnection `json:"privateEndpointConnections,omitempty"`
}

ClusterGetProperties the properties of cluster.

func (ClusterGetProperties) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterGetProperties.

type ClusterIdentity

type ClusterIdentity struct {
	// PrincipalID - READ-ONLY; The principal id of cluster identity. This property will only be provided for a system assigned identity.
	PrincipalID *string `json:"principalId,omitempty"`
	// TenantID - 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"`
	// Type - 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. Possible values include: 'ResourceIdentityTypeSystemAssigned', 'ResourceIdentityTypeUserAssigned', 'ResourceIdentityTypeSystemAssignedUserAssigned', 'ResourceIdentityTypeNone'
	Type ResourceIdentityType `json:"type,omitempty"`
	// UserAssignedIdentities - 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"`
}

ClusterIdentity identity for the cluster.

func (ClusterIdentity) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterIdentity.

type ClusterListPersistedScriptActionsResult

type ClusterListPersistedScriptActionsResult struct {
	// Value - The list of Persisted Script Actions.
	Value *[]RuntimeScriptAction `json:"value,omitempty"`
	// NextLink - READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty"`
}

ClusterListPersistedScriptActionsResult the ListPersistedScriptActions operation response.

func (ClusterListPersistedScriptActionsResult) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterListPersistedScriptActionsResult.

type ClusterListResult

type ClusterListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Clusters.
	Value *[]Cluster `json:"value,omitempty"`
	// NextLink - READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty"`
}

ClusterListResult the List Cluster operation response.

func (ClusterListResult) IsEmpty

func (clr ClusterListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (ClusterListResult) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterListResult.

type ClusterListResultIterator

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

ClusterListResultIterator provides access to a complete listing of Cluster values.

func NewClusterListResultIterator

func NewClusterListResultIterator(page ClusterListResultPage) ClusterListResultIterator

Creates a new instance of the ClusterListResultIterator type.

func (*ClusterListResultIterator) Next

func (iter *ClusterListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ClusterListResultIterator) NextWithContext

func (iter *ClusterListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (ClusterListResultIterator) NotDone

func (iter ClusterListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (ClusterListResultIterator) Response

Response returns the raw server response from the last page request.

func (ClusterListResultIterator) Value

func (iter ClusterListResultIterator) Value() Cluster

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type ClusterListResultPage

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

ClusterListResultPage contains a page of Cluster values.

func NewClusterListResultPage

func NewClusterListResultPage(cur ClusterListResult, getNextPage func(context.Context, ClusterListResult) (ClusterListResult, error)) ClusterListResultPage

Creates a new instance of the ClusterListResultPage type.

func (*ClusterListResultPage) Next

func (page *ClusterListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ClusterListResultPage) NextWithContext

func (page *ClusterListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (ClusterListResultPage) NotDone

func (page ClusterListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (ClusterListResultPage) Response

func (page ClusterListResultPage) Response() ClusterListResult

Response returns the raw server response from the last page request.

func (ClusterListResultPage) Values

func (page ClusterListResultPage) Values() []Cluster

Values returns the slice of values for the current page or nil if there are no values.

type ClusterMonitoringRequest

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

ClusterMonitoringRequest the cluster monitor parameters.

type ClusterMonitoringResponse

type ClusterMonitoringResponse struct {
	autorest.Response `json:"-"`
	// ClusterMonitoringEnabled - The status of the monitor on the HDInsight cluster.
	ClusterMonitoringEnabled *bool `json:"clusterMonitoringEnabled,omitempty"`
	// WorkspaceID - 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 {
	// Tags - The resource tags.
	Tags map[string]*string `json:"tags"`
}

ClusterPatchParameters the PatchCluster request parameters

func (ClusterPatchParameters) MarshalJSON

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

MarshalJSON is the custom marshaler for ClusterPatchParameters.

type ClusterProvisioningState

type ClusterProvisioningState string

ClusterProvisioningState enumerates the values for cluster provisioning state.

const (
	// ClusterProvisioningStateCanceled ...
	ClusterProvisioningStateCanceled ClusterProvisioningState = "Canceled"
	// ClusterProvisioningStateDeleting ...
	ClusterProvisioningStateDeleting ClusterProvisioningState = "Deleting"
	// ClusterProvisioningStateFailed ...
	ClusterProvisioningStateFailed ClusterProvisioningState = "Failed"
	// ClusterProvisioningStateInProgress ...
	ClusterProvisioningStateInProgress ClusterProvisioningState = "InProgress"
	// ClusterProvisioningStateSucceeded ...
	ClusterProvisioningStateSucceeded ClusterProvisioningState = "Succeeded"
)

func PossibleClusterProvisioningStateValues

func PossibleClusterProvisioningStateValues() []ClusterProvisioningState

PossibleClusterProvisioningStateValues returns an array of possible values for the ClusterProvisioningState const type.

type ClusterResizeParameters

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

ClusterResizeParameters the Resize Cluster request parameters.

type ClustersClient

type ClustersClient struct {
	BaseClient
}

ClustersClient is the hDInsight Management Client

func NewClustersClient

func NewClustersClient(subscriptionID string) ClustersClient

NewClustersClient creates an instance of the ClustersClient client.

func NewClustersClientWithBaseURI

func NewClustersClientWithBaseURI(baseURI string, subscriptionID string) ClustersClient

NewClustersClientWithBaseURI creates an instance of the ClustersClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ClustersClient) Create

func (client ClustersClient) Create(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterCreateParametersExtended) (result ClustersCreateFuture, err error)

Create creates a new HDInsight cluster with the specified parameters. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the cluster create request.

func (ClustersClient) CreatePreparer

func (client ClustersClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterCreateParametersExtended) (*http.Request, error)

CreatePreparer prepares the Create request.

func (ClustersClient) CreateResponder

func (client ClustersClient) CreateResponder(resp *http.Response) (result Cluster, err error)

CreateResponder handles the response to the Create request. The method always closes the http.Response Body.

func (ClustersClient) CreateSender

func (client ClustersClient) CreateSender(req *http.Request) (future ClustersCreateFuture, err error)

CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Delete

func (client ClustersClient) Delete(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDeleteFuture, err error)

Delete deletes the specified HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ClustersClient) DeletePreparer

func (client ClustersClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ClustersClient) DeleteResponder

func (client ClustersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (ClustersClient) DeleteSender

func (client ClustersClient) DeleteSender(req *http.Request) (future ClustersDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ExecuteScriptActions

func (client ClustersClient) ExecuteScriptActions(ctx context.Context, resourceGroupName string, clusterName string, parameters ExecuteScriptActionParameters) (result ClustersExecuteScriptActionsFuture, err error)

ExecuteScriptActions executes script actions on the specified HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the parameters for executing script actions.

func (ClustersClient) ExecuteScriptActionsPreparer

func (client ClustersClient) ExecuteScriptActionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ExecuteScriptActionParameters) (*http.Request, error)

ExecuteScriptActionsPreparer prepares the ExecuteScriptActions request.

func (ClustersClient) ExecuteScriptActionsResponder

func (client ClustersClient) ExecuteScriptActionsResponder(resp *http.Response) (result autorest.Response, err error)

ExecuteScriptActionsResponder handles the response to the ExecuteScriptActions request. The method always closes the http.Response Body.

func (ClustersClient) ExecuteScriptActionsSender

func (client ClustersClient) ExecuteScriptActionsSender(req *http.Request) (future ClustersExecuteScriptActionsFuture, err error)

ExecuteScriptActionsSender sends the ExecuteScriptActions request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Get

func (client ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string) (result Cluster, err error)

Get gets the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ClustersClient) GetAzureAsyncOperationStatus

func (client ClustersClient) GetAzureAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, operationID string) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatus the the async operation status. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. operationID - the long running operation id.

func (ClustersClient) GetAzureAsyncOperationStatusPreparer

func (client ClustersClient) GetAzureAsyncOperationStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string, operationID string) (*http.Request, error)

GetAzureAsyncOperationStatusPreparer prepares the GetAzureAsyncOperationStatus request.

func (ClustersClient) GetAzureAsyncOperationStatusResponder

func (client ClustersClient) GetAzureAsyncOperationStatusResponder(resp *http.Response) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatusResponder handles the response to the GetAzureAsyncOperationStatus request. The method always closes the http.Response Body.

func (ClustersClient) GetAzureAsyncOperationStatusSender

func (client ClustersClient) GetAzureAsyncOperationStatusSender(req *http.Request) (*http.Response, error)

GetAzureAsyncOperationStatusSender sends the GetAzureAsyncOperationStatus request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) GetGatewaySettings

func (client ClustersClient) GetGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string) (result GatewaySettings, err error)

GetGatewaySettings gets the gateway settings for the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ClustersClient) GetGatewaySettingsPreparer

func (client ClustersClient) GetGatewaySettingsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

GetGatewaySettingsPreparer prepares the GetGatewaySettings request.

func (ClustersClient) GetGatewaySettingsResponder

func (client ClustersClient) GetGatewaySettingsResponder(resp *http.Response) (result GatewaySettings, err error)

GetGatewaySettingsResponder handles the response to the GetGatewaySettings request. The method always closes the http.Response Body.

func (ClustersClient) GetGatewaySettingsSender

func (client ClustersClient) GetGatewaySettingsSender(req *http.Request) (*http.Response, error)

GetGatewaySettingsSender sends the GetGatewaySettings request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) GetPreparer

func (client ClustersClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ClustersClient) GetResponder

func (client ClustersClient) GetResponder(resp *http.Response) (result Cluster, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ClustersClient) GetSender

func (client ClustersClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) List

func (client ClustersClient) List(ctx context.Context) (result ClusterListResultPage, err error)

List lists all the HDInsight clusters under the subscription.

func (ClustersClient) ListByResourceGroup

func (client ClustersClient) ListByResourceGroup(ctx context.Context, resourceGroupName string) (result ClusterListResultPage, err error)

ListByResourceGroup lists the HDInsight clusters in a resource group. Parameters: resourceGroupName - the name of the resource group.

func (ClustersClient) ListByResourceGroupComplete

func (client ClustersClient) ListByResourceGroupComplete(ctx context.Context, resourceGroupName string) (result ClusterListResultIterator, err error)

ListByResourceGroupComplete enumerates all values, automatically crossing page boundaries as required.

func (ClustersClient) ListByResourceGroupPreparer

func (client ClustersClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error)

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (ClustersClient) ListByResourceGroupResponder

func (client ClustersClient) ListByResourceGroupResponder(resp *http.Response) (result ClusterListResult, err error)

ListByResourceGroupResponder handles the response to the ListByResourceGroup request. The method always closes the http.Response Body.

func (ClustersClient) ListByResourceGroupSender

func (client ClustersClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)

ListByResourceGroupSender sends the ListByResourceGroup request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ListComplete

func (client ClustersClient) ListComplete(ctx context.Context) (result ClusterListResultIterator, err error)

ListComplete enumerates all values, automatically crossing page boundaries as required.

func (ClustersClient) ListPreparer

func (client ClustersClient) ListPreparer(ctx context.Context) (*http.Request, error)

ListPreparer prepares the List request.

func (ClustersClient) ListResponder

func (client ClustersClient) ListResponder(resp *http.Response) (result ClusterListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (ClustersClient) ListSender

func (client ClustersClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Resize

func (client ClustersClient) Resize(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterResizeParameters) (result ClustersResizeFuture, err error)

Resize resizes the specified HDInsight cluster to the specified size. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the parameters for the resize operation.

func (ClustersClient) ResizePreparer

func (client ClustersClient) ResizePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterResizeParameters) (*http.Request, error)

ResizePreparer prepares the Resize request.

func (ClustersClient) ResizeResponder

func (client ClustersClient) ResizeResponder(resp *http.Response) (result autorest.Response, err error)

ResizeResponder handles the response to the Resize request. The method always closes the http.Response Body.

func (ClustersClient) ResizeSender

func (client ClustersClient) ResizeSender(req *http.Request) (future ClustersResizeFuture, err error)

ResizeSender sends the Resize request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) RotateDiskEncryptionKey

func (client ClustersClient) RotateDiskEncryptionKey(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterDiskEncryptionParameters) (result ClustersRotateDiskEncryptionKeyFuture, err error)

RotateDiskEncryptionKey rotate disk encryption key of the specified HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the parameters for the disk encryption operation.

func (ClustersClient) RotateDiskEncryptionKeyPreparer

func (client ClustersClient) RotateDiskEncryptionKeyPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterDiskEncryptionParameters) (*http.Request, error)

RotateDiskEncryptionKeyPreparer prepares the RotateDiskEncryptionKey request.

func (ClustersClient) RotateDiskEncryptionKeyResponder

func (client ClustersClient) RotateDiskEncryptionKeyResponder(resp *http.Response) (result autorest.Response, err error)

RotateDiskEncryptionKeyResponder handles the response to the RotateDiskEncryptionKey request. The method always closes the http.Response Body.

func (ClustersClient) RotateDiskEncryptionKeySender

func (client ClustersClient) RotateDiskEncryptionKeySender(req *http.Request) (future ClustersRotateDiskEncryptionKeyFuture, err error)

RotateDiskEncryptionKeySender sends the RotateDiskEncryptionKey request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Update

func (client ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterPatchParameters) (result Cluster, err error)

Update patch HDInsight cluster with the specified parameters. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the cluster patch request.

func (ClustersClient) UpdateAutoScaleConfiguration

func (client ClustersClient) UpdateAutoScaleConfiguration(ctx context.Context, resourceGroupName string, clusterName string, parameters AutoscaleConfigurationUpdateParameter) (result ClustersUpdateAutoScaleConfigurationFuture, err error)

UpdateAutoScaleConfiguration updates the Autoscale Configuration for HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the parameters for the update autoscale configuration operation.

func (ClustersClient) UpdateAutoScaleConfigurationPreparer

func (client ClustersClient) UpdateAutoScaleConfigurationPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters AutoscaleConfigurationUpdateParameter) (*http.Request, error)

UpdateAutoScaleConfigurationPreparer prepares the UpdateAutoScaleConfiguration request.

func (ClustersClient) UpdateAutoScaleConfigurationResponder

func (client ClustersClient) UpdateAutoScaleConfigurationResponder(resp *http.Response) (result autorest.Response, err error)

UpdateAutoScaleConfigurationResponder handles the response to the UpdateAutoScaleConfiguration request. The method always closes the http.Response Body.

func (ClustersClient) UpdateAutoScaleConfigurationSender

func (client ClustersClient) UpdateAutoScaleConfigurationSender(req *http.Request) (future ClustersUpdateAutoScaleConfigurationFuture, err error)

UpdateAutoScaleConfigurationSender sends the UpdateAutoScaleConfiguration request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) UpdateGatewaySettings

func (client ClustersClient) UpdateGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateGatewaySettingsParameters) (result ClustersUpdateGatewaySettingsFuture, err error)

UpdateGatewaySettings configures the gateway settings on the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the cluster configurations.

func (ClustersClient) UpdateGatewaySettingsPreparer

func (client ClustersClient) UpdateGatewaySettingsPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateGatewaySettingsParameters) (*http.Request, error)

UpdateGatewaySettingsPreparer prepares the UpdateGatewaySettings request.

func (ClustersClient) UpdateGatewaySettingsResponder

func (client ClustersClient) UpdateGatewaySettingsResponder(resp *http.Response) (result autorest.Response, err error)

UpdateGatewaySettingsResponder handles the response to the UpdateGatewaySettings request. The method always closes the http.Response Body.

func (ClustersClient) UpdateGatewaySettingsSender

func (client ClustersClient) UpdateGatewaySettingsSender(req *http.Request) (future ClustersUpdateGatewaySettingsFuture, err error)

UpdateGatewaySettingsSender sends the UpdateGatewaySettings request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) UpdateIdentityCertificate

func (client ClustersClient) UpdateIdentityCertificate(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateClusterIdentityCertificateParameters) (result ClustersUpdateIdentityCertificateFuture, err error)

UpdateIdentityCertificate updates the cluster identity certificate. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the cluster configurations.

func (ClustersClient) UpdateIdentityCertificatePreparer

func (client ClustersClient) UpdateIdentityCertificatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateClusterIdentityCertificateParameters) (*http.Request, error)

UpdateIdentityCertificatePreparer prepares the UpdateIdentityCertificate request.

func (ClustersClient) UpdateIdentityCertificateResponder

func (client ClustersClient) UpdateIdentityCertificateResponder(resp *http.Response) (result autorest.Response, err error)

UpdateIdentityCertificateResponder handles the response to the UpdateIdentityCertificate request. The method always closes the http.Response Body.

func (ClustersClient) UpdateIdentityCertificateSender

func (client ClustersClient) UpdateIdentityCertificateSender(req *http.Request) (future ClustersUpdateIdentityCertificateFuture, err error)

UpdateIdentityCertificateSender sends the UpdateIdentityCertificate request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) UpdatePreparer

func (client ClustersClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterPatchParameters) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (ClustersClient) UpdateResponder

func (client ClustersClient) UpdateResponder(resp *http.Response) (result Cluster, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (ClustersClient) UpdateSender

func (client ClustersClient) UpdateSender(req *http.Request) (*http.Response, error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type ClustersCreateFuture

type ClustersCreateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (Cluster, error)
}

ClustersCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersCreateFuture) UnmarshalJSON

func (future *ClustersCreateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersDeleteFuture

type ClustersDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersDeleteFuture) UnmarshalJSON

func (future *ClustersDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersExecuteScriptActionsFuture

type ClustersExecuteScriptActionsFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersExecuteScriptActionsFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersExecuteScriptActionsFuture) UnmarshalJSON

func (future *ClustersExecuteScriptActionsFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersResizeFuture

type ClustersResizeFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersResizeFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersResizeFuture) UnmarshalJSON

func (future *ClustersResizeFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersRotateDiskEncryptionKeyFuture

type ClustersRotateDiskEncryptionKeyFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersRotateDiskEncryptionKeyFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersRotateDiskEncryptionKeyFuture) UnmarshalJSON

func (future *ClustersRotateDiskEncryptionKeyFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersUpdateAutoScaleConfigurationFuture

type ClustersUpdateAutoScaleConfigurationFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersUpdateAutoScaleConfigurationFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersUpdateAutoScaleConfigurationFuture) UnmarshalJSON

func (future *ClustersUpdateAutoScaleConfigurationFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersUpdateGatewaySettingsFuture

type ClustersUpdateGatewaySettingsFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersUpdateGatewaySettingsFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersUpdateGatewaySettingsFuture) UnmarshalJSON

func (future *ClustersUpdateGatewaySettingsFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersUpdateIdentityCertificateFuture

type ClustersUpdateIdentityCertificateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersUpdateIdentityCertificateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersUpdateIdentityCertificateFuture) UnmarshalJSON

func (future *ClustersUpdateIdentityCertificateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ComputeIsolationProperties

type ComputeIsolationProperties struct {
	// EnableComputeIsolation - The flag indicates whether enable compute isolation or not.
	EnableComputeIsolation *bool `json:"enableComputeIsolation,omitempty"`
	// HostSku - The host sku.
	HostSku *string `json:"hostSku,omitempty"`
}

ComputeIsolationProperties the compute isolation properties.

type ComputeProfile

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

ComputeProfile describes the compute profile.

type ConfigurationsClient

type ConfigurationsClient struct {
	BaseClient
}

ConfigurationsClient is the hDInsight Management Client

func NewConfigurationsClient

func NewConfigurationsClient(subscriptionID string) ConfigurationsClient

NewConfigurationsClient creates an instance of the ConfigurationsClient client.

func NewConfigurationsClientWithBaseURI

func NewConfigurationsClientWithBaseURI(baseURI string, subscriptionID string) ConfigurationsClient

NewConfigurationsClientWithBaseURI creates an instance of the ConfigurationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ConfigurationsClient) Get

func (client ConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, configurationName string) (result SetString, err 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. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. configurationName - the name of the cluster configuration.

func (ConfigurationsClient) GetPreparer

func (client ConfigurationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, configurationName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ConfigurationsClient) GetResponder

func (client ConfigurationsClient) GetResponder(resp *http.Response) (result SetString, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ConfigurationsClient) GetSender

func (client ConfigurationsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (ConfigurationsClient) List

func (client ConfigurationsClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterConfigurations, err error)

List gets all configuration information for an HDI cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ConfigurationsClient) ListPreparer

func (client ConfigurationsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListPreparer prepares the List request.

func (ConfigurationsClient) ListResponder

func (client ConfigurationsClient) ListResponder(resp *http.Response) (result ClusterConfigurations, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (ConfigurationsClient) ListSender

func (client ConfigurationsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

func (ConfigurationsClient) Update

func (client ConfigurationsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, parameters map[string]*string) (result ConfigurationsUpdateFuture, err error)

Update configures the HTTP settings on the specified cluster. This API is deprecated, please use UpdateGatewaySettings in cluster endpoint instead. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. configurationName - the name of the cluster configuration. parameters - the cluster configurations.

func (ConfigurationsClient) UpdatePreparer

func (client ConfigurationsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, parameters map[string]*string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (ConfigurationsClient) UpdateResponder

func (client ConfigurationsClient) UpdateResponder(resp *http.Response) (result autorest.Response, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (ConfigurationsClient) UpdateSender

func (client ConfigurationsClient) UpdateSender(req *http.Request) (future ConfigurationsUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type ConfigurationsUpdateFuture

type ConfigurationsUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ConfigurationsClient) (autorest.Response, error)
}

ConfigurationsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ConfigurationsUpdateFuture) UnmarshalJSON

func (future *ConfigurationsUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ConnectivityEndpoint

type ConnectivityEndpoint struct {
	// Name - The name of the endpoint.
	Name *string `json:"name,omitempty"`
	// Protocol - The protocol of the endpoint.
	Protocol *string `json:"protocol,omitempty"`
	// Location - The location of the endpoint.
	Location *string `json:"location,omitempty"`
	// Port - The port to connect to.
	Port *int32 `json:"port,omitempty"`
	// PrivateIPAddress - The private ip address of the endpoint.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`
}

ConnectivityEndpoint the connectivity properties

type CreatedByType

type CreatedByType string

CreatedByType enumerates the values for created by type.

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

func PossibleCreatedByTypeValues

func PossibleCreatedByTypeValues() []CreatedByType

PossibleCreatedByTypeValues returns an array of possible values for the CreatedByType const type.

type DataDisksGroups

type DataDisksGroups struct {
	// DisksPerNode - The number of disks per node.
	DisksPerNode *int32 `json:"disksPerNode,omitempty"`
	// StorageAccountType - READ-ONLY; ReadOnly. The storage account type. Do not set this value.
	StorageAccountType *string `json:"storageAccountType,omitempty"`
	// DiskSizeGB - READ-ONLY; ReadOnly. The DiskSize in GB. Do not set this value.
	DiskSizeGB *int32 `json:"diskSizeGB,omitempty"`
}

DataDisksGroups the data disks groups for the role.

func (DataDisksGroups) MarshalJSON

func (ddg DataDisksGroups) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DataDisksGroups.

type DaysOfWeek

type DaysOfWeek string

DaysOfWeek enumerates the values for days of week.

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

func PossibleDaysOfWeekValues

func PossibleDaysOfWeekValues() []DaysOfWeek

PossibleDaysOfWeekValues returns an array of possible values for the DaysOfWeek const type.

type Dimension

type Dimension struct {
	// Name - The name of the dimension.
	Name *string `json:"name,omitempty"`
	// DisplayName - The display name of the dimension.
	DisplayName *string `json:"displayName,omitempty"`
	// InternalName - The display name of the dimension.
	InternalName *string `json:"internalName,omitempty"`
	// ToBeExportedForShoebox - 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 enumerates the values for directory type.

const (
	// DirectoryTypeActiveDirectory ...
	DirectoryTypeActiveDirectory DirectoryType = "ActiveDirectory"
)

func PossibleDirectoryTypeValues

func PossibleDirectoryTypeValues() []DirectoryType

PossibleDirectoryTypeValues returns an array of possible values for the DirectoryType const type.

type DiskBillingMeters

type DiskBillingMeters struct {
	// DiskRpMeter - The managed disk meter guid.
	DiskRpMeter *string `json:"diskRpMeter,omitempty"`
	// Sku - The managed disk billing sku, P30 or S30.
	Sku *string `json:"sku,omitempty"`
	// Tier - The managed disk billing tier, Standard or Premium. Possible values include: 'TierStandard', 'TierPremium'
	Tier Tier `json:"tier,omitempty"`
}

DiskBillingMeters the disk billing meters.

type DiskEncryptionProperties

type DiskEncryptionProperties struct {
	// VaultURI - Base key vault URI where the customers key is located eg. https://myvault.vault.azure.net
	VaultURI *string `json:"vaultUri,omitempty"`
	// KeyName - Key name that is used for enabling disk encryption.
	KeyName *string `json:"keyName,omitempty"`
	// KeyVersion - Specific key version that is used for enabling disk encryption.
	KeyVersion *string `json:"keyVersion,omitempty"`
	// EncryptionAlgorithm - Algorithm identifier for encryption, default RSA-OAEP. Possible values include: 'JSONWebKeyEncryptionAlgorithmRSAOAEP', 'JSONWebKeyEncryptionAlgorithmRSAOAEP256', 'JSONWebKeyEncryptionAlgorithmRSA15'
	EncryptionAlgorithm JSONWebKeyEncryptionAlgorithm `json:"encryptionAlgorithm,omitempty"`
	// MsiResourceID - Resource ID of Managed Identity that is used to access the key vault.
	MsiResourceID *string `json:"msiResourceId,omitempty"`
	// EncryptionAtHost - Indicates whether or not resource disk encryption is enabled.
	EncryptionAtHost *bool `json:"encryptionAtHost,omitempty"`
}

DiskEncryptionProperties the disk encryption properties

type EncryptionInTransitProperties

type EncryptionInTransitProperties struct {
	// IsEncryptionInTransitEnabled - 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 {
	// Code - Error code
	Code *string `json:"code,omitempty"`
	// Message - Error message indicating why the operation failed.
	Message *string `json:"message,omitempty"`
}

ErrorResponse describes the format of Error response.

type Errors

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

Errors the error message associated with the cluster creation.

type ExcludedServicesConfig

type ExcludedServicesConfig struct {
	// ExcludedServicesConfigID - The config id of excluded services.
	ExcludedServicesConfigID *string `json:"excludedServicesConfigId,omitempty"`
	// ExcludedServicesList - 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 {
	// ScriptActions - The list of run time script actions.
	ScriptActions *[]RuntimeScriptAction `json:"scriptActions,omitempty"`
	// PersistOnSuccess - Gets or sets if the scripts needs to be persisted.
	PersistOnSuccess *bool `json:"persistOnSuccess,omitempty"`
}

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

type Extension

type Extension struct {
	// WorkspaceID - The workspace ID for the cluster monitoring extension.
	WorkspaceID *string `json:"workspaceId,omitempty"`
	// PrimaryKey - The certificate for the cluster monitoring extensions.
	PrimaryKey *string `json:"primaryKey,omitempty"`
}

Extension cluster monitoring extensions.

type ExtensionsClient

type ExtensionsClient struct {
	BaseClient
}

ExtensionsClient is the hDInsight Management Client

func NewExtensionsClient

func NewExtensionsClient(subscriptionID string) ExtensionsClient

NewExtensionsClient creates an instance of the ExtensionsClient client.

func NewExtensionsClientWithBaseURI

func NewExtensionsClientWithBaseURI(baseURI string, subscriptionID string) ExtensionsClient

NewExtensionsClientWithBaseURI creates an instance of the ExtensionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ExtensionsClient) Create

func (client ExtensionsClient) Create(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, parameters Extension) (result ExtensionsCreateFuture, err error)

Create creates an HDInsight cluster extension. Parameters: 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.

func (ExtensionsClient) CreatePreparer

func (client ExtensionsClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, parameters Extension) (*http.Request, error)

CreatePreparer prepares the Create request.

func (ExtensionsClient) CreateResponder

func (client ExtensionsClient) CreateResponder(resp *http.Response) (result autorest.Response, err error)

CreateResponder handles the response to the Create request. The method always closes the http.Response Body.

func (ExtensionsClient) CreateSender

func (client ExtensionsClient) CreateSender(req *http.Request) (future ExtensionsCreateFuture, err error)

CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) Delete

func (client ExtensionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, extensionName string) (result ExtensionsDeleteFuture, err error)

Delete deletes the specified extension for HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. extensionName - the name of the cluster extension.

func (ExtensionsClient) DeletePreparer

func (client ExtensionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, extensionName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ExtensionsClient) DeleteResponder

func (client ExtensionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (ExtensionsClient) DeleteSender

func (client ExtensionsClient) DeleteSender(req *http.Request) (future ExtensionsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) DisableAzureMonitor

func (client ExtensionsClient) DisableAzureMonitor(ctx context.Context, resourceGroupName string, clusterName string) (result ExtensionsDisableAzureMonitorFuture, err error)

DisableAzureMonitor disables the Azure Monitor on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ExtensionsClient) DisableAzureMonitorPreparer

func (client ExtensionsClient) DisableAzureMonitorPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

DisableAzureMonitorPreparer prepares the DisableAzureMonitor request.

func (ExtensionsClient) DisableAzureMonitorResponder

func (client ExtensionsClient) DisableAzureMonitorResponder(resp *http.Response) (result autorest.Response, err error)

DisableAzureMonitorResponder handles the response to the DisableAzureMonitor request. The method always closes the http.Response Body.

func (ExtensionsClient) DisableAzureMonitorSender

func (client ExtensionsClient) DisableAzureMonitorSender(req *http.Request) (future ExtensionsDisableAzureMonitorFuture, err error)

DisableAzureMonitorSender sends the DisableAzureMonitor request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) DisableMonitoring

func (client ExtensionsClient) DisableMonitoring(ctx context.Context, resourceGroupName string, clusterName string) (result ExtensionsDisableMonitoringFuture, err error)

DisableMonitoring disables the Operations Management Suite (OMS) on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ExtensionsClient) DisableMonitoringPreparer

func (client ExtensionsClient) DisableMonitoringPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

DisableMonitoringPreparer prepares the DisableMonitoring request.

func (ExtensionsClient) DisableMonitoringResponder

func (client ExtensionsClient) DisableMonitoringResponder(resp *http.Response) (result autorest.Response, err error)

DisableMonitoringResponder handles the response to the DisableMonitoring request. The method always closes the http.Response Body.

func (ExtensionsClient) DisableMonitoringSender

func (client ExtensionsClient) DisableMonitoringSender(req *http.Request) (future ExtensionsDisableMonitoringFuture, err error)

DisableMonitoringSender sends the DisableMonitoring request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) EnableAzureMonitor

func (client ExtensionsClient) EnableAzureMonitor(ctx context.Context, resourceGroupName string, clusterName string, parameters AzureMonitorRequest) (result ExtensionsEnableAzureMonitorFuture, err error)

EnableAzureMonitor enables the Azure Monitor on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the Log Analytics workspace parameters.

func (ExtensionsClient) EnableAzureMonitorPreparer

func (client ExtensionsClient) EnableAzureMonitorPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters AzureMonitorRequest) (*http.Request, error)

EnableAzureMonitorPreparer prepares the EnableAzureMonitor request.

func (ExtensionsClient) EnableAzureMonitorResponder

func (client ExtensionsClient) EnableAzureMonitorResponder(resp *http.Response) (result autorest.Response, err error)

EnableAzureMonitorResponder handles the response to the EnableAzureMonitor request. The method always closes the http.Response Body.

func (ExtensionsClient) EnableAzureMonitorSender

func (client ExtensionsClient) EnableAzureMonitorSender(req *http.Request) (future ExtensionsEnableAzureMonitorFuture, err error)

EnableAzureMonitorSender sends the EnableAzureMonitor request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) EnableMonitoring

func (client ExtensionsClient) EnableMonitoring(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterMonitoringRequest) (result ExtensionsEnableMonitoringFuture, err error)

EnableMonitoring enables the Operations Management Suite (OMS) on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the Operations Management Suite (OMS) workspace parameters.

func (ExtensionsClient) EnableMonitoringPreparer

func (client ExtensionsClient) EnableMonitoringPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterMonitoringRequest) (*http.Request, error)

EnableMonitoringPreparer prepares the EnableMonitoring request.

func (ExtensionsClient) EnableMonitoringResponder

func (client ExtensionsClient) EnableMonitoringResponder(resp *http.Response) (result autorest.Response, err error)

EnableMonitoringResponder handles the response to the EnableMonitoring request. The method always closes the http.Response Body.

func (ExtensionsClient) EnableMonitoringSender

func (client ExtensionsClient) EnableMonitoringSender(req *http.Request) (future ExtensionsEnableMonitoringFuture, err error)

EnableMonitoringSender sends the EnableMonitoring request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) Get

func (client ExtensionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, extensionName string) (result ClusterMonitoringResponse, err error)

Get gets the extension properties for the specified HDInsight cluster extension. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. extensionName - the name of the cluster extension.

func (ExtensionsClient) GetAzureAsyncOperationStatus

func (client ExtensionsClient) GetAzureAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, operationID string) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatus gets the async operation status. Parameters: 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.

func (ExtensionsClient) GetAzureAsyncOperationStatusPreparer

func (client ExtensionsClient) GetAzureAsyncOperationStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, operationID string) (*http.Request, error)

GetAzureAsyncOperationStatusPreparer prepares the GetAzureAsyncOperationStatus request.

func (ExtensionsClient) GetAzureAsyncOperationStatusResponder

func (client ExtensionsClient) GetAzureAsyncOperationStatusResponder(resp *http.Response) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatusResponder handles the response to the GetAzureAsyncOperationStatus request. The method always closes the http.Response Body.

func (ExtensionsClient) GetAzureAsyncOperationStatusSender

func (client ExtensionsClient) GetAzureAsyncOperationStatusSender(req *http.Request) (*http.Response, error)

GetAzureAsyncOperationStatusSender sends the GetAzureAsyncOperationStatus request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) GetAzureMonitorStatus

func (client ExtensionsClient) GetAzureMonitorStatus(ctx context.Context, resourceGroupName string, clusterName string) (result AzureMonitorResponse, err error)

GetAzureMonitorStatus gets the status of Azure Monitor on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ExtensionsClient) GetAzureMonitorStatusPreparer

func (client ExtensionsClient) GetAzureMonitorStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

GetAzureMonitorStatusPreparer prepares the GetAzureMonitorStatus request.

func (ExtensionsClient) GetAzureMonitorStatusResponder

func (client ExtensionsClient) GetAzureMonitorStatusResponder(resp *http.Response) (result AzureMonitorResponse, err error)

GetAzureMonitorStatusResponder handles the response to the GetAzureMonitorStatus request. The method always closes the http.Response Body.

func (ExtensionsClient) GetAzureMonitorStatusSender

func (client ExtensionsClient) GetAzureMonitorStatusSender(req *http.Request) (*http.Response, error)

GetAzureMonitorStatusSender sends the GetAzureMonitorStatus request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) GetMonitoringStatus

func (client ExtensionsClient) GetMonitoringStatus(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterMonitoringResponse, err error)

GetMonitoringStatus gets the status of Operations Management Suite (OMS) on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ExtensionsClient) GetMonitoringStatusPreparer

func (client ExtensionsClient) GetMonitoringStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

GetMonitoringStatusPreparer prepares the GetMonitoringStatus request.

func (ExtensionsClient) GetMonitoringStatusResponder

func (client ExtensionsClient) GetMonitoringStatusResponder(resp *http.Response) (result ClusterMonitoringResponse, err error)

GetMonitoringStatusResponder handles the response to the GetMonitoringStatus request. The method always closes the http.Response Body.

func (ExtensionsClient) GetMonitoringStatusSender

func (client ExtensionsClient) GetMonitoringStatusSender(req *http.Request) (*http.Response, error)

GetMonitoringStatusSender sends the GetMonitoringStatus request. The method will close the http.Response Body if it receives an error.

func (ExtensionsClient) GetPreparer

func (client ExtensionsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, extensionName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ExtensionsClient) GetResponder

func (client ExtensionsClient) GetResponder(resp *http.Response) (result ClusterMonitoringResponse, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ExtensionsClient) GetSender

func (client ExtensionsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

type ExtensionsCreateFuture

type ExtensionsCreateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ExtensionsClient) (autorest.Response, error)
}

ExtensionsCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ExtensionsCreateFuture) UnmarshalJSON

func (future *ExtensionsCreateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ExtensionsDeleteFuture

type ExtensionsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ExtensionsClient) (autorest.Response, error)
}

ExtensionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ExtensionsDeleteFuture) UnmarshalJSON

func (future *ExtensionsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ExtensionsDisableAzureMonitorFuture

type ExtensionsDisableAzureMonitorFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ExtensionsClient) (autorest.Response, error)
}

ExtensionsDisableAzureMonitorFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ExtensionsDisableAzureMonitorFuture) UnmarshalJSON

func (future *ExtensionsDisableAzureMonitorFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ExtensionsDisableMonitoringFuture

type ExtensionsDisableMonitoringFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ExtensionsClient) (autorest.Response, error)
}

ExtensionsDisableMonitoringFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ExtensionsDisableMonitoringFuture) UnmarshalJSON

func (future *ExtensionsDisableMonitoringFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ExtensionsEnableAzureMonitorFuture

type ExtensionsEnableAzureMonitorFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ExtensionsClient) (autorest.Response, error)
}

ExtensionsEnableAzureMonitorFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ExtensionsEnableAzureMonitorFuture) UnmarshalJSON

func (future *ExtensionsEnableAzureMonitorFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ExtensionsEnableMonitoringFuture

type ExtensionsEnableMonitoringFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ExtensionsClient) (autorest.Response, error)
}

ExtensionsEnableMonitoringFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ExtensionsEnableMonitoringFuture) UnmarshalJSON

func (future *ExtensionsEnableMonitoringFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type FilterMode

type FilterMode string

FilterMode enumerates the values for filter mode.

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

func PossibleFilterModeValues

func PossibleFilterModeValues() []FilterMode

PossibleFilterModeValues returns an array of possible values for the FilterMode const type.

type GatewaySettings

type GatewaySettings struct {
	autorest.Response `json:"-"`
	// IsCredentialEnabled - READ-ONLY; Indicates whether or not the gateway settings based authorization is enabled.
	IsCredentialEnabled *string `json:"restAuthCredential.isEnabled,omitempty"`
	// UserName - READ-ONLY; The gateway settings user name.
	UserName *string `json:"restAuthCredential.username,omitempty"`
	// Password - READ-ONLY; The gateway settings user password.
	Password *string `json:"restAuthCredential.password,omitempty"`
}

GatewaySettings gateway settings.

func (GatewaySettings) MarshalJSON

func (gs GatewaySettings) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for GatewaySettings.

type HardwareProfile

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

HardwareProfile the hardware profile.

type HostInfo

type HostInfo struct {
	// Name - The host name
	Name *string `json:"name,omitempty"`
	// Fqdn - The Fully Qualified Domain Name of host
	Fqdn *string `json:"fqdn,omitempty"`
	// EffectiveDiskEncryptionKeyURL - The effective disk encryption key URL used by the host
	EffectiveDiskEncryptionKeyURL *string `json:"effectiveDiskEncryptionKeyUrl,omitempty"`
}

HostInfo the cluster host information.

type IPConfiguration

type IPConfiguration struct {
	// ID - READ-ONLY; The private link IP configuration id.
	ID *string `json:"id,omitempty"`
	// Name - The name of private link IP configuration.
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the private link IP configuration.
	Type *string `json:"type,omitempty"`
	// IPConfigurationProperties - The private link ip configuration properties.
	*IPConfigurationProperties `json:"properties,omitempty"`
}

IPConfiguration the ip configurations for the private link service.

func (IPConfiguration) MarshalJSON

func (ic IPConfiguration) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for IPConfiguration.

func (*IPConfiguration) UnmarshalJSON

func (ic *IPConfiguration) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for IPConfiguration struct.

type IPConfigurationProperties

type IPConfigurationProperties struct {
	// ProvisioningState - READ-ONLY; The private link configuration provisioning state, which only appears in the response. Possible values include: 'PrivateLinkConfigurationProvisioningStateInProgress', 'PrivateLinkConfigurationProvisioningStateFailed', 'PrivateLinkConfigurationProvisioningStateSucceeded', 'PrivateLinkConfigurationProvisioningStateCanceled', 'PrivateLinkConfigurationProvisioningStateDeleting'
	ProvisioningState PrivateLinkConfigurationProvisioningState `json:"provisioningState,omitempty"`
	// Primary - Indicates whether this IP configuration is primary for the corresponding NIC.
	Primary *bool `json:"primary,omitempty"`
	// PrivateIPAddress - The IP address.
	PrivateIPAddress *string `json:"privateIPAddress,omitempty"`
	// PrivateIPAllocationMethod - The method that private IP address is allocated. Possible values include: 'PrivateIPAllocationMethodDynamic', 'PrivateIPAllocationMethodStatic'
	PrivateIPAllocationMethod PrivateIPAllocationMethod `json:"privateIPAllocationMethod,omitempty"`
	// Subnet - The subnet resource id.
	Subnet *ResourceID `json:"subnet,omitempty"`
}

IPConfigurationProperties the private link ip configuration properties.

func (IPConfigurationProperties) MarshalJSON

func (icp IPConfigurationProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for IPConfigurationProperties.

type JSONWebKeyEncryptionAlgorithm

type JSONWebKeyEncryptionAlgorithm string

JSONWebKeyEncryptionAlgorithm enumerates the values for json web key encryption algorithm.

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

func PossibleJSONWebKeyEncryptionAlgorithmValues

func PossibleJSONWebKeyEncryptionAlgorithmValues() []JSONWebKeyEncryptionAlgorithm

PossibleJSONWebKeyEncryptionAlgorithmValues returns an array of possible values for the JSONWebKeyEncryptionAlgorithm const type.

type KafkaRestProperties

type KafkaRestProperties struct {
	// ClientGroupInfo - The information of AAD security group.
	ClientGroupInfo *ClientGroupInfo `json:"clientGroupInfo,omitempty"`
	// ConfigurationOverride - The configurations that need to be overriden.
	ConfigurationOverride map[string]*string `json:"configurationOverride"`
}

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

func (KafkaRestProperties) MarshalJSON

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

MarshalJSON is the custom marshaler for KafkaRestProperties.

type LinuxOperatingSystemProfile

type LinuxOperatingSystemProfile struct {
	// Username - The username.
	Username *string `json:"username,omitempty"`
	// Password - The password.
	Password *string `json:"password,omitempty"`
	// SSHProfile - The SSH profile.
	SSHProfile *SSHProfile `json:"sshProfile,omitempty"`
}

LinuxOperatingSystemProfile the ssh username, password, and ssh public key.

type ListHostInfo

type ListHostInfo struct {
	autorest.Response `json:"-"`
	Value             *[]HostInfo `json:"value,omitempty"`
}

ListHostInfo ...

type LocalizedName

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

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

type LocationsClient

type LocationsClient struct {
	BaseClient
}

LocationsClient is the hDInsight Management Client

func NewLocationsClient

func NewLocationsClient(subscriptionID string) LocationsClient

NewLocationsClient creates an instance of the LocationsClient client.

func NewLocationsClientWithBaseURI

func NewLocationsClientWithBaseURI(baseURI string, subscriptionID string) LocationsClient

NewLocationsClientWithBaseURI creates an instance of the LocationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (LocationsClient) CheckNameAvailability

func (client LocationsClient) CheckNameAvailability(ctx context.Context, location string, parameters NameAvailabilityCheckRequestParameters) (result NameAvailabilityCheckResult, err error)

CheckNameAvailability check the cluster name is available or not. Parameters: location - the Azure location (region) for which to make the request.

func (LocationsClient) CheckNameAvailabilityPreparer

func (client LocationsClient) CheckNameAvailabilityPreparer(ctx context.Context, location string, parameters NameAvailabilityCheckRequestParameters) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (LocationsClient) CheckNameAvailabilityResponder

func (client LocationsClient) CheckNameAvailabilityResponder(resp *http.Response) (result NameAvailabilityCheckResult, err error)

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (LocationsClient) CheckNameAvailabilitySender

func (client LocationsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)

CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.

func (LocationsClient) GetAzureAsyncOperationStatus

func (client LocationsClient) GetAzureAsyncOperationStatus(ctx context.Context, location string, operationID string) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatus get the async operation status. Parameters: location - the Azure location (region) for which to make the request. operationID - the long running operation id.

func (LocationsClient) GetAzureAsyncOperationStatusPreparer

func (client LocationsClient) GetAzureAsyncOperationStatusPreparer(ctx context.Context, location string, operationID string) (*http.Request, error)

GetAzureAsyncOperationStatusPreparer prepares the GetAzureAsyncOperationStatus request.

func (LocationsClient) GetAzureAsyncOperationStatusResponder

func (client LocationsClient) GetAzureAsyncOperationStatusResponder(resp *http.Response) (result AsyncOperationResult, err error)

GetAzureAsyncOperationStatusResponder handles the response to the GetAzureAsyncOperationStatus request. The method always closes the http.Response Body.

func (LocationsClient) GetAzureAsyncOperationStatusSender

func (client LocationsClient) GetAzureAsyncOperationStatusSender(req *http.Request) (*http.Response, error)

GetAzureAsyncOperationStatusSender sends the GetAzureAsyncOperationStatus request. The method will close the http.Response Body if it receives an error.

func (LocationsClient) GetCapabilities

func (client LocationsClient) GetCapabilities(ctx context.Context, location string) (result CapabilitiesResult, err error)

GetCapabilities gets the capabilities for the specified location. Parameters: location - the Azure location (region) for which to make the request.

func (LocationsClient) GetCapabilitiesPreparer

func (client LocationsClient) GetCapabilitiesPreparer(ctx context.Context, location string) (*http.Request, error)

GetCapabilitiesPreparer prepares the GetCapabilities request.

func (LocationsClient) GetCapabilitiesResponder

func (client LocationsClient) GetCapabilitiesResponder(resp *http.Response) (result CapabilitiesResult, err error)

GetCapabilitiesResponder handles the response to the GetCapabilities request. The method always closes the http.Response Body.

func (LocationsClient) GetCapabilitiesSender

func (client LocationsClient) GetCapabilitiesSender(req *http.Request) (*http.Response, error)

GetCapabilitiesSender sends the GetCapabilities request. The method will close the http.Response Body if it receives an error.

func (LocationsClient) ListBillingSpecs

func (client LocationsClient) ListBillingSpecs(ctx context.Context, location string) (result BillingResponseListResult, err error)

ListBillingSpecs lists the billingSpecs for the specified subscription and location. Parameters: location - the Azure location (region) for which to make the request.

func (LocationsClient) ListBillingSpecsPreparer

func (client LocationsClient) ListBillingSpecsPreparer(ctx context.Context, location string) (*http.Request, error)

ListBillingSpecsPreparer prepares the ListBillingSpecs request.

func (LocationsClient) ListBillingSpecsResponder

func (client LocationsClient) ListBillingSpecsResponder(resp *http.Response) (result BillingResponseListResult, err error)

ListBillingSpecsResponder handles the response to the ListBillingSpecs request. The method always closes the http.Response Body.

func (LocationsClient) ListBillingSpecsSender

func (client LocationsClient) ListBillingSpecsSender(req *http.Request) (*http.Response, error)

ListBillingSpecsSender sends the ListBillingSpecs request. The method will close the http.Response Body if it receives an error.

func (LocationsClient) ListUsages

func (client LocationsClient) ListUsages(ctx context.Context, location string) (result UsagesListResult, err error)

ListUsages lists the usages for the specified location. Parameters: location - the Azure location (region) for which to make the request.

func (LocationsClient) ListUsagesPreparer

func (client LocationsClient) ListUsagesPreparer(ctx context.Context, location string) (*http.Request, error)

ListUsagesPreparer prepares the ListUsages request.

func (LocationsClient) ListUsagesResponder

func (client LocationsClient) ListUsagesResponder(resp *http.Response) (result UsagesListResult, err error)

ListUsagesResponder handles the response to the ListUsages request. The method always closes the http.Response Body.

func (LocationsClient) ListUsagesSender

func (client LocationsClient) ListUsagesSender(req *http.Request) (*http.Response, error)

ListUsagesSender sends the ListUsages request. The method will close the http.Response Body if it receives an error.

func (LocationsClient) ValidateClusterCreateRequest

func (client LocationsClient) ValidateClusterCreateRequest(ctx context.Context, location string, parameters ClusterCreateRequestValidationParameters) (result ClusterCreateValidationResult, err error)

ValidateClusterCreateRequest validate the cluster create request spec is valid or not. Parameters: location - the Azure location (region) for which to make the request.

func (LocationsClient) ValidateClusterCreateRequestPreparer

func (client LocationsClient) ValidateClusterCreateRequestPreparer(ctx context.Context, location string, parameters ClusterCreateRequestValidationParameters) (*http.Request, error)

ValidateClusterCreateRequestPreparer prepares the ValidateClusterCreateRequest request.

func (LocationsClient) ValidateClusterCreateRequestResponder

func (client LocationsClient) ValidateClusterCreateRequestResponder(resp *http.Response) (result ClusterCreateValidationResult, err error)

ValidateClusterCreateRequestResponder handles the response to the ValidateClusterCreateRequest request. The method always closes the http.Response Body.

func (LocationsClient) ValidateClusterCreateRequestSender

func (client LocationsClient) ValidateClusterCreateRequestSender(req *http.Request) (*http.Response, error)

ValidateClusterCreateRequestSender sends the ValidateClusterCreateRequest request. The method will close the http.Response Body if it receives an error.

type MetricSpecifications

type MetricSpecifications struct {
	// Name - The name of the metric specification.
	Name *string `json:"name,omitempty"`
	// DisplayName - The display name of the metric specification.
	DisplayName *string `json:"displayName,omitempty"`
	// DisplayDescription - The display description of the metric specification.
	DisplayDescription *string `json:"displayDescription,omitempty"`
	// Unit - The unit of the metric specification.
	Unit *string `json:"unit,omitempty"`
	// AggregationType - The aggregation type of the metric specification.
	AggregationType *string `json:"aggregationType,omitempty"`
	// SupportedAggregationTypes - The supported aggregation types of the metric specification.
	SupportedAggregationTypes *[]string `json:"supportedAggregationTypes,omitempty"`
	// SupportedTimeGrainTypes - The supported time grain types of the metric specification.
	SupportedTimeGrainTypes *[]string `json:"supportedTimeGrainTypes,omitempty"`
	// EnableRegionalMdmAccount - The flag indicates whether enable regional mdm account or not.
	EnableRegionalMdmAccount *bool `json:"enableRegionalMdmAccount,omitempty"`
	// SourceMdmAccount - The source mdm account.
	SourceMdmAccount *string `json:"sourceMdmAccount,omitempty"`
	// SourceMdmNamespace - The source mdm namespace.
	SourceMdmNamespace *string `json:"sourceMdmNamespace,omitempty"`
	// MetricFilterPattern - The metric filter pattern.
	MetricFilterPattern *string `json:"metricFilterPattern,omitempty"`
	// FillGapWithZero - The flag indicates whether filling gap with zero.
	FillGapWithZero *bool `json:"fillGapWithZero,omitempty"`
	// Category - The category of the metric.
	Category *string `json:"category,omitempty"`
	// ResourceIDDimensionNameOverride - The override name of resource id dimension name.
	ResourceIDDimensionNameOverride *string `json:"resourceIdDimensionNameOverride,omitempty"`
	// IsInternal - The flag indicates whether the metric is internal or not.
	IsInternal *bool `json:"isInternal,omitempty"`
	// DelegateMetricNameOverride - The override name of delegate metric.
	DelegateMetricNameOverride *string `json:"delegateMetricNameOverride,omitempty"`
	// Dimensions - The dimensions of the metric specification.
	Dimensions *[]Dimension `json:"dimensions,omitempty"`
}

MetricSpecifications the details of metric specifications.

type NameAvailabilityCheckRequestParameters

type NameAvailabilityCheckRequestParameters struct {
	// Name - The resource name.
	Name *string `json:"name,omitempty"`
	// Type - The resource type
	Type *string `json:"type,omitempty"`
}

NameAvailabilityCheckRequestParameters the request spec of checking name availability.

type NameAvailabilityCheckResult

type NameAvailabilityCheckResult struct {
	autorest.Response `json:"-"`
	// NameAvailable - This indicates whether the name is available.
	NameAvailable *bool `json:"nameAvailable,omitempty"`
	// Reason - READ-ONLY; The reason of the result.
	Reason *string `json:"reason,omitempty"`
	// Message - READ-ONLY; The related message.
	Message *string `json:"message,omitempty"`
}

NameAvailabilityCheckResult the response spec of checking name availability.

func (NameAvailabilityCheckResult) MarshalJSON

func (nacr NameAvailabilityCheckResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for NameAvailabilityCheckResult.

type NetworkProperties

type NetworkProperties struct {
	// ResourceProviderConnection - The direction for the resource provider connection. Possible values include: 'ResourceProviderConnectionInbound', 'ResourceProviderConnectionOutbound'
	ResourceProviderConnection ResourceProviderConnection `json:"resourceProviderConnection,omitempty"`
	// PrivateLink - Indicates whether or not private link is enabled. Possible values include: 'PrivateLinkDisabled', 'PrivateLinkEnabled'
	PrivateLink PrivateLink `json:"privateLink,omitempty"`
}

NetworkProperties the network properties.

type OSType

type OSType string

OSType enumerates the values for os type.

const (
	// OSTypeLinux ...
	OSTypeLinux OSType = "Linux"
	// OSTypeWindows ...
	OSTypeWindows OSType = "Windows"
)

func PossibleOSTypeValues

func PossibleOSTypeValues() []OSType

PossibleOSTypeValues returns an array of possible values for the OSType const type.

type Operation

type Operation struct {
	// Name - The operation name: {provider}/{resource}/{operation}
	Name *string `json:"name,omitempty"`
	// Display - The display of operation.
	Display *OperationDisplay `json:"display,omitempty"`
	// Properties - The operation properties.
	Properties *OperationProperties `json:"properties,omitempty"`
}

Operation the HDInsight REST API operation.

type OperationDisplay

type OperationDisplay struct {
	// Provider - The service provider: Microsoft.HDInsight
	Provider *string `json:"provider,omitempty"`
	// Resource - The resource on which the operation is performed: Cluster, Applications, etc.
	Resource *string `json:"resource,omitempty"`
	// Operation - The operation type: read, write, delete, etc.
	Operation *string `json:"operation,omitempty"`
	// Description - Localized friendly description for the operation
	Description *string `json:"description,omitempty"`
}

OperationDisplay the object that represents the operation.

type OperationListResult

type OperationListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of HDInsight operations supported by the HDInsight resource provider.
	Value *[]Operation `json:"value,omitempty"`
	// NextLink - The URL to get the next set of operation list results if there are any.
	NextLink *string `json:"nextLink,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) IsEmpty

func (olr OperationListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type OperationListResultIterator

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

OperationListResultIterator provides access to a complete listing of Operation values.

func NewOperationListResultIterator

func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator

Creates a new instance of the OperationListResultIterator type.

func (*OperationListResultIterator) Next

func (iter *OperationListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultIterator) NextWithContext

func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (OperationListResultIterator) NotDone

func (iter OperationListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (OperationListResultIterator) Response

Response returns the raw server response from the last page request.

func (OperationListResultIterator) Value

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type OperationListResultPage

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

OperationListResultPage contains a page of Operation values.

func NewOperationListResultPage

func NewOperationListResultPage(cur OperationListResult, getNextPage func(context.Context, OperationListResult) (OperationListResult, error)) OperationListResultPage

Creates a new instance of the OperationListResultPage type.

func (*OperationListResultPage) Next

func (page *OperationListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultPage) NextWithContext

func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (OperationListResultPage) NotDone

func (page OperationListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (OperationListResultPage) Response

Response returns the raw server response from the last page request.

func (OperationListResultPage) Values

func (page OperationListResultPage) Values() []Operation

Values returns the slice of values for the current page or nil if there are no values.

type OperationProperties

type OperationProperties struct {
	// ServiceSpecification - The specification of the service.
	ServiceSpecification *ServiceSpecification `json:"serviceSpecification,omitempty"`
}

OperationProperties the details of operation.

type OperationsClient

type OperationsClient struct {
	BaseClient
}

OperationsClient is the hDInsight Management Client

func NewOperationsClient

func NewOperationsClient(subscriptionID string) OperationsClient

NewOperationsClient creates an instance of the OperationsClient client.

func NewOperationsClientWithBaseURI

func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient

NewOperationsClientWithBaseURI creates an instance of the OperationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (OperationsClient) List

func (client OperationsClient) List(ctx context.Context) (result OperationListResultPage, err error)

List lists all of the available HDInsight REST API operations.

func (OperationsClient) ListComplete

func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error)

ListComplete enumerates all values, automatically crossing page boundaries as required.

func (OperationsClient) ListPreparer

func (client OperationsClient) ListPreparer(ctx context.Context) (*http.Request, error)

ListPreparer prepares the List request.

func (OperationsClient) ListResponder

func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (OperationsClient) ListSender

func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type OsProfile

type OsProfile struct {
	// LinuxOperatingSystemProfile - The Linux OS profile.
	LinuxOperatingSystemProfile *LinuxOperatingSystemProfile `json:"linuxOperatingSystemProfile,omitempty"`
}

OsProfile the Linux operation systems profile.

type PrivateEndpoint

type PrivateEndpoint struct {
	// ID - The private endpoint id.
	ID *string `json:"id,omitempty"`
}

PrivateEndpoint the private endpoint.

type PrivateEndpointConnection

type PrivateEndpointConnection struct {
	autorest.Response `json:"-"`
	// PrivateEndpointConnectionProperties - The private endpoint connection properties.
	*PrivateEndpointConnectionProperties `json:"properties,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

PrivateEndpointConnection the private endpoint connection.

func (PrivateEndpointConnection) MarshalJSON

func (pec PrivateEndpointConnection) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointConnection.

func (*PrivateEndpointConnection) UnmarshalJSON

func (pec *PrivateEndpointConnection) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for PrivateEndpointConnection struct.

type PrivateEndpointConnectionListResult

type PrivateEndpointConnectionListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of private endpoint connections.
	Value *[]PrivateEndpointConnection `json:"value,omitempty"`
	// NextLink - READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty"`
}

PrivateEndpointConnectionListResult the list private endpoint connections response.

func (PrivateEndpointConnectionListResult) IsEmpty

func (peclr PrivateEndpointConnectionListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (PrivateEndpointConnectionListResult) MarshalJSON

func (peclr PrivateEndpointConnectionListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointConnectionListResult.

type PrivateEndpointConnectionListResultIterator

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

PrivateEndpointConnectionListResultIterator provides access to a complete listing of PrivateEndpointConnection values.

func NewPrivateEndpointConnectionListResultIterator

func NewPrivateEndpointConnectionListResultIterator(page PrivateEndpointConnectionListResultPage) PrivateEndpointConnectionListResultIterator

Creates a new instance of the PrivateEndpointConnectionListResultIterator type.

func (*PrivateEndpointConnectionListResultIterator) Next

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*PrivateEndpointConnectionListResultIterator) NextWithContext

func (iter *PrivateEndpointConnectionListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (PrivateEndpointConnectionListResultIterator) NotDone

NotDone returns true if the enumeration should be started or is not yet complete.

func (PrivateEndpointConnectionListResultIterator) Response

Response returns the raw server response from the last page request.

func (PrivateEndpointConnectionListResultIterator) Value

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type PrivateEndpointConnectionListResultPage

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

PrivateEndpointConnectionListResultPage contains a page of PrivateEndpointConnection values.

func NewPrivateEndpointConnectionListResultPage

Creates a new instance of the PrivateEndpointConnectionListResultPage type.

func (*PrivateEndpointConnectionListResultPage) Next

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*PrivateEndpointConnectionListResultPage) NextWithContext

func (page *PrivateEndpointConnectionListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (PrivateEndpointConnectionListResultPage) NotDone

NotDone returns true if the page enumeration should be started or is not yet complete.

func (PrivateEndpointConnectionListResultPage) Response

Response returns the raw server response from the last page request.

func (PrivateEndpointConnectionListResultPage) Values

Values returns the slice of values for the current page or nil if there are no values.

type PrivateEndpointConnectionProperties

type PrivateEndpointConnectionProperties struct {
	// PrivateEndpoint - READ-ONLY; The private endpoint of the private endpoint connection
	PrivateEndpoint *PrivateEndpoint `json:"privateEndpoint,omitempty"`
	// PrivateLinkServiceConnectionState - The private link service connection state.
	PrivateLinkServiceConnectionState *PrivateLinkServiceConnectionState `json:"privateLinkServiceConnectionState,omitempty"`
	// LinkIdentifier - READ-ONLY; The link identifier.
	LinkIdentifier *string `json:"linkIdentifier,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioning state, which only appears in the response. Possible values include: 'PrivateEndpointConnectionProvisioningStateInProgress', 'PrivateEndpointConnectionProvisioningStateUpdating', 'PrivateEndpointConnectionProvisioningStateFailed', 'PrivateEndpointConnectionProvisioningStateSucceeded', 'PrivateEndpointConnectionProvisioningStateCanceled', 'PrivateEndpointConnectionProvisioningStateDeleting'
	ProvisioningState PrivateEndpointConnectionProvisioningState `json:"provisioningState,omitempty"`
}

PrivateEndpointConnectionProperties the private endpoint connection properties.

func (PrivateEndpointConnectionProperties) MarshalJSON

func (pecp PrivateEndpointConnectionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointConnectionProperties.

type PrivateEndpointConnectionProvisioningState

type PrivateEndpointConnectionProvisioningState string

PrivateEndpointConnectionProvisioningState enumerates the values for private endpoint connection provisioning state.

const (
	// PrivateEndpointConnectionProvisioningStateCanceled ...
	PrivateEndpointConnectionProvisioningStateCanceled PrivateEndpointConnectionProvisioningState = "Canceled"
	// PrivateEndpointConnectionProvisioningStateDeleting ...
	PrivateEndpointConnectionProvisioningStateDeleting PrivateEndpointConnectionProvisioningState = "Deleting"
	// PrivateEndpointConnectionProvisioningStateFailed ...
	PrivateEndpointConnectionProvisioningStateFailed PrivateEndpointConnectionProvisioningState = "Failed"
	// PrivateEndpointConnectionProvisioningStateInProgress ...
	PrivateEndpointConnectionProvisioningStateInProgress PrivateEndpointConnectionProvisioningState = "InProgress"
	// PrivateEndpointConnectionProvisioningStateSucceeded ...
	PrivateEndpointConnectionProvisioningStateSucceeded PrivateEndpointConnectionProvisioningState = "Succeeded"
	// PrivateEndpointConnectionProvisioningStateUpdating ...
	PrivateEndpointConnectionProvisioningStateUpdating PrivateEndpointConnectionProvisioningState = "Updating"
)

func PossiblePrivateEndpointConnectionProvisioningStateValues

func PossiblePrivateEndpointConnectionProvisioningStateValues() []PrivateEndpointConnectionProvisioningState

PossiblePrivateEndpointConnectionProvisioningStateValues returns an array of possible values for the PrivateEndpointConnectionProvisioningState const type.

type PrivateEndpointConnectionsClient

type PrivateEndpointConnectionsClient struct {
	BaseClient
}

PrivateEndpointConnectionsClient is the hDInsight Management Client

func NewPrivateEndpointConnectionsClient

func NewPrivateEndpointConnectionsClient(subscriptionID string) PrivateEndpointConnectionsClient

NewPrivateEndpointConnectionsClient creates an instance of the PrivateEndpointConnectionsClient client.

func NewPrivateEndpointConnectionsClientWithBaseURI

func NewPrivateEndpointConnectionsClientWithBaseURI(baseURI string, subscriptionID string) PrivateEndpointConnectionsClient

NewPrivateEndpointConnectionsClientWithBaseURI creates an instance of the PrivateEndpointConnectionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (PrivateEndpointConnectionsClient) CreateOrUpdate

func (client PrivateEndpointConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection) (result PrivateEndpointConnectionsCreateOrUpdateFuture, err error)

CreateOrUpdate approve or reject a private endpoint connection manually. Parameters: 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.

func (PrivateEndpointConnectionsClient) CreateOrUpdatePreparer

func (client PrivateEndpointConnectionsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (PrivateEndpointConnectionsClient) CreateOrUpdateResponder

func (client PrivateEndpointConnectionsClient) CreateOrUpdateResponder(resp *http.Response) (result PrivateEndpointConnection, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (PrivateEndpointConnectionsClient) CreateOrUpdateSender

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (PrivateEndpointConnectionsClient) Delete

func (client PrivateEndpointConnectionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (result PrivateEndpointConnectionsDeleteFuture, err error)

Delete deletes the specific private endpoint connection. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. privateEndpointConnectionName - the name of the private endpoint connection.

func (PrivateEndpointConnectionsClient) DeletePreparer

func (client PrivateEndpointConnectionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (PrivateEndpointConnectionsClient) DeleteResponder

func (client PrivateEndpointConnectionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (PrivateEndpointConnectionsClient) DeleteSender

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (PrivateEndpointConnectionsClient) Get

func (client PrivateEndpointConnectionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (result PrivateEndpointConnection, err error)

Get gets the specific private endpoint connection. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. privateEndpointConnectionName - the name of the private endpoint connection.

func (PrivateEndpointConnectionsClient) GetPreparer

func (client PrivateEndpointConnectionsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (PrivateEndpointConnectionsClient) GetResponder

func (client PrivateEndpointConnectionsClient) GetResponder(resp *http.Response) (result PrivateEndpointConnection, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (PrivateEndpointConnectionsClient) GetSender

func (client PrivateEndpointConnectionsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (PrivateEndpointConnectionsClient) ListByCluster

func (client PrivateEndpointConnectionsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result PrivateEndpointConnectionListResultPage, err error)

ListByCluster lists the private endpoint connections for a HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (PrivateEndpointConnectionsClient) ListByClusterComplete

func (client PrivateEndpointConnectionsClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result PrivateEndpointConnectionListResultIterator, err error)

ListByClusterComplete enumerates all values, automatically crossing page boundaries as required.

func (PrivateEndpointConnectionsClient) ListByClusterPreparer

func (client PrivateEndpointConnectionsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListByClusterPreparer prepares the ListByCluster request.

func (PrivateEndpointConnectionsClient) ListByClusterResponder

func (client PrivateEndpointConnectionsClient) ListByClusterResponder(resp *http.Response) (result PrivateEndpointConnectionListResult, err error)

ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.

func (PrivateEndpointConnectionsClient) ListByClusterSender

func (client PrivateEndpointConnectionsClient) ListByClusterSender(req *http.Request) (*http.Response, error)

ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.

type PrivateEndpointConnectionsCreateOrUpdateFuture

type PrivateEndpointConnectionsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(PrivateEndpointConnectionsClient) (PrivateEndpointConnection, error)
}

PrivateEndpointConnectionsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*PrivateEndpointConnectionsCreateOrUpdateFuture) UnmarshalJSON

func (future *PrivateEndpointConnectionsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type PrivateEndpointConnectionsDeleteFuture

type PrivateEndpointConnectionsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(PrivateEndpointConnectionsClient) (autorest.Response, error)
}

PrivateEndpointConnectionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*PrivateEndpointConnectionsDeleteFuture) UnmarshalJSON

func (future *PrivateEndpointConnectionsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type PrivateIPAllocationMethod

type PrivateIPAllocationMethod string

PrivateIPAllocationMethod enumerates the values for private ip allocation method.

const (
	// PrivateIPAllocationMethodDynamic ...
	PrivateIPAllocationMethodDynamic PrivateIPAllocationMethod = "dynamic"
	// PrivateIPAllocationMethodStatic ...
	PrivateIPAllocationMethodStatic PrivateIPAllocationMethod = "static"
)

func PossiblePrivateIPAllocationMethodValues

func PossiblePrivateIPAllocationMethodValues() []PrivateIPAllocationMethod

PossiblePrivateIPAllocationMethodValues returns an array of possible values for the PrivateIPAllocationMethod const type.

type PrivateLink string

PrivateLink enumerates the values for private link.

const (
	// PrivateLinkDisabled ...
	PrivateLinkDisabled PrivateLink = "Disabled"
	// PrivateLinkEnabled ...
	PrivateLinkEnabled PrivateLink = "Enabled"
)

func PossiblePrivateLinkValues

func PossiblePrivateLinkValues() []PrivateLink

PossiblePrivateLinkValues returns an array of possible values for the PrivateLink const type.

type PrivateLinkConfiguration

type PrivateLinkConfiguration struct {
	// ID - READ-ONLY; The private link configuration id.
	ID *string `json:"id,omitempty"`
	// Name - The name of private link configuration.
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the private link configuration.
	Type *string `json:"type,omitempty"`
	// PrivateLinkConfigurationProperties - The private link configuration properties.
	*PrivateLinkConfigurationProperties `json:"properties,omitempty"`
}

PrivateLinkConfiguration the private link configuration.

func (PrivateLinkConfiguration) MarshalJSON

func (plc PrivateLinkConfiguration) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkConfiguration.

func (*PrivateLinkConfiguration) UnmarshalJSON

func (plc *PrivateLinkConfiguration) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for PrivateLinkConfiguration struct.

type PrivateLinkConfigurationProperties

type PrivateLinkConfigurationProperties struct {
	// GroupID - The HDInsight private linkable sub-resource name to apply the private link configuration to. For example, 'headnode', 'gateway', 'edgenode'.
	GroupID *string `json:"groupId,omitempty"`
	// ProvisioningState - READ-ONLY; The private link configuration provisioning state, which only appears in the response. Possible values include: 'PrivateLinkConfigurationProvisioningStateInProgress', 'PrivateLinkConfigurationProvisioningStateFailed', 'PrivateLinkConfigurationProvisioningStateSucceeded', 'PrivateLinkConfigurationProvisioningStateCanceled', 'PrivateLinkConfigurationProvisioningStateDeleting'
	ProvisioningState PrivateLinkConfigurationProvisioningState `json:"provisioningState,omitempty"`
	// IPConfigurations - The IP configurations for the private link service.
	IPConfigurations *[]IPConfiguration `json:"ipConfigurations,omitempty"`
}

PrivateLinkConfigurationProperties the private link configuration properties.

func (PrivateLinkConfigurationProperties) MarshalJSON

func (plcp PrivateLinkConfigurationProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkConfigurationProperties.

type PrivateLinkConfigurationProvisioningState

type PrivateLinkConfigurationProvisioningState string

PrivateLinkConfigurationProvisioningState enumerates the values for private link configuration provisioning state.

const (
	// PrivateLinkConfigurationProvisioningStateCanceled ...
	PrivateLinkConfigurationProvisioningStateCanceled PrivateLinkConfigurationProvisioningState = "Canceled"
	// PrivateLinkConfigurationProvisioningStateDeleting ...
	PrivateLinkConfigurationProvisioningStateDeleting PrivateLinkConfigurationProvisioningState = "Deleting"
	// PrivateLinkConfigurationProvisioningStateFailed ...
	PrivateLinkConfigurationProvisioningStateFailed PrivateLinkConfigurationProvisioningState = "Failed"
	// PrivateLinkConfigurationProvisioningStateInProgress ...
	PrivateLinkConfigurationProvisioningStateInProgress PrivateLinkConfigurationProvisioningState = "InProgress"
	// PrivateLinkConfigurationProvisioningStateSucceeded ...
	PrivateLinkConfigurationProvisioningStateSucceeded PrivateLinkConfigurationProvisioningState = "Succeeded"
)

func PossiblePrivateLinkConfigurationProvisioningStateValues

func PossiblePrivateLinkConfigurationProvisioningStateValues() []PrivateLinkConfigurationProvisioningState

PossiblePrivateLinkConfigurationProvisioningStateValues returns an array of possible values for the PrivateLinkConfigurationProvisioningState const type.

type PrivateLinkResource

type PrivateLinkResource struct {
	autorest.Response `json:"-"`
	// PrivateLinkResourceProperties - Resource properties.
	*PrivateLinkResourceProperties `json:"properties,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

PrivateLinkResource a private link resource

func (PrivateLinkResource) MarshalJSON

func (plr PrivateLinkResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkResource.

func (*PrivateLinkResource) UnmarshalJSON

func (plr *PrivateLinkResource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for PrivateLinkResource struct.

type PrivateLinkResourceListResult

type PrivateLinkResourceListResult struct {
	autorest.Response `json:"-"`
	// Value - Array of private link resources
	Value *[]PrivateLinkResource `json:"value,omitempty"`
}

PrivateLinkResourceListResult a list of private link resources

type PrivateLinkResourceProperties

type PrivateLinkResourceProperties struct {
	// GroupID - READ-ONLY; The private link resource group id.
	GroupID *string `json:"groupId,omitempty"`
	// RequiredMembers - READ-ONLY; The private link resource required member names.
	RequiredMembers *[]string `json:"requiredMembers,omitempty"`
	// RequiredZoneNames - The private link resource Private link DNS zone name.
	RequiredZoneNames *[]string `json:"requiredZoneNames,omitempty"`
}

PrivateLinkResourceProperties properties of a private link resource.

func (PrivateLinkResourceProperties) MarshalJSON

func (plrp PrivateLinkResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkResourceProperties.

type PrivateLinkResourcesClient

type PrivateLinkResourcesClient struct {
	BaseClient
}

PrivateLinkResourcesClient is the hDInsight Management Client

func NewPrivateLinkResourcesClient

func NewPrivateLinkResourcesClient(subscriptionID string) PrivateLinkResourcesClient

NewPrivateLinkResourcesClient creates an instance of the PrivateLinkResourcesClient client.

func NewPrivateLinkResourcesClientWithBaseURI

func NewPrivateLinkResourcesClientWithBaseURI(baseURI string, subscriptionID string) PrivateLinkResourcesClient

NewPrivateLinkResourcesClientWithBaseURI creates an instance of the PrivateLinkResourcesClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (PrivateLinkResourcesClient) Get

func (client PrivateLinkResourcesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateLinkResourceName string) (result PrivateLinkResource, err error)

Get gets the specific private link resource. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. privateLinkResourceName - the name of the private link resource.

func (PrivateLinkResourcesClient) GetPreparer

func (client PrivateLinkResourcesClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, privateLinkResourceName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (PrivateLinkResourcesClient) GetResponder

func (client PrivateLinkResourcesClient) GetResponder(resp *http.Response) (result PrivateLinkResource, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (PrivateLinkResourcesClient) GetSender

func (client PrivateLinkResourcesClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (PrivateLinkResourcesClient) ListByCluster

func (client PrivateLinkResourcesClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result PrivateLinkResourceListResult, err error)

ListByCluster lists the private link resources in a HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (PrivateLinkResourcesClient) ListByClusterPreparer

func (client PrivateLinkResourcesClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListByClusterPreparer prepares the ListByCluster request.

func (PrivateLinkResourcesClient) ListByClusterResponder

func (client PrivateLinkResourcesClient) ListByClusterResponder(resp *http.Response) (result PrivateLinkResourceListResult, err error)

ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.

func (PrivateLinkResourcesClient) ListByClusterSender

func (client PrivateLinkResourcesClient) ListByClusterSender(req *http.Request) (*http.Response, error)

ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.

type PrivateLinkServiceConnectionState

type PrivateLinkServiceConnectionState struct {
	// Status - The concrete private link service connection. Possible values include: 'PrivateLinkServiceConnectionStatusApproved', 'PrivateLinkServiceConnectionStatusRejected', 'PrivateLinkServiceConnectionStatusPending', 'PrivateLinkServiceConnectionStatusRemoved'
	Status PrivateLinkServiceConnectionStatus `json:"status,omitempty"`
	// Description - The optional description of the status.
	Description *string `json:"description,omitempty"`
	// ActionsRequired - Whether there is further actions.
	ActionsRequired *string `json:"actionsRequired,omitempty"`
}

PrivateLinkServiceConnectionState the private link service connection state.

type PrivateLinkServiceConnectionStatus

type PrivateLinkServiceConnectionStatus string

PrivateLinkServiceConnectionStatus enumerates the values for private link service connection status.

const (
	// PrivateLinkServiceConnectionStatusApproved ...
	PrivateLinkServiceConnectionStatusApproved PrivateLinkServiceConnectionStatus = "Approved"
	// PrivateLinkServiceConnectionStatusPending ...
	PrivateLinkServiceConnectionStatusPending PrivateLinkServiceConnectionStatus = "Pending"
	// PrivateLinkServiceConnectionStatusRejected ...
	PrivateLinkServiceConnectionStatusRejected PrivateLinkServiceConnectionStatus = "Rejected"
	// PrivateLinkServiceConnectionStatusRemoved ...
	PrivateLinkServiceConnectionStatusRemoved PrivateLinkServiceConnectionStatus = "Removed"
)

func PossiblePrivateLinkServiceConnectionStatusValues

func PossiblePrivateLinkServiceConnectionStatusValues() []PrivateLinkServiceConnectionStatus

PossiblePrivateLinkServiceConnectionStatusValues returns an array of possible values for the PrivateLinkServiceConnectionStatus const type.

type ProxyResource

type ProxyResource struct {
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

ProxyResource the resource model definition for a Azure Resource Manager proxy resource. It will not have tags and a location

func (ProxyResource) MarshalJSON

func (pr ProxyResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ProxyResource.

type QuotaCapability

type QuotaCapability struct {
	// CoresUsed - The number of cores used in the subscription.
	CoresUsed *int64 `json:"coresUsed,omitempty"`
	// MaxCoresAllowed - The number of cores that the subscription allowed.
	MaxCoresAllowed *int64 `json:"maxCoresAllowed,omitempty"`
	// RegionalQuotas - The list of region quota capabilities.
	RegionalQuotas *[]RegionalQuotaCapability `json:"regionalQuotas,omitempty"`
}

QuotaCapability the regional quota capability.

type QuotaInfo

type QuotaInfo struct {
	// CoresUsed - The cores used by the cluster.
	CoresUsed *int32 `json:"coresUsed,omitempty"`
}

QuotaInfo the quota properties for the cluster.

type RegionalQuotaCapability

type RegionalQuotaCapability struct {
	// RegionName - The region name.
	RegionName *string `json:"regionName,omitempty"`
	// CoresUsed - The number of cores used in the region.
	CoresUsed *int64 `json:"coresUsed,omitempty"`
	// CoresAvailable - The number of cores available in the region.
	CoresAvailable *int64 `json:"coresAvailable,omitempty"`
}

RegionalQuotaCapability the regional quota capacity.

type RegionsCapability

type RegionsCapability struct {
	// Available - The list of region capabilities.
	Available *[]string `json:"available,omitempty"`
}

RegionsCapability the regions capability.

type Resource

type Resource struct {
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

Resource common fields that are returned in the response for all Azure Resource Manager resources

func (Resource) MarshalJSON

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

MarshalJSON is the custom marshaler for Resource.

type ResourceID

type ResourceID struct {
	// ID - The azure resource id.
	ID *string `json:"id,omitempty"`
}

ResourceID the azure resource id.

type ResourceIdentityType

type ResourceIdentityType string

ResourceIdentityType enumerates the values for resource identity type.

const (
	// ResourceIdentityTypeNone ...
	ResourceIdentityTypeNone ResourceIdentityType = "None"
	// ResourceIdentityTypeSystemAssigned ...
	ResourceIdentityTypeSystemAssigned ResourceIdentityType = "SystemAssigned"
	// ResourceIdentityTypeSystemAssignedUserAssigned ...
	ResourceIdentityTypeSystemAssignedUserAssigned ResourceIdentityType = "SystemAssigned, UserAssigned"
	// ResourceIdentityTypeUserAssigned ...
	ResourceIdentityTypeUserAssigned ResourceIdentityType = "UserAssigned"
)

func PossibleResourceIdentityTypeValues

func PossibleResourceIdentityTypeValues() []ResourceIdentityType

PossibleResourceIdentityTypeValues returns an array of possible values for the ResourceIdentityType const type.

type ResourceProviderConnection

type ResourceProviderConnection string

ResourceProviderConnection enumerates the values for resource provider connection.

const (
	// ResourceProviderConnectionInbound ...
	ResourceProviderConnectionInbound ResourceProviderConnection = "Inbound"
	// ResourceProviderConnectionOutbound ...
	ResourceProviderConnectionOutbound ResourceProviderConnection = "Outbound"
)

func PossibleResourceProviderConnectionValues

func PossibleResourceProviderConnectionValues() []ResourceProviderConnection

PossibleResourceProviderConnectionValues returns an array of possible values for the ResourceProviderConnection const type.

type Role

type Role struct {
	// Name - The name of the role.
	Name *string `json:"name,omitempty"`
	// MinInstanceCount - The minimum instance count of the cluster.
	MinInstanceCount *int32 `json:"minInstanceCount,omitempty"`
	// TargetInstanceCount - The instance count of the cluster.
	TargetInstanceCount *int32 `json:"targetInstanceCount,omitempty"`
	// VMGroupName - The name of the virtual machine group.
	VMGroupName *string `json:"VMGroupName,omitempty"`
	// AutoscaleConfiguration - The autoscale configurations.
	AutoscaleConfiguration *Autoscale `json:"autoscale,omitempty"`
	// HardwareProfile - The hardware profile.
	HardwareProfile *HardwareProfile `json:"hardwareProfile,omitempty"`
	// OsProfile - The operating system profile.
	OsProfile *OsProfile `json:"osProfile,omitempty"`
	// VirtualNetworkProfile - The virtual network profile.
	VirtualNetworkProfile *VirtualNetworkProfile `json:"virtualNetworkProfile,omitempty"`
	// DataDisksGroups - The data disks groups for the role.
	DataDisksGroups *[]DataDisksGroups `json:"dataDisksGroups,omitempty"`
	// ScriptActions - The list of script actions on the role.
	ScriptActions *[]ScriptAction `json:"scriptActions,omitempty"`
	// EncryptDataDisks - Indicates whether encrypt the data disks.
	EncryptDataDisks *bool `json:"encryptDataDisks,omitempty"`
}

Role describes a role on the cluster.

type RuntimeScriptAction

type RuntimeScriptAction struct {
	// Name - The name of the script action.
	Name *string `json:"name,omitempty"`
	// URI - The URI to the script.
	URI *string `json:"uri,omitempty"`
	// Parameters - The parameters for the script
	Parameters *string `json:"parameters,omitempty"`
	// Roles - The list of roles where script will be executed.
	Roles *[]string `json:"roles,omitempty"`
	// ApplicationName - READ-ONLY; The application name of the script action, if any.
	ApplicationName *string `json:"applicationName,omitempty"`
}

RuntimeScriptAction describes a script action on a running cluster.

func (RuntimeScriptAction) MarshalJSON

func (rsaVar RuntimeScriptAction) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for RuntimeScriptAction.

type RuntimeScriptActionDetail

type RuntimeScriptActionDetail struct {
	autorest.Response `json:"-"`
	// ScriptExecutionID - READ-ONLY; The execution id of the script action.
	ScriptExecutionID *int64 `json:"scriptExecutionId,omitempty"`
	// StartTime - READ-ONLY; The start time of script action execution.
	StartTime *string `json:"startTime,omitempty"`
	// EndTime - READ-ONLY; The end time of script action execution.
	EndTime *string `json:"endTime,omitempty"`
	// Status - READ-ONLY; The current execution status of the script action.
	Status *string `json:"status,omitempty"`
	// Operation - READ-ONLY; The reason why the script action was executed.
	Operation *string `json:"operation,omitempty"`
	// ExecutionSummary - READ-ONLY; The summary of script action execution result.
	ExecutionSummary *[]ScriptActionExecutionSummary `json:"executionSummary,omitempty"`
	// DebugInformation - READ-ONLY; The script action execution debug information.
	DebugInformation *string `json:"debugInformation,omitempty"`
	// Name - The name of the script action.
	Name *string `json:"name,omitempty"`
	// URI - The URI to the script.
	URI *string `json:"uri,omitempty"`
	// Parameters - The parameters for the script
	Parameters *string `json:"parameters,omitempty"`
	// Roles - The list of roles where script will be executed.
	Roles *[]string `json:"roles,omitempty"`
	// ApplicationName - READ-ONLY; The application name of the script action, if any.
	ApplicationName *string `json:"applicationName,omitempty"`
}

RuntimeScriptActionDetail the execution details of a script action.

func (RuntimeScriptActionDetail) MarshalJSON

func (rsad RuntimeScriptActionDetail) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for RuntimeScriptActionDetail.

type SSHProfile

type SSHProfile struct {
	// PublicKeys - The list of SSH public keys.
	PublicKeys *[]SSHPublicKey `json:"publicKeys,omitempty"`
}

SSHProfile the list of SSH public keys.

type SSHPublicKey

type SSHPublicKey struct {
	// CertificateData - The certificate for SSH.
	CertificateData *string `json:"certificateData,omitempty"`
}

SSHPublicKey the SSH public key for the cluster nodes.

type ScriptAction

type ScriptAction struct {
	// Name - The name of the script action.
	Name *string `json:"name,omitempty"`
	// URI - The URI to the script.
	URI *string `json:"uri,omitempty"`
	// Parameters - The parameters for the script provided.
	Parameters *string `json:"parameters,omitempty"`
}

ScriptAction describes a script action on role on the cluster.

type ScriptActionExecutionHistoryList

type ScriptActionExecutionHistoryList struct {
	autorest.Response `json:"-"`
	// Value - READ-ONLY; The list of persisted script action details for the cluster.
	Value *[]RuntimeScriptActionDetail `json:"value,omitempty"`
	// NextLink - READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty"`
}

ScriptActionExecutionHistoryList the list script execution history response.

func (ScriptActionExecutionHistoryList) IsEmpty

func (saehl ScriptActionExecutionHistoryList) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (ScriptActionExecutionHistoryList) MarshalJSON

func (saehl ScriptActionExecutionHistoryList) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ScriptActionExecutionHistoryList.

type ScriptActionExecutionHistoryListIterator

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

ScriptActionExecutionHistoryListIterator provides access to a complete listing of RuntimeScriptActionDetail values.

func NewScriptActionExecutionHistoryListIterator

func NewScriptActionExecutionHistoryListIterator(page ScriptActionExecutionHistoryListPage) ScriptActionExecutionHistoryListIterator

Creates a new instance of the ScriptActionExecutionHistoryListIterator type.

func (*ScriptActionExecutionHistoryListIterator) Next

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ScriptActionExecutionHistoryListIterator) NextWithContext

func (iter *ScriptActionExecutionHistoryListIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (ScriptActionExecutionHistoryListIterator) NotDone

NotDone returns true if the enumeration should be started or is not yet complete.

func (ScriptActionExecutionHistoryListIterator) Response

Response returns the raw server response from the last page request.

func (ScriptActionExecutionHistoryListIterator) Value

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type ScriptActionExecutionHistoryListPage

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

ScriptActionExecutionHistoryListPage contains a page of RuntimeScriptActionDetail values.

func NewScriptActionExecutionHistoryListPage

Creates a new instance of the ScriptActionExecutionHistoryListPage type.

func (*ScriptActionExecutionHistoryListPage) Next

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ScriptActionExecutionHistoryListPage) NextWithContext

func (page *ScriptActionExecutionHistoryListPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (ScriptActionExecutionHistoryListPage) NotDone

NotDone returns true if the page enumeration should be started or is not yet complete.

func (ScriptActionExecutionHistoryListPage) Response

Response returns the raw server response from the last page request.

func (ScriptActionExecutionHistoryListPage) Values

Values returns the slice of values for the current page or nil if there are no values.

type ScriptActionExecutionSummary

type ScriptActionExecutionSummary struct {
	// Status - READ-ONLY; The status of script action execution.
	Status *string `json:"status,omitempty"`
	// InstanceCount - READ-ONLY; The instance count for a given script action execution status.
	InstanceCount *int32 `json:"instanceCount,omitempty"`
}

ScriptActionExecutionSummary the execution summary of a script action.

func (ScriptActionExecutionSummary) MarshalJSON

func (saes ScriptActionExecutionSummary) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ScriptActionExecutionSummary.

type ScriptActionPersistedGetResponseSpec

type ScriptActionPersistedGetResponseSpec struct {
	// Name - The name of script action.
	Name *string `json:"name,omitempty"`
	// URI - The URI to the script.
	URI *string `json:"uri,omitempty"`
	// Parameters - The parameters for the script provided.
	Parameters *string `json:"parameters,omitempty"`
	// Roles - The list of roles where script will be executed.
	Roles *[]string `json:"roles,omitempty"`
	// ApplicationName - The application name for the script action.
	ApplicationName *string `json:"applicationName,omitempty"`
}

ScriptActionPersistedGetResponseSpec the persisted script action for cluster.

type ScriptActionsClient

type ScriptActionsClient struct {
	BaseClient
}

ScriptActionsClient is the hDInsight Management Client

func NewScriptActionsClient

func NewScriptActionsClient(subscriptionID string) ScriptActionsClient

NewScriptActionsClient creates an instance of the ScriptActionsClient client.

func NewScriptActionsClientWithBaseURI

func NewScriptActionsClientWithBaseURI(baseURI string, subscriptionID string) ScriptActionsClient

NewScriptActionsClientWithBaseURI creates an instance of the ScriptActionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ScriptActionsClient) Delete

func (client ScriptActionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, scriptName string) (result autorest.Response, err error)

Delete deletes a specified persisted script action of the cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. scriptName - the name of the script.

func (ScriptActionsClient) DeletePreparer

func (client ScriptActionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, scriptName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ScriptActionsClient) DeleteResponder

func (client ScriptActionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (ScriptActionsClient) DeleteSender

func (client ScriptActionsClient) DeleteSender(req *http.Request) (*http.Response, error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ScriptActionsClient) GetExecutionAsyncOperationStatus

func (client ScriptActionsClient) GetExecutionAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, operationID string) (result AsyncOperationResult, err error)

GetExecutionAsyncOperationStatus gets the async operation status of execution operation. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. operationID - the long running operation id.

func (ScriptActionsClient) GetExecutionAsyncOperationStatusPreparer

func (client ScriptActionsClient) GetExecutionAsyncOperationStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string, operationID string) (*http.Request, error)

GetExecutionAsyncOperationStatusPreparer prepares the GetExecutionAsyncOperationStatus request.

func (ScriptActionsClient) GetExecutionAsyncOperationStatusResponder

func (client ScriptActionsClient) GetExecutionAsyncOperationStatusResponder(resp *http.Response) (result AsyncOperationResult, err error)

GetExecutionAsyncOperationStatusResponder handles the response to the GetExecutionAsyncOperationStatus request. The method always closes the http.Response Body.

func (ScriptActionsClient) GetExecutionAsyncOperationStatusSender

func (client ScriptActionsClient) GetExecutionAsyncOperationStatusSender(req *http.Request) (*http.Response, error)

GetExecutionAsyncOperationStatusSender sends the GetExecutionAsyncOperationStatus request. The method will close the http.Response Body if it receives an error.

func (ScriptActionsClient) GetExecutionDetail

func (client ScriptActionsClient) GetExecutionDetail(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string) (result RuntimeScriptActionDetail, err error)

GetExecutionDetail gets the script execution detail for the given script execution ID. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. scriptExecutionID - the script execution Id

func (ScriptActionsClient) GetExecutionDetailPreparer

func (client ScriptActionsClient) GetExecutionDetailPreparer(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string) (*http.Request, error)

GetExecutionDetailPreparer prepares the GetExecutionDetail request.

func (ScriptActionsClient) GetExecutionDetailResponder

func (client ScriptActionsClient) GetExecutionDetailResponder(resp *http.Response) (result RuntimeScriptActionDetail, err error)

GetExecutionDetailResponder handles the response to the GetExecutionDetail request. The method always closes the http.Response Body.

func (ScriptActionsClient) GetExecutionDetailSender

func (client ScriptActionsClient) GetExecutionDetailSender(req *http.Request) (*http.Response, error)

GetExecutionDetailSender sends the GetExecutionDetail request. The method will close the http.Response Body if it receives an error.

func (ScriptActionsClient) ListByCluster

func (client ScriptActionsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionsListPage, err error)

ListByCluster lists all the persisted script actions for the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ScriptActionsClient) ListByClusterComplete

func (client ScriptActionsClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionsListIterator, err error)

ListByClusterComplete enumerates all values, automatically crossing page boundaries as required.

func (ScriptActionsClient) ListByClusterPreparer

func (client ScriptActionsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListByClusterPreparer prepares the ListByCluster request.

func (ScriptActionsClient) ListByClusterResponder

func (client ScriptActionsClient) ListByClusterResponder(resp *http.Response) (result ScriptActionsList, err error)

ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.

func (ScriptActionsClient) ListByClusterSender

func (client ScriptActionsClient) ListByClusterSender(req *http.Request) (*http.Response, error)

ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.

type ScriptActionsList

type ScriptActionsList struct {
	autorest.Response `json:"-"`
	// Value - The list of persisted script action details for the cluster.
	Value *[]RuntimeScriptActionDetail `json:"value,omitempty"`
	// NextLink - READ-ONLY; The link (url) to the next page of results.
	NextLink *string `json:"nextLink,omitempty"`
}

ScriptActionsList the persisted script action for the cluster.

func (ScriptActionsList) IsEmpty

func (sal ScriptActionsList) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (ScriptActionsList) MarshalJSON

func (sal ScriptActionsList) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ScriptActionsList.

type ScriptActionsListIterator

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

ScriptActionsListIterator provides access to a complete listing of RuntimeScriptActionDetail values.

func NewScriptActionsListIterator

func NewScriptActionsListIterator(page ScriptActionsListPage) ScriptActionsListIterator

Creates a new instance of the ScriptActionsListIterator type.

func (*ScriptActionsListIterator) Next

func (iter *ScriptActionsListIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ScriptActionsListIterator) NextWithContext

func (iter *ScriptActionsListIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (ScriptActionsListIterator) NotDone

func (iter ScriptActionsListIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (ScriptActionsListIterator) Response

Response returns the raw server response from the last page request.

func (ScriptActionsListIterator) Value

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type ScriptActionsListPage

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

ScriptActionsListPage contains a page of RuntimeScriptActionDetail values.

func NewScriptActionsListPage

func NewScriptActionsListPage(cur ScriptActionsList, getNextPage func(context.Context, ScriptActionsList) (ScriptActionsList, error)) ScriptActionsListPage

Creates a new instance of the ScriptActionsListPage type.

func (*ScriptActionsListPage) Next

func (page *ScriptActionsListPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*ScriptActionsListPage) NextWithContext

func (page *ScriptActionsListPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (ScriptActionsListPage) NotDone

func (page ScriptActionsListPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (ScriptActionsListPage) Response

func (page ScriptActionsListPage) Response() ScriptActionsList

Response returns the raw server response from the last page request.

func (ScriptActionsListPage) Values

Values returns the slice of values for the current page or nil if there are no values.

type ScriptExecutionHistoryClient

type ScriptExecutionHistoryClient struct {
	BaseClient
}

ScriptExecutionHistoryClient is the hDInsight Management Client

func NewScriptExecutionHistoryClient

func NewScriptExecutionHistoryClient(subscriptionID string) ScriptExecutionHistoryClient

NewScriptExecutionHistoryClient creates an instance of the ScriptExecutionHistoryClient client.

func NewScriptExecutionHistoryClientWithBaseURI

func NewScriptExecutionHistoryClientWithBaseURI(baseURI string, subscriptionID string) ScriptExecutionHistoryClient

NewScriptExecutionHistoryClientWithBaseURI creates an instance of the ScriptExecutionHistoryClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ScriptExecutionHistoryClient) ListByCluster

func (client ScriptExecutionHistoryClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionExecutionHistoryListPage, err error)

ListByCluster lists all scripts' execution history for the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (ScriptExecutionHistoryClient) ListByClusterComplete

func (client ScriptExecutionHistoryClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionExecutionHistoryListIterator, err error)

ListByClusterComplete enumerates all values, automatically crossing page boundaries as required.

func (ScriptExecutionHistoryClient) ListByClusterPreparer

func (client ScriptExecutionHistoryClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListByClusterPreparer prepares the ListByCluster request.

func (ScriptExecutionHistoryClient) ListByClusterResponder

func (client ScriptExecutionHistoryClient) ListByClusterResponder(resp *http.Response) (result ScriptActionExecutionHistoryList, err error)

ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.

func (ScriptExecutionHistoryClient) ListByClusterSender

func (client ScriptExecutionHistoryClient) ListByClusterSender(req *http.Request) (*http.Response, error)

ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.

func (ScriptExecutionHistoryClient) Promote

func (client ScriptExecutionHistoryClient) Promote(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string) (result autorest.Response, err error)

Promote promotes the specified ad-hoc script execution to a persisted script. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. scriptExecutionID - the script execution Id

func (ScriptExecutionHistoryClient) PromotePreparer

func (client ScriptExecutionHistoryClient) PromotePreparer(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string) (*http.Request, error)

PromotePreparer prepares the Promote request.

func (ScriptExecutionHistoryClient) PromoteResponder

func (client ScriptExecutionHistoryClient) PromoteResponder(resp *http.Response) (result autorest.Response, err error)

PromoteResponder handles the response to the Promote request. The method always closes the http.Response Body.

func (ScriptExecutionHistoryClient) PromoteSender

func (client ScriptExecutionHistoryClient) PromoteSender(req *http.Request) (*http.Response, error)

PromoteSender sends the Promote request. The method will close the http.Response Body if it receives an error.

type SecurityProfile

type SecurityProfile struct {
	// DirectoryType - The directory type. Possible values include: 'DirectoryTypeActiveDirectory'
	DirectoryType DirectoryType `json:"directoryType,omitempty"`
	// Domain - The organization's active directory domain.
	Domain *string `json:"domain,omitempty"`
	// OrganizationalUnitDN - The organizational unit within the Active Directory to place the cluster and service accounts.
	OrganizationalUnitDN *string `json:"organizationalUnitDN,omitempty"`
	// LdapsUrls - The LDAPS protocol URLs to communicate with the Active Directory.
	LdapsUrls *[]string `json:"ldapsUrls,omitempty"`
	// DomainUsername - The domain user account that will have admin privileges on the cluster.
	DomainUsername *string `json:"domainUsername,omitempty"`
	// DomainUserPassword - The domain admin password.
	DomainUserPassword *string `json:"domainUserPassword,omitempty"`
	// ClusterUsersGroupDNS - Optional. The Distinguished Names for cluster user groups
	ClusterUsersGroupDNS *[]string `json:"clusterUsersGroupDNs,omitempty"`
	// AaddsResourceID - The resource ID of the user's Azure Active Directory Domain Service.
	AaddsResourceID *string `json:"aaddsResourceId,omitempty"`
	// MsiResourceID - User assigned identity that has permissions to read and create cluster-related artifacts in the user's AADDS.
	MsiResourceID *string `json:"msiResourceId,omitempty"`
}

SecurityProfile the security profile which contains Ssh public key for the HDInsight cluster.

type ServiceSpecification

type ServiceSpecification struct {
	// MetricSpecifications - The metric specifications.
	MetricSpecifications *[]MetricSpecifications `json:"metricSpecifications,omitempty"`
}

ServiceSpecification the specification of the service.

type SetString

type SetString struct {
	autorest.Response `json:"-"`
	Value             map[string]*string `json:"value"`
}

SetString ...

func (SetString) MarshalJSON

func (ss SetString) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SetString.

type StorageAccount

type StorageAccount struct {
	// Name - The name of the storage account.
	Name *string `json:"name,omitempty"`
	// IsDefault - Whether or not the storage account is the default storage account.
	IsDefault *bool `json:"isDefault,omitempty"`
	// Container - The container in the storage account, only to be specified for WASB storage accounts.
	Container *string `json:"container,omitempty"`
	// FileSystem - The filesystem, only to be specified for Azure Data Lake Storage Gen 2.
	FileSystem *string `json:"fileSystem,omitempty"`
	// Key - The storage account access key.
	Key *string `json:"key,omitempty"`
	// ResourceID - The resource ID of storage account, only to be specified for Azure Data Lake Storage Gen 2.
	ResourceID *string `json:"resourceId,omitempty"`
	// MsiResourceID - 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"`
	// Saskey - The shared access signature key.
	Saskey *string `json:"saskey,omitempty"`
	// Fileshare - The file share name.
	Fileshare *string `json:"fileshare,omitempty"`
}

StorageAccount the storage Account.

type StorageProfile

type StorageProfile struct {
	// Storageaccounts - The list of storage accounts in the cluster.
	Storageaccounts *[]StorageAccount `json:"storageaccounts,omitempty"`
}

StorageProfile the storage profile.

type SystemData

type SystemData struct {
	// CreatedBy - The identity that created the resource.
	CreatedBy *string `json:"createdBy,omitempty"`
	// CreatedByType - The type of identity that created the resource. Possible values include: 'CreatedByTypeUser', 'CreatedByTypeApplication', 'CreatedByTypeManagedIdentity', 'CreatedByTypeKey'
	CreatedByType CreatedByType `json:"createdByType,omitempty"`
	// CreatedAt - The timestamp of resource creation (UTC).
	CreatedAt *date.Time `json:"createdAt,omitempty"`
	// LastModifiedBy - The identity that last modified the resource.
	LastModifiedBy *string `json:"lastModifiedBy,omitempty"`
	// LastModifiedByType - The type of identity that last modified the resource. Possible values include: 'CreatedByTypeUser', 'CreatedByTypeApplication', 'CreatedByTypeManagedIdentity', 'CreatedByTypeKey'
	LastModifiedByType CreatedByType `json:"lastModifiedByType,omitempty"`
	// LastModifiedAt - The timestamp of resource last modification (UTC)
	LastModifiedAt *date.Time `json:"lastModifiedAt,omitempty"`
}

SystemData metadata pertaining to creation and last modification of the resource.

type Tier

type Tier string

Tier enumerates the values for tier.

const (
	// TierPremium ...
	TierPremium Tier = "Premium"
	// TierStandard ...
	TierStandard Tier = "Standard"
)

func PossibleTierValues

func PossibleTierValues() []Tier

PossibleTierValues returns an array of possible values for the Tier const type.

type TrackedResource

type TrackedResource struct {
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - The geo-location where the resource lives
	Location *string `json:"location,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

TrackedResource the resource model definition for an Azure Resource Manager tracked top level resource which has 'tags' and a 'location'

func (TrackedResource) MarshalJSON

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

MarshalJSON is the custom marshaler for TrackedResource.

type UpdateClusterIdentityCertificateParameters

type UpdateClusterIdentityCertificateParameters struct {
	// ApplicationID - The application id.
	ApplicationID *string `json:"applicationId,omitempty"`
	// Certificate - The certificate in base64 encoded format.
	Certificate *string `json:"certificate,omitempty"`
	// CertificatePassword - The password of the certificate.
	CertificatePassword *string `json:"certificatePassword,omitempty"`
}

UpdateClusterIdentityCertificateParameters the update cluster identity certificate request parameters.

type UpdateGatewaySettingsParameters

type UpdateGatewaySettingsParameters struct {
	// IsCredentialEnabled - Indicates whether or not the gateway settings based authorization is enabled.
	IsCredentialEnabled *bool `json:"restAuthCredential.isEnabled,omitempty"`
	// UserName - The gateway settings user name.
	UserName *string `json:"restAuthCredential.username,omitempty"`
	// Password - The gateway settings user password.
	Password *string `json:"restAuthCredential.password,omitempty"`
}

UpdateGatewaySettingsParameters the update gateway settings request parameters.

type Usage

type Usage struct {
	// Unit - The type of measurement for usage.
	Unit *string `json:"unit,omitempty"`
	// CurrentValue - The current usage.
	CurrentValue *int64 `json:"currentValue,omitempty"`
	// Limit - The maximum allowed usage.
	Limit *int64 `json:"limit,omitempty"`
	// Name - The details about the localizable name of the used resource.
	Name *LocalizedName `json:"name,omitempty"`
}

Usage the details about the usage of a particular limited resource.

type UsagesListResult

type UsagesListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of usages.
	Value *[]Usage `json:"value,omitempty"`
}

UsagesListResult the response for the operation to get regional usages for a subscription.

type UserAssignedIdentity

type UserAssignedIdentity struct {
	// PrincipalID - READ-ONLY; The principal id of user assigned identity.
	PrincipalID *string `json:"principalId,omitempty"`
	// ClientID - READ-ONLY; The client id of user assigned identity.
	ClientID *string `json:"clientId,omitempty"`
	// TenantID - The tenant id of user assigned identity.
	TenantID *string `json:"tenantId,omitempty"`
}

UserAssignedIdentity the User Assigned Identity

func (UserAssignedIdentity) MarshalJSON

func (uai UserAssignedIdentity) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for UserAssignedIdentity.

type VMSizeCompatibilityFilterV2

type VMSizeCompatibilityFilterV2 struct {
	// FilterMode - The filtering mode. Effectively this can enabling or disabling the VM sizes in a particular set. Possible values include: 'FilterModeExclude', 'FilterModeInclude', 'FilterModeRecommend', 'FilterModeDefault'
	FilterMode FilterMode `json:"filterMode,omitempty"`
	// Regions - The list of regions under the effect of the filter.
	Regions *[]string `json:"regions,omitempty"`
	// ClusterFlavors - The list of cluster flavors under the effect of the filter.
	ClusterFlavors *[]string `json:"clusterFlavors,omitempty"`
	// NodeTypes - The list of node types affected by the filter.
	NodeTypes *[]string `json:"nodeTypes,omitempty"`
	// ClusterVersions - The list of cluster versions affected in Major.Minor format.
	ClusterVersions *[]string `json:"clusterVersions,omitempty"`
	// OsType - The OSType affected, Windows or Linux.
	OsType *[]OSType `json:"osType,omitempty"`
	// VMSizes - The list of virtual machine sizes to include or exclude.
	VMSizes *[]string `json:"vmSizes,omitempty"`
	// EspApplied - 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"`
	// ComputeIsolationSupported - Whether support compute isolation. 'true' means only for ComputeIsolationEnabled, 'false' means only for regular cluster.
	ComputeIsolationSupported *string `json:"computeIsolationSupported,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.

type VMSizeProperty

type VMSizeProperty struct {
	// Name - The vm size name.
	Name *string `json:"name,omitempty"`
	// Cores - The number of cores that the vm size has.
	Cores *int32 `json:"cores,omitempty"`
	// DataDiskStorageTier - The data disk storage tier of the vm size.
	DataDiskStorageTier *string `json:"dataDiskStorageTier,omitempty"`
	// Label - The label of the vm size.
	Label *string `json:"label,omitempty"`
	// MaxDataDiskCount - The max data disk count of the vm size.
	MaxDataDiskCount *int64 `json:"maxDataDiskCount,omitempty"`
	// MemoryInMb - The memory whose unit is MB of the vm size.
	MemoryInMb *int64 `json:"memoryInMb,omitempty"`
	// SupportedByVirtualMachines - This indicates this vm size is supported by virtual machines or not
	SupportedByVirtualMachines *bool `json:"supportedByVirtualMachines,omitempty"`
	// SupportedByWebWorkerRoles - The indicates this vm size is supported by web worker roles or not
	SupportedByWebWorkerRoles *bool `json:"supportedByWebWorkerRoles,omitempty"`
	// VirtualMachineResourceDiskSizeInMb - The virtual machine resource disk size whose unit is MB of the vm size.
	VirtualMachineResourceDiskSizeInMb *int64 `json:"virtualMachineResourceDiskSizeInMb,omitempty"`
	// WebWorkerResourceDiskSizeInMb - 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 {
	// Code - The error code.
	Code *string `json:"code,omitempty"`
	// Message - The error message.
	Message *string `json:"message,omitempty"`
	// ErrorResource - The error resource.
	ErrorResource *string `json:"errorResource,omitempty"`
	// MessageArguments - The message arguments
	MessageArguments *[]string `json:"messageArguments,omitempty"`
}

ValidationErrorInfo the validation error information.

type VersionSpec

type VersionSpec struct {
	// FriendlyName - The friendly name
	FriendlyName *string `json:"friendlyName,omitempty"`
	// DisplayName - The display name
	DisplayName *string `json:"displayName,omitempty"`
	// IsDefault - Whether or not the version is the default version.
	IsDefault *bool `json:"isDefault,omitempty"`
	// ComponentVersions - The component version property.
	ComponentVersions map[string]*string `json:"componentVersions"`
}

VersionSpec the version properties.

func (VersionSpec) MarshalJSON

func (vs VersionSpec) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for VersionSpec.

type VersionsCapability

type VersionsCapability struct {
	// Available - The list of version capabilities.
	Available *[]VersionSpec `json:"available,omitempty"`
}

VersionsCapability the version capability.

type VirtualMachinesClient

type VirtualMachinesClient struct {
	BaseClient
}

VirtualMachinesClient is the hDInsight Management Client

func NewVirtualMachinesClient

func NewVirtualMachinesClient(subscriptionID string) VirtualMachinesClient

NewVirtualMachinesClient creates an instance of the VirtualMachinesClient client.

func NewVirtualMachinesClientWithBaseURI

func NewVirtualMachinesClientWithBaseURI(baseURI string, subscriptionID string) VirtualMachinesClient

NewVirtualMachinesClientWithBaseURI creates an instance of the VirtualMachinesClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (VirtualMachinesClient) GetAsyncOperationStatus

func (client VirtualMachinesClient) GetAsyncOperationStatus(ctx context.Context, resourceGroupName string, clusterName string, operationID string) (result AsyncOperationResult, err error)

GetAsyncOperationStatus gets the async operation status. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. operationID - the long running operation id.

func (VirtualMachinesClient) GetAsyncOperationStatusPreparer

func (client VirtualMachinesClient) GetAsyncOperationStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string, operationID string) (*http.Request, error)

GetAsyncOperationStatusPreparer prepares the GetAsyncOperationStatus request.

func (VirtualMachinesClient) GetAsyncOperationStatusResponder

func (client VirtualMachinesClient) GetAsyncOperationStatusResponder(resp *http.Response) (result AsyncOperationResult, err error)

GetAsyncOperationStatusResponder handles the response to the GetAsyncOperationStatus request. The method always closes the http.Response Body.

func (VirtualMachinesClient) GetAsyncOperationStatusSender

func (client VirtualMachinesClient) GetAsyncOperationStatusSender(req *http.Request) (*http.Response, error)

GetAsyncOperationStatusSender sends the GetAsyncOperationStatus request. The method will close the http.Response Body if it receives an error.

func (VirtualMachinesClient) ListHosts

func (client VirtualMachinesClient) ListHosts(ctx context.Context, resourceGroupName string, clusterName string) (result ListHostInfo, err error)

ListHosts lists the HDInsight clusters hosts Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.

func (VirtualMachinesClient) ListHostsPreparer

func (client VirtualMachinesClient) ListHostsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListHostsPreparer prepares the ListHosts request.

func (VirtualMachinesClient) ListHostsResponder

func (client VirtualMachinesClient) ListHostsResponder(resp *http.Response) (result ListHostInfo, err error)

ListHostsResponder handles the response to the ListHosts request. The method always closes the http.Response Body.

func (VirtualMachinesClient) ListHostsSender

func (client VirtualMachinesClient) ListHostsSender(req *http.Request) (*http.Response, error)

ListHostsSender sends the ListHosts request. The method will close the http.Response Body if it receives an error.

func (VirtualMachinesClient) RestartHosts

func (client VirtualMachinesClient) RestartHosts(ctx context.Context, resourceGroupName string, clusterName string, hosts []string) (result VirtualMachinesRestartHostsFuture, err error)

RestartHosts restarts the specified HDInsight cluster hosts. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. hosts - the list of hosts to restart

func (VirtualMachinesClient) RestartHostsPreparer

func (client VirtualMachinesClient) RestartHostsPreparer(ctx context.Context, resourceGroupName string, clusterName string, hosts []string) (*http.Request, error)

RestartHostsPreparer prepares the RestartHosts request.

func (VirtualMachinesClient) RestartHostsResponder

func (client VirtualMachinesClient) RestartHostsResponder(resp *http.Response) (result autorest.Response, err error)

RestartHostsResponder handles the response to the RestartHosts request. The method always closes the http.Response Body.

func (VirtualMachinesClient) RestartHostsSender

func (client VirtualMachinesClient) RestartHostsSender(req *http.Request) (future VirtualMachinesRestartHostsFuture, err error)

RestartHostsSender sends the RestartHosts request. The method will close the http.Response Body if it receives an error.

type VirtualMachinesRestartHostsFuture

type VirtualMachinesRestartHostsFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(VirtualMachinesClient) (autorest.Response, error)
}

VirtualMachinesRestartHostsFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*VirtualMachinesRestartHostsFuture) UnmarshalJSON

func (future *VirtualMachinesRestartHostsFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type VirtualNetworkProfile

type VirtualNetworkProfile struct {
	// ID - The ID of the virtual network.
	ID *string `json:"id,omitempty"`
	// Subnet - The name of the subnet.
	Subnet *string `json:"subnet,omitempty"`
}

VirtualNetworkProfile the virtual network properties.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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