Versions in this module Expand all Collapse all v0 v0.13.3 Jul 20, 2023 v0.13.2 Jul 20, 2023 Changes in this version + func TrimLeadingWhitespace(commandStr string) (newCommand string) + type AddInstanceProfile struct + IamRoleArn string + InstanceProfileArn string + IsMetaInstanceProfile bool + SkipValidation bool + type AutoScale struct + MaxWorkers int + MinWorkers int + type AwsAttributes struct + Availability AwsAvailability + EbsVolumeCount int + EbsVolumeIops int + EbsVolumeSize int + EbsVolumeThroughput int + EbsVolumeType EbsVolumeType + FirstOnDemand int + InstanceProfileArn string + SpotBidPricePercent int + ZoneId string + type AwsAvailability string + const AwsAvailabilityOnDemand + const AwsAvailabilitySpot + const AwsAvailabilitySpotWithFallback + func (f *AwsAvailability) Set(v string) error + func (f *AwsAvailability) String() string + func (f *AwsAvailability) Type() string + type AzureAttributes struct + Availability AzureAvailability + FirstOnDemand int + LogAnalyticsInfo *LogAnalyticsInfo + SpotBidMaxPrice float64 + type AzureAvailability string + const AzureAvailabilityOnDemandAzure + const AzureAvailabilitySpotAzure + const AzureAvailabilitySpotWithFallbackAzure + func (f *AzureAvailability) Set(v string) error + func (f *AzureAvailability) String() string + func (f *AzureAvailability) Type() string + type CancelCommand struct + ClusterId string + CommandId string + ContextId string + type ChangeClusterOwner struct + ClusterId string + OwnerUsername string + type ClientsTypes struct + Jobs bool + Notebooks bool + type CloudProviderNodeInfo struct + Status []CloudProviderNodeStatus + type CloudProviderNodeStatus string + const CloudProviderNodeStatusNotAvailableInRegion + const CloudProviderNodeStatusNotEnabledOnSubscription + func (f *CloudProviderNodeStatus) Set(v string) error + func (f *CloudProviderNodeStatus) String() string + func (f *CloudProviderNodeStatus) Type() string + type ClusterAttributes struct + AutoterminationMinutes int + AwsAttributes *AwsAttributes + AzureAttributes *AzureAttributes + ClusterLogConf *ClusterLogConf + ClusterName string + ClusterSource ClusterSource + CustomTags map[string]string + DataSecurityMode DataSecurityMode + DockerImage *DockerImage + DriverInstancePoolId string + DriverNodeTypeId string + EnableElasticDisk bool + EnableLocalDiskEncryption bool + GcpAttributes *GcpAttributes + InitScripts []InitScriptInfo + InstancePoolId string + NodeTypeId string + PolicyId string + RuntimeEngine RuntimeEngine + SingleUserName string + SparkConf map[string]string + SparkEnvVars map[string]string + SparkVersion string + SshPublicKeys []string + WorkloadType *WorkloadType + type ClusterDetails struct + Autoscale *AutoScale + AutoterminationMinutes int + AwsAttributes *AwsAttributes + AzureAttributes *AzureAttributes + ClusterCores float64 + ClusterId string + ClusterLogConf *ClusterLogConf + ClusterLogStatus *LogSyncStatus + ClusterMemoryMb int64 + ClusterName string + ClusterSource ClusterSource + CreatorUserName string + CustomTags map[string]string + DataSecurityMode DataSecurityMode + DefaultTags map[string]string + DockerImage *DockerImage + Driver *SparkNode + DriverInstancePoolId string + DriverNodeTypeId string + EnableElasticDisk bool + EnableLocalDiskEncryption bool + Executors []SparkNode + GcpAttributes *GcpAttributes + InitScripts []InitScriptInfo + InstancePoolId string + JdbcPort int + LastRestartedTime int64 + LastStateLossTime int64 + NodeTypeId string + NumWorkers int + PolicyId string + RuntimeEngine RuntimeEngine + SingleUserName string + SparkConf map[string]string + SparkContextId int64 + SparkEnvVars map[string]string + SparkVersion string + SshPublicKeys []string + StartTime int64 + State State + StateMessage string + TerminatedTime int64 + TerminationReason *TerminationReason + WorkloadType *WorkloadType + func (c *ClusterDetails) IsRunningOrResizing() bool + type ClusterEvent struct + ClusterId string + DataPlaneEventDetails *DataPlaneEventDetails + Details *EventDetails + Timestamp int64 + Type EventType + type ClusterLibraryStatuses struct + ClusterId string + LibraryStatuses []LibraryFullStatus + func (cls ClusterLibraryStatuses) IsRetryNeeded(w Wait) (bool, error) + func (cls ClusterLibraryStatuses) ToLibraryList() InstallLibraries + type ClusterLogConf struct + Dbfs *DbfsStorageInfo + S3 *S3StorageInfo + type ClusterPoliciesAPI struct + func NewClusterPolicies(client *client.DatabricksClient) *ClusterPoliciesAPI + func (a *ClusterPoliciesAPI) Create(ctx context.Context, request CreatePolicy) (*CreatePolicyResponse, error) + func (a *ClusterPoliciesAPI) Delete(ctx context.Context, request DeletePolicy) error + func (a *ClusterPoliciesAPI) DeleteByPolicyId(ctx context.Context, policyId string) error + func (a *ClusterPoliciesAPI) Edit(ctx context.Context, request EditPolicy) error + func (a *ClusterPoliciesAPI) Get(ctx context.Context, request GetClusterPolicyRequest) (*Policy, error) + func (a *ClusterPoliciesAPI) GetByName(ctx context.Context, name string) (*Policy, error) + func (a *ClusterPoliciesAPI) GetByPolicyId(ctx context.Context, policyId string) (*Policy, error) + func (a *ClusterPoliciesAPI) Impl() ClusterPoliciesService + func (a *ClusterPoliciesAPI) ListAll(ctx context.Context, request ListClusterPoliciesRequest) ([]Policy, error) + func (a *ClusterPoliciesAPI) PolicyNameToPolicyIdMap(ctx context.Context, request ListClusterPoliciesRequest) (map[string]string, error) + func (a *ClusterPoliciesAPI) WithImpl(impl ClusterPoliciesService) *ClusterPoliciesAPI + type ClusterPoliciesService interface + Create func(ctx context.Context, request CreatePolicy) (*CreatePolicyResponse, error) + Delete func(ctx context.Context, request DeletePolicy) error + Edit func(ctx context.Context, request EditPolicy) error + Get func(ctx context.Context, request GetClusterPolicyRequest) (*Policy, error) + List func(ctx context.Context, request ListClusterPoliciesRequest) (*ListPoliciesResponse, error) + type ClusterSize struct + Autoscale *AutoScale + NumWorkers int + type ClusterSource string + const ClusterSourceApi + const ClusterSourceJob + const ClusterSourceModels + const ClusterSourcePipeline + const ClusterSourcePipelineMaintenance + const ClusterSourceSql + const ClusterSourceUi + func (f *ClusterSource) Set(v string) error + func (f *ClusterSource) String() string + func (f *ClusterSource) Type() string + type ClusterSpec struct + Autoscale *AutoScale + AutoterminationMinutes int + AwsAttributes *AwsAttributes + AzureAttributes *AzureAttributes + ClusterLogConf *ClusterLogConf + ClusterName string + ClusterSource ClusterSource + CustomTags map[string]string + DataSecurityMode DataSecurityMode + DockerImage *DockerImage + DriverInstancePoolId string + DriverNodeTypeId string + EnableElasticDisk bool + EnableLocalDiskEncryption bool + GcpAttributes *GcpAttributes + InitScripts []InitScriptInfo + InstancePoolId string + NodeTypeId string + NumWorkers int + PolicyId string + RuntimeEngine RuntimeEngine + SingleUserName string + SparkConf map[string]string + SparkEnvVars map[string]string + SparkVersion string + SshPublicKeys []string + WorkloadType *WorkloadType + type ClusterStatusRequest struct + ClusterId string + type ClustersAPI struct + func NewClusters(client *client.DatabricksClient) *ClustersAPI + func (a *ClustersAPI) ChangeOwner(ctx context.Context, request ChangeClusterOwner) error + func (a *ClustersAPI) ClusterDetailsClusterNameToClusterIdMap(ctx context.Context, request ListClustersRequest) (map[string]string, error) + func (a *ClustersAPI) Create(ctx context.Context, createCluster CreateCluster) (*WaitGetClusterRunning[CreateClusterResponse], error) + func (a *ClustersAPI) CreateAndWait(ctx context.Context, createCluster CreateCluster, ...) (*ClusterDetails, error) + func (a *ClustersAPI) Delete(ctx context.Context, deleteCluster DeleteCluster) (*WaitGetClusterTerminated[any], error) + func (a *ClustersAPI) DeleteAndWait(ctx context.Context, deleteCluster DeleteCluster, ...) (*ClusterDetails, error) + func (a *ClustersAPI) DeleteByClusterId(ctx context.Context, clusterId string) error + func (a *ClustersAPI) DeleteByClusterIdAndWait(ctx context.Context, clusterId string, ...) (*ClusterDetails, error) + func (a *ClustersAPI) Edit(ctx context.Context, editCluster EditCluster) (*WaitGetClusterRunning[any], error) + func (a *ClustersAPI) EditAndWait(ctx context.Context, editCluster EditCluster, ...) (*ClusterDetails, error) + func (a *ClustersAPI) EnsureClusterIsRunning(ctx context.Context, clusterId string) error + func (a *ClustersAPI) EventsAll(ctx context.Context, request GetEvents) ([]ClusterEvent, error) + func (a *ClustersAPI) Get(ctx context.Context, request GetClusterRequest) (*ClusterDetails, error) + func (a *ClustersAPI) GetByClusterId(ctx context.Context, clusterId string) (*ClusterDetails, error) + func (a *ClustersAPI) GetByClusterName(ctx context.Context, name string) (*ClusterDetails, error) + func (a *ClustersAPI) GetOrCreateRunningCluster(ctx context.Context, name string, custom ...CreateCluster) (c *ClusterDetails, err error) + func (a *ClustersAPI) Impl() ClustersService + func (a *ClustersAPI) ListAll(ctx context.Context, request ListClustersRequest) ([]ClusterDetails, error) + func (a *ClustersAPI) ListByCanUseClient(ctx context.Context, canUseClient string) (*ListClustersResponse, error) + func (a *ClustersAPI) ListNodeTypes(ctx context.Context) (*ListNodeTypesResponse, error) + func (a *ClustersAPI) ListZones(ctx context.Context) (*ListAvailableZonesResponse, error) + func (a *ClustersAPI) PermanentDelete(ctx context.Context, request PermanentDeleteCluster) error + func (a *ClustersAPI) PermanentDeleteByClusterId(ctx context.Context, clusterId string) error + func (a *ClustersAPI) Pin(ctx context.Context, request PinCluster) error + func (a *ClustersAPI) PinByClusterId(ctx context.Context, clusterId string) error + func (a *ClustersAPI) Resize(ctx context.Context, resizeCluster ResizeCluster) (*WaitGetClusterRunning[any], error) + func (a *ClustersAPI) ResizeAndWait(ctx context.Context, resizeCluster ResizeCluster, ...) (*ClusterDetails, error) + func (a *ClustersAPI) Restart(ctx context.Context, restartCluster RestartCluster) (*WaitGetClusterRunning[any], error) + func (a *ClustersAPI) RestartAndWait(ctx context.Context, restartCluster RestartCluster, ...) (*ClusterDetails, error) + func (a *ClustersAPI) SelectNodeType(ctx context.Context, r NodeTypeRequest) (string, error) + func (a *ClustersAPI) SelectSparkVersion(ctx context.Context, r SparkVersionRequest) (string, error) + func (a *ClustersAPI) SparkVersions(ctx context.Context) (*GetSparkVersionsResponse, error) + func (a *ClustersAPI) Start(ctx context.Context, startCluster StartCluster) (*WaitGetClusterRunning[any], error) + func (a *ClustersAPI) StartAndWait(ctx context.Context, startCluster StartCluster, ...) (*ClusterDetails, error) + func (a *ClustersAPI) StartByClusterId(ctx context.Context, clusterId string) error + func (a *ClustersAPI) StartByClusterIdAndWait(ctx context.Context, clusterId string, ...) (*ClusterDetails, error) + func (a *ClustersAPI) Unpin(ctx context.Context, request UnpinCluster) error + func (a *ClustersAPI) UnpinByClusterId(ctx context.Context, clusterId string) error + func (a *ClustersAPI) WaitGetClusterRunning(ctx context.Context, clusterId string, timeout time.Duration, ...) (*ClusterDetails, error) + func (a *ClustersAPI) WaitGetClusterTerminated(ctx context.Context, clusterId string, timeout time.Duration, ...) (*ClusterDetails, error) + func (a *ClustersAPI) WithImpl(impl ClustersService) *ClustersAPI + type ClustersService interface + ChangeOwner func(ctx context.Context, request ChangeClusterOwner) error + Create func(ctx context.Context, request CreateCluster) (*CreateClusterResponse, error) + Delete func(ctx context.Context, request DeleteCluster) error + Edit func(ctx context.Context, request EditCluster) error + Events func(ctx context.Context, request GetEvents) (*GetEventsResponse, error) + Get func(ctx context.Context, request GetClusterRequest) (*ClusterDetails, error) + List func(ctx context.Context, request ListClustersRequest) (*ListClustersResponse, error) + ListNodeTypes func(ctx context.Context) (*ListNodeTypesResponse, error) + ListZones func(ctx context.Context) (*ListAvailableZonesResponse, error) + PermanentDelete func(ctx context.Context, request PermanentDeleteCluster) error + Pin func(ctx context.Context, request PinCluster) error + Resize func(ctx context.Context, request ResizeCluster) error + Restart func(ctx context.Context, request RestartCluster) error + SparkVersions func(ctx context.Context) (*GetSparkVersionsResponse, error) + Start func(ctx context.Context, request StartCluster) error + Unpin func(ctx context.Context, request UnpinCluster) error + type Command struct + ClusterId string + Command string + ContextId string + Language Language + type CommandExecutionAPI struct + func NewCommandExecution(client *client.DatabricksClient) *CommandExecutionAPI + func (a *CommandExecutionAPI) Cancel(ctx context.Context, cancelCommand CancelCommand) (*WaitCommandStatusCommandExecutionCancelled[any], error) + func (a *CommandExecutionAPI) CancelAndWait(ctx context.Context, cancelCommand CancelCommand, ...) (*CommandStatusResponse, error) + func (a *CommandExecutionAPI) CommandStatus(ctx context.Context, request CommandStatusRequest) (*CommandStatusResponse, error) + func (a *CommandExecutionAPI) ContextStatus(ctx context.Context, request ContextStatusRequest) (*ContextStatusResponse, error) + func (a *CommandExecutionAPI) Create(ctx context.Context, createContext CreateContext) (*WaitContextStatusCommandExecutionRunning[Created], error) + func (a *CommandExecutionAPI) CreateAndWait(ctx context.Context, createContext CreateContext, ...) (*ContextStatusResponse, error) + func (a *CommandExecutionAPI) Destroy(ctx context.Context, request DestroyContext) error + func (a *CommandExecutionAPI) Execute(ctx context.Context, command Command) (*WaitCommandStatusCommandExecutionFinishedOrError[Created], error) + func (a *CommandExecutionAPI) ExecuteAndWait(ctx context.Context, command Command, ...) (*CommandStatusResponse, error) + func (a *CommandExecutionAPI) Impl() CommandExecutionService + func (a *CommandExecutionAPI) Start(ctx context.Context, clusterID string, language Language) (*CommandExecutorV2, error) + func (a *CommandExecutionAPI) WaitCommandStatusCommandExecutionCancelled(ctx context.Context, clusterId string, commandId string, contextId string, ...) (*CommandStatusResponse, error) + func (a *CommandExecutionAPI) WaitCommandStatusCommandExecutionFinishedOrError(ctx context.Context, clusterId string, commandId string, contextId string, ...) (*CommandStatusResponse, error) + func (a *CommandExecutionAPI) WaitContextStatusCommandExecutionRunning(ctx context.Context, clusterId string, contextId string, timeout time.Duration, ...) (*ContextStatusResponse, error) + func (a *CommandExecutionAPI) WithImpl(impl CommandExecutionService) *CommandExecutionAPI + type CommandExecutionService interface + Cancel func(ctx context.Context, request CancelCommand) error + CommandStatus func(ctx context.Context, request CommandStatusRequest) (*CommandStatusResponse, error) + ContextStatus func(ctx context.Context, request ContextStatusRequest) (*ContextStatusResponse, error) + Create func(ctx context.Context, request CreateContext) (*Created, error) + Destroy func(ctx context.Context, request DestroyContext) error + Execute func(ctx context.Context, request Command) (*Created, error) + type CommandExecutor interface + Execute func(ctx context.Context, clusterID, language, commandStr string) Results + func NewCommandExecutor(client *client.DatabricksClient) CommandExecutor + type CommandExecutorV2 struct + func (c *CommandExecutorV2) Destroy(ctx context.Context) error + func (c *CommandExecutorV2) Execute(ctx context.Context, command string) (*Results, error) + type CommandMock func(commandStr string) Results + func (m CommandMock) Execute(_ context.Context, _, _, commandStr string) Results + type CommandStatus string + const CommandStatusCancelled + const CommandStatusCancelling + const CommandStatusError + const CommandStatusFinished + const CommandStatusQueued + const CommandStatusRunning + func (f *CommandStatus) Set(v string) error + func (f *CommandStatus) String() string + func (f *CommandStatus) Type() string + type CommandStatusRequest struct + ClusterId string + CommandId string + ContextId string + type CommandStatusResponse struct + Id string + Results *Results + Status CommandStatus + type CommandsHighLevelAPI struct + func (a *CommandsHighLevelAPI) Execute(ctx context.Context, clusterID, language, commandStr string) Results + type ComputeSpec struct + Kind ComputeSpecKind + type ComputeSpecKind string + const ComputeSpecKindServerlessPreview + func (f *ComputeSpecKind) Set(v string) error + func (f *ComputeSpecKind) String() string + func (f *ComputeSpecKind) Type() string + type ContextStatus string + const ContextStatusError + const ContextStatusPending + const ContextStatusRunning + func (f *ContextStatus) Set(v string) error + func (f *ContextStatus) String() string + func (f *ContextStatus) Type() string + type ContextStatusRequest struct + ClusterId string + ContextId string + type ContextStatusResponse struct + Id string + Status ContextStatus + type CreateCluster struct + ApplyPolicyDefaultValues bool + Autoscale *AutoScale + AutoterminationMinutes int + AwsAttributes *AwsAttributes + AzureAttributes *AzureAttributes + ClusterLogConf *ClusterLogConf + ClusterName string + ClusterSource ClusterSource + CustomTags map[string]string + DriverInstancePoolId string + DriverNodeTypeId string + EnableElasticDisk bool + EnableLocalDiskEncryption bool + GcpAttributes *GcpAttributes + InitScripts []InitScriptInfo + InstancePoolId string + NodeTypeId string + NumWorkers int + PolicyId string + RuntimeEngine RuntimeEngine + SparkConf map[string]string + SparkEnvVars map[string]string + SparkVersion string + SshPublicKeys []string + WorkloadType *WorkloadType + type CreateClusterResponse struct + ClusterId string + type CreateContext struct + ClusterId string + Language Language + type CreateInstancePool struct + AwsAttributes *InstancePoolAwsAttributes + AzureAttributes *InstancePoolAzureAttributes + CustomTags map[string]string + DiskSpec *DiskSpec + EnableElasticDisk bool + GcpAttributes *InstancePoolGcpAttributes + IdleInstanceAutoterminationMinutes int + InstancePoolFleetAttributes *InstancePoolFleetAttributes + InstancePoolName string + MaxCapacity int + MinIdleInstances int + NodeTypeId string + PreloadedDockerImages []DockerImage + PreloadedSparkVersions []string + type CreateInstancePoolResponse struct + InstancePoolId string + type CreatePolicy struct + Definition string + Description string + MaxClustersPerUser int64 + Name string + PolicyFamilyDefinitionOverrides string + PolicyFamilyId string + type CreatePolicyResponse struct + PolicyId string + type CreateResponse struct + ScriptId string + type Created struct + Id string + type DataPlaneEventDetails struct + EventType DataPlaneEventDetailsEventType + ExecutorFailures int + HostId string + Timestamp int64 + type DataPlaneEventDetailsEventType string + const DataPlaneEventDetailsEventTypeNodeBlacklisted + const DataPlaneEventDetailsEventTypeNodeExcludedDecommissioned + func (f *DataPlaneEventDetailsEventType) Set(v string) error + func (f *DataPlaneEventDetailsEventType) String() string + func (f *DataPlaneEventDetailsEventType) Type() string + type DataSecurityMode string + const DataSecurityModeLegacyPassthrough + const DataSecurityModeLegacySingleUser + const DataSecurityModeLegacyTableAcl + const DataSecurityModeNone + const DataSecurityModeSingleUser + const DataSecurityModeUserIsolation + func (f *DataSecurityMode) Set(v string) error + func (f *DataSecurityMode) String() string + func (f *DataSecurityMode) Type() string + type DbfsStorageInfo struct + Destination string + type DeleteCluster struct + ClusterId string + type DeleteGlobalInitScriptRequest struct + ScriptId string + type DeleteInstancePool struct + InstancePoolId string + type DeletePolicy struct + PolicyId string + type DestroyContext struct + ClusterId string + ContextId string + type DiskSpec struct + DiskCount int + DiskIops int + DiskSize int + DiskThroughput int + DiskType *DiskType + type DiskType struct + AzureDiskVolumeType DiskTypeAzureDiskVolumeType + EbsVolumeType DiskTypeEbsVolumeType + type DiskTypeAzureDiskVolumeType string + const DiskTypeAzureDiskVolumeTypePremiumLrs + const DiskTypeAzureDiskVolumeTypeStandardLrs + func (f *DiskTypeAzureDiskVolumeType) Set(v string) error + func (f *DiskTypeAzureDiskVolumeType) String() string + func (f *DiskTypeAzureDiskVolumeType) Type() string + type DiskTypeEbsVolumeType string + const DiskTypeEbsVolumeTypeGeneralPurposeSsd + const DiskTypeEbsVolumeTypeThroughputOptimizedHdd + func (f *DiskTypeEbsVolumeType) Set(v string) error + func (f *DiskTypeEbsVolumeType) String() string + func (f *DiskTypeEbsVolumeType) Type() string + type DockerBasicAuth struct + Password string + Username string + type DockerImage struct + BasicAuth *DockerBasicAuth + Url string + type EbsVolumeType string + const EbsVolumeTypeGeneralPurposeSsd + const EbsVolumeTypeThroughputOptimizedHdd + func (f *EbsVolumeType) Set(v string) error + func (f *EbsVolumeType) String() string + func (f *EbsVolumeType) Type() string + type EditCluster struct + ApplyPolicyDefaultValues bool + Autoscale *AutoScale + AutoterminationMinutes int + AwsAttributes *AwsAttributes + AzureAttributes *AzureAttributes + ClusterId string + ClusterLogConf *ClusterLogConf + ClusterName string + ClusterSource ClusterSource + CustomTags map[string]string + DataSecurityMode DataSecurityMode + DockerImage *DockerImage + DriverInstancePoolId string + DriverNodeTypeId string + EnableElasticDisk bool + EnableLocalDiskEncryption bool + GcpAttributes *GcpAttributes + InitScripts []InitScriptInfo + InstancePoolId string + NodeTypeId string + NumWorkers int + PolicyId string + RuntimeEngine RuntimeEngine + SingleUserName string + SparkConf map[string]string + SparkEnvVars map[string]string + SparkVersion string + SshPublicKeys []string + WorkloadType *WorkloadType + type EditInstancePool struct + AwsAttributes *InstancePoolAwsAttributes + AzureAttributes *InstancePoolAzureAttributes + CustomTags map[string]string + DiskSpec *DiskSpec + EnableElasticDisk bool + GcpAttributes *InstancePoolGcpAttributes + IdleInstanceAutoterminationMinutes int + InstancePoolFleetAttributes *InstancePoolFleetAttributes + InstancePoolId string + InstancePoolName string + MaxCapacity int + MinIdleInstances int + NodeTypeId string + PreloadedDockerImages []DockerImage + PreloadedSparkVersions []string + type EditPolicy struct + Definition string + Description string + MaxClustersPerUser int64 + Name string + PolicyFamilyDefinitionOverrides string + PolicyFamilyId string + PolicyId string + type EventDetails struct + Attributes *ClusterAttributes + Cause EventDetailsCause + ClusterSize *ClusterSize + CurrentNumVcpus int + CurrentNumWorkers int + DidNotExpandReason string + DiskSize int64 + DriverStateMessage string + EnableTerminationForNodeBlocklisted bool + FreeSpace int64 + InstanceId string + JobRunName string + PreviousAttributes *ClusterAttributes + PreviousClusterSize *ClusterSize + PreviousDiskSize int64 + Reason *TerminationReason + TargetNumVcpus int + TargetNumWorkers int + User string + type EventDetailsCause string + const EventDetailsCauseAutorecovery + const EventDetailsCauseAutoscale + const EventDetailsCauseReplaceBadNodes + const EventDetailsCauseUserRequest + func (f *EventDetailsCause) Set(v string) error + func (f *EventDetailsCause) String() string + func (f *EventDetailsCause) Type() string + type EventType string + const EventTypeAutoscalingStatsReport + const EventTypeCreating + const EventTypeDbfsDown + const EventTypeDidNotExpandDisk + const EventTypeDriverHealthy + const EventTypeDriverNotResponding + const EventTypeDriverUnavailable + const EventTypeEdited + const EventTypeExpandedDisk + const EventTypeFailedToExpandDisk + const EventTypeInitScriptsFinished + const EventTypeInitScriptsStarted + const EventTypeMetastoreDown + const EventTypeNodeBlacklisted + const EventTypeNodeExcludedDecommissioned + const EventTypeNodesLost + const EventTypePinned + const EventTypeResizing + const EventTypeRestarting + const EventTypeRunning + const EventTypeSparkException + const EventTypeStarting + const EventTypeTerminating + const EventTypeUnpinned + const EventTypeUpsizeCompleted + func (f *EventType) Set(v string) error + func (f *EventType) String() string + func (f *EventType) Type() string + type FleetLaunchTemplateOverride struct + AvailabilityZone string + InstanceType string + MaxPrice float64 + Priority float64 + type FleetOnDemandOption struct + AllocationStrategy FleetOnDemandOptionAllocationStrategy + MaxTotalPrice float64 + UseCapacityReservationsFirst bool + type FleetOnDemandOptionAllocationStrategy string + const FleetOnDemandOptionAllocationStrategyCapacityOptimized + const FleetOnDemandOptionAllocationStrategyDiversified + const FleetOnDemandOptionAllocationStrategyLowestPrice + const FleetOnDemandOptionAllocationStrategyPrioritized + func (f *FleetOnDemandOptionAllocationStrategy) Set(v string) error + func (f *FleetOnDemandOptionAllocationStrategy) String() string + func (f *FleetOnDemandOptionAllocationStrategy) Type() string + type FleetSpotOption struct + AllocationStrategy FleetSpotOptionAllocationStrategy + InstancePoolsToUseCount int + MaxTotalPrice float64 + type FleetSpotOptionAllocationStrategy string + const FleetSpotOptionAllocationStrategyCapacityOptimized + const FleetSpotOptionAllocationStrategyDiversified + const FleetSpotOptionAllocationStrategyLowestPrice + const FleetSpotOptionAllocationStrategyPrioritized + func (f *FleetSpotOptionAllocationStrategy) Set(v string) error + func (f *FleetSpotOptionAllocationStrategy) String() string + func (f *FleetSpotOptionAllocationStrategy) Type() string + type GcpAttributes struct + Availability GcpAvailability + BootDiskSize int + GoogleServiceAccount string + LocalSsdCount int + type GcpAvailability string + const GcpAvailabilityOnDemandGcp + const GcpAvailabilityPreemptibleGcp + const GcpAvailabilityPreemptibleWithFallbackGcp + func (f *GcpAvailability) Set(v string) error + func (f *GcpAvailability) String() string + func (f *GcpAvailability) Type() string + type GetClusterPolicyRequest struct + PolicyId string + type GetClusterRequest struct + ClusterId string + type GetEvents struct + ClusterId string + EndTime int64 + EventTypes []EventType + Limit int64 + Offset int64 + Order GetEventsOrder + StartTime int64 + type GetEventsOrder string + const GetEventsOrderAsc + const GetEventsOrderDesc + func (f *GetEventsOrder) Set(v string) error + func (f *GetEventsOrder) String() string + func (f *GetEventsOrder) Type() string + type GetEventsResponse struct + Events []ClusterEvent + NextPage *GetEvents + TotalCount int64 + type GetGlobalInitScriptRequest struct + ScriptId string + type GetInstancePool struct + AwsAttributes *InstancePoolAwsAttributes + AzureAttributes *InstancePoolAzureAttributes + CustomTags map[string]string + DefaultTags map[string]string + DiskSpec *DiskSpec + EnableElasticDisk bool + GcpAttributes *InstancePoolGcpAttributes + IdleInstanceAutoterminationMinutes int + InstancePoolFleetAttributes *InstancePoolFleetAttributes + InstancePoolId string + InstancePoolName string + MaxCapacity int + MinIdleInstances int + NodeTypeId string + PreloadedDockerImages []DockerImage + PreloadedSparkVersions []string + State InstancePoolState + Stats *InstancePoolStats + Status *InstancePoolStatus + type GetInstancePoolRequest struct + InstancePoolId string + type GetPolicyFamilyRequest struct + PolicyFamilyId string + type GetSparkVersionsResponse struct + Versions []SparkVersion + func (sv GetSparkVersionsResponse) Select(req SparkVersionRequest) (string, error) + type GlobalInitScriptCreateRequest struct + Enabled bool + Name string + Position int + Script string + type GlobalInitScriptDetails struct + CreatedAt int + CreatedBy string + Enabled bool + Name string + Position int + ScriptId string + UpdatedAt int + UpdatedBy string + type GlobalInitScriptDetailsWithContent struct + CreatedAt int + CreatedBy string + Enabled bool + Name string + Position int + Script string + ScriptId string + UpdatedAt int + UpdatedBy string + type GlobalInitScriptUpdateRequest struct + Enabled bool + Name string + Position int + Script string + ScriptId string + type GlobalInitScriptsAPI struct + func NewGlobalInitScripts(client *client.DatabricksClient) *GlobalInitScriptsAPI + func (a *GlobalInitScriptsAPI) Create(ctx context.Context, request GlobalInitScriptCreateRequest) (*CreateResponse, error) + func (a *GlobalInitScriptsAPI) Delete(ctx context.Context, request DeleteGlobalInitScriptRequest) error + func (a *GlobalInitScriptsAPI) DeleteByScriptId(ctx context.Context, scriptId string) error + func (a *GlobalInitScriptsAPI) Get(ctx context.Context, request GetGlobalInitScriptRequest) (*GlobalInitScriptDetailsWithContent, error) + func (a *GlobalInitScriptsAPI) GetByName(ctx context.Context, name string) (*GlobalInitScriptDetails, error) + func (a *GlobalInitScriptsAPI) GetByScriptId(ctx context.Context, scriptId string) (*GlobalInitScriptDetailsWithContent, error) + func (a *GlobalInitScriptsAPI) GlobalInitScriptDetailsNameToScriptIdMap(ctx context.Context) (map[string]string, error) + func (a *GlobalInitScriptsAPI) Impl() GlobalInitScriptsService + func (a *GlobalInitScriptsAPI) ListAll(ctx context.Context) ([]GlobalInitScriptDetails, error) + func (a *GlobalInitScriptsAPI) Update(ctx context.Context, request GlobalInitScriptUpdateRequest) error + func (a *GlobalInitScriptsAPI) WithImpl(impl GlobalInitScriptsService) *GlobalInitScriptsAPI + type GlobalInitScriptsService interface + Create func(ctx context.Context, request GlobalInitScriptCreateRequest) (*CreateResponse, error) + Delete func(ctx context.Context, request DeleteGlobalInitScriptRequest) error + Get func(ctx context.Context, request GetGlobalInitScriptRequest) (*GlobalInitScriptDetailsWithContent, error) + List func(ctx context.Context) (*ListGlobalInitScriptsResponse, error) + Update func(ctx context.Context, request GlobalInitScriptUpdateRequest) error + type InitScriptInfo struct + Dbfs *DbfsStorageInfo + S3 *S3StorageInfo + Workspace *WorkspaceStorageInfo + type InstallLibraries struct + ClusterId string + Libraries []Library + func (cll *InstallLibraries) Sort() + type InstancePoolAndStats struct + AwsAttributes *InstancePoolAwsAttributes + AzureAttributes *InstancePoolAzureAttributes + CustomTags map[string]string + DefaultTags map[string]string + DiskSpec *DiskSpec + EnableElasticDisk bool + GcpAttributes *InstancePoolGcpAttributes + IdleInstanceAutoterminationMinutes int + InstancePoolFleetAttributes *InstancePoolFleetAttributes + InstancePoolId string + InstancePoolName string + MaxCapacity int + MinIdleInstances int + NodeTypeId string + PreloadedDockerImages []DockerImage + PreloadedSparkVersions []string + State InstancePoolState + Stats *InstancePoolStats + Status *InstancePoolStatus + type InstancePoolAwsAttributes struct + Availability InstancePoolAwsAttributesAvailability + SpotBidPricePercent int + ZoneId string + type InstancePoolAwsAttributesAvailability string + const InstancePoolAwsAttributesAvailabilityOnDemand + const InstancePoolAwsAttributesAvailabilitySpot + const InstancePoolAwsAttributesAvailabilitySpotWithFallback + func (f *InstancePoolAwsAttributesAvailability) Set(v string) error + func (f *InstancePoolAwsAttributesAvailability) String() string + func (f *InstancePoolAwsAttributesAvailability) Type() string + type InstancePoolAzureAttributes struct + Availability InstancePoolAzureAttributesAvailability + SpotBidMaxPrice float64 + type InstancePoolAzureAttributesAvailability string + const InstancePoolAzureAttributesAvailabilityOnDemandAzure + const InstancePoolAzureAttributesAvailabilitySpotAzure + const InstancePoolAzureAttributesAvailabilitySpotWithFallbackAzure + func (f *InstancePoolAzureAttributesAvailability) Set(v string) error + func (f *InstancePoolAzureAttributesAvailability) String() string + func (f *InstancePoolAzureAttributesAvailability) Type() string + type InstancePoolFleetAttributes struct + FleetOnDemandOption *FleetOnDemandOption + FleetSpotOption *FleetSpotOption + LaunchTemplateOverrides []FleetLaunchTemplateOverride + type InstancePoolGcpAttributes struct + GcpAvailability GcpAvailability + LocalSsdCount int + type InstancePoolState string + const InstancePoolStateActive + const InstancePoolStateDeleted + const InstancePoolStateStopped + func (f *InstancePoolState) Set(v string) error + func (f *InstancePoolState) String() string + func (f *InstancePoolState) Type() string + type InstancePoolStats struct + IdleCount int + PendingIdleCount int + PendingUsedCount int + UsedCount int + type InstancePoolStatus struct + PendingInstanceErrors []PendingInstanceError + type InstancePoolsAPI struct + func NewInstancePools(client *client.DatabricksClient) *InstancePoolsAPI + func (a *InstancePoolsAPI) Create(ctx context.Context, request CreateInstancePool) (*CreateInstancePoolResponse, error) + func (a *InstancePoolsAPI) Delete(ctx context.Context, request DeleteInstancePool) error + func (a *InstancePoolsAPI) DeleteByInstancePoolId(ctx context.Context, instancePoolId string) error + func (a *InstancePoolsAPI) Edit(ctx context.Context, request EditInstancePool) error + func (a *InstancePoolsAPI) Get(ctx context.Context, request GetInstancePoolRequest) (*GetInstancePool, error) + func (a *InstancePoolsAPI) GetByInstancePoolId(ctx context.Context, instancePoolId string) (*GetInstancePool, error) + func (a *InstancePoolsAPI) GetByInstancePoolName(ctx context.Context, name string) (*InstancePoolAndStats, error) + func (a *InstancePoolsAPI) Impl() InstancePoolsService + func (a *InstancePoolsAPI) InstancePoolAndStatsInstancePoolNameToInstancePoolIdMap(ctx context.Context) (map[string]string, error) + func (a *InstancePoolsAPI) ListAll(ctx context.Context) ([]InstancePoolAndStats, error) + func (a *InstancePoolsAPI) WithImpl(impl InstancePoolsService) *InstancePoolsAPI + type InstancePoolsService interface + Create func(ctx context.Context, request CreateInstancePool) (*CreateInstancePoolResponse, error) + Delete func(ctx context.Context, request DeleteInstancePool) error + Edit func(ctx context.Context, request EditInstancePool) error + Get func(ctx context.Context, request GetInstancePoolRequest) (*GetInstancePool, error) + List func(ctx context.Context) (*ListInstancePools, error) + type InstanceProfile struct + IamRoleArn string + InstanceProfileArn string + IsMetaInstanceProfile bool + type InstanceProfilesAPI struct + func NewInstanceProfiles(client *client.DatabricksClient) *InstanceProfilesAPI + func (a *InstanceProfilesAPI) Add(ctx context.Context, request AddInstanceProfile) error + func (a *InstanceProfilesAPI) Edit(ctx context.Context, request InstanceProfile) error + func (a *InstanceProfilesAPI) Impl() InstanceProfilesService + func (a *InstanceProfilesAPI) ListAll(ctx context.Context) ([]InstanceProfile, error) + func (a *InstanceProfilesAPI) Remove(ctx context.Context, request RemoveInstanceProfile) error + func (a *InstanceProfilesAPI) RemoveByInstanceProfileArn(ctx context.Context, instanceProfileArn string) error + func (a *InstanceProfilesAPI) WithImpl(impl InstanceProfilesService) *InstanceProfilesAPI + type InstanceProfilesService interface + Add func(ctx context.Context, request AddInstanceProfile) error + Edit func(ctx context.Context, request InstanceProfile) error + List func(ctx context.Context) (*ListInstanceProfilesResponse, error) + Remove func(ctx context.Context, request RemoveInstanceProfile) error + type Language string + const LanguagePython + const LanguageScala + const LanguageSql + func (f *Language) Set(v string) error + func (f *Language) String() string + func (f *Language) Type() string + type LibrariesAPI struct + func NewLibraries(client *client.DatabricksClient) *LibrariesAPI + func (a *LibrariesAPI) AllClusterStatuses(ctx context.Context) (*ListAllClusterLibraryStatusesResponse, error) + func (a *LibrariesAPI) ClusterStatus(ctx context.Context, request ClusterStatusRequest) (*ClusterLibraryStatuses, error) + func (a *LibrariesAPI) ClusterStatusByClusterId(ctx context.Context, clusterId string) (*ClusterLibraryStatuses, error) + func (a *LibrariesAPI) Impl() LibrariesService + func (a *LibrariesAPI) Install(ctx context.Context, request InstallLibraries) error + func (a *LibrariesAPI) Uninstall(ctx context.Context, request UninstallLibraries) error + func (a *LibrariesAPI) UpdateAndWait(ctx context.Context, update Update, ...) error + func (a *LibrariesAPI) Wait(ctx context.Context, wait Wait, ...) (*ClusterLibraryStatuses, error) + func (a *LibrariesAPI) WithImpl(impl LibrariesService) *LibrariesAPI + type LibrariesService interface + AllClusterStatuses func(ctx context.Context) (*ListAllClusterLibraryStatusesResponse, error) + ClusterStatus func(ctx context.Context, request ClusterStatusRequest) (*ClusterLibraryStatuses, error) + Install func(ctx context.Context, request InstallLibraries) error + Uninstall func(ctx context.Context, request UninstallLibraries) error + type Library struct + Cran *RCranLibrary + Egg string + Jar string + Maven *MavenLibrary + Pypi *PythonPyPiLibrary + Whl string + func (library Library) String() string + type LibraryFullStatus struct + IsLibraryForAllClusters bool + Library *Library + Messages []string + Status LibraryFullStatusStatus + type LibraryFullStatusStatus string + const LibraryFullStatusStatusFailed + const LibraryFullStatusStatusInstalled + const LibraryFullStatusStatusInstalling + const LibraryFullStatusStatusPending + const LibraryFullStatusStatusResolving + const LibraryFullStatusStatusSkipped + const LibraryFullStatusStatusUninstallOnRestart + func (f *LibraryFullStatusStatus) Set(v string) error + func (f *LibraryFullStatusStatus) String() string + func (f *LibraryFullStatusStatus) Type() string + type ListAllClusterLibraryStatusesResponse struct + Statuses []ClusterLibraryStatuses + type ListAvailableZonesResponse struct + DefaultZone string + Zones []string + type ListClusterPoliciesRequest struct + SortColumn ListSortColumn + SortOrder ListSortOrder + type ListClustersRequest struct + CanUseClient string + type ListClustersResponse struct + Clusters []ClusterDetails + type ListGlobalInitScriptsResponse struct + Scripts []GlobalInitScriptDetails + type ListInstancePools struct + InstancePools []InstancePoolAndStats + type ListInstanceProfilesResponse struct + InstanceProfiles []InstanceProfile + type ListNodeTypesResponse struct + NodeTypes []NodeType + func (ntl *ListNodeTypesResponse) Smallest(r NodeTypeRequest) (string, error) + type ListPoliciesResponse struct + Policies []Policy + type ListPolicyFamiliesRequest struct + MaxResults int64 + PageToken string + type ListPolicyFamiliesResponse struct + NextPageToken string + PolicyFamilies []PolicyFamily + type ListSortColumn string + const ListSortColumnPolicyCreationTime + const ListSortColumnPolicyName + func (f *ListSortColumn) Set(v string) error + func (f *ListSortColumn) String() string + func (f *ListSortColumn) Type() string + type ListSortOrder string + const ListSortOrderAsc + const ListSortOrderDesc + func (f *ListSortOrder) Set(v string) error + func (f *ListSortOrder) String() string + func (f *ListSortOrder) Type() string + type LogAnalyticsInfo struct + LogAnalyticsPrimaryKey string + LogAnalyticsWorkspaceId string + type LogSyncStatus struct + LastAttempted int64 + LastException string + type MavenLibrary struct + Coordinates string + Exclusions []string + Repo string + type NodeInstanceType struct + InstanceTypeId string + LocalDiskSizeGb int + LocalDisks int + LocalNvmeDiskSizeGb int + LocalNvmeDisks int + type NodeType struct + Category string + Description string + DisplayOrder int + InstanceTypeId string + IsDeprecated bool + IsEncryptedInTransit bool + IsGraviton bool + IsHidden bool + IsIoCacheEnabled bool + MemoryMb int + NodeInfo *CloudProviderNodeInfo + NodeInstanceType *NodeInstanceType + NodeTypeId string + NumCores float64 + NumGpus int + PhotonDriverCapable bool + PhotonWorkerCapable bool + SupportClusterTags bool + SupportEbsVolumes bool + SupportPortForwarding bool + type NodeTypeRequest struct + Category string + Fleet bool + GBPerCore int32 + Graviton bool + Id string + IsIOCacheEnabled bool + LocalDisk bool + LocalDiskMinSize int32 + MinCores int32 + MinGPUs int32 + MinMemoryGB int32 + PhotonDriverCapable bool + PhotonWorkerCapable bool + SupportPortForwarding bool + type PendingInstanceError struct + InstanceId string + Message string + type PermanentDeleteCluster struct + ClusterId string + type PinCluster struct + ClusterId string + type Policy struct + CreatedAtTimestamp int64 + CreatorUserName string + Definition string + Description string + IsDefault bool + MaxClustersPerUser int64 + Name string + PolicyFamilyDefinitionOverrides string + PolicyFamilyId string + PolicyId string + type PolicyFamiliesAPI struct + func NewPolicyFamilies(client *client.DatabricksClient) *PolicyFamiliesAPI + func (a *PolicyFamiliesAPI) Get(ctx context.Context, request GetPolicyFamilyRequest) (*PolicyFamily, error) + func (a *PolicyFamiliesAPI) GetByPolicyFamilyId(ctx context.Context, policyFamilyId string) (*PolicyFamily, error) + func (a *PolicyFamiliesAPI) Impl() PolicyFamiliesService + func (a *PolicyFamiliesAPI) ListAll(ctx context.Context, request ListPolicyFamiliesRequest) ([]PolicyFamily, error) + func (a *PolicyFamiliesAPI) WithImpl(impl PolicyFamiliesService) *PolicyFamiliesAPI + type PolicyFamiliesService interface + Get func(ctx context.Context, request GetPolicyFamilyRequest) (*PolicyFamily, error) + List func(ctx context.Context, request ListPolicyFamiliesRequest) (*ListPolicyFamiliesResponse, error) + type PolicyFamily struct + Definition string + Description string + Name string + PolicyFamilyId string + type PythonPyPiLibrary struct + Package string + Repo string + type RCranLibrary struct + Package string + Repo string + type RemoveInstanceProfile struct + InstanceProfileArn string + type ResizeCluster struct + Autoscale *AutoScale + ClusterId string + NumWorkers int + type RestartCluster struct + ClusterId string + RestartUser string + type ResultType string + const ResultTypeError + const ResultTypeImage + const ResultTypeImages + const ResultTypeTable + const ResultTypeText + func (f *ResultType) Set(v string) error + func (f *ResultType) String() string + func (f *ResultType) Type() string + type Results struct + Cause string + Data any + FileName string + FileNames []string + IsJsonSchema bool + Pos int + ResultType ResultType + Schema []map[string]any + Summary string + Truncated bool + func (r *Results) Err() error + func (r *Results) Error() string + func (r *Results) Failed() bool + func (r *Results) Scan(dest ...any) bool + func (r *Results) Text() string + type RuntimeEngine string + const RuntimeEngineNull + const RuntimeEnginePhoton + const RuntimeEngineStandard + func (f *RuntimeEngine) Set(v string) error + func (f *RuntimeEngine) String() string + func (f *RuntimeEngine) Type() string + type S3StorageInfo struct + CannedAcl string + Destination string + EnableEncryption bool + EncryptionType string + Endpoint string + KmsKey string + Region string + type SparkNode struct + HostPrivateIp string + InstanceId string + NodeAwsAttributes *SparkNodeAwsAttributes + NodeId string + PrivateIp string + PublicDns string + StartTimestamp int64 + type SparkNodeAwsAttributes struct + IsSpot bool + type SparkVersion struct + Key string + Name string + type SparkVersionRequest struct + Beta bool + GPU bool + Genomics bool + Graviton bool + Id string + Latest bool + LongTermSupport bool + ML bool + Photon bool + Scala string + SparkVersion string + type StartCluster struct + ClusterId string + type State string + const StateError + const StatePending + const StateResizing + const StateRestarting + const StateRunning + const StateTerminated + const StateTerminating + const StateUnknown + func (f *State) Set(v string) error + func (f *State) String() string + func (f *State) Type() string + type TerminationReason struct + Code TerminationReasonCode + Parameters map[string]string + Type TerminationReasonType + type TerminationReasonCode string + const TerminationReasonCodeAbuseDetected + const TerminationReasonCodeAttachProjectFailure + const TerminationReasonCodeAwsAuthorizationFailure + const TerminationReasonCodeAwsInsufficientFreeAddressesInSubnetFailure + const TerminationReasonCodeAwsInsufficientInstanceCapacityFailure + const TerminationReasonCodeAwsMaxSpotInstanceCountExceededFailure + const TerminationReasonCodeAwsRequestLimitExceeded + const TerminationReasonCodeAwsUnsupportedFailure + const TerminationReasonCodeAzureByokKeyPermissionFailure + const TerminationReasonCodeAzureEphemeralDiskFailure + const TerminationReasonCodeAzureInvalidDeploymentTemplate + const TerminationReasonCodeAzureOperationNotAllowedException + const TerminationReasonCodeAzureQuotaExceededException + const TerminationReasonCodeAzureResourceManagerThrottling + const TerminationReasonCodeAzureResourceProviderThrottling + const TerminationReasonCodeAzureUnexpectedDeploymentTemplateFailure + const TerminationReasonCodeAzureVmExtensionFailure + const TerminationReasonCodeAzureVnetConfigurationFailure + const TerminationReasonCodeBootstrapTimeout + const TerminationReasonCodeBootstrapTimeoutCloudProviderException + const TerminationReasonCodeCloudProviderDiskSetupFailure + const TerminationReasonCodeCloudProviderLaunchFailure + const TerminationReasonCodeCloudProviderResourceStockout + const TerminationReasonCodeCloudProviderShutdown + const TerminationReasonCodeCommunicationLost + const TerminationReasonCodeContainerLaunchFailure + const TerminationReasonCodeControlPlaneRequestFailure + const TerminationReasonCodeDatabaseConnectionFailure + const TerminationReasonCodeDbfsComponentUnhealthy + const TerminationReasonCodeDockerImagePullFailure + const TerminationReasonCodeDriverUnreachable + const TerminationReasonCodeDriverUnresponsive + const TerminationReasonCodeExecutionComponentUnhealthy + const TerminationReasonCodeGcpQuotaExceeded + const TerminationReasonCodeGcpServiceAccountDeleted + const TerminationReasonCodeGlobalInitScriptFailure + const TerminationReasonCodeHiveMetastoreProvisioningFailure + const TerminationReasonCodeImagePullPermissionDenied + const TerminationReasonCodeInactivity + const TerminationReasonCodeInitScriptFailure + const TerminationReasonCodeInstancePoolClusterFailure + const TerminationReasonCodeInstanceUnreachable + const TerminationReasonCodeInternalError + const TerminationReasonCodeInvalidArgument + const TerminationReasonCodeInvalidSparkImage + const TerminationReasonCodeIpExhaustionFailure + const TerminationReasonCodeJobFinished + const TerminationReasonCodeK8sAutoscalingFailure + const TerminationReasonCodeK8sDbrClusterLaunchTimeout + const TerminationReasonCodeMetastoreComponentUnhealthy + const TerminationReasonCodeNephosResourceManagement + const TerminationReasonCodeNetworkConfigurationFailure + const TerminationReasonCodeNfsMountFailure + const TerminationReasonCodeNpipTunnelSetupFailure + const TerminationReasonCodeNpipTunnelTokenFailure + const TerminationReasonCodeRequestRejected + const TerminationReasonCodeRequestThrottled + const TerminationReasonCodeSecretResolutionError + const TerminationReasonCodeSecurityDaemonRegistrationException + const TerminationReasonCodeSelfBootstrapFailure + const TerminationReasonCodeSkippedSlowNodes + const TerminationReasonCodeSlowImageDownload + const TerminationReasonCodeSparkError + const TerminationReasonCodeSparkImageDownloadFailure + const TerminationReasonCodeSparkStartupFailure + const TerminationReasonCodeSpotInstanceTermination + const TerminationReasonCodeStorageDownloadFailure + const TerminationReasonCodeStsClientSetupFailure + const TerminationReasonCodeSubnetExhaustedFailure + const TerminationReasonCodeTemporarilyUnavailable + const TerminationReasonCodeTrialExpired + const TerminationReasonCodeUnexpectedLaunchFailure + const TerminationReasonCodeUnknown + const TerminationReasonCodeUnsupportedInstanceType + const TerminationReasonCodeUpdateInstanceProfileFailure + const TerminationReasonCodeUserRequest + const TerminationReasonCodeWorkerSetupFailure + const TerminationReasonCodeWorkspaceCancelledError + const TerminationReasonCodeWorkspaceConfigurationError + func (f *TerminationReasonCode) Set(v string) error + func (f *TerminationReasonCode) String() string + func (f *TerminationReasonCode) Type() string + type TerminationReasonType string + const TerminationReasonTypeClientError + const TerminationReasonTypeCloudFailure + const TerminationReasonTypeServiceFault + const TerminationReasonTypeSuccess + func (f *TerminationReasonType) Set(v string) error + func (f *TerminationReasonType) String() string + func (f *TerminationReasonType) Type() string + type UninstallLibraries struct + ClusterId string + Libraries []Library + type UnpinCluster struct + ClusterId string + type Update struct + ClusterId string + Install []Library + Uninstall []Library + type Wait struct + ClusterID string + IsRefresh bool + IsRunning bool + Libraries []Library + func (w *Wait) IsNotInScope(lib *Library) bool + type WaitCommandStatusCommandExecutionCancelled struct + ClusterId string + CommandId string + ContextId string + Response *R + func (w *WaitCommandStatusCommandExecutionCancelled[R]) Get() (*CommandStatusResponse, error) + func (w *WaitCommandStatusCommandExecutionCancelled[R]) GetWithTimeout(timeout time.Duration) (*CommandStatusResponse, error) + func (w *WaitCommandStatusCommandExecutionCancelled[R]) OnProgress(callback func(*CommandStatusResponse)) *WaitCommandStatusCommandExecutionCancelled[R] + type WaitCommandStatusCommandExecutionFinishedOrError struct + ClusterId string + CommandId string + ContextId string + Response *R + func (w *WaitCommandStatusCommandExecutionFinishedOrError[R]) Get() (*CommandStatusResponse, error) + func (w *WaitCommandStatusCommandExecutionFinishedOrError[R]) GetWithTimeout(timeout time.Duration) (*CommandStatusResponse, error) + func (w *WaitCommandStatusCommandExecutionFinishedOrError[R]) OnProgress(callback func(*CommandStatusResponse)) *WaitCommandStatusCommandExecutionFinishedOrError[R] + type WaitContextStatusCommandExecutionRunning struct + ClusterId string + ContextId string + Response *R + func (w *WaitContextStatusCommandExecutionRunning[R]) Get() (*ContextStatusResponse, error) + func (w *WaitContextStatusCommandExecutionRunning[R]) GetWithTimeout(timeout time.Duration) (*ContextStatusResponse, error) + func (w *WaitContextStatusCommandExecutionRunning[R]) OnProgress(callback func(*ContextStatusResponse)) *WaitContextStatusCommandExecutionRunning[R] + type WaitGetClusterRunning struct + ClusterId string + Response *R + func (w *WaitGetClusterRunning[R]) Get() (*ClusterDetails, error) + func (w *WaitGetClusterRunning[R]) GetWithTimeout(timeout time.Duration) (*ClusterDetails, error) + func (w *WaitGetClusterRunning[R]) OnProgress(callback func(*ClusterDetails)) *WaitGetClusterRunning[R] + type WaitGetClusterTerminated struct + ClusterId string + Response *R + func (w *WaitGetClusterTerminated[R]) Get() (*ClusterDetails, error) + func (w *WaitGetClusterTerminated[R]) GetWithTimeout(timeout time.Duration) (*ClusterDetails, error) + func (w *WaitGetClusterTerminated[R]) OnProgress(callback func(*ClusterDetails)) *WaitGetClusterTerminated[R] + type WorkloadType struct + Clients *ClientsTypes + type WorkspaceStorageInfo struct + Destination string
Go to main page