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
- func (iter *ApplicationListResultIterator) Next() error
- func (iter *ApplicationListResultIterator) NextWithContext(ctx context.Context) (err error)
- func (iter ApplicationListResultIterator) NotDone() bool
- func (iter ApplicationListResultIterator) Response() ApplicationListResult
- func (iter ApplicationListResultIterator) Value() Application
- type ApplicationListResultPage
- func (page *ApplicationListResultPage) Next() error
- func (page *ApplicationListResultPage) NextWithContext(ctx context.Context) (err error)
- func (page ApplicationListResultPage) NotDone() bool
- func (page ApplicationListResultPage) Response() ApplicationListResult
- func (page ApplicationListResultPage) Values() []Application
- 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 Autoscale
- type AutoscaleCapacity
- type AutoscaleConfigurationUpdateParameter
- type AutoscaleRecurrence
- type AutoscaleSchedule
- type AutoscaleTimeAndCapacity
- type BaseClient
- type BillingMeters
- type BillingResources
- type BillingResponseListResult
- type CapabilitiesResult
- type ClientGroupInfo
- type Cluster
- type ClusterConfigurations
- type ClusterCreateParametersExtended
- type ClusterCreateProperties
- type ClusterDefinition
- type ClusterDiskEncryptionParameters
- type ClusterGetProperties
- type ClusterIdentity
- type ClusterIdentityUserAssignedIdentitiesValue
- type ClusterListPersistedScriptActionsResult
- type ClusterListResult
- type ClusterListResultIterator
- func (iter *ClusterListResultIterator) Next() error
- func (iter *ClusterListResultIterator) NextWithContext(ctx context.Context) (err error)
- func (iter ClusterListResultIterator) NotDone() bool
- func (iter ClusterListResultIterator) Response() ClusterListResult
- func (iter ClusterListResultIterator) Value() Cluster
- 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) GetGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string) (result GatewaySettings, err error)
- func (client ClustersClient) GetGatewaySettingsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) GetGatewaySettingsResponder(resp *http.Response) (result GatewaySettings, err error)
- func (client ClustersClient) GetGatewaySettingsSender(req *http.Request) (*http.Response, 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) RotateDiskEncryptionKey(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersRotateDiskEncryptionKeyFuture, err error)
- func (client ClustersClient) RotateDiskEncryptionKeyPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) RotateDiskEncryptionKeyResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) RotateDiskEncryptionKeySender(req *http.Request) (future ClustersRotateDiskEncryptionKeyFuture, err error)
- func (client ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, ...) (result Cluster, err error)
- func (client ClustersClient) UpdateAutoScaleConfiguration(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersUpdateAutoScaleConfigurationFuture, err error)
- func (client ClustersClient) UpdateAutoScaleConfigurationPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) UpdateAutoScaleConfigurationResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) UpdateAutoScaleConfigurationSender(req *http.Request) (future ClustersUpdateAutoScaleConfigurationFuture, err error)
- func (client ClustersClient) UpdateGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersUpdateGatewaySettingsFuture, err error)
- func (client ClustersClient) UpdateGatewaySettingsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) UpdateGatewaySettingsResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) UpdateGatewaySettingsSender(req *http.Request) (future ClustersUpdateGatewaySettingsFuture, 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 ClustersRotateDiskEncryptionKeyFuture
- type ClustersUpdateAutoScaleConfigurationFuture
- type ClustersUpdateGatewaySettingsFuture
- type ComputeIsolationProperties
- 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) List(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterConfigurations, err error)
- func (client ConfigurationsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ConfigurationsClient) ListResponder(resp *http.Response) (result ClusterConfigurations, err error)
- func (client ConfigurationsClient) ListSender(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 DaysOfWeek
- type DirectoryType
- type DiskBillingMeters
- type DiskEncryptionProperties
- type EncryptionInTransitProperties
- 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 FilterMode
- type GatewaySettings
- type HardwareProfile
- type HostInfo
- type JSONWebKeyEncryptionAlgorithm
- type KafkaRestProperties
- type LinuxOperatingSystemProfile
- type ListHostInfo
- type LocalizedName
- type LocationsClient
- func (client LocationsClient) GetCapabilities(ctx context.Context, location string) (result CapabilitiesResult, err error)
- func (client LocationsClient) GetCapabilitiesPreparer(ctx context.Context, location string) (*http.Request, error)
- func (client LocationsClient) GetCapabilitiesResponder(resp *http.Response) (result CapabilitiesResult, err error)
- func (client LocationsClient) GetCapabilitiesSender(req *http.Request) (*http.Response, error)
- func (client LocationsClient) ListBillingSpecs(ctx context.Context, location string) (result BillingResponseListResult, err error)
- func (client LocationsClient) ListBillingSpecsPreparer(ctx context.Context, location string) (*http.Request, error)
- func (client LocationsClient) ListBillingSpecsResponder(resp *http.Response) (result BillingResponseListResult, err error)
- func (client LocationsClient) ListBillingSpecsSender(req *http.Request) (*http.Response, error)
- 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 NetworkProperties
- type OSType
- type Operation
- type OperationDisplay
- type OperationListResult
- type OperationListResultIterator
- func (iter *OperationListResultIterator) Next() error
- func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error)
- func (iter OperationListResultIterator) NotDone() bool
- func (iter OperationListResultIterator) Response() OperationListResult
- func (iter OperationListResultIterator) Value() Operation
- type OperationListResultPage
- func (page *OperationListResultPage) Next() error
- func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error)
- func (page OperationListResultPage) NotDone() bool
- func (page OperationListResultPage) Response() OperationListResult
- func (page OperationListResultPage) Values() []Operation
- 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 PrivateLink
- type ProxyResource
- type QuotaCapability
- type QuotaInfo
- type RegionalQuotaCapability
- type RegionsCapability
- type Resource
- type ResourceIdentityType
- type ResourceProviderConnection
- type Role
- type RuntimeScriptAction
- type RuntimeScriptActionDetail
- type SSHProfile
- type SSHPublicKey
- type ScriptAction
- type ScriptActionExecutionHistoryList
- type ScriptActionExecutionHistoryListIterator
- func (iter *ScriptActionExecutionHistoryListIterator) Next() error
- func (iter *ScriptActionExecutionHistoryListIterator) NextWithContext(ctx context.Context) (err 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) NextWithContext(ctx context.Context) (err 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
- func (iter *ScriptActionsListIterator) Next() error
- func (iter *ScriptActionsListIterator) NextWithContext(ctx context.Context) (err error)
- func (iter ScriptActionsListIterator) NotDone() bool
- func (iter ScriptActionsListIterator) Response() ScriptActionsList
- func (iter ScriptActionsListIterator) Value() RuntimeScriptActionDetail
- type ScriptActionsListPage
- func (page *ScriptActionsListPage) Next() error
- func (page *ScriptActionsListPage) NextWithContext(ctx context.Context) (err error)
- func (page ScriptActionsListPage) NotDone() bool
- func (page ScriptActionsListPage) Response() ScriptActionsList
- func (page ScriptActionsListPage) Values() []RuntimeScriptActionDetail
- 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 UpdateGatewaySettingsParameters
- type Usage
- type UsagesListResult
- type VMSizeCompatibilityFilter
- type VMSizeCompatibilityFilterV2
- type VMSizesCapability
- type VersionSpec
- type VersionsCapability
- type VirtualMachinesClient
- func (client VirtualMachinesClient) ListHosts(ctx context.Context, resourceGroupName string, clusterName string) (result ListHostInfo, err error)
- func (client VirtualMachinesClient) ListHostsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client VirtualMachinesClient) ListHostsResponder(resp *http.Response) (result ListHostInfo, err error)
- func (client VirtualMachinesClient) ListHostsSender(req *http.Request) (*http.Response, error)
- func (client VirtualMachinesClient) RestartHosts(ctx context.Context, resourceGroupName string, clusterName string, ...) (result VirtualMachinesRestartHostsFuture, err error)
- func (client VirtualMachinesClient) RestartHostsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client VirtualMachinesClient) RestartHostsResponder(resp *http.Response) (result autorest.Response, err error)
- func (client VirtualMachinesClient) RestartHostsSender(req *http.Request) (future VirtualMachinesRestartHostsFuture, err error)
- type VirtualMachinesRestartHostsFuture
- 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 - READ-ONLY; Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. 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 { // 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"` // SubDomainSuffix - The subdomain suffix of the application. SubDomainSuffix *string `json:"subDomainSuffix,omitempty"` // DisableGatewayAuth - The value indicates whether to disable GatewayAuth. DisableGatewayAuth *bool `json:"disableGatewayAuth,omitempty"` }
ApplicationGetHTTPSEndpoint gets the application HTTP endpoints.
type ApplicationListResult ¶
type ApplicationListResult struct { autorest.Response `json:"-"` // Value - The list of HDInsight applications installed on HDInsight cluster. Value *[]Application `json:"value,omitempty"` // NextLink - READ-ONLY; The URL to get the next set of operation list results if there are any. NextLink *string `json:"nextLink,omitempty"` }
ApplicationListResult result of the request to list cluster Applications. It contains a list of operations and a URL link to get the next set of results.
func (ApplicationListResult) IsEmpty ¶
func (alr ApplicationListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
func (ApplicationListResult) MarshalJSON ¶
func (alr ApplicationListResult) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ApplicationListResult.
type ApplicationListResultIterator ¶
type ApplicationListResultIterator struct {
// contains filtered or unexported fields
}
ApplicationListResultIterator provides access to a complete listing of Application values.
func NewApplicationListResultIterator ¶
func NewApplicationListResultIterator(page ApplicationListResultPage) ApplicationListResultIterator
Creates a new instance of the ApplicationListResultIterator type.
func (*ApplicationListResultIterator) Next ¶
func (iter *ApplicationListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*ApplicationListResultIterator) NextWithContext ¶
func (iter *ApplicationListResultIterator) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (ApplicationListResultIterator) NotDone ¶
func (iter ApplicationListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (ApplicationListResultIterator) Response ¶
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 NewApplicationListResultPage ¶
func NewApplicationListResultPage(cur ApplicationListResult, getNextPage func(context.Context, ApplicationListResult) (ApplicationListResult, error)) ApplicationListResultPage
Creates a new instance of the ApplicationListResultPage type.
func (*ApplicationListResultPage) Next ¶
func (page *ApplicationListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*ApplicationListResultPage) NextWithContext ¶
func (page *ApplicationListResultPage) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (ApplicationListResultPage) NotDone ¶
func (page ApplicationListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (ApplicationListResultPage) Response ¶
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 - READ-ONLY; The provisioning state of the application. ProvisioningState *string `json:"provisioningState,omitempty"` // ApplicationType - The application type. ApplicationType *string `json:"applicationType,omitempty"` // ApplicationState - READ-ONLY; The application state. ApplicationState *string `json:"applicationState,omitempty"` // Errors - The list of errors. Errors *[]Errors `json:"errors,omitempty"` // CreatedDate - READ-ONLY; The application create date time. CreatedDate *string `json:"createdDate,omitempty"` // MarketplaceIdentifier - READ-ONLY; The marketplace identifier. MarketplaceIdentifier *string `json:"marketplaceIdentifier,omitempty"` }
ApplicationProperties the HDInsight cluster application GET response.
func (ApplicationProperties) MarshalJSON ¶
func (ap ApplicationProperties) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ApplicationProperties.
type ApplicationsClient ¶
type ApplicationsClient struct {
BaseClient
}
ApplicationsClient is the hDInsight Management Client
func NewApplicationsClient ¶
func NewApplicationsClient(subscriptionID string) ApplicationsClient
NewApplicationsClient creates an instance of the ApplicationsClient client.
func NewApplicationsClientWithBaseURI ¶
func NewApplicationsClientWithBaseURI(baseURI string, subscriptionID string) ApplicationsClient
NewApplicationsClientWithBaseURI creates an instance of the ApplicationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ApplicationsClient) Create ¶
func (client ApplicationsClient) Create(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, parameters Application) (result ApplicationsCreateFuture, err error)
Create creates applications for the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. applicationName - the constant value for the application name. parameters - the application create request.
func (ApplicationsClient) CreatePreparer ¶
func (client ApplicationsClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, applicationName string, parameters Application) (*http.Request, error)
CreatePreparer prepares the Create request.
func (ApplicationsClient) CreateResponder ¶
func (client ApplicationsClient) CreateResponder(resp *http.Response) (result Application, err error)
CreateResponder handles the response to the Create request. The method always closes the http.Response Body.
func (ApplicationsClient) CreateSender ¶
func (client ApplicationsClient) CreateSender(req *http.Request) (future ApplicationsCreateFuture, err error)
CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.
func (ApplicationsClient) Delete ¶
func (client ApplicationsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, applicationName string) (result ApplicationsDeleteFuture, err error)
Delete deletes the specified application on the HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. applicationName - the constant value for the application name.
func (ApplicationsClient) DeletePreparer ¶
func (client ApplicationsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, applicationName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ApplicationsClient) DeleteResponder ¶
func (client ApplicationsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (ApplicationsClient) DeleteSender ¶
func (client ApplicationsClient) DeleteSender(req *http.Request) (future ApplicationsDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (ApplicationsClient) Get ¶
func (client ApplicationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, applicationName string) (result Application, err error)
Get gets properties of the specified application. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. applicationName - the constant value for the application name.
func (ApplicationsClient) 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 ¶
type ApplicationsCreateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ApplicationsClient) (Application, error) }
ApplicationsCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ApplicationsDeleteFuture ¶
type ApplicationsDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ApplicationsClient) (autorest.Response, error) }
ApplicationsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
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 Autoscale ¶
type Autoscale struct { // Capacity - Parameters for load-based autoscale Capacity *AutoscaleCapacity `json:"capacity,omitempty"` // Recurrence - Parameters for schedule-based autoscale Recurrence *AutoscaleRecurrence `json:"recurrence,omitempty"` }
Autoscale the autoscale request parameters
type AutoscaleCapacity ¶
type AutoscaleCapacity struct { // MinInstanceCount - The minimum instance count of the cluster MinInstanceCount *int32 `json:"minInstanceCount,omitempty"` // MaxInstanceCount - The maximum instance count of the cluster MaxInstanceCount *int32 `json:"maxInstanceCount,omitempty"` }
AutoscaleCapacity the load-based autoscale request parameters
type AutoscaleConfigurationUpdateParameter ¶
type AutoscaleConfigurationUpdateParameter struct { // Autoscale - The autoscale configuration. Autoscale *Autoscale `json:"autoscale,omitempty"` }
AutoscaleConfigurationUpdateParameter the autoscale configuration update parameter.
type AutoscaleRecurrence ¶
type AutoscaleRecurrence struct { // TimeZone - The time zone for the autoscale schedule times TimeZone *string `json:"timeZone,omitempty"` // Schedule - Array of schedule-based autoscale rules Schedule *[]AutoscaleSchedule `json:"schedule,omitempty"` }
AutoscaleRecurrence schedule-based autoscale request parameters
type AutoscaleSchedule ¶
type AutoscaleSchedule struct { // Days - Days of the week for a schedule-based autoscale rule Days *[]DaysOfWeek `json:"days,omitempty"` // TimeAndCapacity - Time and capacity for a schedule-based autoscale rule TimeAndCapacity *AutoscaleTimeAndCapacity `json:"timeAndCapacity,omitempty"` }
AutoscaleSchedule parameters for a schedule-based autoscale rule, consisting of an array of days + a time and capacity
type AutoscaleTimeAndCapacity ¶
type AutoscaleTimeAndCapacity struct { // Time - 24-hour time in the form xx:xx Time *string `json:"time,omitempty"` // MinInstanceCount - The minimum instance count of the cluster MinInstanceCount *int32 `json:"minInstanceCount,omitempty"` // MaxInstanceCount - The maximum instance count of the cluster MaxInstanceCount *int32 `json:"maxInstanceCount,omitempty"` }
AutoscaleTimeAndCapacity time and capacity request parameters
type 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 using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
type BillingMeters ¶
type BillingMeters struct { // MeterParameter - The virtual machine sizes. MeterParameter *string `json:"meterParameter,omitempty"` // Meter - The HDInsight meter guid. Meter *string `json:"meter,omitempty"` // Unit - The unit of meter, VMHours or CoreHours. Unit *string `json:"unit,omitempty"` }
BillingMeters the billing meters.
type BillingResources ¶
type BillingResources struct { // Region - The region or location. Region *string `json:"region,omitempty"` // BillingMeters - The billing meter information. BillingMeters *[]BillingMeters `json:"billingMeters,omitempty"` // DiskBillingMeters - The managed disk billing information. DiskBillingMeters *[]DiskBillingMeters `json:"diskBillingMeters,omitempty"` }
BillingResources the billing resources.
type BillingResponseListResult ¶
type BillingResponseListResult struct { autorest.Response `json:"-"` // VMSizes - The virtual machine sizes to include or exclude. VMSizes *[]string `json:"vmSizes,omitempty"` // VMSizeFilters - The virtual machine filtering mode. Effectively this can enabling or disabling the virtual machine sizes in a particular set. VMSizeFilters *[]VMSizeCompatibilityFilterV2 `json:"vmSizeFilters,omitempty"` // BillingResources - The billing and managed disk billing resources for a region. BillingResources *[]BillingResources `json:"billingResources,omitempty"` }
BillingResponseListResult the response for the operation to get regional billingSpecs for a subscription.
type CapabilitiesResult ¶
type CapabilitiesResult struct { autorest.Response `json:"-"` // Versions - The version capability. Versions map[string]*VersionsCapability `json:"versions"` // Regions - The virtual machine size compatibility features. Regions map[string]*RegionsCapability `json:"regions"` // VMSizes - The virtual machine sizes. VMSizes map[string]*VMSizesCapability `json:"vmSizes"` // VMSizeFilters - The virtual machine size compatibility filters. VMSizeFilters *[]VMSizeCompatibilityFilter `json:"vmSize_filters,omitempty"` // Features - The capability features. Features *[]string `json:"features,omitempty"` // Quota - The quota capability. Quota *QuotaCapability `json:"quota,omitempty"` }
CapabilitiesResult the Get Capabilities operation response.
func (CapabilitiesResult) MarshalJSON ¶
func (cr CapabilitiesResult) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for CapabilitiesResult.
type ClientGroupInfo ¶
type ClientGroupInfo struct { // GroupName - The AAD security group name. GroupName *string `json:"groupName,omitempty"` // GroupID - The AAD security group id. GroupID *string `json:"groupId,omitempty"` }
ClientGroupInfo the information of AAD security group.
type Cluster ¶
type Cluster struct { autorest.Response `json:"-"` // Etag - The ETag for the resource Etag *string `json:"etag,omitempty"` // 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 - READ-ONLY; Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. Type *string `json:"type,omitempty"` }
Cluster the HDInsight cluster.
func (Cluster) MarshalJSON ¶
MarshalJSON is the custom marshaler for Cluster.
type ClusterConfigurations ¶
type ClusterConfigurations struct { autorest.Response `json:"-"` // Configurations - The configuration object for the specified configuration for the specified cluster. Configurations map[string]map[string]*string `json:"configurations"` }
ClusterConfigurations the configuration object for the specified cluster.
func (ClusterConfigurations) MarshalJSON ¶
func (cc ClusterConfigurations) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterConfigurations.
type ClusterCreateParametersExtended ¶
type ClusterCreateParametersExtended struct { // Location - The location of the cluster. Location *string `json:"location,omitempty"` // Tags - The resource tags. Tags map[string]*string `json:"tags"` // 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"` // KafkaRestProperties - The cluster kafka rest proxy configuration. KafkaRestProperties *KafkaRestProperties `json:"kafkaRestProperties,omitempty"` // SecurityProfile - The security profile. SecurityProfile *SecurityProfile `json:"securityProfile,omitempty"` // ComputeProfile - The compute profile. ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"` // StorageProfile - The storage profile. StorageProfile *StorageProfile `json:"storageProfile,omitempty"` // DiskEncryptionProperties - The disk encryption properties. DiskEncryptionProperties *DiskEncryptionProperties `json:"diskEncryptionProperties,omitempty"` // EncryptionInTransitProperties - The encryption-in-transit properties. EncryptionInTransitProperties *EncryptionInTransitProperties `json:"encryptionInTransitProperties,omitempty"` // MinSupportedTLSVersion - The minimal supported tls version. MinSupportedTLSVersion *string `json:"minSupportedTlsVersion,omitempty"` // NetworkProperties - The network properties. NetworkProperties *NetworkProperties `json:"networkProperties,omitempty"` // ComputeIsolationProperties - The compute isolation properties. ComputeIsolationProperties *ComputeIsolationProperties `json:"computeIsolationProperties,omitempty"` }
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 ClusterDiskEncryptionParameters ¶
type ClusterDiskEncryptionParameters struct { // VaultURI - Base key vault URI where the customers key is located eg. https://myvault.vault.azure.net VaultURI *string `json:"vaultUri,omitempty"` // KeyName - Key name that is used for enabling disk encryption. KeyName *string `json:"keyName,omitempty"` // KeyVersion - Specific key version that is used for enabling disk encryption. KeyVersion *string `json:"keyVersion,omitempty"` }
ClusterDiskEncryptionParameters the Disk Encryption Cluster request parameters.
type ClusterGetProperties ¶
type ClusterGetProperties struct { // ClusterVersion - The version of the cluster. ClusterVersion *string `json:"clusterVersion,omitempty"` // 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"` // ClusterID - The cluster id. ClusterID *string `json:"clusterId,omitempty"` // ClusterDefinition - The cluster definition. ClusterDefinition *ClusterDefinition `json:"clusterDefinition,omitempty"` // KafkaRestProperties - The cluster kafka rest proxy configuration. KafkaRestProperties *KafkaRestProperties `json:"kafkaRestProperties,omitempty"` // SecurityProfile - The security profile. SecurityProfile *SecurityProfile `json:"securityProfile,omitempty"` // ComputeProfile - The compute profile. ComputeProfile *ComputeProfile `json:"computeProfile,omitempty"` // ProvisioningState - The provisioning state, which only appears in the response. Possible values include: 'ClusterProvisioningStateInProgress', 'ClusterProvisioningStateFailed', 'ClusterProvisioningStateSucceeded', 'ClusterProvisioningStateCanceled', 'ClusterProvisioningStateDeleting' ProvisioningState ClusterProvisioningState `json:"provisioningState,omitempty"` // CreatedDate - The date on which the cluster was created. CreatedDate *string `json:"createdDate,omitempty"` // ClusterState - The state of the cluster. ClusterState *string `json:"clusterState,omitempty"` // QuotaInfo - The quota information. QuotaInfo *QuotaInfo `json:"quotaInfo,omitempty"` // Errors - The list of errors. Errors *[]Errors `json:"errors,omitempty"` // ConnectivityEndpoints - The list of connectivity endpoints. ConnectivityEndpoints *[]ConnectivityEndpoint `json:"connectivityEndpoints,omitempty"` // DiskEncryptionProperties - The disk encryption properties. DiskEncryptionProperties *DiskEncryptionProperties `json:"diskEncryptionProperties,omitempty"` // EncryptionInTransitProperties - The encryption-in-transit properties. EncryptionInTransitProperties *EncryptionInTransitProperties `json:"encryptionInTransitProperties,omitempty"` // MinSupportedTLSVersion - The minimal supported tls version. MinSupportedTLSVersion *string `json:"minSupportedTlsVersion,omitempty"` // NetworkProperties - The network properties. NetworkProperties *NetworkProperties `json:"networkProperties,omitempty"` // ComputeIsolationProperties - The compute isolation properties. ComputeIsolationProperties *ComputeIsolationProperties `json:"computeIsolationProperties,omitempty"` }
ClusterGetProperties the properties of cluster.
type ClusterIdentity ¶
type ClusterIdentity struct { // PrincipalID - READ-ONLY; The principal id of cluster identity. This property will only be provided for a system assigned identity. PrincipalID *string `json:"principalId,omitempty"` // TenantID - READ-ONLY; The tenant id associated with the cluster. This property will only be provided for a system assigned identity. TenantID *string `json:"tenantId,omitempty"` // Type - The type of identity used for the cluster. The type 'SystemAssigned, UserAssigned' includes both an implicitly created identity and a set of user assigned identities. Possible values include: '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 - READ-ONLY; The principal id of user assigned identity. PrincipalID *string `json:"principalId,omitempty"` // ClientID - READ-ONLY; The client id of user assigned identity. ClientID *string `json:"clientId,omitempty"` }
ClusterIdentityUserAssignedIdentitiesValue ...
type ClusterListPersistedScriptActionsResult ¶
type ClusterListPersistedScriptActionsResult struct { // Value - The list of Persisted Script Actions. Value *[]RuntimeScriptAction `json:"value,omitempty"` // NextLink - READ-ONLY; The link (url) to the next page of results. NextLink *string `json:"nextLink,omitempty"` }
ClusterListPersistedScriptActionsResult the ListPersistedScriptActions operation response.
func (ClusterListPersistedScriptActionsResult) MarshalJSON ¶
func (clpsar ClusterListPersistedScriptActionsResult) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterListPersistedScriptActionsResult.
type ClusterListResult ¶
type ClusterListResult struct { autorest.Response `json:"-"` // Value - The list of Clusters. Value *[]Cluster `json:"value,omitempty"` // NextLink - READ-ONLY; The link (url) to the next page of results. NextLink *string `json:"nextLink,omitempty"` }
ClusterListResult the List Cluster operation response.
func (ClusterListResult) IsEmpty ¶
func (clr ClusterListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
func (ClusterListResult) MarshalJSON ¶
func (clr ClusterListResult) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterListResult.
type ClusterListResultIterator ¶
type ClusterListResultIterator struct {
// contains filtered or unexported fields
}
ClusterListResultIterator provides access to a complete listing of Cluster values.
func NewClusterListResultIterator ¶
func NewClusterListResultIterator(page ClusterListResultPage) ClusterListResultIterator
Creates a new instance of the ClusterListResultIterator type.
func (*ClusterListResultIterator) Next ¶
func (iter *ClusterListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*ClusterListResultIterator) NextWithContext ¶
func (iter *ClusterListResultIterator) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (ClusterListResultIterator) NotDone ¶
func (iter ClusterListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (ClusterListResultIterator) Response ¶
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 NewClusterListResultPage ¶
func NewClusterListResultPage(cur ClusterListResult, getNextPage func(context.Context, ClusterListResult) (ClusterListResult, error)) ClusterListResultPage
Creates a new instance of the ClusterListResultPage type.
func (*ClusterListResultPage) Next ¶
func (page *ClusterListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*ClusterListResultPage) NextWithContext ¶
func (page *ClusterListResultPage) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (ClusterListResultPage) NotDone ¶
func (page ClusterListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (ClusterListResultPage) Response ¶
func (page ClusterListResultPage) Response() ClusterListResult
Response returns the raw server response from the last page request.
func (ClusterListResultPage) Values ¶
func (page ClusterListResultPage) Values() []Cluster
Values returns the slice of values for the current page or nil if there are no values.
type ClusterListRuntimeScriptActionDetailResult ¶
type ClusterListRuntimeScriptActionDetailResult struct { // Value - READ-ONLY; The list of persisted script action details for the cluster. Value *[]RuntimeScriptActionDetail `json:"value,omitempty"` // NextLink - READ-ONLY; The link (url) to the next page of results. NextLink *string `json:"nextLink,omitempty"` }
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 using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ClustersClient) Create ¶
func (client ClustersClient) Create(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterCreateParametersExtended) (result ClustersCreateFuture, err error)
Create creates a new HDInsight cluster with the specified parameters. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the cluster create request.
func (ClustersClient) CreatePreparer ¶
func (client ClustersClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterCreateParametersExtended) (*http.Request, error)
CreatePreparer prepares the Create request.
func (ClustersClient) CreateResponder ¶
func (client ClustersClient) CreateResponder(resp *http.Response) (result Cluster, err error)
CreateResponder handles the response to the Create request. The method always closes the http.Response Body.
func (ClustersClient) CreateSender ¶
func (client ClustersClient) CreateSender(req *http.Request) (future ClustersCreateFuture, err error)
CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Delete ¶
func (client ClustersClient) Delete(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDeleteFuture, err error)
Delete deletes the specified HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.
func (ClustersClient) DeletePreparer ¶
func (client ClustersClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ClustersClient) DeleteResponder ¶
func (client ClustersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (ClustersClient) DeleteSender ¶
func (client ClustersClient) DeleteSender(req *http.Request) (future ClustersDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) ExecuteScriptActions ¶
func (client ClustersClient) ExecuteScriptActions(ctx context.Context, resourceGroupName string, clusterName string, parameters ExecuteScriptActionParameters) (result ClustersExecuteScriptActionsFuture, err error)
ExecuteScriptActions executes script actions on the specified HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the parameters for executing script actions.
func (ClustersClient) ExecuteScriptActionsPreparer ¶
func (client ClustersClient) ExecuteScriptActionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ExecuteScriptActionParameters) (*http.Request, error)
ExecuteScriptActionsPreparer prepares the ExecuteScriptActions request.
func (ClustersClient) ExecuteScriptActionsResponder ¶
func (client ClustersClient) ExecuteScriptActionsResponder(resp *http.Response) (result autorest.Response, err error)
ExecuteScriptActionsResponder handles the response to the ExecuteScriptActions request. The method always closes the http.Response Body.
func (ClustersClient) ExecuteScriptActionsSender ¶
func (client ClustersClient) ExecuteScriptActionsSender(req *http.Request) (future ClustersExecuteScriptActionsFuture, err error)
ExecuteScriptActionsSender sends the ExecuteScriptActions request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Get ¶
func (client ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string) (result Cluster, err error)
Get gets the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.
func (ClustersClient) GetGatewaySettings ¶
func (client ClustersClient) GetGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string) (result GatewaySettings, err error)
GetGatewaySettings gets the gateway settings for the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.
func (ClustersClient) GetGatewaySettingsPreparer ¶
func (client ClustersClient) GetGatewaySettingsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
GetGatewaySettingsPreparer prepares the GetGatewaySettings request.
func (ClustersClient) GetGatewaySettingsResponder ¶
func (client ClustersClient) GetGatewaySettingsResponder(resp *http.Response) (result GatewaySettings, err error)
GetGatewaySettingsResponder handles the response to the GetGatewaySettings request. The method always closes the http.Response Body.
func (ClustersClient) GetGatewaySettingsSender ¶
GetGatewaySettingsSender sends the GetGatewaySettings request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) GetPreparer ¶
func (client ClustersClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (ClustersClient) GetResponder ¶
func (client ClustersClient) GetResponder(resp *http.Response) (result Cluster, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ClustersClient) GetSender ¶
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) RotateDiskEncryptionKey ¶
func (client ClustersClient) RotateDiskEncryptionKey(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterDiskEncryptionParameters) (result ClustersRotateDiskEncryptionKeyFuture, err error)
RotateDiskEncryptionKey rotate disk encryption key of the specified HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the parameters for the disk encryption operation.
func (ClustersClient) RotateDiskEncryptionKeyPreparer ¶
func (client ClustersClient) RotateDiskEncryptionKeyPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterDiskEncryptionParameters) (*http.Request, error)
RotateDiskEncryptionKeyPreparer prepares the RotateDiskEncryptionKey request.
func (ClustersClient) RotateDiskEncryptionKeyResponder ¶
func (client ClustersClient) RotateDiskEncryptionKeyResponder(resp *http.Response) (result autorest.Response, err error)
RotateDiskEncryptionKeyResponder handles the response to the RotateDiskEncryptionKey request. The method always closes the http.Response Body.
func (ClustersClient) RotateDiskEncryptionKeySender ¶
func (client ClustersClient) RotateDiskEncryptionKeySender(req *http.Request) (future ClustersRotateDiskEncryptionKeyFuture, err error)
RotateDiskEncryptionKeySender sends the RotateDiskEncryptionKey request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Update ¶
func (client ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterPatchParameters) (result Cluster, err error)
Update patch HDInsight cluster with the specified parameters. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the cluster patch request.
func (ClustersClient) UpdateAutoScaleConfiguration ¶
func (client ClustersClient) UpdateAutoScaleConfiguration(ctx context.Context, resourceGroupName string, clusterName string, parameters AutoscaleConfigurationUpdateParameter) (result ClustersUpdateAutoScaleConfigurationFuture, err error)
UpdateAutoScaleConfiguration updates the Autoscale Configuration for HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the parameters for the update autoscale configuration operation.
func (ClustersClient) UpdateAutoScaleConfigurationPreparer ¶
func (client ClustersClient) UpdateAutoScaleConfigurationPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters AutoscaleConfigurationUpdateParameter) (*http.Request, error)
UpdateAutoScaleConfigurationPreparer prepares the UpdateAutoScaleConfiguration request.
func (ClustersClient) UpdateAutoScaleConfigurationResponder ¶
func (client ClustersClient) UpdateAutoScaleConfigurationResponder(resp *http.Response) (result autorest.Response, err error)
UpdateAutoScaleConfigurationResponder handles the response to the UpdateAutoScaleConfiguration request. The method always closes the http.Response Body.
func (ClustersClient) UpdateAutoScaleConfigurationSender ¶
func (client ClustersClient) UpdateAutoScaleConfigurationSender(req *http.Request) (future ClustersUpdateAutoScaleConfigurationFuture, err error)
UpdateAutoScaleConfigurationSender sends the UpdateAutoScaleConfiguration request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) UpdateGatewaySettings ¶
func (client ClustersClient) UpdateGatewaySettings(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateGatewaySettingsParameters) (result ClustersUpdateGatewaySettingsFuture, err error)
UpdateGatewaySettings configures the gateway settings on the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. parameters - the cluster configurations.
func (ClustersClient) UpdateGatewaySettingsPreparer ¶
func (client ClustersClient) UpdateGatewaySettingsPreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters UpdateGatewaySettingsParameters) (*http.Request, error)
UpdateGatewaySettingsPreparer prepares the UpdateGatewaySettings request.
func (ClustersClient) UpdateGatewaySettingsResponder ¶
func (client ClustersClient) UpdateGatewaySettingsResponder(resp *http.Response) (result autorest.Response, err error)
UpdateGatewaySettingsResponder handles the response to the UpdateGatewaySettings request. The method always closes the http.Response Body.
func (ClustersClient) UpdateGatewaySettingsSender ¶
func (client ClustersClient) UpdateGatewaySettingsSender(req *http.Request) (future ClustersUpdateGatewaySettingsFuture, err error)
UpdateGatewaySettingsSender sends the UpdateGatewaySettings request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) 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 ¶
type ClustersCreateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (Cluster, error) }
ClustersCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ClustersDeleteFuture ¶
type ClustersDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ClustersExecuteScriptActionsFuture ¶
type ClustersExecuteScriptActionsFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersExecuteScriptActionsFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ClustersResizeFuture ¶
type ClustersResizeFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersResizeFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ClustersRotateDiskEncryptionKeyFuture ¶
type ClustersRotateDiskEncryptionKeyFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersRotateDiskEncryptionKeyFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ClustersUpdateAutoScaleConfigurationFuture ¶
type ClustersUpdateAutoScaleConfigurationFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersUpdateAutoScaleConfigurationFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ClustersUpdateGatewaySettingsFuture ¶
type ClustersUpdateGatewaySettingsFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersUpdateGatewaySettingsFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ComputeIsolationProperties ¶
type ComputeIsolationProperties struct { // EnableComputeIsolation - The flag indicates whether enable compute isolation or not. EnableComputeIsolation *bool `json:"enableComputeIsolation,omitempty"` // HostSku - The host sku. HostSku *string `json:"hostSku,omitempty"` }
ComputeIsolationProperties the compute isolation properties.
type ComputeProfile ¶
type ComputeProfile struct { // Roles - The list of roles in the cluster. Roles *[]Role `json:"roles,omitempty"` }
ComputeProfile describes the compute profile.
type ConfigurationsClient ¶
type ConfigurationsClient struct {
BaseClient
}
ConfigurationsClient is the hDInsight Management Client
func NewConfigurationsClient ¶
func NewConfigurationsClient(subscriptionID string) ConfigurationsClient
NewConfigurationsClient creates an instance of the ConfigurationsClient client.
func NewConfigurationsClientWithBaseURI ¶
func NewConfigurationsClientWithBaseURI(baseURI string, subscriptionID string) ConfigurationsClient
NewConfigurationsClientWithBaseURI creates an instance of the ConfigurationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ConfigurationsClient) Get ¶
func (client ConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, configurationName string) (result SetString, err error)
Get the configuration object for the specified cluster. This API is not recommended and might be removed in the future. Please consider using List configurations API instead. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. configurationName - the name of the cluster configuration.
func (ConfigurationsClient) GetPreparer ¶
func (client ConfigurationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, configurationName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (ConfigurationsClient) GetResponder ¶
func (client ConfigurationsClient) GetResponder(resp *http.Response) (result SetString, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ConfigurationsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (ConfigurationsClient) List ¶
func (client ConfigurationsClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterConfigurations, err error)
List gets all configuration information for an HDI cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.
func (ConfigurationsClient) ListPreparer ¶
func (client ConfigurationsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListPreparer prepares the List request.
func (ConfigurationsClient) ListResponder ¶
func (client ConfigurationsClient) ListResponder(resp *http.Response) (result ClusterConfigurations, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (ConfigurationsClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (ConfigurationsClient) Update ¶
func (client ConfigurationsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, parameters map[string]*string) (result ConfigurationsUpdateFuture, err error)
Update configures the HTTP settings on the specified cluster. This API is deprecated, please use UpdateGatewaySettings in cluster endpoint instead. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. configurationName - the name of the cluster configuration. parameters - the cluster configurations.
func (ConfigurationsClient) UpdatePreparer ¶
func (client ConfigurationsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, parameters map[string]*string) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (ConfigurationsClient) UpdateResponder ¶
func (client ConfigurationsClient) UpdateResponder(resp *http.Response) (result autorest.Response, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (ConfigurationsClient) UpdateSender ¶
func (client ConfigurationsClient) UpdateSender(req *http.Request) (future ConfigurationsUpdateFuture, err error)
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type ConfigurationsUpdateFuture ¶
type ConfigurationsUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ConfigurationsClient) (autorest.Response, error) }
ConfigurationsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
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 - READ-ONLY; ReadOnly. The storage account type. Do not set this value. StorageAccountType *string `json:"storageAccountType,omitempty"` // DiskSizeGB - READ-ONLY; ReadOnly. The DiskSize in GB. Do not set this value. DiskSizeGB *int32 `json:"diskSizeGB,omitempty"` }
DataDisksGroups the data disks groups for the role.
func (DataDisksGroups) MarshalJSON ¶
func (ddg DataDisksGroups) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for DataDisksGroups.
type DaysOfWeek ¶
type DaysOfWeek string
DaysOfWeek enumerates the values for days of week.
const ( // Friday ... Friday DaysOfWeek = "Friday" // Monday ... Monday DaysOfWeek = "Monday" // Saturday ... Saturday DaysOfWeek = "Saturday" // Sunday ... Sunday DaysOfWeek = "Sunday" // Thursday ... Thursday DaysOfWeek = "Thursday" // Tuesday ... Tuesday DaysOfWeek = "Tuesday" // Wednesday ... Wednesday DaysOfWeek = "Wednesday" )
func PossibleDaysOfWeekValues ¶
func PossibleDaysOfWeekValues() []DaysOfWeek
PossibleDaysOfWeekValues returns an array of possible values for the DaysOfWeek const type.
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 DiskBillingMeters ¶
type DiskBillingMeters struct { // DiskRpMeter - The managed disk meter guid. DiskRpMeter *string `json:"diskRpMeter,omitempty"` // Sku - The managed disk billing sku, P30 or S30. Sku *string `json:"sku,omitempty"` // Tier - The managed disk billing tier, Standard or Premium. Possible values include: 'Standard', 'Premium' Tier Tier `json:"tier,omitempty"` }
DiskBillingMeters the disk billing meters.
type DiskEncryptionProperties ¶
type DiskEncryptionProperties struct { // VaultURI - Base key vault URI where the customers key is located eg. https://myvault.vault.azure.net VaultURI *string `json:"vaultUri,omitempty"` // KeyName - Key name that is used for enabling disk encryption. KeyName *string `json:"keyName,omitempty"` // KeyVersion - Specific key version that is used for enabling disk encryption. KeyVersion *string `json:"keyVersion,omitempty"` // EncryptionAlgorithm - Algorithm identifier for encryption, default RSA-OAEP. Possible values include: 'RSAOAEP', 'RSAOAEP256', 'RSA15' EncryptionAlgorithm JSONWebKeyEncryptionAlgorithm `json:"encryptionAlgorithm,omitempty"` // MsiResourceID - Resource ID of Managed Identity that is used to access the key vault. MsiResourceID *string `json:"msiResourceId,omitempty"` // EncryptionAtHost - Indicates whether or not resource disk encryption is enabled. EncryptionAtHost *bool `json:"encryptionAtHost,omitempty"` }
DiskEncryptionProperties the disk encryption properties
type EncryptionInTransitProperties ¶
type EncryptionInTransitProperties struct { // IsEncryptionInTransitEnabled - Indicates whether or not inter cluster node communication is encrypted in transit. IsEncryptionInTransitEnabled *bool `json:"isEncryptionInTransitEnabled,omitempty"` }
EncryptionInTransitProperties the encryption-in-transit properties.
type ErrorResponse ¶
type ErrorResponse struct { // Code - Error code Code *string `json:"code,omitempty"` // Message - Error message indicating why the operation failed. Message *string `json:"message,omitempty"` }
ErrorResponse describes the format of Error response.
type Errors ¶
type Errors struct { // Code - The error code. Code *string `json:"code,omitempty"` // Message - The error message. Message *string `json:"message,omitempty"` }
Errors the error message associated with the cluster creation.
type 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 using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ExtensionsClient) Create ¶
func (client ExtensionsClient) Create(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, parameters Extension) (result ExtensionsCreateFuture, err error)
Create creates an HDInsight cluster extension. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. extensionName - the name of the cluster extension. parameters - the cluster extensions create request.
func (ExtensionsClient) CreatePreparer ¶
func (client ExtensionsClient) CreatePreparer(ctx context.Context, resourceGroupName string, clusterName string, extensionName string, parameters Extension) (*http.Request, error)
CreatePreparer prepares the Create request.
func (ExtensionsClient) CreateResponder ¶
func (client ExtensionsClient) CreateResponder(resp *http.Response) (result autorest.Response, err error)
CreateResponder handles the response to the Create request. The method always closes the http.Response Body.
func (ExtensionsClient) CreateSender ¶
func (client ExtensionsClient) CreateSender(req *http.Request) (future ExtensionsCreateFuture, err error)
CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.
func (ExtensionsClient) Delete ¶
func (client ExtensionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, extensionName string) (result ExtensionsDeleteFuture, err error)
Delete deletes the specified extension for HDInsight cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. extensionName - the name of the cluster extension.
func (ExtensionsClient) DeletePreparer ¶
func (client ExtensionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, extensionName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ExtensionsClient) DeleteResponder ¶
func (client ExtensionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (ExtensionsClient) DeleteSender ¶
func (client ExtensionsClient) DeleteSender(req *http.Request) (future ExtensionsDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (ExtensionsClient) 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 ¶
type ExtensionsCreateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ExtensionsClient) (autorest.Response, error) }
ExtensionsCreateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ExtensionsDeleteFuture ¶
type ExtensionsDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ExtensionsClient) (autorest.Response, error) }
ExtensionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ExtensionsDisableMonitoringFuture ¶
type ExtensionsDisableMonitoringFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ExtensionsClient) (autorest.Response, error) }
ExtensionsDisableMonitoringFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type ExtensionsEnableMonitoringFuture ¶
type ExtensionsEnableMonitoringFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ExtensionsClient) (autorest.Response, error) }
ExtensionsEnableMonitoringFuture an abstraction for monitoring and retrieving the results of a long-running operation.
type FilterMode ¶
type FilterMode string
FilterMode enumerates the values for filter mode.
const ( // Exclude ... Exclude FilterMode = "Exclude" // Include ... Include FilterMode = "Include" )
func PossibleFilterModeValues ¶
func PossibleFilterModeValues() []FilterMode
PossibleFilterModeValues returns an array of possible values for the FilterMode const type.
type GatewaySettings ¶
type GatewaySettings struct { autorest.Response `json:"-"` // IsCredentialEnabled - READ-ONLY; Indicates whether or not the gateway settings based authorization is enabled. IsCredentialEnabled *string `json:"restAuthCredential.isEnabled,omitempty"` // UserName - READ-ONLY; The gateway settings user name. UserName *string `json:"restAuthCredential.username,omitempty"` // Password - READ-ONLY; The gateway settings user password. Password *string `json:"restAuthCredential.password,omitempty"` }
GatewaySettings gateway settings.
type HardwareProfile ¶
type HardwareProfile struct { // VMSize - The size of the VM VMSize *string `json:"vmSize,omitempty"` }
HardwareProfile the hardware profile.
type HostInfo ¶
type HostInfo struct { // Name - The host name Name *string `json:"name,omitempty"` // Fqdn - The Fully Qualified Domain Name of host Fqdn *string `json:"fqdn,omitempty"` // EffectiveDiskEncryptionKeyURL - The effective disk encryption key URL used by the host EffectiveDiskEncryptionKeyURL *string `json:"effectiveDiskEncryptionKeyUrl,omitempty"` }
HostInfo the cluster host information.
type JSONWebKeyEncryptionAlgorithm ¶
type JSONWebKeyEncryptionAlgorithm string
JSONWebKeyEncryptionAlgorithm enumerates the values for json web key encryption algorithm.
const ( // RSA15 ... RSA15 JSONWebKeyEncryptionAlgorithm = "RSA1_5" // RSAOAEP ... RSAOAEP JSONWebKeyEncryptionAlgorithm = "RSA-OAEP" // RSAOAEP256 ... RSAOAEP256 JSONWebKeyEncryptionAlgorithm = "RSA-OAEP-256" )
func PossibleJSONWebKeyEncryptionAlgorithmValues ¶
func PossibleJSONWebKeyEncryptionAlgorithmValues() []JSONWebKeyEncryptionAlgorithm
PossibleJSONWebKeyEncryptionAlgorithmValues returns an array of possible values for the JSONWebKeyEncryptionAlgorithm const type.
type KafkaRestProperties ¶
type KafkaRestProperties struct { // ClientGroupInfo - The information of AAD security group. ClientGroupInfo *ClientGroupInfo `json:"clientGroupInfo,omitempty"` }
KafkaRestProperties the kafka rest proxy configuration which contains AAD security group information.
type LinuxOperatingSystemProfile ¶
type LinuxOperatingSystemProfile struct { // Username - The username. Username *string `json:"username,omitempty"` // Password - The password. Password *string `json:"password,omitempty"` // SSHProfile - The SSH profile. SSHProfile *SSHProfile `json:"sshProfile,omitempty"` }
LinuxOperatingSystemProfile the ssh username, password, and ssh public key.
type ListHostInfo ¶
type ListHostInfo struct { autorest.Response `json:"-"` Value *[]HostInfo `json:"value,omitempty"` }
ListHostInfo ...
type LocalizedName ¶
type LocalizedName struct { // Value - The name of the used resource. Value *string `json:"value,omitempty"` // LocalizedValue - The localized name of the used resource. LocalizedValue *string `json:"localizedValue,omitempty"` }
LocalizedName the details about the localizable name of a type of usage.
type LocationsClient ¶
type LocationsClient struct {
BaseClient
}
LocationsClient is the hDInsight Management Client
func NewLocationsClient ¶
func NewLocationsClient(subscriptionID string) LocationsClient
NewLocationsClient creates an instance of the LocationsClient client.
func NewLocationsClientWithBaseURI ¶
func NewLocationsClientWithBaseURI(baseURI string, subscriptionID string) LocationsClient
NewLocationsClientWithBaseURI creates an instance of the LocationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (LocationsClient) GetCapabilities ¶
func (client LocationsClient) GetCapabilities(ctx context.Context, location string) (result CapabilitiesResult, err error)
GetCapabilities gets the capabilities for the specified location. Parameters: location - the Azure location (region) for which to make the request.
func (LocationsClient) GetCapabilitiesPreparer ¶
func (client LocationsClient) GetCapabilitiesPreparer(ctx context.Context, location string) (*http.Request, error)
GetCapabilitiesPreparer prepares the GetCapabilities request.
func (LocationsClient) GetCapabilitiesResponder ¶
func (client LocationsClient) GetCapabilitiesResponder(resp *http.Response) (result CapabilitiesResult, err error)
GetCapabilitiesResponder handles the response to the GetCapabilities request. The method always closes the http.Response Body.
func (LocationsClient) GetCapabilitiesSender ¶
GetCapabilitiesSender sends the GetCapabilities request. The method will close the http.Response Body if it receives an error.
func (LocationsClient) ListBillingSpecs ¶
func (client LocationsClient) ListBillingSpecs(ctx context.Context, location string) (result BillingResponseListResult, err error)
ListBillingSpecs lists the billingSpecs for the specified subscription and location. Parameters: location - the Azure location (region) for which to make the request.
func (LocationsClient) ListBillingSpecsPreparer ¶
func (client LocationsClient) ListBillingSpecsPreparer(ctx context.Context, location string) (*http.Request, error)
ListBillingSpecsPreparer prepares the ListBillingSpecs request.
func (LocationsClient) ListBillingSpecsResponder ¶
func (client LocationsClient) ListBillingSpecsResponder(resp *http.Response) (result BillingResponseListResult, err error)
ListBillingSpecsResponder handles the response to the ListBillingSpecs request. The method always closes the http.Response Body.
func (LocationsClient) ListBillingSpecsSender ¶
ListBillingSpecsSender sends the ListBillingSpecs request. The method will close the http.Response Body if it receives an error.
func (LocationsClient) ListUsages ¶
func (client LocationsClient) ListUsages(ctx context.Context, location string) (result UsagesListResult, err error)
ListUsages lists the usages for the specified location. Parameters: location - the Azure location (region) for which to make the request.
func (LocationsClient) ListUsagesPreparer ¶
func (client LocationsClient) ListUsagesPreparer(ctx context.Context, location string) (*http.Request, error)
ListUsagesPreparer prepares the ListUsages request.
func (LocationsClient) ListUsagesResponder ¶
func (client LocationsClient) ListUsagesResponder(resp *http.Response) (result UsagesListResult, err error)
ListUsagesResponder handles the response to the ListUsages request. The method always closes the http.Response Body.
func (LocationsClient) ListUsagesSender ¶
ListUsagesSender sends the ListUsages request. The method will close the http.Response Body if it receives an error.
type NetworkProperties ¶
type NetworkProperties struct { // ResourceProviderConnection - The direction for the resource provider connection. Possible values include: 'Inbound', 'Outbound' ResourceProviderConnection ResourceProviderConnection `json:"resourceProviderConnection,omitempty"` // PrivateLink - Indicates whether or not private link is enabled. Possible values include: 'Disabled', 'Enabled' PrivateLink PrivateLink `json:"privateLink,omitempty"` }
NetworkProperties the network properties.
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 NewOperationListResultIterator ¶
func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator
Creates a new instance of the OperationListResultIterator type.
func (*OperationListResultIterator) Next ¶
func (iter *OperationListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*OperationListResultIterator) NextWithContext ¶
func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (OperationListResultIterator) NotDone ¶
func (iter OperationListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (OperationListResultIterator) Response ¶
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 NewOperationListResultPage ¶
func NewOperationListResultPage(cur OperationListResult, getNextPage func(context.Context, OperationListResult) (OperationListResult, error)) OperationListResultPage
Creates a new instance of the OperationListResultPage type.
func (*OperationListResultPage) Next ¶
func (page *OperationListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*OperationListResultPage) NextWithContext ¶
func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (OperationListResultPage) NotDone ¶
func (page OperationListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (OperationListResultPage) Response ¶
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 using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (OperationsClient) List ¶
func (client OperationsClient) List(ctx context.Context) (result OperationListResultPage, err error)
List lists all of the available HDInsight REST API operations.
func (OperationsClient) ListComplete ¶
func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (OperationsClient) ListPreparer ¶
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 PrivateLink ¶
type PrivateLink string
PrivateLink enumerates the values for private link.
const ( // Disabled ... Disabled PrivateLink = "Disabled" // Enabled ... Enabled PrivateLink = "Enabled" )
func PossiblePrivateLinkValues ¶
func PossiblePrivateLinkValues() []PrivateLink
PossiblePrivateLinkValues returns an array of possible values for the PrivateLink const type.
type ProxyResource ¶
type ProxyResource struct { // ID - READ-ONLY; Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. 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 QuotaCapability ¶
type QuotaCapability struct { // CoresUsed - The number of cores used in the subscription. CoresUsed *int64 `json:"cores_used,omitempty"` // MaxCoresAllowed - The number of cores that the subscription allowed. MaxCoresAllowed *int64 `json:"max_cores_allowed,omitempty"` // RegionalQuotas - The list of region quota capabilities. RegionalQuotas *[]RegionalQuotaCapability `json:"regionalQuotas,omitempty"` }
QuotaCapability the regional quota capability.
type QuotaInfo ¶
type QuotaInfo struct { // CoresUsed - The cores used by the cluster. CoresUsed *int32 `json:"coresUsed,omitempty"` }
QuotaInfo the quota properties for the cluster.
type RegionalQuotaCapability ¶
type RegionalQuotaCapability struct { // RegionName - The region name. RegionName *string `json:"region_name,omitempty"` // CoresUsed - The number of cores used in the region. CoresUsed *int64 `json:"cores_used,omitempty"` // CoresAvailable - The number of cores available in the region. CoresAvailable *int64 `json:"cores_available,omitempty"` }
RegionalQuotaCapability the regional quota capacity.
type RegionsCapability ¶
type RegionsCapability struct { // Available - The list of region capabilities. Available *[]string `json:"available,omitempty"` }
RegionsCapability the regions capability.
type Resource ¶
type Resource struct { // ID - READ-ONLY; Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. 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 ResourceProviderConnection ¶
type ResourceProviderConnection string
ResourceProviderConnection enumerates the values for resource provider connection.
const ( // Inbound ... Inbound ResourceProviderConnection = "Inbound" // Outbound ... Outbound ResourceProviderConnection = "Outbound" )
func PossibleResourceProviderConnectionValues ¶
func PossibleResourceProviderConnectionValues() []ResourceProviderConnection
PossibleResourceProviderConnectionValues returns an array of possible values for the ResourceProviderConnection const type.
type Role ¶
type Role struct { // Name - The name of the role. Name *string `json:"name,omitempty"` // MinInstanceCount - The minimum instance count of the cluster. MinInstanceCount *int32 `json:"minInstanceCount,omitempty"` // TargetInstanceCount - The instance count of the cluster. TargetInstanceCount *int32 `json:"targetInstanceCount,omitempty"` // AutoscaleConfiguration - The autoscale configurations. AutoscaleConfiguration *Autoscale `json:"autoscale,omitempty"` // HardwareProfile - The hardware profile. HardwareProfile *HardwareProfile `json:"hardwareProfile,omitempty"` // OsProfile - The operating system profile. OsProfile *OsProfile `json:"osProfile,omitempty"` // VirtualNetworkProfile - The virtual network profile. VirtualNetworkProfile *VirtualNetworkProfile `json:"virtualNetworkProfile,omitempty"` // DataDisksGroups - The data disks groups for the role. DataDisksGroups *[]DataDisksGroups `json:"dataDisksGroups,omitempty"` // ScriptActions - The list of script actions on the role. ScriptActions *[]ScriptAction `json:"scriptActions,omitempty"` }
Role describes a role on the cluster.
type RuntimeScriptAction ¶
type RuntimeScriptAction struct { // Name - The name of the script action. Name *string `json:"name,omitempty"` // URI - The URI to the script. URI *string `json:"uri,omitempty"` // Parameters - The parameters for the script Parameters *string `json:"parameters,omitempty"` // Roles - The list of roles where script will be executed. Roles *[]string `json:"roles,omitempty"` // ApplicationName - READ-ONLY; The application name of the script action, if any. ApplicationName *string `json:"applicationName,omitempty"` }
RuntimeScriptAction describes a script action on a running cluster.
func (RuntimeScriptAction) MarshalJSON ¶
func (rsaVar RuntimeScriptAction) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for RuntimeScriptAction.
type RuntimeScriptActionDetail ¶
type RuntimeScriptActionDetail struct { autorest.Response `json:"-"` // ScriptExecutionID - READ-ONLY; The execution id of the script action. ScriptExecutionID *int64 `json:"scriptExecutionId,omitempty"` // StartTime - READ-ONLY; The start time of script action execution. StartTime *string `json:"startTime,omitempty"` // EndTime - READ-ONLY; The end time of script action execution. EndTime *string `json:"endTime,omitempty"` // Status - READ-ONLY; The current execution status of the script action. Status *string `json:"status,omitempty"` // Operation - READ-ONLY; The reason why the script action was executed. Operation *string `json:"operation,omitempty"` // ExecutionSummary - READ-ONLY; The summary of script action execution result. ExecutionSummary *[]ScriptActionExecutionSummary `json:"executionSummary,omitempty"` // DebugInformation - READ-ONLY; The script action execution debug information. DebugInformation *string `json:"debugInformation,omitempty"` // Name - The name of the script action. Name *string `json:"name,omitempty"` // URI - The URI to the script. URI *string `json:"uri,omitempty"` // Parameters - The parameters for the script Parameters *string `json:"parameters,omitempty"` // Roles - The list of roles where script will be executed. Roles *[]string `json:"roles,omitempty"` // ApplicationName - READ-ONLY; The application name of the script action, if any. ApplicationName *string `json:"applicationName,omitempty"` }
RuntimeScriptActionDetail the execution details of a script action.
func (RuntimeScriptActionDetail) MarshalJSON ¶
func (rsad RuntimeScriptActionDetail) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for RuntimeScriptActionDetail.
type SSHProfile ¶
type SSHProfile struct { // PublicKeys - The list of SSH public keys. PublicKeys *[]SSHPublicKey `json:"publicKeys,omitempty"` }
SSHProfile the list of SSH public keys.
type SSHPublicKey ¶
type SSHPublicKey struct { // CertificateData - The certificate for SSH. CertificateData *string `json:"certificateData,omitempty"` }
SSHPublicKey the SSH public key for the cluster nodes.
type ScriptAction ¶
type ScriptAction struct { // Name - The name of the script action. Name *string `json:"name,omitempty"` // URI - The URI to the script. URI *string `json:"uri,omitempty"` // Parameters - The parameters for the script provided. Parameters *string `json:"parameters,omitempty"` }
ScriptAction describes a script action on role on the cluster.
type ScriptActionExecutionHistoryList ¶
type ScriptActionExecutionHistoryList struct { autorest.Response `json:"-"` // Value - READ-ONLY; The list of persisted script action details for the cluster. Value *[]RuntimeScriptActionDetail `json:"value,omitempty"` // NextLink - READ-ONLY; The link (url) to the next page of results. NextLink *string `json:"nextLink,omitempty"` }
ScriptActionExecutionHistoryList the list script execution history response.
func (ScriptActionExecutionHistoryList) IsEmpty ¶
func (saehl ScriptActionExecutionHistoryList) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type ScriptActionExecutionHistoryListIterator ¶
type ScriptActionExecutionHistoryListIterator struct {
// contains filtered or unexported fields
}
ScriptActionExecutionHistoryListIterator provides access to a complete listing of RuntimeScriptActionDetail values.
func NewScriptActionExecutionHistoryListIterator ¶
func NewScriptActionExecutionHistoryListIterator(page ScriptActionExecutionHistoryListPage) ScriptActionExecutionHistoryListIterator
Creates a new instance of the ScriptActionExecutionHistoryListIterator type.
func (*ScriptActionExecutionHistoryListIterator) Next ¶
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. Deprecated: Use NextWithContext() instead.
func (*ScriptActionExecutionHistoryListIterator) NextWithContext ¶
func (iter *ScriptActionExecutionHistoryListIterator) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (ScriptActionExecutionHistoryListIterator) NotDone ¶
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 NewScriptActionExecutionHistoryListPage ¶
func NewScriptActionExecutionHistoryListPage(cur ScriptActionExecutionHistoryList, getNextPage func(context.Context, ScriptActionExecutionHistoryList) (ScriptActionExecutionHistoryList, error)) ScriptActionExecutionHistoryListPage
Creates a new instance of the ScriptActionExecutionHistoryListPage type.
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. Deprecated: Use NextWithContext() instead.
func (*ScriptActionExecutionHistoryListPage) NextWithContext ¶
func (page *ScriptActionExecutionHistoryListPage) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (ScriptActionExecutionHistoryListPage) NotDone ¶
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 - READ-ONLY; The status of script action execution. Status *string `json:"status,omitempty"` // InstanceCount - READ-ONLY; The instance count for a given script action execution status. InstanceCount *int32 `json:"instanceCount,omitempty"` }
ScriptActionExecutionSummary the execution summary of a script action.
type ScriptActionPersistedGetResponseSpec ¶
type ScriptActionPersistedGetResponseSpec struct { // Name - The name of script action. Name *string `json:"name,omitempty"` // URI - The URI to the script. URI *string `json:"uri,omitempty"` // Parameters - The parameters for the script provided. Parameters *string `json:"parameters,omitempty"` // Roles - The list of roles where script will be executed. Roles *[]string `json:"roles,omitempty"` // ApplicationName - The application name for the script action. ApplicationName *string `json:"applicationName,omitempty"` }
ScriptActionPersistedGetResponseSpec the persisted script action for cluster.
type ScriptActionsClient ¶
type ScriptActionsClient struct {
BaseClient
}
ScriptActionsClient is the hDInsight Management Client
func NewScriptActionsClient ¶
func NewScriptActionsClient(subscriptionID string) ScriptActionsClient
NewScriptActionsClient creates an instance of the ScriptActionsClient client.
func NewScriptActionsClientWithBaseURI ¶
func NewScriptActionsClientWithBaseURI(baseURI string, subscriptionID string) ScriptActionsClient
NewScriptActionsClientWithBaseURI creates an instance of the ScriptActionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ScriptActionsClient) Delete ¶
func (client ScriptActionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, scriptName string) (result autorest.Response, err error)
Delete deletes a specified persisted script action of the cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. scriptName - the name of the script.
func (ScriptActionsClient) DeletePreparer ¶
func (client ScriptActionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, scriptName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ScriptActionsClient) DeleteResponder ¶
func (client ScriptActionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (ScriptActionsClient) DeleteSender ¶
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 - READ-ONLY; The link (url) to the next page of results. NextLink *string `json:"nextLink,omitempty"` }
ScriptActionsList the persisted script action for the cluster.
func (ScriptActionsList) IsEmpty ¶
func (sal ScriptActionsList) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
func (ScriptActionsList) MarshalJSON ¶
func (sal ScriptActionsList) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ScriptActionsList.
type ScriptActionsListIterator ¶
type ScriptActionsListIterator struct {
// contains filtered or unexported fields
}
ScriptActionsListIterator provides access to a complete listing of RuntimeScriptActionDetail values.
func NewScriptActionsListIterator ¶
func NewScriptActionsListIterator(page ScriptActionsListPage) ScriptActionsListIterator
Creates a new instance of the ScriptActionsListIterator type.
func (*ScriptActionsListIterator) Next ¶
func (iter *ScriptActionsListIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*ScriptActionsListIterator) NextWithContext ¶
func (iter *ScriptActionsListIterator) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (ScriptActionsListIterator) NotDone ¶
func (iter ScriptActionsListIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (ScriptActionsListIterator) Response ¶
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 NewScriptActionsListPage ¶
func NewScriptActionsListPage(cur ScriptActionsList, getNextPage func(context.Context, ScriptActionsList) (ScriptActionsList, error)) ScriptActionsListPage
Creates a new instance of the ScriptActionsListPage type.
func (*ScriptActionsListPage) Next ¶
func (page *ScriptActionsListPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*ScriptActionsListPage) NextWithContext ¶
func (page *ScriptActionsListPage) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (ScriptActionsListPage) NotDone ¶
func (page ScriptActionsListPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (ScriptActionsListPage) Response ¶
func (page ScriptActionsListPage) Response() ScriptActionsList
Response returns the raw server response from the last page request.
func (ScriptActionsListPage) Values ¶
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 using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ScriptExecutionHistoryClient) ListByCluster ¶
func (client ScriptExecutionHistoryClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionExecutionHistoryListPage, err error)
ListByCluster lists all scripts' execution history for the specified cluster. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.
func (ScriptExecutionHistoryClient) ListByClusterComplete ¶
func (client ScriptExecutionHistoryClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ScriptActionExecutionHistoryListIterator, err error)
ListByClusterComplete enumerates all values, automatically crossing page boundaries as required.
func (ScriptExecutionHistoryClient) ListByClusterPreparer ¶
func (client ScriptExecutionHistoryClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListByClusterPreparer prepares the ListByCluster request.
func (ScriptExecutionHistoryClient) ListByClusterResponder ¶
func (client ScriptExecutionHistoryClient) ListByClusterResponder(resp *http.Response) (result ScriptActionExecutionHistoryList, err error)
ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.
func (ScriptExecutionHistoryClient) ListByClusterSender ¶
func (client ScriptExecutionHistoryClient) ListByClusterSender(req *http.Request) (*http.Response, error)
ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.
func (ScriptExecutionHistoryClient) Promote ¶
func (client ScriptExecutionHistoryClient) Promote(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string) (result autorest.Response, err error)
Promote promotes the specified ad-hoc script execution to a persisted script. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. scriptExecutionID - the script execution Id
func (ScriptExecutionHistoryClient) PromotePreparer ¶
func (client ScriptExecutionHistoryClient) PromotePreparer(ctx context.Context, resourceGroupName string, clusterName string, scriptExecutionID string) (*http.Request, error)
PromotePreparer prepares the Promote request.
func (ScriptExecutionHistoryClient) PromoteResponder ¶
func (client ScriptExecutionHistoryClient) PromoteResponder(resp *http.Response) (result autorest.Response, err error)
PromoteResponder handles the response to the Promote request. The method always closes the http.Response Body.
func (ScriptExecutionHistoryClient) PromoteSender ¶
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 Gen 2. FileSystem *string `json:"fileSystem,omitempty"` // Key - The storage account access key. Key *string `json:"key,omitempty"` // ResourceID - The resource ID of storage account, only to be specified for Azure Data Lake Storage Gen 2. ResourceID *string `json:"resourceId,omitempty"` // MsiResourceID - The managed identity (MSI) that is allowed to access the storage account, only to be specified for Azure Data Lake Storage Gen 2. MsiResourceID *string `json:"msiResourceId,omitempty"` }
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 - READ-ONLY; Fully qualified resource Id for the resource. ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. 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 UpdateGatewaySettingsParameters ¶
type UpdateGatewaySettingsParameters struct { // IsCredentialEnabled - Indicates whether or not the gateway settings based authorization is enabled. IsCredentialEnabled *bool `json:"restAuthCredential.isEnabled,omitempty"` // UserName - The gateway settings user name. UserName *string `json:"restAuthCredential.username,omitempty"` // Password - The gateway settings user password. Password *string `json:"restAuthCredential.password,omitempty"` }
UpdateGatewaySettingsParameters the update gateway settings request parameters.
type Usage ¶
type Usage struct { // Unit - The type of measurement for usage. Unit *string `json:"unit,omitempty"` // CurrentValue - The current usage. CurrentValue *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 VMSizeCompatibilityFilter ¶
type VMSizeCompatibilityFilter struct { // FilterMode - The mode for the filter. FilterMode *string `json:"FilterMode,omitempty"` // Regions - The list of regions. Regions *[]string `json:"Regions,omitempty"` // ClusterFlavors - The list of cluster types available. ClusterFlavors *[]string `json:"ClusterFlavors,omitempty"` // NodeTypes - The list of node types. NodeTypes *[]string `json:"NodeTypes,omitempty"` // ClusterVersions - The list of cluster versions. ClusterVersions *[]string `json:"ClusterVersions,omitempty"` // Vmsizes - The list of virtual machine sizes. Vmsizes *[]string `json:"vmsizes,omitempty"` }
VMSizeCompatibilityFilter the virtual machine type compatibility filter.
type VMSizeCompatibilityFilterV2 ¶
type VMSizeCompatibilityFilterV2 struct { // FilterMode - The filtering mode. Effectively this can enabling or disabling the VM sizes in a particular set. Possible values include: 'Exclude', 'Include' FilterMode FilterMode `json:"filterMode,omitempty"` // Regions - The list of regions under the effect of the filter. Regions *[]string `json:"regions,omitempty"` // ClusterFlavors - The list of cluster flavors under the effect of the filter. ClusterFlavors *[]string `json:"clusterFlavors,omitempty"` // NodeTypes - The list of node types affected by the filter. NodeTypes *[]string `json:"nodeTypes,omitempty"` // ClusterVersions - The list of cluster versions affected in Major.Minor format. ClusterVersions *[]string `json:"clusterVersions,omitempty"` // OsType - The OSType affected, Windows or Linux. OsType *[]OSType `json:"osType,omitempty"` // VMSizes - The list of virtual machine sizes to include or exclude. VMSizes *[]string `json:"vmSizes,omitempty"` }
VMSizeCompatibilityFilterV2 this class represent a single filter object that defines a multidimensional set. The dimensions of this set are Regions, ClusterFlavors, NodeTypes and ClusterVersions. The constraint should be defined based on the following: FilterMode (Exclude vs Include), VMSizes (the vm sizes in affect of exclusion/inclusion) and the ordering of the Filters. Later filters override previous settings if conflicted.
type VMSizesCapability ¶
type VMSizesCapability struct { // Available - The list of virtual machine size capabilities. Available *[]string `json:"available,omitempty"` }
VMSizesCapability the virtual machine sizes capability.
type VersionSpec ¶
type VersionSpec struct { // FriendlyName - The friendly name FriendlyName *string `json:"friendlyName,omitempty"` // DisplayName - The display name DisplayName *string `json:"displayName,omitempty"` // IsDefault - Whether or not the version is the default version. IsDefault *string `json:"isDefault,omitempty"` // ComponentVersions - The component version property. ComponentVersions map[string]*string `json:"componentVersions"` }
VersionSpec the version properties.
func (VersionSpec) MarshalJSON ¶
func (vs VersionSpec) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for VersionSpec.
type VersionsCapability ¶
type VersionsCapability struct { // Available - The list of version capabilities. Available *[]VersionSpec `json:"available,omitempty"` }
VersionsCapability the version capability.
type VirtualMachinesClient ¶
type VirtualMachinesClient struct {
BaseClient
}
VirtualMachinesClient is the hDInsight Management Client
func NewVirtualMachinesClient ¶
func NewVirtualMachinesClient(subscriptionID string) VirtualMachinesClient
NewVirtualMachinesClient creates an instance of the VirtualMachinesClient client.
func NewVirtualMachinesClientWithBaseURI ¶
func NewVirtualMachinesClientWithBaseURI(baseURI string, subscriptionID string) VirtualMachinesClient
NewVirtualMachinesClientWithBaseURI creates an instance of the VirtualMachinesClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (VirtualMachinesClient) ListHosts ¶
func (client VirtualMachinesClient) ListHosts(ctx context.Context, resourceGroupName string, clusterName string) (result ListHostInfo, err error)
ListHosts lists the HDInsight clusters hosts Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster.
func (VirtualMachinesClient) ListHostsPreparer ¶
func (client VirtualMachinesClient) ListHostsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListHostsPreparer prepares the ListHosts request.
func (VirtualMachinesClient) ListHostsResponder ¶
func (client VirtualMachinesClient) ListHostsResponder(resp *http.Response) (result ListHostInfo, err error)
ListHostsResponder handles the response to the ListHosts request. The method always closes the http.Response Body.
func (VirtualMachinesClient) ListHostsSender ¶
ListHostsSender sends the ListHosts request. The method will close the http.Response Body if it receives an error.
func (VirtualMachinesClient) RestartHosts ¶
func (client VirtualMachinesClient) RestartHosts(ctx context.Context, resourceGroupName string, clusterName string, hosts []string) (result VirtualMachinesRestartHostsFuture, err error)
RestartHosts restarts the specified HDInsight cluster hosts. Parameters: resourceGroupName - the name of the resource group. clusterName - the name of the cluster. hosts - the list of hosts to restart
func (VirtualMachinesClient) RestartHostsPreparer ¶
func (client VirtualMachinesClient) RestartHostsPreparer(ctx context.Context, resourceGroupName string, clusterName string, hosts []string) (*http.Request, error)
RestartHostsPreparer prepares the RestartHosts request.
func (VirtualMachinesClient) RestartHostsResponder ¶
func (client VirtualMachinesClient) RestartHostsResponder(resp *http.Response) (result autorest.Response, err error)
RestartHostsResponder handles the response to the RestartHosts request. The method always closes the http.Response Body.
func (VirtualMachinesClient) RestartHostsSender ¶
func (client VirtualMachinesClient) RestartHostsSender(req *http.Request) (future VirtualMachinesRestartHostsFuture, err error)
RestartHostsSender sends the RestartHosts request. The method will close the http.Response Body if it receives an error.
type VirtualMachinesRestartHostsFuture ¶
type VirtualMachinesRestartHostsFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(VirtualMachinesClient) (autorest.Response, error) }
VirtualMachinesRestartHostsFuture an abstraction for monitoring and retrieving the results of a long-running operation.
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.