Documentation ¶
Overview ¶
Package hdinsight implements the Azure ARM Hdinsight service API version 2018-06-01-preview.
HDInsight Management Client
Index ¶
- Constants
- func UserAgent() string
- func Version() string
- type Application
- type ApplicationGetEndpoint
- type ApplicationGetHTTPSEndpoint
- type ApplicationListResult
- type ApplicationListResultIterator
- type ApplicationListResultPage
- type ApplicationProperties
- type ApplicationsClient
- func (client ApplicationsClient) Create(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ApplicationsCreateFuture, err error)
- func (client ApplicationsClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ApplicationsClient) CreateResponder(resp *http.Response) (result Application, err error)
- func (client ApplicationsClient) CreateSender(req *http.Request) (future ApplicationsCreateFuture, err error)
- func (client ApplicationsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ApplicationsDeleteFuture, err error)
- func (client ApplicationsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ApplicationsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ApplicationsClient) DeleteSender(req *http.Request) (future ApplicationsDeleteFuture, err error)
- func (client ApplicationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result Application, err error)
- func (client ApplicationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ApplicationsClient) GetResponder(resp *http.Response) (result Application, err error)
- func (client ApplicationsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ApplicationsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result ApplicationListResultPage, err error)
- func (client ApplicationsClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ApplicationListResultIterator, err error)
- func (client ApplicationsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ApplicationsClient) ListByClusterResponder(resp *http.Response) (result ApplicationListResult, err error)
- func (client ApplicationsClient) ListByClusterSender(req *http.Request) (*http.Response, error)
- type ApplicationsCreateFuture
- type ApplicationsDeleteFuture
- type AsyncOperationState
- type BaseClient
- type Cluster
- type ClusterCreateParametersExtended
- type ClusterCreateProperties
- type ClusterDefinition
- type ClusterGetProperties
- type ClusterIdentity
- type ClusterIdentityUserAssignedIdentitiesValue
- type ClusterListPersistedScriptActionsResult
- type ClusterListResult
- type ClusterListResultIterator
- type ClusterListResultPage
- type ClusterListRuntimeScriptActionDetailResult
- type ClusterMonitoringRequest
- type ClusterMonitoringResponse
- type ClusterPatchParameters
- type ClusterProvisioningState
- type ClusterResizeParameters
- type ClustersClient
- func (client ClustersClient) Create(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersCreateFuture, err error)
- func (client ClustersClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) CreateResponder(resp *http.Response) (result Cluster, err error)
- func (client ClustersClient) CreateSender(req *http.Request) (future ClustersCreateFuture, err error)
- func (client ClustersClient) Delete(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDeleteFuture, err error)
- func (client ClustersClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) DeleteSender(req *http.Request) (future ClustersDeleteFuture, err error)
- func (client ClustersClient) ExecuteScriptActions(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersExecuteScriptActionsFuture, err error)
- func (client ClustersClient) ExecuteScriptActionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) ExecuteScriptActionsResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) ExecuteScriptActionsSender(req *http.Request) (future ClustersExecuteScriptActionsFuture, err error)
- func (client ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string) (result Cluster, err error)
- func (client ClustersClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) GetResponder(resp *http.Response) (result Cluster, err error)
- func (client ClustersClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) List(ctx context.Context) (result ClusterListResultPage, err error)
- func (client ClustersClient) ListByResourceGroup(ctx context.Context, resourceGroupName string) (result ClusterListResultPage, err error)
- func (client ClustersClient) ListByResourceGroupComplete(ctx context.Context, resourceGroupName string) (result ClusterListResultIterator, err error)
- func (client ClustersClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error)
- func (client ClustersClient) ListByResourceGroupResponder(resp *http.Response) (result ClusterListResult, err error)
- func (client ClustersClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) ListComplete(ctx context.Context) (result ClusterListResultIterator, err error)
- func (client ClustersClient) ListPreparer(ctx context.Context) (*http.Request, error)
- func (client ClustersClient) ListResponder(resp *http.Response) (result ClusterListResult, err error)
- func (client ClustersClient) ListSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) Resize(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersResizeFuture, err error)
- func (client ClustersClient) ResizePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) ResizeResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) ResizeSender(req *http.Request) (future ClustersResizeFuture, err error)
- func (client ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, ...) (result Cluster, err error)
- func (client ClustersClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) UpdateResponder(resp *http.Response) (result Cluster, err error)
- func (client ClustersClient) UpdateSender(req *http.Request) (*http.Response, error)
- type ClustersCreateFuture
- type ClustersDeleteFuture
- type ClustersExecuteScriptActionsFuture
- type ClustersResizeFuture
- type ComputeProfile
- type ConfigurationsClient
- func (client ConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result SetString, err error)
- func (client ConfigurationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ConfigurationsClient) GetResponder(resp *http.Response) (result SetString, err error)
- func (client ConfigurationsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ConfigurationsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ConfigurationsUpdateFuture, err error)
- func (client ConfigurationsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ConfigurationsClient) UpdateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ConfigurationsClient) UpdateSender(req *http.Request) (future ConfigurationsUpdateFuture, err error)
- type ConfigurationsUpdateFuture
- type ConnectivityEndpoint
- type DataDisksGroups
- type DirectoryType
- type ErrorResponse
- type Errors
- type ExecuteScriptActionParameters
- type Extension
- type ExtensionsClient
- func (client ExtensionsClient) Create(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ExtensionsCreateFuture, err error)
- func (client ExtensionsClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ExtensionsClient) CreateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ExtensionsClient) CreateSender(req *http.Request) (future ExtensionsCreateFuture, err error)
- func (client ExtensionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ExtensionsDeleteFuture, err error)
- func (client ExtensionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ExtensionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ExtensionsClient) DeleteSender(req *http.Request) (future ExtensionsDeleteFuture, err error)
- func (client ExtensionsClient) DisableMonitoring(ctx context.Context, resourceGroupName string, clusterName string) (result ExtensionsDisableMonitoringFuture, err error)
- func (client ExtensionsClient) DisableMonitoringPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ExtensionsClient) DisableMonitoringResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ExtensionsClient) DisableMonitoringSender(req *http.Request) (future ExtensionsDisableMonitoringFuture, err error)
- func (client ExtensionsClient) EnableMonitoring(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ExtensionsEnableMonitoringFuture, err error)
- func (client ExtensionsClient) EnableMonitoringPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ExtensionsClient) EnableMonitoringResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ExtensionsClient) EnableMonitoringSender(req *http.Request) (future ExtensionsEnableMonitoringFuture, err error)
- func (client ExtensionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result Extension, err error)
- func (client ExtensionsClient) GetMonitoringStatus(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterMonitoringResponse, err error)
- func (client ExtensionsClient) GetMonitoringStatusPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ExtensionsClient) GetMonitoringStatusResponder(resp *http.Response) (result ClusterMonitoringResponse, err error)
- func (client ExtensionsClient) GetMonitoringStatusSender(req *http.Request) (*http.Response, error)
- func (client ExtensionsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ExtensionsClient) GetResponder(resp *http.Response) (result Extension, err error)
- func (client ExtensionsClient) GetSender(req *http.Request) (*http.Response, error)
- type ExtensionsCreateFuture
- type ExtensionsDeleteFuture
- type ExtensionsDisableMonitoringFuture
- type ExtensionsEnableMonitoringFuture
- type HardwareProfile
- type LinuxOperatingSystemProfile
- type LocalizedName
- type LocationsClient
- func (client LocationsClient) ListUsages(ctx context.Context, location string) (result UsagesListResult, err error)
- func (client LocationsClient) ListUsagesPreparer(ctx context.Context, location string) (*http.Request, error)
- func (client LocationsClient) ListUsagesResponder(resp *http.Response) (result UsagesListResult, err error)
- func (client LocationsClient) ListUsagesSender(req *http.Request) (*http.Response, error)
- type OSType
- type Operation
- type OperationDisplay
- type OperationListResult
- type OperationListResultIterator
- type OperationListResultPage
- type OperationResource
- type OperationsClient
- func (client OperationsClient) List(ctx context.Context) (result OperationListResultPage, err error)
- func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error)
- func (client OperationsClient) ListPreparer(ctx context.Context) (*http.Request, error)
- func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)
- func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)
- type OsProfile
- type ProxyResource
- type QuotaInfo
- type Resource
- type ResourceIdentityType
- type Role
- type RuntimeScriptAction
- type RuntimeScriptActionDetail
- type SSHProfile
- type SSHPublicKey
- type ScriptAction
- type ScriptActionExecutionHistoryList
- type ScriptActionExecutionHistoryListIterator
- func (iter *ScriptActionExecutionHistoryListIterator) Next() error
- func (iter ScriptActionExecutionHistoryListIterator) NotDone() bool
- func (iter ScriptActionExecutionHistoryListIterator) Response() ScriptActionExecutionHistoryList
- func (iter ScriptActionExecutionHistoryListIterator) Value() RuntimeScriptActionDetail
- type ScriptActionExecutionHistoryListPage
- func (page *ScriptActionExecutionHistoryListPage) Next() error
- func (page ScriptActionExecutionHistoryListPage) NotDone() bool
- func (page ScriptActionExecutionHistoryListPage) Response() ScriptActionExecutionHistoryList
- func (page ScriptActionExecutionHistoryListPage) Values() []RuntimeScriptActionDetail
- type ScriptActionExecutionSummary
- type ScriptActionPersistedGetResponseSpec
- type ScriptActionsClient
- func (client ScriptActionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result autorest.Response, err error)
- func (client ScriptActionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptActionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ScriptActionsClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client ScriptActionsClient) GetExecutionDetail(ctx context.Context, resourceGroupName string, clusterName string, ...) (result RuntimeScriptActionDetail, err error)
- func (client ScriptActionsClient) GetExecutionDetailPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptActionsClient) GetExecutionDetailResponder(resp *http.Response) (result RuntimeScriptActionDetail, err error)
- func (client ScriptActionsClient) GetExecutionDetailSender(req *http.Request) (*http.Response, error)
- func (client ScriptActionsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionsListPage, err error)
- func (client ScriptActionsClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionsListIterator, err error)
- func (client ScriptActionsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ScriptActionsClient) ListByClusterResponder(resp *http.Response) (result ScriptActionsList, err error)
- func (client ScriptActionsClient) ListByClusterSender(req *http.Request) (*http.Response, error)
- type ScriptActionsList
- type ScriptActionsListIterator
- type ScriptActionsListPage
- type ScriptExecutionHistoryClient
- func (client ScriptExecutionHistoryClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionExecutionHistoryListPage, err error)
- func (client ScriptExecutionHistoryClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionExecutionHistoryListIterator, err error)
- func (client ScriptExecutionHistoryClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ScriptExecutionHistoryClient) ListByClusterResponder(resp *http.Response) (result ScriptActionExecutionHistoryList, err error)
- func (client ScriptExecutionHistoryClient) ListByClusterSender(req *http.Request) (*http.Response, error)
- func (client ScriptExecutionHistoryClient) Promote(ctx context.Context, resourceGroupName string, clusterName string, ...) (result autorest.Response, err error)
- func (client ScriptExecutionHistoryClient) PromotePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptExecutionHistoryClient) PromoteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ScriptExecutionHistoryClient) PromoteSender(req *http.Request) (*http.Response, error)
- type SecurityProfile
- type SetString
- type StorageAccount
- type StorageProfile
- type Tier
- type TrackedResource
- type Usage
- type UsagesListResult
- type VirtualNetworkProfile
Constants ¶
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:"-"` // 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"` // ID - Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. 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"` }
ApplicationGetEndpoint gets the application SSH endpoint
type ApplicationGetHTTPSEndpoint ¶
type ApplicationGetHTTPSEndpoint struct { // AdditionalProperties - Unmatched properties from the message are deserialized this collection AdditionalProperties map[string]*string `json:""` // AccessModes - The list of access modes for the application. AccessModes *[]string `json:"accessModes,omitempty"` // 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"` }
ApplicationGetHTTPSEndpoint gets the application HTTP endpoints.
func (ApplicationGetHTTPSEndpoint) MarshalJSON ¶
func (aghe ApplicationGetHTTPSEndpoint) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ApplicationGetHTTPSEndpoint.
func (*ApplicationGetHTTPSEndpoint) UnmarshalJSON ¶
func (aghe *ApplicationGetHTTPSEndpoint) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for ApplicationGetHTTPSEndpoint struct.
type ApplicationListResult ¶
type ApplicationListResult struct { autorest.Response `json:"-"` // Value - The list of HDInsight applications installed on HDInsight cluster. Value *[]Application `json:"value,omitempty"` // NextLink - 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.
type ApplicationListResultIterator ¶
type ApplicationListResultIterator struct {
// contains filtered or unexported fields
}
ApplicationListResultIterator provides access to a complete listing of Application values.
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.
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 ¶
func (iter ApplicationListResultIterator) Response() ApplicationListResult
Response returns the raw server response from the last page request.
func (ApplicationListResultIterator) Value ¶
func (iter ApplicationListResultIterator) Value() Application
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 (*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.
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 ¶
func (page ApplicationListResultPage) Response() ApplicationListResult
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 - The provisioning state of the application. ProvisioningState *string `json:"provisioningState,omitempty"` // ApplicationType - The application type. ApplicationType *string `json:"applicationType,omitempty"` // ApplicationState - The application state. ApplicationState *string `json:"applicationState,omitempty"` // Errors - The list of errors. Errors *[]Errors `json:"errors,omitempty"` // CreatedDate - The application create date time. CreatedDate *string `json:"createdDate,omitempty"` // MarketplaceIdentifier - The marketplace identifier. MarketplaceIdentifier *string `json:"marketplaceIdentifier,omitempty"` // AdditionalProperties - The additional properties for application. AdditionalProperties *string `json:"additionalProperties,omitempty"` }
ApplicationProperties the HDInsight cluster application GET response.
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.
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) 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 ¶
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 ¶
ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.
type ApplicationsCreateFuture ¶
ApplicationsCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ApplicationsCreateFuture) Result ¶
func (future *ApplicationsCreateFuture) Result(client ApplicationsClient) (a Application, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ApplicationsDeleteFuture ¶
ApplicationsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ApplicationsDeleteFuture) Result ¶
func (future *ApplicationsDeleteFuture) Result(client ApplicationsClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type AsyncOperationState ¶
type AsyncOperationState string
AsyncOperationState enumerates the values for async operation state.
const ( // Failed ... Failed AsyncOperationState = "Failed" // InProgress ... InProgress AsyncOperationState = "InProgress" // Succeeded ... Succeeded AsyncOperationState = "Succeeded" )
func PossibleAsyncOperationStateValues ¶
func PossibleAsyncOperationStateValues() []AsyncOperationState
PossibleAsyncOperationStateValues returns an array of possible values for the AsyncOperationState const type.
type BaseClient ¶
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.
type Cluster ¶
type Cluster struct { autorest.Response `json:"-"` // Etag - The ETag for the resource Etag *string `json:"etag,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"` // Location - The Azure Region where the resource lives Location *string `json:"location,omitempty"` // Tags - Resource tags. Tags map[string]*string `json:"tags"` // ID - Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Type *string `json:"type,omitempty"` }
Cluster the HDInsight cluster.
func (Cluster) MarshalJSON ¶
MarshalJSON is the custom marshaler for Cluster.
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"` // 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: 'Windows', 'Linux' OsType OSType `json:"osType,omitempty"` // Tier - The cluster tier. Possible values include: 'Standard', 'Premium' Tier Tier `json:"tier,omitempty"` // ClusterDefinition - The cluster definition. ClusterDefinition *ClusterDefinition `json:"clusterDefinition,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"` }
ClusterCreateProperties the cluster create parameters.
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 ClusterGetProperties ¶
type ClusterGetProperties struct { // ClusterVersion - The version of the cluster. ClusterVersion *string `json:"clusterVersion,omitempty"` // OsType - The type of operating system. Possible values include: 'Windows', 'Linux' OsType OSType `json:"osType,omitempty"` // Tier - The cluster tier. Possible values include: 'Standard', 'Premium' Tier Tier `json:"tier,omitempty"` // ClusterDefinition - The cluster definition. ClusterDefinition *ClusterDefinition `json:"clusterDefinition,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"` }
ClusterGetProperties the properties of cluster.
type ClusterIdentity ¶
type ClusterIdentity struct { // PrincipalID - The principal id of cluster identity. This property will only be provided for a system assigned identity. PrincipalID *string `json:"principalId,omitempty"` // TenantID - 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: 'SystemAssigned', 'UserAssigned', 'SystemAssignedUserAssigned', 'None' 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]*ClusterIdentityUserAssignedIdentitiesValue `json:"userAssignedIdentities"` }
ClusterIdentity identity for the cluster.
func (ClusterIdentity) MarshalJSON ¶
func (ci ClusterIdentity) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterIdentity.
type ClusterIdentityUserAssignedIdentitiesValue ¶
type ClusterIdentityUserAssignedIdentitiesValue struct { // PrincipalID - The principal id of user assigned identity. PrincipalID *string `json:"principalId,omitempty"` // ClientID - The client id of user assigned identity. ClientID *string `json:"clientId,omitempty"` }
ClusterIdentityUserAssignedIdentitiesValue ...
type ClusterListPersistedScriptActionsResult ¶
type ClusterListPersistedScriptActionsResult struct { // Value - The list of Persisted Script Actions. Value *[]RuntimeScriptAction `json:"value,omitempty"` // NextLink - The link (url) to the next page of results. NextLink *string `json:"nextLink,omitempty"` }
ClusterListPersistedScriptActionsResult the ListPersistedScriptActions operation response.
type ClusterListResult ¶
type ClusterListResult struct { autorest.Response `json:"-"` // Value - The list of Clusters. Value *[]Cluster `json:"value,omitempty"` // NextLink - 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.
type ClusterListResultIterator ¶
type ClusterListResultIterator struct {
// contains filtered or unexported fields
}
ClusterListResultIterator provides access to a complete listing of Cluster values.
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.
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 ¶
func (iter ClusterListResultIterator) Response() ClusterListResult
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 (*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.
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 ClusterListRuntimeScriptActionDetailResult ¶
type ClusterListRuntimeScriptActionDetailResult struct { // Value - The list of persisted script action details for the cluster. Value *[]RuntimeScriptActionDetail `json:"value,omitempty"` // NextLink - The link (url) to the next page of results. NextLink *string `json:"nextLink,omitempty"` }
ClusterListRuntimeScriptActionDetailResult the list runtime script action detail response.
type ClusterMonitoringRequest ¶
type ClusterMonitoringRequest struct { // WorkspaceID - The Operations Management Suite (OMS) workspace ID. WorkspaceID *string `json:"workspaceId,omitempty"` // PrimaryKey - The Operations Management Suite (OMS) workspace key. PrimaryKey *string `json:"primaryKey,omitempty"` }
ClusterMonitoringRequest the Operations Management Suite (OMS) parameters.
type ClusterMonitoringResponse ¶
type ClusterMonitoringResponse struct { autorest.Response `json:"-"` // ClusterMonitoringEnabled - The status of the Operations Management Suite (OMS) on the HDInsight cluster. ClusterMonitoringEnabled *bool `json:"clusterMonitoringEnabled,omitempty"` // WorkspaceID - The workspace ID of the Operations Management Suite (OMS) on the HDInsight cluster. WorkspaceID *string `json:"workspaceId,omitempty"` }
ClusterMonitoringResponse the Operations Management Suite (OMS) 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.
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) 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 ¶
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 ¶
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 ¶
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 ¶
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) 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) 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 ¶
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type ClustersCreateFuture ¶
ClustersCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersCreateFuture) Result ¶
func (future *ClustersCreateFuture) Result(client ClustersClient) (c Cluster, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ClustersDeleteFuture ¶
ClustersDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersDeleteFuture) Result ¶
func (future *ClustersDeleteFuture) Result(client ClustersClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ClustersExecuteScriptActionsFuture ¶
ClustersExecuteScriptActionsFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersExecuteScriptActionsFuture) Result ¶
func (future *ClustersExecuteScriptActionsFuture) Result(client ClustersClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ClustersResizeFuture ¶
ClustersResizeFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersResizeFuture) Result ¶
func (future *ClustersResizeFuture) Result(client ClustersClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
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.
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. 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 ¶
GetSender sends the Get 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 configuration on the specified cluster. 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 ¶
ConfigurationsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ConfigurationsUpdateFuture) Result ¶
func (future *ConfigurationsUpdateFuture) Result(client ConfigurationsClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
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"` }
ConnectivityEndpoint the connectivity properties
type DataDisksGroups ¶
type DataDisksGroups struct { // DisksPerNode - The number of disks per node. DisksPerNode *int32 `json:"disksPerNode,omitempty"` // StorageAccountType - ReadOnly. The storage account type. Do not set this value. StorageAccountType *string `json:"storageAccountType,omitempty"` // DiskSizeGB - ReadOnly. The DiskSize in GB. Do not set this value. DiskSizeGB *int32 `json:"diskSizeGB,omitempty"` }
DataDisksGroups the data disks groups for the role.
type DirectoryType ¶
type DirectoryType string
DirectoryType enumerates the values for directory type.
const ( // ActiveDirectory ... ActiveDirectory DirectoryType = "ActiveDirectory" )
func PossibleDirectoryTypeValues ¶
func PossibleDirectoryTypeValues() []DirectoryType
PossibleDirectoryTypeValues returns an array of possible values for the DirectoryType const type.
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 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 { autorest.Response `json:"-"` // 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.
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) 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) 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 Extension, 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) 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 ¶
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 Extension, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
type ExtensionsCreateFuture ¶
ExtensionsCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ExtensionsCreateFuture) Result ¶
func (future *ExtensionsCreateFuture) Result(client ExtensionsClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ExtensionsDeleteFuture ¶
ExtensionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ExtensionsDeleteFuture) Result ¶
func (future *ExtensionsDeleteFuture) Result(client ExtensionsClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ExtensionsDisableMonitoringFuture ¶
ExtensionsDisableMonitoringFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ExtensionsDisableMonitoringFuture) Result ¶
func (future *ExtensionsDisableMonitoringFuture) Result(client ExtensionsClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ExtensionsEnableMonitoringFuture ¶
ExtensionsEnableMonitoringFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ExtensionsEnableMonitoringFuture) Result ¶
func (future *ExtensionsEnableMonitoringFuture) Result(client ExtensionsClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type HardwareProfile ¶
type HardwareProfile struct { // VMSize - The size of the VM VMSize *string `json:"vmSize,omitempty"` }
HardwareProfile the hardware profile.
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 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.
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 location to get capabilities for.
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 ¶
ListUsagesSender sends the ListUsages request. The method will close the http.Response Body if it receives an error.
type OSType ¶
type OSType string
OSType enumerates the values for os type.
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 object that represents the operation. Display *OperationDisplay `json:"display,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"` }
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 (*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.
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 ¶
func (iter OperationListResultIterator) Response() OperationListResult
Response returns the raw server response from the last page request.
func (OperationListResultIterator) Value ¶
func (iter OperationListResultIterator) Value() Operation
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 (*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.
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 ¶
func (page OperationListResultPage) Response() OperationListResult
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 OperationResource ¶
type OperationResource struct { // Status - The async operation state. Possible values include: 'InProgress', 'Succeeded', 'Failed' Status AsyncOperationState `json:"status,omitempty"` // Error - The operation error information. Error *Errors `json:"error,omitempty"` }
OperationResource the azure async operation response.
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.
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 ¶
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 ¶
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 ProxyResource ¶
type ProxyResource struct { // ID - Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Type *string `json:"type,omitempty"` }
ProxyResource the resource model definition for a ARM proxy resource. It will have everything other than required location and tags
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 Resource ¶
type Resource struct { // ID - Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Type *string `json:"type,omitempty"` }
Resource the core properties of ARM resources
type ResourceIdentityType ¶
type ResourceIdentityType string
ResourceIdentityType enumerates the values for resource identity type.
const ( // None ... None ResourceIdentityType = "None" // SystemAssigned ... SystemAssigned ResourceIdentityType = "SystemAssigned" // SystemAssignedUserAssigned ... SystemAssignedUserAssigned ResourceIdentityType = "SystemAssigned, UserAssigned" // UserAssigned ... UserAssigned ResourceIdentityType = "UserAssigned" )
func PossibleResourceIdentityTypeValues ¶
func PossibleResourceIdentityTypeValues() []ResourceIdentityType
PossibleResourceIdentityTypeValues returns an array of possible values for the ResourceIdentityType 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"` // 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"` }
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 - The application name of the script action, if any. ApplicationName *string `json:"applicationName,omitempty"` }
RuntimeScriptAction describes a script action on a running cluster.
type RuntimeScriptActionDetail ¶
type RuntimeScriptActionDetail struct { autorest.Response `json:"-"` // ScriptExecutionID - The execution id of the script action. ScriptExecutionID *int64 `json:"scriptExecutionId,omitempty"` // StartTime - The start time of script action execution. StartTime *string `json:"startTime,omitempty"` // EndTime - The end time of script action execution. EndTime *string `json:"endTime,omitempty"` // Status - The current execution status of the script action. Status *string `json:"status,omitempty"` // Operation - The reason why the script action was executed. Operation *string `json:"operation,omitempty"` // ExecutionSummary - The summary of script action execution result. ExecutionSummary *[]ScriptActionExecutionSummary `json:"executionSummary,omitempty"` // DebugInformation - 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 - The application name of the script action, if any. ApplicationName *string `json:"applicationName,omitempty"` }
RuntimeScriptActionDetail the execution details of a script action.
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 - The list of persisted script action details for the cluster. Value *[]RuntimeScriptActionDetail `json:"value,omitempty"` // NextLink - 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.
type ScriptActionExecutionHistoryListIterator ¶
type ScriptActionExecutionHistoryListIterator struct {
// contains filtered or unexported fields
}
ScriptActionExecutionHistoryListIterator provides access to a complete listing of RuntimeScriptActionDetail values.
func (*ScriptActionExecutionHistoryListIterator) Next ¶
func (iter *ScriptActionExecutionHistoryListIterator) 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.
func (ScriptActionExecutionHistoryListIterator) NotDone ¶
func (iter ScriptActionExecutionHistoryListIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (ScriptActionExecutionHistoryListIterator) Response ¶
func (iter ScriptActionExecutionHistoryListIterator) Response() ScriptActionExecutionHistoryList
Response returns the raw server response from the last page request.
func (ScriptActionExecutionHistoryListIterator) Value ¶
func (iter ScriptActionExecutionHistoryListIterator) Value() RuntimeScriptActionDetail
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 (*ScriptActionExecutionHistoryListPage) Next ¶
func (page *ScriptActionExecutionHistoryListPage) 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.
func (ScriptActionExecutionHistoryListPage) NotDone ¶
func (page ScriptActionExecutionHistoryListPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (ScriptActionExecutionHistoryListPage) Response ¶
func (page ScriptActionExecutionHistoryListPage) Response() ScriptActionExecutionHistoryList
Response returns the raw server response from the last page request.
func (ScriptActionExecutionHistoryListPage) Values ¶
func (page ScriptActionExecutionHistoryListPage) Values() []RuntimeScriptActionDetail
Values returns the slice of values for the current page or nil if there are no values.
type ScriptActionExecutionSummary ¶
type ScriptActionExecutionSummary struct { // Status - The status of script action execution. Status *string `json:"status,omitempty"` // InstanceCount - The instance count for a given script action execution status. InstanceCount *int32 `json:"instanceCount,omitempty"` }
ScriptActionExecutionSummary the execution summary of a script action.
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.
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 ¶
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(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 ¶
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 - 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.
type ScriptActionsListIterator ¶
type ScriptActionsListIterator struct {
// contains filtered or unexported fields
}
ScriptActionsListIterator provides access to a complete listing of RuntimeScriptActionDetail values.
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.
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 ¶
func (iter ScriptActionsListIterator) Response() ScriptActionsList
Response returns the raw server response from the last page request.
func (ScriptActionsListIterator) Value ¶
func (iter ScriptActionsListIterator) Value() RuntimeScriptActionDetail
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 (*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.
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 ¶
func (page ScriptActionsListPage) Values() []RuntimeScriptActionDetail
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.
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 ¶
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: 'ActiveDirectory' 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 SetString ¶
SetString ...
func (SetString) MarshalJSON ¶
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 type Gen 2. FileSystem *string `json:"fileSystem,omitempty"` // Key - The storage account access key. Key *string `json:"key,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 Tier ¶
type Tier string
Tier enumerates the values for tier.
func PossibleTierValues ¶
func PossibleTierValues() []Tier
PossibleTierValues returns an array of possible values for the Tier const type.
type TrackedResource ¶
type TrackedResource struct { // Location - The Azure Region where the resource lives Location *string `json:"location,omitempty"` // Tags - Resource tags. Tags map[string]*string `json:"tags"` // ID - Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Type *string `json:"type,omitempty"` }
TrackedResource the resource model definition for a ARM tracked top level resource
func (TrackedResource) MarshalJSON ¶
func (tr TrackedResource) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for TrackedResource.
type Usage ¶
type Usage struct { // Unit - The type of measurement for usage. Unit *string `json:"unit,omitempty"` // CurrentValue - The current usage. CurrentValue *int32 `json:"currentValue,omitempty"` // Limit - The maximum allowed usage. Limit *int32 `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 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.