hdinsight

package
v11.2.2-beta+incompatible Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2017 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package hdinsight implements the Azure ARM Hdinsight service API version 2015-03-01-preview.

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 Application 

type Application struct {
	autorest.Response `json:"-"`
	ID                *string                   `json:"id,omitempty"`
	Name              *string                   `json:"name,omitempty"`
	Type              *string                   `json:"type,omitempty"`
	Etag              *string                   `json:"etag,omitempty"`
	Tags              *map[string]*string       `json:"tags,omitempty"`
	Properties        *ApplicationGetProperties `json:"properties,omitempty"`
}

Application is the HDInsight cluster application

type ApplicationGetEndpoint 

type ApplicationGetEndpoint struct {
	Location        *string `json:"location,omitempty"`
	DestinationPort *int32  `json:"destinationPort,omitempty"`
	PublicPort      *int32  `json:"publicPort,omitempty"`
}

ApplicationGetEndpoint is gets the application SSH endpoint

type ApplicationGetHTTPSEndpoint 

type ApplicationGetHTTPSEndpoint struct {
	AdditionalProperties *map[string]*string `json:",omitempty"`
	AccessModes          *[]string           `json:"accessModes,omitempty"`
	Location             *string             `json:"location,omitempty"`
	DestinationPort      *int32              `json:"destinationPort,omitempty"`
	PublicPort           *int32              `json:"publicPort,omitempty"`
}

ApplicationGetHTTPSEndpoint is gets the application HTTP endpoints.

type ApplicationGetProperties 

type ApplicationGetProperties struct {
	ComputeProfile         *ComputeProfile                `json:"computeProfile,omitempty"`
	InstallScriptActions   *[]RuntimeScriptAction         `json:"installScriptActions,omitempty"`
	UninstallScriptActions *[]RuntimeScriptAction         `json:"uninstallScriptActions,omitempty"`
	HTTPSEndpoints         *[]ApplicationGetHTTPSEndpoint `json:"httpsEndpoints,omitempty"`
	SSHEndpoints           *[]ApplicationGetEndpoint      `json:"sshEndpoints,omitempty"`
	ProvisioningState      *string                        `json:"provisioningState,omitempty"`
	ApplicationType        *string                        `json:"applicationType,omitempty"`
	ApplicationState       *string                        `json:"applicationState,omitempty"`
	Errors                 *[]Errors                      `json:"errors,omitempty"`
	CreatedDate            *string                        `json:"createdDate,omitempty"`
	MarketplaceIdentifier  *string                        `json:"marketplaceIdentifier,omitempty"`
	AdditionalProperties   *string                        `json:"additionalProperties,omitempty"`
}

ApplicationGetProperties is the HDInsight cluster application GET response.

type ApplicationListResult 

type ApplicationListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Application `json:"value,omitempty"`
	NextLink          *string        `json:"nextLink,omitempty"`
}

ApplicationListResult is 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) ApplicationListResultPreparer 

func (client ApplicationListResult) ApplicationListResultPreparer() (*http.Request, error)

ApplicationListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type ApplicationsClient 

type ApplicationsClient struct {
	ManagementClient
}

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.

func (ApplicationsClient) Create 

func (client ApplicationsClient) Create(resourceGroupName string, clusterName string, applicationName string, parameters ApplicationGetProperties) (result Application, err error)

Create creates applications for the HDInsight cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. applicationName is the constant value for the application name. parameters is the application create request.

func (ApplicationsClient) CreatePreparer 

func (client ApplicationsClient) CreatePreparer(resourceGroupName string, clusterName string, applicationName string, parameters ApplicationGetProperties) (*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) (*http.Response, 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(resourceGroupName string, clusterName string, applicationName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

Delete deletes the specified application on the HDInsight cluster. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. applicationName is the constant value for the application name.

func (ApplicationsClient) DeletePreparer 

func (client ApplicationsClient) DeletePreparer(resourceGroupName string, clusterName string, applicationName string, cancel <-chan struct{}) (*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) (*http.Response, 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(resourceGroupName string, clusterName string, applicationName string) (result Application, err error)

Get lists properties of the specified application.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. applicationName is the constant value for the application name.

func (ApplicationsClient) GetPreparer 

func (client ApplicationsClient) GetPreparer(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) List 

func (client ApplicationsClient) List(resourceGroupName string, clusterName string) (result ApplicationListResult, err error)

List lists all of the applications HDInsight cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster.

func (ApplicationsClient) ListComplete 

func (client ApplicationsClient) ListComplete(resourceGroupName string, clusterName string, cancel <-chan struct{}) (<-chan Application, <-chan error)

ListComplete gets all elements from the list without paging.

func (ApplicationsClient) ListNextResults 

func (client ApplicationsClient) ListNextResults(lastResults ApplicationListResult) (result ApplicationListResult, err error)

ListNextResults retrieves the next set of results, if any.

func (ApplicationsClient) ListPreparer 

func (client ApplicationsClient) ListPreparer(resourceGroupName string, clusterName string) (*http.Request, error)

ListPreparer prepares the List request.

func (ApplicationsClient) ListResponder 

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

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

func (ApplicationsClient) ListSender 

func (client ApplicationsClient) 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 AsyncOperationState 

type AsyncOperationState string

AsyncOperationState enumerates the values for async operation state. 

const (
	// Failed specifies the failed state for async operation state.
	Failed AsyncOperationState = "Failed"
	// InProgress specifies the in progress state for async operation state.
	InProgress AsyncOperationState = "InProgress"
	// Succeeded specifies the succeeded state for async operation state.
	Succeeded AsyncOperationState = "Succeeded"
)

type CapabilitiesResult 

type CapabilitiesResult struct {
	autorest.Response `json:"-"`
	Versions          *map[string]*VersionsCapability `json:"versions,omitempty"`
	Regions           *map[string]*RegionsCapability  `json:"regions,omitempty"`
	VMSizes           *map[string]*VMSizesCapability  `json:"vmSizes,omitempty"`
	VMSizeFilters     *[]VMSizeCompatibilityFilter    `json:"vmSize_filters,omitempty"`
	Features          *[]string                       `json:"features,omitempty"`
	Quota             *QuotaCapability                `json:"quota,omitempty"`
}

CapabilitiesResult is the Get Capabilities operation response.

type Cluster 

type Cluster struct {
	autorest.Response `json:"-"`
	ID                *string               `json:"id,omitempty"`
	Name              *string               `json:"name,omitempty"`
	Type              *string               `json:"type,omitempty"`
	Location          *string               `json:"location,omitempty"`
	Tags              *map[string]*string   `json:"tags,omitempty"`
	Etag              *string               `json:"etag,omitempty"`
	Properties        *ClusterGetProperties `json:"properties,omitempty"`
}

Cluster is the HDInsight cluster.

type ClusterCreateParametersExtended 

type ClusterCreateParametersExtended struct {
	Location   *string                  `json:"location,omitempty"`
	Tags       *map[string]*string      `json:"tags,omitempty"`
	Properties *ClusterCreateProperties `json:"properties,omitempty"`
}

ClusterCreateParametersExtended is the CreateCluster request parameters.

type ClusterCreateProperties 

type ClusterCreateProperties struct {
	ClusterVersion    *string            `json:"clusterVersion,omitempty"`
	OsType            OSType             `json:"osType,omitempty"`
	Tier              Tier               `json:"tier,omitempty"`
	ClusterDefinition *ClusterDefinition `json:"clusterDefinition,omitempty"`
	SecurityProfile   *SecurityProfile   `json:"securityProfile,omitempty"`
	ComputeProfile    *ComputeProfile    `json:"computeProfile,omitempty"`
	StorageProfile    *StorageProfile    `json:"storageProfile,omitempty"`
}

ClusterCreateProperties is the cluster create parameters.

type ClusterDefinition 

type ClusterDefinition struct {
	Blueprint        *string                 `json:"blueprint,omitempty"`
	Kind             *string                 `json:"kind,omitempty"`
	ComponentVersion *map[string]*string     `json:"componentVersion,omitempty"`
	Configurations   *map[string]interface{} `json:"configurations,omitempty"`
}

ClusterDefinition is the cluster definition.

type ClusterGetProperties 

type ClusterGetProperties struct {
	ClusterVersion        *string                  `json:"clusterVersion,omitempty"`
	OsType                OSType                   `json:"osType,omitempty"`
	Tier                  Tier                     `json:"tier,omitempty"`
	ClusterDefinition     *ClusterDefinition       `json:"clusterDefinition,omitempty"`
	SecurityProfile       *SecurityProfile         `json:"securityProfile,omitempty"`
	ComputeProfile        *ComputeProfile          `json:"computeProfile,omitempty"`
	ProvisioningState     ClusterProvisioningState `json:"provisioningState,omitempty"`
	CreatedDate           *string                  `json:"createdDate,omitempty"`
	ClusterState          *string                  `json:"clusterState,omitempty"`
	QuotaInfo             *QuotaInfo               `json:"quotaInfo,omitempty"`
	Errors                *[]Errors                `json:"errors,omitempty"`
	ConnectivityEndpoints *[]ConnectivityEndpoint  `json:"connectivityEndpoints,omitempty"`
}

ClusterGetProperties is the properties of cluster.

type ClusterListPersistedScriptActionsResult 

type ClusterListPersistedScriptActionsResult struct {
	Value    *[]RuntimeScriptAction `json:"value,omitempty"`
	NextLink *string                `json:"nextLink,omitempty"`
}

ClusterListPersistedScriptActionsResult is the ListPersistedScriptActions operation response.

type ClusterListResult 

type ClusterListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Cluster `json:"value,omitempty"`
	NextLink          *string    `json:"nextLink,omitempty"`
}

ClusterListResult is the List Cluster operation response.

func (ClusterListResult) ClusterListResultPreparer 

func (client ClusterListResult) ClusterListResultPreparer() (*http.Request, error)

ClusterListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type ClusterListRuntimeScriptActionDetailResult 

type ClusterListRuntimeScriptActionDetailResult struct {
	Value    *[]RuntimeScriptActionDetail `json:"value,omitempty"`
	NextLink *string                      `json:"nextLink,omitempty"`
}

ClusterListRuntimeScriptActionDetailResult is the list runtime script action detail response.

type ClusterMonitoringRequest 

type ClusterMonitoringRequest struct {
	WorkspaceID *string `json:"workspaceId,omitempty"`
	PrimaryKey  *string `json:"primaryKey,omitempty"`
}

ClusterMonitoringRequest is the Operations Management Suite (OMS) parameters.

type ClusterMonitoringResponse 

type ClusterMonitoringResponse struct {
	autorest.Response        `json:"-"`
	ClusterMonitoringEnabled *bool   `json:"ClusterMonitoringEnabled,omitempty"`
	WorkspaceID              *string `json:"WorkspaceId,omitempty"`
}

ClusterMonitoringResponse is the Operations Management Suite (OMS) status response

type ClusterPatchParameters 

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

ClusterPatchParameters is the PatchCluster request parameters

type ClusterProvisioningState 

type ClusterProvisioningState string

ClusterProvisioningState enumerates the values for cluster provisioning state. 

const (
	// ClusterProvisioningStateCanceled specifies the cluster provisioning state canceled state for cluster provisioning
	// state.
	ClusterProvisioningStateCanceled ClusterProvisioningState = "Canceled"
	// ClusterProvisioningStateDeleting specifies the cluster provisioning state deleting state for cluster provisioning
	// state.
	ClusterProvisioningStateDeleting ClusterProvisioningState = "Deleting"
	// ClusterProvisioningStateFailed specifies the cluster provisioning state failed state for cluster provisioning state.
	ClusterProvisioningStateFailed ClusterProvisioningState = "Failed"
	// ClusterProvisioningStateInProgress specifies the cluster provisioning state in progress state for cluster
	// provisioning state.
	ClusterProvisioningStateInProgress ClusterProvisioningState = "InProgress"
	// ClusterProvisioningStateSucceeded specifies the cluster provisioning state succeeded state for cluster provisioning
	// state.
	ClusterProvisioningStateSucceeded ClusterProvisioningState = "Succeeded"
)

type ClusterResizeParameters 

type ClusterResizeParameters struct {
	TargetInstanceCount *int32 `json:"targetInstanceCount,omitempty"`
}

ClusterResizeParameters is the Resize Cluster request parameters.

type ClustersClient 

type ClustersClient struct {
	ManagementClient
}

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.

func (ClustersClient) Create 

func (client ClustersClient) Create(resourceGroupName string, clusterName string, parameters ClusterCreateParametersExtended, cancel <-chan struct{}) (<-chan Cluster, <-chan error)

Create creates a new HDInsight cluster with the specified parameters. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. parameters is the cluster create request.

func (ClustersClient) CreatePreparer 

func (client ClustersClient) CreatePreparer(resourceGroupName string, clusterName string, parameters ClusterCreateParametersExtended, cancel <-chan struct{}) (*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) (*http.Response, 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(resourceGroupName string, clusterName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

Delete deletes the specified HDInsight cluster. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster.

func (ClustersClient) DeletePreparer 

func (client ClustersClient) DeletePreparer(resourceGroupName string, clusterName string, cancel <-chan struct{}) (*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) (*http.Response, 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(resourceGroupName string, clusterName string, parameters ExecuteScriptActionParameters, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

ExecuteScriptActions executes script actions on the specified HDInsight cluster. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. parameters is the parameters for executing script actions.

func (ClustersClient) ExecuteScriptActionsPreparer 

func (client ClustersClient) ExecuteScriptActionsPreparer(resourceGroupName string, clusterName string, parameters ExecuteScriptActionParameters, cancel <-chan struct{}) (*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) (*http.Response, 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(resourceGroupName string, clusterName string) (result Cluster, err error)

Get gets the specified cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster.

func (ClustersClient) GetPreparer 

func (client ClustersClient) GetPreparer(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() (result ClusterListResult, err error)

List lists all the HDInsight clusters under the subscription.

func (ClustersClient) ListByResourceGroup 

func (client ClustersClient) ListByResourceGroup(resourceGroupName string) (result ClusterListResult, err error)

ListByResourceGroup lists the HDInsight clusters in a resource group.

resourceGroupName is the name of the resource group.

func (ClustersClient) ListByResourceGroupComplete 

func (client ClustersClient) ListByResourceGroupComplete(resourceGroupName string, cancel <-chan struct{}) (<-chan Cluster, <-chan error)

ListByResourceGroupComplete gets all elements from the list without paging.

func (ClustersClient) ListByResourceGroupNextResults 

func (client ClustersClient) ListByResourceGroupNextResults(lastResults ClusterListResult) (result ClusterListResult, err error)

ListByResourceGroupNextResults retrieves the next set of results, if any.

func (ClustersClient) ListByResourceGroupPreparer 

func (client ClustersClient) ListByResourceGroupPreparer(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(cancel <-chan struct{}) (<-chan Cluster, <-chan error)

ListComplete gets all elements from the list without paging.

func (ClustersClient) ListNextResults 

func (client ClustersClient) ListNextResults(lastResults ClusterListResult) (result ClusterListResult, err error)

ListNextResults retrieves the next set of results, if any.

func (ClustersClient) ListPreparer 

func (client ClustersClient) ListPreparer() (*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(resourceGroupName string, clusterName string, roleName string, parameters ClusterResizeParameters, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

Resize resizes the specified HDInsight cluster to the specified size. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. roleName is the constant value for the roleName parameters is the parameters for the resize operation.

func (ClustersClient) ResizePreparer 

func (client ClustersClient) ResizePreparer(resourceGroupName string, clusterName string, roleName string, parameters ClusterResizeParameters, cancel <-chan struct{}) (*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) (*http.Response, error)

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

func (ClustersClient) Update 

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

Update patch HDInsight cluster with the specified parameters.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. parameters is the cluster patch request.

func (ClustersClient) UpdatePreparer 

func (client ClustersClient) UpdatePreparer(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 ComputeProfile 

type ComputeProfile struct {
	Roles *[]Role `json:"roles,omitempty"`
}

ComputeProfile is describes the compute profile.

type ConfigurationsClient 

type ConfigurationsClient struct {
	ManagementClient
}

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.

func (ConfigurationsClient) Get 

func (client ConfigurationsClient) Get(resourceGroupName string, clusterName string, configurationName string) (result SetString, err error)

Get the configuration object for the specified cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. configurationName is the constant for configuration type of gateway.

func (ConfigurationsClient) GetPreparer 

func (client ConfigurationsClient) GetPreparer(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) UpdateHTTPSettings 

func (client ConfigurationsClient) UpdateHTTPSettings(resourceGroupName string, clusterName string, configurationName string, parameters HTTPConnectivitySettings, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

UpdateHTTPSettings configures the HTTP settings on the specified cluster. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. configurationName is the constant for configuration type of gateway. parameters is the name of the resource group.

func (ConfigurationsClient) UpdateHTTPSettingsPreparer 

func (client ConfigurationsClient) UpdateHTTPSettingsPreparer(resourceGroupName string, clusterName string, configurationName string, parameters HTTPConnectivitySettings, cancel <-chan struct{}) (*http.Request, error)

UpdateHTTPSettingsPreparer prepares the UpdateHTTPSettings request.

func (ConfigurationsClient) UpdateHTTPSettingsResponder 

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

UpdateHTTPSettingsResponder handles the response to the UpdateHTTPSettings request. The method always closes the http.Response Body.

func (ConfigurationsClient) UpdateHTTPSettingsSender 

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

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

type ConnectivityEndpoint 

type ConnectivityEndpoint struct {
	Name     *string `json:"name,omitempty"`
	Protocol *string `json:"protocol,omitempty"`
	Location *string `json:"location,omitempty"`
	Port     *int32  `json:"port,omitempty"`
}

ConnectivityEndpoint is the connectivity properties

type DataDisksGroups 

type DataDisksGroups struct {
	DisksPerNode       *int32  `json:"disksPerNode,omitempty"`
	StorageAccountType *string `json:"storageAccountType,omitempty"`
	DiskSizeGB         *int32  `json:"diskSizeGB,omitempty"`
}

DataDisksGroups is the data disks groups for the role.

type DirectoryType 

type DirectoryType string

DirectoryType enumerates the values for directory type. 

const (
	// ActiveDirectory specifies the active directory state for directory type.
	ActiveDirectory DirectoryType = "ActiveDirectory"
)

type EnabledCredential 

type EnabledCredential string

EnabledCredential enumerates the values for enabled credential. 

const (
	// False specifies the false state for enabled credential.
	False EnabledCredential = "false"
	// True specifies the true state for enabled credential.
	True EnabledCredential = "true"
)

type Errors 

type Errors struct {
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
}

Errors is the error message associated with the cluster creation.

type ExecuteScriptActionParameters 

type ExecuteScriptActionParameters struct {
	ScriptActions    *[]RuntimeScriptAction `json:"scriptActions,omitempty"`
	PersistOnSuccess *bool                  `json:"persistOnSuccess,omitempty"`
}

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

type Extension 

type Extension struct {
	autorest.Response `json:"-"`
	WorkspaceID       *string `json:"workspaceId,omitempty"`
	PrimaryKey        *string `json:"primaryKey,omitempty"`
}

Extension is cluster monitoring extensions

type ExtensionClient 

type ExtensionClient struct {
	ManagementClient
}

ExtensionClient is the hDInsight Management Client

func NewExtensionClient 

func NewExtensionClient(subscriptionID string) ExtensionClient

NewExtensionClient creates an instance of the ExtensionClient client.

func NewExtensionClientWithBaseURI 

func NewExtensionClientWithBaseURI(baseURI string, subscriptionID string) ExtensionClient

NewExtensionClientWithBaseURI creates an instance of the ExtensionClient client.

func (ExtensionClient) Create 

func (client ExtensionClient) Create(resourceGroupName string, clusterName string, parameters Extension, extensionName string) (result autorest.Response, err error)

Create creates an HDInsight cluster extension.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. parameters is the cluster extensions create request. extensionName is the name of the cluster extension.

func (ExtensionClient) CreatePreparer 

func (client ExtensionClient) CreatePreparer(resourceGroupName string, clusterName string, parameters Extension, extensionName string) (*http.Request, error)

CreatePreparer prepares the Create request.

func (ExtensionClient) CreateResponder 

func (client ExtensionClient) 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 (ExtensionClient) CreateSender 

func (client ExtensionClient) CreateSender(req *http.Request) (*http.Response, error)

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

func (ExtensionClient) Delete 

func (client ExtensionClient) Delete(resourceGroupName string, clusterName string, extensionName string) (result autorest.Response, err error)

Delete deletes the specified extension for HDInsight cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. extensionName is the name of the cluster extension.

func (ExtensionClient) DeletePreparer 

func (client ExtensionClient) DeletePreparer(resourceGroupName string, clusterName string, extensionName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ExtensionClient) DeleteResponder 

func (client ExtensionClient) 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 (ExtensionClient) DeleteSender 

func (client ExtensionClient) 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 (ExtensionClient) DisableMonitoring 

func (client ExtensionClient) DisableMonitoring(resourceGroupName string, clusterName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

DisableMonitoring disables the Operations Management Suite (OMS) on the HDInsight cluster. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster.

func (ExtensionClient) DisableMonitoringPreparer 

func (client ExtensionClient) DisableMonitoringPreparer(resourceGroupName string, clusterName string, cancel <-chan struct{}) (*http.Request, error)

DisableMonitoringPreparer prepares the DisableMonitoring request.

func (ExtensionClient) DisableMonitoringResponder 

func (client ExtensionClient) 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 (ExtensionClient) DisableMonitoringSender 

func (client ExtensionClient) DisableMonitoringSender(req *http.Request) (*http.Response, error)

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

func (ExtensionClient) EnableMonitoring 

func (client ExtensionClient) EnableMonitoring(resourceGroupName string, clusterName string, parameters ClusterMonitoringRequest, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

EnableMonitoring enables the Operations Management Suite (OMS) on the HDInsight cluster. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. parameters is the Operations Management Suite (OMS) workspace parameters.

func (ExtensionClient) EnableMonitoringPreparer 

func (client ExtensionClient) EnableMonitoringPreparer(resourceGroupName string, clusterName string, parameters ClusterMonitoringRequest, cancel <-chan struct{}) (*http.Request, error)

EnableMonitoringPreparer prepares the EnableMonitoring request.

func (ExtensionClient) EnableMonitoringResponder 

func (client ExtensionClient) 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 (ExtensionClient) EnableMonitoringSender 

func (client ExtensionClient) EnableMonitoringSender(req *http.Request) (*http.Response, error)

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

func (ExtensionClient) Get 

func (client ExtensionClient) Get(resourceGroupName string, clusterName string, extensionName string) (result Extension, err error)

Get gets the extension properties for the specified HDInsight cluster extension.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. extensionName is the name of the cluster extension.

func (ExtensionClient) GetMonitoringStatus 

func (client ExtensionClient) GetMonitoringStatus(resourceGroupName string, clusterName string) (result ClusterMonitoringResponse, err error)

GetMonitoringStatus gets the status of Operations Management Suite (OMS) on the HDInsight cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster.

func (ExtensionClient) GetMonitoringStatusPreparer 

func (client ExtensionClient) GetMonitoringStatusPreparer(resourceGroupName string, clusterName string) (*http.Request, error)

GetMonitoringStatusPreparer prepares the GetMonitoringStatus request.

func (ExtensionClient) GetMonitoringStatusResponder 

func (client ExtensionClient) 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 (ExtensionClient) GetMonitoringStatusSender 

func (client ExtensionClient) 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 (ExtensionClient) GetPreparer 

func (client ExtensionClient) GetPreparer(resourceGroupName string, clusterName string, extensionName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ExtensionClient) GetResponder 

func (client ExtensionClient) GetResponder(resp *http.Response) (result Extension, err error)

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

func (ExtensionClient) GetSender 

func (client ExtensionClient) 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 HTTPConnectivitySettings 

type HTTPConnectivitySettings struct {
	EnabledCredential EnabledCredential `json:"restAuthCredential.isEnabled,omitempty"`
	Username          *string           `json:"restAuthCredential.username,omitempty"`
	Password          *string           `json:"restAuthCredential.password,omitempty"`
}

HTTPConnectivitySettings is the payload for a Configure HTTP settings request.

type HardwareProfile 

type HardwareProfile struct {
	VMSize *string `json:"vmSize,omitempty"`
}

HardwareProfile is the hardware profile.

type LinuxOperatingSystemProfile 

type LinuxOperatingSystemProfile struct {
	Username   *string     `json:"username,omitempty"`
	Password   *string     `json:"password,omitempty"`
	SSHProfile *SSHProfile `json:"sshProfile,omitempty"`
}

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

type LocationClient 

type LocationClient struct {
	ManagementClient
}

LocationClient is the hDInsight Management Client

func NewLocationClient 

func NewLocationClient(subscriptionID string) LocationClient

NewLocationClient creates an instance of the LocationClient client.

func NewLocationClientWithBaseURI 

func NewLocationClientWithBaseURI(baseURI string, subscriptionID string) LocationClient

NewLocationClientWithBaseURI creates an instance of the LocationClient client.

func (LocationClient) GetCapabilities 

func (client LocationClient) GetCapabilities(location string) (result CapabilitiesResult, err error)

GetCapabilities gets the capabilities for the specified location.

location is the location to get capabilities for.

func (LocationClient) GetCapabilitiesPreparer 

func (client LocationClient) GetCapabilitiesPreparer(location string) (*http.Request, error)

GetCapabilitiesPreparer prepares the GetCapabilities request.

func (LocationClient) GetCapabilitiesResponder 

func (client LocationClient) 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 (LocationClient) GetCapabilitiesSender 

func (client LocationClient) 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.

type ManagementClient 

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

ManagementClient is the base client for Hdinsight.

func New 

func New(subscriptionID string) ManagementClient

New creates an instance of the ManagementClient client.

func NewWithBaseURI 

func NewWithBaseURI(baseURI string, subscriptionID string) ManagementClient

NewWithBaseURI creates an instance of the ManagementClient client.

type OSType 

type OSType string

OSType enumerates the values for os type. 

const (
	// Linux specifies the linux state for os type.
	Linux OSType = "Linux"
	// Windows specifies the windows state for os type.
	Windows OSType = "Windows"
)

type Operation 

type Operation struct {
	Name    *string           `json:"name,omitempty"`
	Display *OperationDisplay `json:"display,omitempty"`
}

Operation is the HDInsight REST API operation.

type OperationDisplay 

type OperationDisplay struct {
	Provider  *string `json:"provider,omitempty"`
	Resource  *string `json:"resource,omitempty"`
	Operation *string `json:"operation,omitempty"`
}

OperationDisplay is the object that represents the operation.

type OperationListResult 

type OperationListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Operation `json:"value,omitempty"`
	NextLink          *string      `json:"nextLink,omitempty"`
}

OperationListResult is 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) OperationListResultPreparer 

func (client OperationListResult) OperationListResultPreparer() (*http.Request, error)

OperationListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type OperationResource 

type OperationResource struct {
	Status AsyncOperationState `json:"status,omitempty"`
	Error  *Errors             `json:"error,omitempty"`
}

OperationResource is the azure async operation response.

type OperationsClient 

type OperationsClient struct {
	ManagementClient
}

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.

func (OperationsClient) List 

func (client OperationsClient) List() (result OperationListResult, err error)

List lists all of the available HDInsight REST API operations.

func (OperationsClient) ListComplete 

func (client OperationsClient) ListComplete(cancel <-chan struct{}) (<-chan Operation, <-chan error)

ListComplete gets all elements from the list without paging.

func (OperationsClient) ListNextResults 

func (client OperationsClient) ListNextResults(lastResults OperationListResult) (result OperationListResult, err error)

ListNextResults retrieves the next set of results, if any.

func (OperationsClient) ListPreparer 

func (client OperationsClient) ListPreparer() (*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 *LinuxOperatingSystemProfile `json:"linuxOperatingSystemProfile,omitempty"`
}

OsProfile is the Linux operation systems profile.

type ProxyResource 

type ProxyResource struct {
	ID   *string `json:"id,omitempty"`
	Name *string `json:"name,omitempty"`
	Type *string `json:"type,omitempty"`
}

ProxyResource is the resource model definition for a ARM proxy resource. It will have everything other than required location and tags

type QuotaCapability 

type QuotaCapability struct {
	RegionalQuotas *[]RegionalQuotaCapability `json:"regionalQuotas,omitempty"`
}

QuotaCapability is the regional quota capability.

type QuotaInfo 

type QuotaInfo struct {
	CoresUsed *int32 `json:"coresUsed,omitempty"`
}

QuotaInfo is the quota properties for the cluster.

type RegionalQuotaCapability 

type RegionalQuotaCapability struct {
	RegionName     *string `json:"region_name,omitempty"`
	CoresUsed      *int64  `json:"cores_used,omitempty"`
	CoresAvailable *int64  `json:"cores_available,omitempty"`
}

RegionalQuotaCapability is the regional quota capacity.

type RegionsCapability 

type RegionsCapability struct {
	Available *[]string `json:"available,omitempty"`
}

RegionsCapability is the regions capability.

type Resource 

type Resource struct {
	ID   *string `json:"id,omitempty"`
	Name *string `json:"name,omitempty"`
	Type *string `json:"type,omitempty"`
}

Resource is the core properties of ARM resources

type Role 

type Role struct {
	Name                  *string                `json:"name,omitempty"`
	MinInstanceCount      *int32                 `json:"minInstanceCount,omitempty"`
	TargetInstanceCount   *int32                 `json:"targetInstanceCount,omitempty"`
	HardwareProfile       *HardwareProfile       `json:"hardwareProfile,omitempty"`
	OsProfile             *OsProfile             `json:"osProfile,omitempty"`
	VirtualNetworkProfile *VirtualNetworkProfile `json:"virtualNetworkProfile,omitempty"`
	DataDisksGroups       *[]DataDisksGroups     `json:"dataDisksGroups,omitempty"`
	ScriptActions         *[]ScriptAction        `json:"scriptActions,omitempty"`
}

Role is describes a role on the cluster.

type RuntimeScriptAction 

type RuntimeScriptAction struct {
	Name            *string   `json:"name,omitempty"`
	URI             *string   `json:"uri,omitempty"`
	Parameters      *string   `json:"parameters,omitempty"`
	Roles           *[]string `json:"roles,omitempty"`
	ApplicationName *string   `json:"applicationName,omitempty"`
}

RuntimeScriptAction is describes a script action on a running cluster.

type RuntimeScriptActionDetail 

type RuntimeScriptActionDetail struct {
	autorest.Response `json:"-"`
	Name              *string                         `json:"name,omitempty"`
	URI               *string                         `json:"uri,omitempty"`
	Parameters        *string                         `json:"parameters,omitempty"`
	Roles             *[]string                       `json:"roles,omitempty"`
	ApplicationName   *string                         `json:"applicationName,omitempty"`
	ScriptExecutionID *int64                          `json:"scriptExecutionId,omitempty"`
	StartTime         *string                         `json:"startTime,omitempty"`
	EndTime           *string                         `json:"endTime,omitempty"`
	Status            *string                         `json:"status,omitempty"`
	Operation         *string                         `json:"operation,omitempty"`
	ExecutionSummary  *[]ScriptActionExecutionSummary `json:"executionSummary,omitempty"`
	DebugInformation  *string                         `json:"debugInformation,omitempty"`
}

RuntimeScriptActionDetail is the execution details of a script action.

type SSHProfile 

type SSHProfile struct {
	PublicKeys *[]SSHPublicKey `json:"publicKeys,omitempty"`
}

SSHProfile is the list of SSH public keys.

type SSHPublicKey 

type SSHPublicKey struct {
	CertificateData *string `json:"certificateData,omitempty"`
}

SSHPublicKey is the SSH public key for the cluster nodes.

type ScriptAction 

type ScriptAction struct {
	Name       *string `json:"name,omitempty"`
	URI        *string `json:"uri,omitempty"`
	Parameters *string `json:"parameters,omitempty"`
}

ScriptAction is describes a script action on role on the cluster.

type ScriptActionExecutionHistoryList 

type ScriptActionExecutionHistoryList struct {
	autorest.Response `json:"-"`
	Value             *[]RuntimeScriptActionDetail `json:"value,omitempty"`
	NextLink          *string                      `json:"nextLink,omitempty"`
}

ScriptActionExecutionHistoryList is the list script execution history response.

func (ScriptActionExecutionHistoryList) ScriptActionExecutionHistoryListPreparer 

func (client ScriptActionExecutionHistoryList) ScriptActionExecutionHistoryListPreparer() (*http.Request, error)

ScriptActionExecutionHistoryListPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type ScriptActionExecutionSummary 

type ScriptActionExecutionSummary struct {
	Status        *string `json:"status,omitempty"`
	InstanceCount *int32  `json:"instanceCount,omitempty"`
}

ScriptActionExecutionSummary is the execution summary of a script action.

type ScriptActionPersistedGetResponseSpec 

type ScriptActionPersistedGetResponseSpec struct {
	Name            *string   `json:"name,omitempty"`
	URI             *string   `json:"uri,omitempty"`
	Parameters      *string   `json:"parameters,omitempty"`
	Roles           *[]string `json:"roles,omitempty"`
	ApplicationName *string   `json:"applicationName,omitempty"`
}

ScriptActionPersistedGetResponseSpec is the persisted script action for cluster.

type ScriptActionsClient 

type ScriptActionsClient struct {
	ManagementClient
}

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.

func (ScriptActionsClient) Delete 

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

Delete deletes a specified persisted script action of the cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. scriptName is the name of the script.

func (ScriptActionsClient) DeletePreparer 

func (client ScriptActionsClient) DeletePreparer(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) GetExecutionDetail 

func (client ScriptActionsClient) GetExecutionDetail(resourceGroupName string, clusterName string, scriptExecutionID string) (result RuntimeScriptActionDetail, err error)

GetExecutionDetail gets the script execution detail for the given script execution ID.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. scriptExecutionID is the script execution Id

func (ScriptActionsClient) GetExecutionDetailPreparer 

func (client ScriptActionsClient) GetExecutionDetailPreparer(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) ListPersistedScripts 

func (client ScriptActionsClient) ListPersistedScripts(resourceGroupName string, clusterName string) (result ScriptActionsList, err error)

ListPersistedScripts lists all the persisted script actions for the specified cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster.

func (ScriptActionsClient) ListPersistedScriptsComplete 

func (client ScriptActionsClient) ListPersistedScriptsComplete(resourceGroupName string, clusterName string, cancel <-chan struct{}) (<-chan RuntimeScriptActionDetail, <-chan error)

ListPersistedScriptsComplete gets all elements from the list without paging.

func (ScriptActionsClient) ListPersistedScriptsNextResults 

func (client ScriptActionsClient) ListPersistedScriptsNextResults(lastResults ScriptActionsList) (result ScriptActionsList, err error)

ListPersistedScriptsNextResults retrieves the next set of results, if any.

func (ScriptActionsClient) ListPersistedScriptsPreparer 

func (client ScriptActionsClient) ListPersistedScriptsPreparer(resourceGroupName string, clusterName string) (*http.Request, error)

ListPersistedScriptsPreparer prepares the ListPersistedScripts request.

func (ScriptActionsClient) ListPersistedScriptsResponder 

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

ListPersistedScriptsResponder handles the response to the ListPersistedScripts request. The method always closes the http.Response Body.

func (ScriptActionsClient) ListPersistedScriptsSender 

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

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

type ScriptActionsList 

type ScriptActionsList struct {
	autorest.Response `json:"-"`
	Value             *[]RuntimeScriptActionDetail `json:"value,omitempty"`
	NextLink          *string                      `json:"nextLink,omitempty"`
}

ScriptActionsList is the persisted script action for the cluster.

func (ScriptActionsList) ScriptActionsListPreparer 

func (client ScriptActionsList) ScriptActionsListPreparer() (*http.Request, error)

ScriptActionsListPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type ScriptExecutionHistoryClient 

type ScriptExecutionHistoryClient struct {
	ManagementClient
}

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.

func (ScriptExecutionHistoryClient) List 

func (client ScriptExecutionHistoryClient) List(resourceGroupName string, clusterName string) (result ScriptActionExecutionHistoryList, err error)

List lists all scripts' execution history for the specified cluster.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster.

func (ScriptExecutionHistoryClient) ListComplete 

func (client ScriptExecutionHistoryClient) ListComplete(resourceGroupName string, clusterName string, cancel <-chan struct{}) (<-chan RuntimeScriptActionDetail, <-chan error)

ListComplete gets all elements from the list without paging.

func (ScriptExecutionHistoryClient) ListNextResults 

func (client ScriptExecutionHistoryClient) ListNextResults(lastResults ScriptActionExecutionHistoryList) (result ScriptActionExecutionHistoryList, err error)

ListNextResults retrieves the next set of results, if any.

func (ScriptExecutionHistoryClient) ListPreparer 

func (client ScriptExecutionHistoryClient) ListPreparer(resourceGroupName string, clusterName string) (*http.Request, error)

ListPreparer prepares the List request.

func (ScriptExecutionHistoryClient) ListResponder 

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

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

func (ScriptExecutionHistoryClient) ListSender 

func (client ScriptExecutionHistoryClient) 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 (ScriptExecutionHistoryClient) Promote 

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

Promote promotes the specified ad-hoc script execution to a persisted script.

resourceGroupName is the name of the resource group. clusterName is the name of the cluster. scriptExecutionID is the script execution ID.

func (ScriptExecutionHistoryClient) PromotePreparer 

func (client ScriptExecutionHistoryClient) PromotePreparer(resourceGroupName string, clusterName string, scriptExecutionID int64) (*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        DirectoryType `json:"directoryType,omitempty"`
	Domain               *string       `json:"domain,omitempty"`
	OrganizationalUnitDN *string       `json:"organizationalUnitDN,omitempty"`
	LdapsUrls            *[]string     `json:"ldapsUrls,omitempty"`
	DomainUsername       *string       `json:"domainUsername,omitempty"`
	DomainUserPassword   *string       `json:"domainUserPassword,omitempty"`
	ClusterUsersGroupDNS *[]string     `json:"clusterUsersGroupDNs,omitempty"`
}

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

type SetString 

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

SetString is

type StorageAccount 

type StorageAccount struct {
	Name      *string `json:"name,omitempty"`
	IsDefault *bool   `json:"isDefault,omitempty"`
	Container *string `json:"container,omitempty"`
	Key       *string `json:"key,omitempty"`
}

StorageAccount is the storage Account.

type StorageProfile 

type StorageProfile struct {
	Storageaccounts *[]StorageAccount `json:"storageaccounts,omitempty"`
}

StorageProfile is the storage profile.

type Tier 

type Tier string

Tier enumerates the values for tier. 

const (
	// Premium specifies the premium state for tier.
	Premium Tier = "Premium"
	// Standard specifies the standard state for tier.
	Standard Tier = "Standard"
)

type TrackedResource 

type TrackedResource struct {
	ID       *string             `json:"id,omitempty"`
	Name     *string             `json:"name,omitempty"`
	Type     *string             `json:"type,omitempty"`
	Location *string             `json:"location,omitempty"`
	Tags     *map[string]*string `json:"tags,omitempty"`
}

TrackedResource is the resource model definition for a ARM tracked top level resource

type VMSizeCompatibilityFilter 

type VMSizeCompatibilityFilter struct {
	FilterMode      *string   `json:"FilterMode,omitempty"`
	Regions         *[]string `json:"Regions,omitempty"`
	ClusterFlavors  *[]string `json:"ClusterFlavors,omitempty"`
	NodeTypes       *[]string `json:"NodeTypes,omitempty"`
	ClusterVersions *[]string `json:"ClusterVersions,omitempty"`
	Vmsizes         *[]string `json:"vmsizes,omitempty"`
}

VMSizeCompatibilityFilter is the virtual machine type compatibility filter.

type VMSizesCapability 

type VMSizesCapability struct {
	Available *[]string `json:"available,omitempty"`
}

VMSizesCapability is the virtual machine sizes capability.

type VersionSpec 

type VersionSpec struct {
	FriendlyName      *string             `json:"friendlyName,omitempty"`
	DisplayName       *string             `json:"displayName,omitempty"`
	IsDefault         *string             `json:"isDefault,omitempty"`
	ComponentVersions *map[string]*string `json:"componentVersions,omitempty"`
}

VersionSpec is the version properties.

type VersionsCapability 

type VersionsCapability struct {
	Available *[]VersionSpec `json:"available,omitempty"`
}

VersionsCapability is the version capability.

type VirtualNetworkProfile 

type VirtualNetworkProfile struct {
	ID     *string `json:"id,omitempty"`
	Subnet *string `json:"subnet,omitempty"`
}

VirtualNetworkProfile is the virtual network properties.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.