compute

Apr 28, 2026

Changes in this version

+ type ConfidentialComputeType string

+ const ConfidentialComputeTypeConfidentialComputeTypeNone

+ const ConfidentialComputeTypeSevSnp

+ func (f *ConfidentialComputeType) Set(v string) error

+ func (f *ConfidentialComputeType) String() string

+ func (f *ConfidentialComputeType) Type() string

+ func (f *ConfidentialComputeType) Values() []ConfidentialComputeType

type GcpAttributes

+ ConfidentialComputeType ConfidentialComputeType

Feb 26, 2026

Changes in this version

type EventDetailsCause

+ const EventDetailsCauseDbrAutoscale

Feb 24, 2026

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeHivemetastoreConnectivityFailure

Feb 10, 2026

Changes in this version

type Environment

+ BaseEnvironment string

type EventType

+ const EventTypeUcVolumeMisconfigured

Feb 3, 2026

Changes in this version

+ type HardwareAcceleratorType string

+ const HardwareAcceleratorTypeGpu1xA10

+ const HardwareAcceleratorTypeGpu8xH100

+ func (f *HardwareAcceleratorType) Set(v string) error

+ func (f *HardwareAcceleratorType) String() string

+ func (f *HardwareAcceleratorType) Type() string

+ func (f *HardwareAcceleratorType) Values() []HardwareAcceleratorType

type TerminationReasonCode

+ const TerminationReasonCodeMtlsPortConnectivityFailure

Jan 20, 2026

Changes in this version

type ClusterAttributes

+ DriverNodeTypeFlexibility *NodeTypeFlexibility

+ WorkerNodeTypeFlexibility *NodeTypeFlexibility

type ClusterDetails

+ DriverNodeTypeFlexibility *NodeTypeFlexibility

+ WorkerNodeTypeFlexibility *NodeTypeFlexibility

type ClusterSpec

+ DriverNodeTypeFlexibility *NodeTypeFlexibility

+ WorkerNodeTypeFlexibility *NodeTypeFlexibility

type CreateCluster

+ DriverNodeTypeFlexibility *NodeTypeFlexibility

+ WorkerNodeTypeFlexibility *NodeTypeFlexibility

type CreateInstancePool

+ NodeTypeFlexibility *NodeTypeFlexibility

type EditCluster

+ DriverNodeTypeFlexibility *NodeTypeFlexibility

+ WorkerNodeTypeFlexibility *NodeTypeFlexibility

type InitScriptInfoAndExecutionDetails

+ Stderr string

type NodeTypeFlexibility

+ AlternateNodeTypeIds []string

type UpdateClusterResource

+ DriverNodeTypeFlexibility *NodeTypeFlexibility

+ WorkerNodeTypeFlexibility *NodeTypeFlexibility

Jan 15, 2026

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeRateLimited

Dec 17, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeControlPlaneConnectionFailure

+ const TerminationReasonCodeControlPlaneConnectionFailureDueToMisconfig

Nov 20, 2025

Changes in this version

type EventDetailsCause

+ const EventDetailsCauseAutoscaleV2

Oct 30, 2025

Changes in this version

type EventType

+ const EventTypeDecommissionEnded

+ const EventTypeDecommissionStarted

type InstancePoolAwsAttributes

+ InstanceProfileArn string

type TerminationReasonCode

+ const TerminationReasonCodeDbrImageResolutionFailure

Oct 20, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeNetworkCheckControlPlaneFailureDueToMisconfig

+ const TerminationReasonCodeNetworkCheckDnsServerFailureDueToMisconfig

+ const TerminationReasonCodeNetworkCheckMetadataEndpointFailureDueToMisconfig

+ const TerminationReasonCodeNetworkCheckMultipleComponentsFailureDueToMisconfig

+ const TerminationReasonCodeNetworkCheckNicFailureDueToMisconfig

+ const TerminationReasonCodeNetworkCheckStorageFailureDueToMisconfig

Oct 13, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeCloudAccountPodQuotaExceeded

+ const TerminationReasonCodeK8sActivePodQuotaExceeded

Sep 18, 2025

Changes in this version

type Environment

+ JavaDependencies []string

type TerminationReasonCode

+ const TerminationReasonCodeNoActivatedK8sTestingTag

Sep 8, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeNoActivatedK8s

+ const TerminationReasonCodeUsagePolicyEntitlementDenied

Aug 13, 2025

Changes in this version

type GcpAttributes

+ FirstOnDemand int

Jul 10, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeDriverDnsResolutionFailure

Jul 3, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeSecurityAgentsFailedInitialVerification

Jun 19, 2025

Changes in this version

type AddResponse

+ func (st *AddResponse) UnmarshalJSON(b []byte) error

+ func (st AddResponse) MarshalJSON() ([]byte, error)

type Adlsgen2Info

+ func (st *Adlsgen2Info) UnmarshalJSON(b []byte) error

+ func (st Adlsgen2Info) MarshalJSON() ([]byte, error)

type CancelResponse

+ func (st *CancelResponse) UnmarshalJSON(b []byte) error

+ func (st CancelResponse) MarshalJSON() ([]byte, error)

type ChangeClusterOwner

+ func (st *ChangeClusterOwner) UnmarshalJSON(b []byte) error

+ func (st ChangeClusterOwner) MarshalJSON() ([]byte, error)

type ChangeClusterOwnerResponse

+ func (st *ChangeClusterOwnerResponse) UnmarshalJSON(b []byte) error

+ func (st ChangeClusterOwnerResponse) MarshalJSON() ([]byte, error)

type CloneCluster

+ func (st *CloneCluster) UnmarshalJSON(b []byte) error

+ func (st CloneCluster) MarshalJSON() ([]byte, error)

type CloudProviderNodeInfo

+ func (st *CloudProviderNodeInfo) UnmarshalJSON(b []byte) error

+ func (st CloudProviderNodeInfo) MarshalJSON() ([]byte, error)

type ClusterAttributes

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type ClusterDetails

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type ClusterLogConf

+ func (st *ClusterLogConf) UnmarshalJSON(b []byte) error

+ func (st ClusterLogConf) MarshalJSON() ([]byte, error)

type ClusterPermissionsRequest

+ func (st *ClusterPermissionsRequest) UnmarshalJSON(b []byte) error

+ func (st ClusterPermissionsRequest) MarshalJSON() ([]byte, error)

type ClusterPolicyPermissionsRequest

+ func (st *ClusterPolicyPermissionsRequest) UnmarshalJSON(b []byte) error

+ func (st ClusterPolicyPermissionsRequest) MarshalJSON() ([]byte, error)

type ClusterSpec

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type ClusterStatus

+ func (st *ClusterStatus) UnmarshalJSON(b []byte) error

+ func (st ClusterStatus) MarshalJSON() ([]byte, error)

type CommandStatusRequest

+ func (st *CommandStatusRequest) UnmarshalJSON(b []byte) error

+ func (st CommandStatusRequest) MarshalJSON() ([]byte, error)

type ContextStatusRequest

+ func (st *ContextStatusRequest) UnmarshalJSON(b []byte) error

+ func (st ContextStatusRequest) MarshalJSON() ([]byte, error)

type CreateCluster

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type CreateInstancePool

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type DeleteCluster

+ func (st *DeleteCluster) UnmarshalJSON(b []byte) error

+ func (st DeleteCluster) MarshalJSON() ([]byte, error)

type DeleteClusterResponse

+ func (st *DeleteClusterResponse) UnmarshalJSON(b []byte) error

+ func (st DeleteClusterResponse) MarshalJSON() ([]byte, error)

type DeleteGlobalInitScriptRequest

+ func (st *DeleteGlobalInitScriptRequest) UnmarshalJSON(b []byte) error

+ func (st DeleteGlobalInitScriptRequest) MarshalJSON() ([]byte, error)

type DeleteInstancePool

+ func (st *DeleteInstancePool) UnmarshalJSON(b []byte) error

+ func (st DeleteInstancePool) MarshalJSON() ([]byte, error)

type DeleteInstancePoolResponse

+ func (st *DeleteInstancePoolResponse) UnmarshalJSON(b []byte) error

+ func (st DeleteInstancePoolResponse) MarshalJSON() ([]byte, error)

type DeletePolicy

+ func (st *DeletePolicy) UnmarshalJSON(b []byte) error

+ func (st DeletePolicy) MarshalJSON() ([]byte, error)

type DeletePolicyResponse

+ func (st *DeletePolicyResponse) UnmarshalJSON(b []byte) error

+ func (st DeletePolicyResponse) MarshalJSON() ([]byte, error)

type DeleteResponse

+ func (st *DeleteResponse) UnmarshalJSON(b []byte) error

+ func (st DeleteResponse) MarshalJSON() ([]byte, error)

type DestroyContext

+ func (st *DestroyContext) UnmarshalJSON(b []byte) error

+ func (st DestroyContext) MarshalJSON() ([]byte, error)

type DestroyResponse

+ func (st *DestroyResponse) UnmarshalJSON(b []byte) error

+ func (st DestroyResponse) MarshalJSON() ([]byte, error)

type DiskType

+ func (st *DiskType) UnmarshalJSON(b []byte) error

+ func (st DiskType) MarshalJSON() ([]byte, error)

type EditCluster

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type EditClusterResponse

+ func (st *EditClusterResponse) UnmarshalJSON(b []byte) error

+ func (st EditClusterResponse) MarshalJSON() ([]byte, error)

type EditInstancePool

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type EditInstancePoolResponse

+ func (st *EditInstancePoolResponse) UnmarshalJSON(b []byte) error

+ func (st EditInstancePoolResponse) MarshalJSON() ([]byte, error)

type EditPolicyResponse

+ func (st *EditPolicyResponse) UnmarshalJSON(b []byte) error

+ func (st EditPolicyResponse) MarshalJSON() ([]byte, error)

type EditResponse

+ func (st *EditResponse) UnmarshalJSON(b []byte) error

+ func (st EditResponse) MarshalJSON() ([]byte, error)

type GcsStorageInfo

+ func (st *GcsStorageInfo) UnmarshalJSON(b []byte) error

+ func (st GcsStorageInfo) MarshalJSON() ([]byte, error)

type GetClusterComplianceRequest

+ func (st *GetClusterComplianceRequest) UnmarshalJSON(b []byte) error

+ func (st GetClusterComplianceRequest) MarshalJSON() ([]byte, error)

type GetClusterPermissionLevelsRequest

+ func (st *GetClusterPermissionLevelsRequest) UnmarshalJSON(b []byte) error

+ func (st GetClusterPermissionLevelsRequest) MarshalJSON() ([]byte, error)

type GetClusterPermissionLevelsResponse

+ func (st *GetClusterPermissionLevelsResponse) UnmarshalJSON(b []byte) error

+ func (st GetClusterPermissionLevelsResponse) MarshalJSON() ([]byte, error)

type GetClusterPermissionsRequest

+ func (st *GetClusterPermissionsRequest) UnmarshalJSON(b []byte) error

+ func (st GetClusterPermissionsRequest) MarshalJSON() ([]byte, error)

type GetClusterPolicyPermissionLevelsRequest

+ func (st *GetClusterPolicyPermissionLevelsRequest) UnmarshalJSON(b []byte) error

+ func (st GetClusterPolicyPermissionLevelsRequest) MarshalJSON() ([]byte, error)

type GetClusterPolicyPermissionLevelsResponse

+ func (st *GetClusterPolicyPermissionLevelsResponse) UnmarshalJSON(b []byte) error

+ func (st GetClusterPolicyPermissionLevelsResponse) MarshalJSON() ([]byte, error)

type GetClusterPolicyPermissionsRequest

+ func (st *GetClusterPolicyPermissionsRequest) UnmarshalJSON(b []byte) error

+ func (st GetClusterPolicyPermissionsRequest) MarshalJSON() ([]byte, error)

type GetClusterPolicyRequest

+ func (st *GetClusterPolicyRequest) UnmarshalJSON(b []byte) error

+ func (st GetClusterPolicyRequest) MarshalJSON() ([]byte, error)

type GetClusterRequest

+ func (st *GetClusterRequest) UnmarshalJSON(b []byte) error

+ func (st GetClusterRequest) MarshalJSON() ([]byte, error)

type GetGlobalInitScriptRequest

+ func (st *GetGlobalInitScriptRequest) UnmarshalJSON(b []byte) error

+ func (st GetGlobalInitScriptRequest) MarshalJSON() ([]byte, error)

type GetInstancePool

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type GetInstancePoolPermissionLevelsRequest

+ func (st *GetInstancePoolPermissionLevelsRequest) UnmarshalJSON(b []byte) error

+ func (st GetInstancePoolPermissionLevelsRequest) MarshalJSON() ([]byte, error)

type GetInstancePoolPermissionLevelsResponse

+ func (st *GetInstancePoolPermissionLevelsResponse) UnmarshalJSON(b []byte) error

+ func (st GetInstancePoolPermissionLevelsResponse) MarshalJSON() ([]byte, error)

type GetInstancePoolPermissionsRequest

+ func (st *GetInstancePoolPermissionsRequest) UnmarshalJSON(b []byte) error

+ func (st GetInstancePoolPermissionsRequest) MarshalJSON() ([]byte, error)

type GetInstancePoolRequest

+ func (st *GetInstancePoolRequest) UnmarshalJSON(b []byte) error

+ func (st GetInstancePoolRequest) MarshalJSON() ([]byte, error)

type GetSparkVersionsResponse

+ func (st *GetSparkVersionsResponse) UnmarshalJSON(b []byte) error

+ func (st GetSparkVersionsResponse) MarshalJSON() ([]byte, error)

type InitScriptInfo

+ func (st *InitScriptInfo) UnmarshalJSON(b []byte) error

+ func (st InitScriptInfo) MarshalJSON() ([]byte, error)

type InstallLibraries

+ func (st *InstallLibraries) UnmarshalJSON(b []byte) error

+ func (st InstallLibraries) MarshalJSON() ([]byte, error)

type InstallLibrariesResponse

+ func (st *InstallLibrariesResponse) UnmarshalJSON(b []byte) error

+ func (st InstallLibrariesResponse) MarshalJSON() ([]byte, error)

type InstancePoolAndStats

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type InstancePoolPermissionsRequest

+ func (st *InstancePoolPermissionsRequest) UnmarshalJSON(b []byte) error

+ func (st InstancePoolPermissionsRequest) MarshalJSON() ([]byte, error)

type InstancePoolStatus

+ func (st *InstancePoolStatus) UnmarshalJSON(b []byte) error

+ func (st InstancePoolStatus) MarshalJSON() ([]byte, error)

type Language

+ const LanguageR

type ListAllClusterLibraryStatusesResponse

+ func (st *ListAllClusterLibraryStatusesResponse) UnmarshalJSON(b []byte) error

+ func (st ListAllClusterLibraryStatusesResponse) MarshalJSON() ([]byte, error)

type ListClusterPoliciesRequest

+ func (st *ListClusterPoliciesRequest) UnmarshalJSON(b []byte) error

+ func (st ListClusterPoliciesRequest) MarshalJSON() ([]byte, error)

type ListClustersSortBy

+ func (st *ListClustersSortBy) UnmarshalJSON(b []byte) error

+ func (st ListClustersSortBy) MarshalJSON() ([]byte, error)

type ListGlobalInitScriptsResponse

+ func (st *ListGlobalInitScriptsResponse) UnmarshalJSON(b []byte) error

+ func (st ListGlobalInitScriptsResponse) MarshalJSON() ([]byte, error)

type ListInstancePools

+ func (st *ListInstancePools) UnmarshalJSON(b []byte) error

+ func (st ListInstancePools) MarshalJSON() ([]byte, error)

type ListInstanceProfilesResponse

+ func (st *ListInstanceProfilesResponse) UnmarshalJSON(b []byte) error

+ func (st ListInstanceProfilesResponse) MarshalJSON() ([]byte, error)

type ListNodeTypesResponse

+ func (st *ListNodeTypesResponse) UnmarshalJSON(b []byte) error

+ func (st ListNodeTypesResponse) MarshalJSON() ([]byte, error)

type ListPoliciesResponse

+ func (st *ListPoliciesResponse) UnmarshalJSON(b []byte) error

+ func (st ListPoliciesResponse) MarshalJSON() ([]byte, error)

type PermanentDeleteCluster

+ func (st *PermanentDeleteCluster) UnmarshalJSON(b []byte) error

+ func (st PermanentDeleteCluster) MarshalJSON() ([]byte, error)

type PermanentDeleteClusterResponse

+ func (st *PermanentDeleteClusterResponse) UnmarshalJSON(b []byte) error

+ func (st PermanentDeleteClusterResponse) MarshalJSON() ([]byte, error)

type PinCluster

+ func (st *PinCluster) UnmarshalJSON(b []byte) error

+ func (st PinCluster) MarshalJSON() ([]byte, error)

type PinClusterResponse

+ func (st *PinClusterResponse) UnmarshalJSON(b []byte) error

+ func (st PinClusterResponse) MarshalJSON() ([]byte, error)

type RemoveInstanceProfile

+ func (st *RemoveInstanceProfile) UnmarshalJSON(b []byte) error

+ func (st RemoveInstanceProfile) MarshalJSON() ([]byte, error)

type RemoveResponse

+ func (st *RemoveResponse) UnmarshalJSON(b []byte) error

+ func (st RemoveResponse) MarshalJSON() ([]byte, error)

type ResizeClusterResponse

+ func (st *ResizeClusterResponse) UnmarshalJSON(b []byte) error

+ func (st ResizeClusterResponse) MarshalJSON() ([]byte, error)

type RestartClusterResponse

+ func (st *RestartClusterResponse) UnmarshalJSON(b []byte) error

+ func (st RestartClusterResponse) MarshalJSON() ([]byte, error)

type StartCluster

+ func (st *StartCluster) UnmarshalJSON(b []byte) error

+ func (st StartCluster) MarshalJSON() ([]byte, error)

type StartClusterResponse

+ func (st *StartClusterResponse) UnmarshalJSON(b []byte) error

+ func (st StartClusterResponse) MarshalJSON() ([]byte, error)

type TerminationReason

+ func (st *TerminationReason) UnmarshalJSON(b []byte) error

+ func (st TerminationReason) MarshalJSON() ([]byte, error)

type UninstallLibraries

+ func (st *UninstallLibraries) UnmarshalJSON(b []byte) error

+ func (st UninstallLibraries) MarshalJSON() ([]byte, error)

type UninstallLibrariesResponse

+ func (st *UninstallLibrariesResponse) UnmarshalJSON(b []byte) error

+ func (st UninstallLibrariesResponse) MarshalJSON() ([]byte, error)

type UnpinCluster

+ func (st *UnpinCluster) UnmarshalJSON(b []byte) error

+ func (st UnpinCluster) MarshalJSON() ([]byte, error)

type UnpinClusterResponse

+ func (st *UnpinClusterResponse) UnmarshalJSON(b []byte) error

+ func (st UnpinClusterResponse) MarshalJSON() ([]byte, error)

type UpdateCluster

+ func (st *UpdateCluster) UnmarshalJSON(b []byte) error

+ func (st UpdateCluster) MarshalJSON() ([]byte, error)

type UpdateClusterResource

+ RemoteDiskThroughput int

+ TotalInitialRemoteDiskSize int

type UpdateClusterResponse

+ func (st *UpdateClusterResponse) UnmarshalJSON(b []byte) error

+ func (st UpdateClusterResponse) MarshalJSON() ([]byte, error)

type UpdateResponse

+ func (st *UpdateResponse) UnmarshalJSON(b []byte) error

+ func (st UpdateResponse) MarshalJSON() ([]byte, error)

type WorkloadType

+ func (st *WorkloadType) UnmarshalJSON(b []byte) error

+ func (st WorkloadType) MarshalJSON() ([]byte, error)

Jun 5, 2025

Changes in this version

type AwsAvailability

+ func (f *AwsAvailability) Values() []AwsAvailability

type AzureAvailability

+ func (f *AzureAvailability) Values() []AzureAvailability

type CloudProviderNodeStatus

+ func (f *CloudProviderNodeStatus) Values() []CloudProviderNodeStatus

type ClusterPermissionLevel

+ func (f *ClusterPermissionLevel) Values() []ClusterPermissionLevel

type ClusterPolicyPermissionLevel

+ func (f *ClusterPolicyPermissionLevel) Values() []ClusterPolicyPermissionLevel

type ClusterSource

+ func (f *ClusterSource) Values() []ClusterSource

type CommandStatus

+ func (f *CommandStatus) Values() []CommandStatus

type ContextStatus

+ func (f *ContextStatus) Values() []ContextStatus

type DataPlaneEventDetailsEventType

+ func (f *DataPlaneEventDetailsEventType) Values() []DataPlaneEventDetailsEventType

type DataSecurityMode

+ func (f *DataSecurityMode) Values() []DataSecurityMode

type DiskTypeAzureDiskVolumeType

+ func (f *DiskTypeAzureDiskVolumeType) Values() []DiskTypeAzureDiskVolumeType

type DiskTypeEbsVolumeType

+ func (f *DiskTypeEbsVolumeType) Values() []DiskTypeEbsVolumeType

type EbsVolumeType

+ func (f *EbsVolumeType) Values() []EbsVolumeType

type EventDetailsCause

+ func (f *EventDetailsCause) Values() []EventDetailsCause

type EventType

+ const EventTypeClusterMigrated

+ func (f *EventType) Values() []EventType

type GcpAvailability

+ func (f *GcpAvailability) Values() []GcpAvailability

type GetEventsOrder

+ func (f *GetEventsOrder) Values() []GetEventsOrder

type InitScriptExecutionDetailsInitScriptExecutionStatus

+ func (f *InitScriptExecutionDetailsInitScriptExecutionStatus) Values() []InitScriptExecutionDetailsInitScriptExecutionStatus

type InstancePoolAwsAttributesAvailability

+ func (f *InstancePoolAwsAttributesAvailability) Values() []InstancePoolAwsAttributesAvailability

type InstancePoolAzureAttributesAvailability

+ func (f *InstancePoolAzureAttributesAvailability) Values() []InstancePoolAzureAttributesAvailability

type InstancePoolPermissionLevel

+ func (f *InstancePoolPermissionLevel) Values() []InstancePoolPermissionLevel

type InstancePoolState

+ func (f *InstancePoolState) Values() []InstancePoolState

type Kind

+ func (f *Kind) Values() []Kind

type Language

+ func (f *Language) Values() []Language

type LibraryInstallStatus

+ func (f *LibraryInstallStatus) Values() []LibraryInstallStatus

type ListClustersSortByDirection

+ func (f *ListClustersSortByDirection) Values() []ListClustersSortByDirection

type ListClustersSortByField

+ func (f *ListClustersSortByField) Values() []ListClustersSortByField

type ListSortColumn

+ func (f *ListSortColumn) Values() []ListSortColumn

type ListSortOrder

+ func (f *ListSortOrder) Values() []ListSortOrder

type ResultType

+ func (f *ResultType) Values() []ResultType

type RuntimeEngine

+ func (f *RuntimeEngine) Values() []RuntimeEngine

type State

+ func (f *State) Values() []State

type TerminationReasonCode

+ const TerminationReasonCodeDriverUnhealthy

+ func (f *TerminationReasonCode) Values() []TerminationReasonCode

type TerminationReasonType

+ func (f *TerminationReasonType) Values() []TerminationReasonType

May 12, 2025

Changes in this version

type Environment

+ EnvironmentVersion string

+ ForceSendFields []string

+ func (s *Environment) UnmarshalJSON(b []byte) error

+ func (s Environment) MarshalJSON() ([]byte, error)

May 2, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeNetworkCheckControlPlaneFailure

+ const TerminationReasonCodeNetworkCheckDnsServerFailure

+ const TerminationReasonCodeNetworkCheckMetadataEndpointFailure

+ const TerminationReasonCodeNetworkCheckMultipleComponentsFailure

+ const TerminationReasonCodeNetworkCheckNicFailure

+ const TerminationReasonCodeNetworkCheckStorageFailure

+ const TerminationReasonCodeSecretPermissionDenied

Apr 30, 2025

Changes in this version

type TerminationReasonCode

+ const TerminationReasonCodeDnsResolutionError

+ const TerminationReasonCodeGcpDeniedByOrgPolicy

Apr 24, 2025

Changes in this version

type EditInstancePool

+ NodeTypeFlexibility *NodeTypeFlexibility

type GetEvents

+ PageSize int

+ PageToken string

type GetEventsResponse

+ NextPageToken string

+ PrevPageToken string

type GetInstancePool

+ NodeTypeFlexibility *NodeTypeFlexibility

type InstancePoolAndStats

+ NodeTypeFlexibility *NodeTypeFlexibility

+ type NodeTypeFlexibility struct

Apr 14, 2025

Changes in this version

type Environment

+ JarDependencies []string

+ type MapAny map[string]any

type TerminationReasonCode

+ const TerminationReasonCodeAllocationTimeoutNoHealthyAndWarmedUpClusters

+ const TerminationReasonCodeDockerContainerCreationException

+ const TerminationReasonCodeDockerImageTooLargeForInstanceException

+ const TerminationReasonCodeDockerInvalidOsException

Mar 26, 2025

Changes in this version

+ type InitScriptExecutionDetailsInitScriptExecutionStatus string

+ const InitScriptExecutionDetailsInitScriptExecutionStatusFailedExecution

+ const InitScriptExecutionDetailsInitScriptExecutionStatusFailedFetch

+ const InitScriptExecutionDetailsInitScriptExecutionStatusFuseMountFailed

+ const InitScriptExecutionDetailsInitScriptExecutionStatusNotExecuted

+ const InitScriptExecutionDetailsInitScriptExecutionStatusSkipped

+ const InitScriptExecutionDetailsInitScriptExecutionStatusSucceeded

+ const InitScriptExecutionDetailsInitScriptExecutionStatusUnknown

+ func (f *InitScriptExecutionDetailsInitScriptExecutionStatus) Set(v string) error

+ func (f *InitScriptExecutionDetailsInitScriptExecutionStatus) String() string

+ func (f *InitScriptExecutionDetailsInitScriptExecutionStatus) Type() string

type InitScriptInfoAndExecutionDetails

+ Abfss *Adlsgen2Info

+ Dbfs *DbfsStorageInfo

+ ErrorMessage string

+ ExecutionDurationSeconds int

+ File *LocalFileInfo

+ ForceSendFields []string

+ Gcs *GcsStorageInfo

+ S3 *S3StorageInfo

+ Status InitScriptExecutionDetailsInitScriptExecutionStatus

+ Volumes *VolumesStorageInfo

+ Workspace *WorkspaceStorageInfo

+ func (s *InitScriptInfoAndExecutionDetails) UnmarshalJSON(b []byte) error

+ func (s InitScriptInfoAndExecutionDetails) MarshalJSON() ([]byte, error)

type TerminationReasonCode

+ const TerminationReasonCodeAccessTokenFailure

+ const TerminationReasonCodeAllocationTimeout

+ const TerminationReasonCodeAllocationTimeoutNoHealthyClusters

+ const TerminationReasonCodeAllocationTimeoutNoMatchedClusters

+ const TerminationReasonCodeAllocationTimeoutNoReadyClusters

+ const TerminationReasonCodeAllocationTimeoutNoUnallocatedClusters

+ const TerminationReasonCodeAllocationTimeoutNoWarmedUpClusters

+ const TerminationReasonCodeAllocationTimeoutNodeDaemonNotReady

+ const TerminationReasonCodeAwsInaccessibleKmsKeyFailure

+ const TerminationReasonCodeAwsInstanceProfileUpdateFailure

+ const TerminationReasonCodeAwsInvalidKeyPair

+ const TerminationReasonCodeAwsInvalidKmsKeyState

+ const TerminationReasonCodeAwsResourceQuotaExceeded

+ const TerminationReasonCodeAzurePackedDeploymentPartialFailure

+ const TerminationReasonCodeBootstrapTimeoutDueToMisconfig

+ const TerminationReasonCodeBudgetPolicyLimitEnforcementActivated

+ const TerminationReasonCodeBudgetPolicyResolutionFailure

+ const TerminationReasonCodeCloudAccountSetupFailure

+ const TerminationReasonCodeCloudOperationCancelled

+ const TerminationReasonCodeCloudProviderInstanceNotLaunched

+ const TerminationReasonCodeCloudProviderLaunchFailureDueToMisconfig

+ const TerminationReasonCodeCloudProviderResourceStockoutDueToMisconfig

+ const TerminationReasonCodeClusterOperationThrottled

+ const TerminationReasonCodeClusterOperationTimeout

+ const TerminationReasonCodeControlPlaneRequestFailureDueToMisconfig

+ const TerminationReasonCodeDataAccessConfigChanged

+ const TerminationReasonCodeDisasterRecoveryReplication

+ const TerminationReasonCodeDriverEviction

+ const TerminationReasonCodeDriverLaunchTimeout

+ const TerminationReasonCodeDriverNodeUnreachable

+ const TerminationReasonCodeDriverOutOfDisk

+ const TerminationReasonCodeDriverOutOfMemory

+ const TerminationReasonCodeDriverPodCreationFailure

+ const TerminationReasonCodeDriverUnexpectedFailure

+ const TerminationReasonCodeDynamicSparkConfSizeExceeded

+ const TerminationReasonCodeEosSparkImage

+ const TerminationReasonCodeExecutorPodUnscheduled

+ const TerminationReasonCodeGcpApiRateQuotaExceeded

+ const TerminationReasonCodeGcpForbidden

+ const TerminationReasonCodeGcpIamTimeout

+ const TerminationReasonCodeGcpInaccessibleKmsKeyFailure

+ const TerminationReasonCodeGcpInsufficientCapacity

+ const TerminationReasonCodeGcpIpSpaceExhausted

+ const TerminationReasonCodeGcpKmsKeyPermissionDenied

+ const TerminationReasonCodeGcpNotFound

+ const TerminationReasonCodeGcpResourceQuotaExceeded

+ const TerminationReasonCodeGcpServiceAccountAccessDenied

+ const TerminationReasonCodeGcpServiceAccountNotFound

+ const TerminationReasonCodeGcpSubnetNotReady

+ const TerminationReasonCodeGcpTrustedImageProjectsViolated

+ const TerminationReasonCodeGkeBasedClusterTermination

+ const TerminationReasonCodeInPenaltyBox

+ const TerminationReasonCodeInitContainerNotFinished

+ const TerminationReasonCodeInstancePoolMaxCapacityReached

+ const TerminationReasonCodeInstancePoolNotFound

+ const TerminationReasonCodeInstanceUnreachableDueToMisconfig

+ const TerminationReasonCodeInternalCapacityFailure

+ const TerminationReasonCodeInvalidAwsParameter

+ const TerminationReasonCodeInvalidInstancePlacementProtocol

+ const TerminationReasonCodeInvalidWorkerImageFailure

+ const TerminationReasonCodeLazyAllocationTimeout

+ const TerminationReasonCodeMaintenanceMode

+ const TerminationReasonCodeNetvisorSetupTimeout

+ const TerminationReasonCodeNoMatchedK8s

+ const TerminationReasonCodeNoMatchedK8sTestingTag

+ const TerminationReasonCodePodAssignmentFailure

+ const TerminationReasonCodePodSchedulingFailure

+ const TerminationReasonCodeResourceUsageBlocked

+ const TerminationReasonCodeSecretCreationFailure

+ const TerminationReasonCodeServerlessLongRunningTerminated

+ const TerminationReasonCodeSparkImageDownloadThrottled

+ const TerminationReasonCodeSparkImageNotFound

+ const TerminationReasonCodeSshBootstrapFailure

+ const TerminationReasonCodeStorageDownloadFailureDueToMisconfig

+ const TerminationReasonCodeStorageDownloadFailureSlow

+ const TerminationReasonCodeStorageDownloadFailureThrottled

+ const TerminationReasonCodeUnexpectedPodRecreation

+ const TerminationReasonCodeUserInitiatedVmTermination

+ const TerminationReasonCodeWorkspaceUpdate

Feb 11, 2025

Changes in this version

type ClusterLogConf

+ Volumes *VolumesStorageInfo

Feb 3, 2025

Changes in this version

+ type CustomPolicyTag struct

+ ForceSendFields []string

+ Key string

+ Value string

+ func (s *CustomPolicyTag) UnmarshalJSON(b []byte) error

+ func (s CustomPolicyTag) MarshalJSON() ([]byte, error)

Jan 22, 2025

Changes in this version

type EventType

+ const EventTypeAddNodesFailed

+ const EventTypeAutomaticClusterUpdate

+ const EventTypeAutoscalingBackoff

+ const EventTypeAutoscalingFailed

Dec 17, 2024

Changes in this version

type ClusterAttributes

+ IsSingleNode bool

+ Kind Kind

+ UseMlRuntime bool

type ClusterDetails

+ IsSingleNode bool

+ Kind Kind

+ UseMlRuntime bool

type ClusterSpec

+ IsSingleNode bool

+ Kind Kind

+ UseMlRuntime bool

type CreateCluster

+ IsSingleNode bool

+ Kind Kind

+ UseMlRuntime bool

type DataSecurityMode

+ const DataSecurityModeDataSecurityModeAuto

+ const DataSecurityModeDataSecurityModeDedicated

+ const DataSecurityModeDataSecurityModeStandard

type EditCluster

+ IsSingleNode bool

+ Kind Kind

+ UseMlRuntime bool

+ type Kind string

+ const KindClassicPreview

+ func (f *Kind) Set(v string) error

+ func (f *Kind) String() string

+ func (f *Kind) Type() string

type UpdateClusterResource

+ IsSingleNode bool

+ Kind Kind

+ UseMlRuntime bool

Aug 21, 2024

Changes in this version

+ type ClusterCompliance struct

+ ClusterId string

+ ForceSendFields []string

+ IsCompliant bool

+ Violations map[string]string

+ func (s *ClusterCompliance) UnmarshalJSON(b []byte) error

+ func (s ClusterCompliance) MarshalJSON() ([]byte, error)

+ type ClusterSettingsChange struct

+ Field string

+ ForceSendFields []string

+ NewValue string

+ PreviousValue string

+ func (s *ClusterSettingsChange) UnmarshalJSON(b []byte) error

+ func (s ClusterSettingsChange) MarshalJSON() ([]byte, error)

+ type EnforceClusterComplianceRequest struct

+ ClusterId string

+ ForceSendFields []string

+ ValidateOnly bool

+ func (s *EnforceClusterComplianceRequest) UnmarshalJSON(b []byte) error

+ func (s EnforceClusterComplianceRequest) MarshalJSON() ([]byte, error)

+ type EnforceClusterComplianceResponse struct

+ Changes []ClusterSettingsChange

+ ForceSendFields []string

+ HasChanges bool

+ func (s *EnforceClusterComplianceResponse) UnmarshalJSON(b []byte) error

+ func (s EnforceClusterComplianceResponse) MarshalJSON() ([]byte, error)

+ type GetClusterComplianceRequest struct

+ ClusterId string

+ type GetClusterComplianceResponse struct

+ ForceSendFields []string

+ IsCompliant bool

+ Violations map[string]string

+ func (s *GetClusterComplianceResponse) UnmarshalJSON(b []byte) error

+ func (s GetClusterComplianceResponse) MarshalJSON() ([]byte, error)

+ type ListClusterCompliancesRequest struct

+ ForceSendFields []string

+ PageSize int

+ PageToken string

+ PolicyId string

+ func (s *ListClusterCompliancesRequest) UnmarshalJSON(b []byte) error

+ func (s ListClusterCompliancesRequest) MarshalJSON() ([]byte, error)

+ type ListClusterCompliancesResponse struct

+ Clusters []ClusterCompliance

+ ForceSendFields []string

+ NextPageToken string

+ PrevPageToken string

+ func (s *ListClusterCompliancesResponse) UnmarshalJSON(b []byte) error

+ func (s ListClusterCompliancesResponse) MarshalJSON() ([]byte, error)

+ type PolicyComplianceForClustersAPI struct

+ func NewPolicyComplianceForClusters(client *client.DatabricksClient) *PolicyComplianceForClustersAPI

+ func (a *PolicyComplianceForClustersAPI) EnforceCompliance(ctx context.Context, request EnforceClusterComplianceRequest) (*EnforceClusterComplianceResponse, error)

+ func (a *PolicyComplianceForClustersAPI) GetCompliance(ctx context.Context, request GetClusterComplianceRequest) (*GetClusterComplianceResponse, error)

+ func (a *PolicyComplianceForClustersAPI) GetComplianceByClusterId(ctx context.Context, clusterId string) (*GetClusterComplianceResponse, error)

+ func (a *PolicyComplianceForClustersAPI) ListCompliance(ctx context.Context, request ListClusterCompliancesRequest) listing.Iterator[ClusterCompliance]

+ func (a *PolicyComplianceForClustersAPI) ListComplianceAll(ctx context.Context, request ListClusterCompliancesRequest) ([]ClusterCompliance, error)

+ type PolicyComplianceForClustersInterface interface

+ EnforceCompliance func(ctx context.Context, request EnforceClusterComplianceRequest) (*EnforceClusterComplianceResponse, error)

+ GetCompliance func(ctx context.Context, request GetClusterComplianceRequest) (*GetClusterComplianceResponse, error)

+ GetComplianceByClusterId func(ctx context.Context, clusterId string) (*GetClusterComplianceResponse, error)

+ ListCompliance func(ctx context.Context, request ListClusterCompliancesRequest) listing.Iterator[ClusterCompliance]

+ ListComplianceAll func(ctx context.Context, request ListClusterCompliancesRequest) ([]ClusterCompliance, error)

+ type PolicyComplianceForClustersService interface

+ EnforceCompliance func(ctx context.Context, request EnforceClusterComplianceRequest) (*EnforceClusterComplianceResponse, error)

+ GetCompliance func(ctx context.Context, request GetClusterComplianceRequest) (*GetClusterComplianceResponse, error)

+ ListCompliance func(ctx context.Context, request ListClusterCompliancesRequest) (*ListClusterCompliancesResponse, error)

Aug 13, 2024

Changes in this version

type ClustersAPI

+ func (a *ClustersAPI) Update(ctx context.Context, updateCluster UpdateCluster) (*WaitGetClusterRunning[struct{}], error)

+ func (a *ClustersAPI) UpdateAndWait(ctx context.Context, updateCluster UpdateCluster, ...) (*ClusterDetails, error)

type ClustersInterface

+ Update func(ctx context.Context, updateCluster UpdateCluster) (*WaitGetClusterRunning[struct{}], error)

+ UpdateAndWait func(ctx context.Context, updateCluster UpdateCluster, ...) (*ClusterDetails, error)

type ClustersService

+ Update func(ctx context.Context, request UpdateCluster) error

type GetPolicyFamilyRequest

+ ForceSendFields []string

+ Version int64

+ func (s *GetPolicyFamilyRequest) UnmarshalJSON(b []byte) error

+ func (s GetPolicyFamilyRequest) MarshalJSON() ([]byte, error)

+ type ListClustersFilterBy struct

+ ClusterSources []ClusterSource

+ ClusterStates []State

+ ForceSendFields []string

+ IsPinned bool

+ PolicyId string

+ func (s *ListClustersFilterBy) UnmarshalJSON(b []byte) error

+ func (s ListClustersFilterBy) MarshalJSON() ([]byte, error)

type ListClustersRequest

+ FilterBy *ListClustersFilterBy

+ PageSize int

+ PageToken string

+ SortBy *ListClustersSortBy

type ListClustersResponse

+ ForceSendFields []string

+ NextPageToken string

+ PrevPageToken string

+ func (s *ListClustersResponse) UnmarshalJSON(b []byte) error

+ func (s ListClustersResponse) MarshalJSON() ([]byte, error)

+ type ListClustersSortBy struct

+ Direction ListClustersSortByDirection

+ Field ListClustersSortByField

+ type ListClustersSortByDirection string

+ const ListClustersSortByDirectionAsc

+ const ListClustersSortByDirectionDesc

+ func (f *ListClustersSortByDirection) Set(v string) error

+ func (f *ListClustersSortByDirection) String() string

+ func (f *ListClustersSortByDirection) Type() string

+ type ListClustersSortByField string

+ const ListClustersSortByFieldClusterName

+ const ListClustersSortByFieldDefault

+ func (f *ListClustersSortByField) Set(v string) error

+ func (f *ListClustersSortByField) String() string

+ func (f *ListClustersSortByField) Type() string

type PolicyFamily

+ ForceSendFields []string

+ func (s *PolicyFamily) UnmarshalJSON(b []byte) error

+ func (s PolicyFamily) MarshalJSON() ([]byte, error)

+ type UpdateCluster struct

+ Cluster *UpdateClusterResource

+ ClusterId string

+ UpdateMask string

+ type UpdateClusterResource struct

+ Autoscale *AutoScale

+ AutoterminationMinutes int

+ AwsAttributes *AwsAttributes

+ AzureAttributes *AzureAttributes

+ ClusterLogConf *ClusterLogConf

+ ClusterName string

+ CustomTags map[string]string

+ DataSecurityMode DataSecurityMode

+ DockerImage *DockerImage

+ DriverInstancePoolId string

+ DriverNodeTypeId string

+ EnableElasticDisk bool

+ EnableLocalDiskEncryption bool

+ ForceSendFields []string

+ 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

+ func (s *UpdateClusterResource) UnmarshalJSON(b []byte) error

+ func (s UpdateClusterResource) MarshalJSON() ([]byte, error)

+ type UpdateClusterResponse struct

Jun 3, 2024

Changes in this version

type DataSecurityMode

+ const DataSecurityModeLegacySingleUserStandard

May 21, 2024

Changes in this version

type LibrariesAPI

+ func (a *LibrariesAPI) AllClusterStatusesAll(ctx context.Context) ([]ClusterLibraryStatuses, error)

type LibrariesInterface

+ AllClusterStatusesAll func(ctx context.Context) ([]ClusterLibraryStatuses, error)

May 2, 2024

Changes in this version

type ClusterStatusResponse

+ func (cls ClusterStatusResponse) ToLibraryList() InstallLibraries

Apr 24, 2024

Changes in this version

+ type ClusterStatus struct

+ ClusterId string

+ type ClusterStatusResponse struct

+ ClusterId string

+ ForceSendFields []string

+ LibraryStatuses []LibraryFullStatus

+ func (cls ClusterStatusResponse) IsRetryNeeded(w Wait) (bool, error)

+ func (s *ClusterStatusResponse) UnmarshalJSON(b []byte) error

+ func (s ClusterStatusResponse) MarshalJSON() ([]byte, error)

type Library

+ Requirements string

+ type LibraryInstallStatus string

+ const LibraryInstallStatusFailed

+ const LibraryInstallStatusInstalled

+ const LibraryInstallStatusInstalling

+ const LibraryInstallStatusPending

+ const LibraryInstallStatusResolving

+ const LibraryInstallStatusRestored

+ const LibraryInstallStatusSkipped

+ const LibraryInstallStatusUninstallOnRestart

+ func (f *LibraryInstallStatus) Set(v string) error

+ func (f *LibraryInstallStatus) String() string

+ func (f *LibraryInstallStatus) Type() string

Apr 11, 2024

Changes in this version

+ type CloneCluster struct

+ SourceClusterId string

type ClusterSpec

+ CloneFrom *CloneCluster

type CreateCluster

+ CloneFrom *CloneCluster

type EditCluster

+ CloneFrom *CloneCluster

+ type Environment struct

+ Client string

+ Dependencies []string

Mar 5, 2024

Changes in this version

+ type AddResponse struct

+ type CancelResponse struct

+ type ChangeClusterOwnerResponse struct

+ type DeleteClusterResponse struct

+ type DeleteInstancePoolResponse struct

+ type DeletePolicyResponse struct

+ type DeleteResponse struct

+ type DestroyResponse struct

+ type EditClusterResponse struct

+ type EditInstancePoolResponse struct

+ type EditPolicyResponse struct

+ type EditResponse struct

+ type InstallLibrariesResponse struct

+ type PermanentDeleteClusterResponse struct

+ type PinClusterResponse struct

+ type RemoveResponse struct

+ type ResizeClusterResponse struct

+ type RestartClusterResponse struct

+ type StartClusterResponse struct

+ type UninstallLibrariesResponse struct

+ type UnpinClusterResponse struct

+ type UpdateResponse struct

Feb 8, 2024

Changes in this version

+ type Adlsgen2Info struct

+ Destination string

type AutoScale

+ ForceSendFields []string

+ func (s *AutoScale) UnmarshalJSON(b []byte) error

+ func (s AutoScale) MarshalJSON() ([]byte, error)

type GcpAttributes

+ UsePreemptibleExecutors bool

+ ZoneId string

+ type GcsStorageInfo struct

+ Destination string

type InitScriptInfo

+ Abfss *Adlsgen2Info

+ Gcs *GcsStorageInfo

Jan 16, 2024

Changes in this version

type WaitCommandStatusCommandExecutionCancelled

+ Poll func(time.Duration, func(*CommandStatusResponse)) (*CommandStatusResponse, error)

type WaitCommandStatusCommandExecutionFinishedOrError

+ Poll func(time.Duration, func(*CommandStatusResponse)) (*CommandStatusResponse, error)

type WaitContextStatusCommandExecutionRunning

+ Poll func(time.Duration, func(*ContextStatusResponse)) (*ContextStatusResponse, error)

type WaitGetClusterRunning

+ Poll func(time.Duration, func(*ClusterDetails)) (*ClusterDetails, error)

type WaitGetClusterTerminated

+ Poll func(time.Duration, func(*ClusterDetails)) (*ClusterDetails, error)

Jan 10, 2024

Changes in this version

+ type ClusterPoliciesInterface interface

+ Create func(ctx context.Context, request CreatePolicy) (*CreatePolicyResponse, error)

+ Delete func(ctx context.Context, request DeletePolicy) error

+ DeleteByPolicyId func(ctx context.Context, policyId string) error

+ Edit func(ctx context.Context, request EditPolicy) error

+ Get func(ctx context.Context, request GetClusterPolicyRequest) (*Policy, error)

+ GetByName func(ctx context.Context, name string) (*Policy, error)

+ GetByPolicyId func(ctx context.Context, policyId string) (*Policy, error)

+ GetPermissionLevels func(ctx context.Context, request GetClusterPolicyPermissionLevelsRequest) (*GetClusterPolicyPermissionLevelsResponse, error)

+ GetPermissionLevelsByClusterPolicyId func(ctx context.Context, clusterPolicyId string) (*GetClusterPolicyPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ GetPermissionsByClusterPolicyId func(ctx context.Context, clusterPolicyId string) (*ClusterPolicyPermissions, error)

+ Impl func() ClusterPoliciesService

+ List func(ctx context.Context, request ListClusterPoliciesRequest) ...

+ ListAll func(ctx context.Context, request ListClusterPoliciesRequest) ([]Policy, error)

+ PolicyNameToPolicyIdMap func(ctx context.Context, request ListClusterPoliciesRequest) (map[string]string, error)

+ SetPermissions func(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ UpdatePermissions func(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ WithImpl func(impl ClusterPoliciesService) ClusterPoliciesInterface

+ type ClustersInterface interface

+ ChangeOwner func(ctx context.Context, request ChangeClusterOwner) error

+ ClusterDetailsClusterNameToClusterIdMap func(ctx context.Context, request ListClustersRequest) (map[string]string, error)

+ Create func(ctx context.Context, createCluster CreateCluster) (*WaitGetClusterRunning[CreateClusterResponse], error)

+ CreateAndWait func(ctx context.Context, createCluster CreateCluster, ...) (*ClusterDetails, error)

+ Delete func(ctx context.Context, deleteCluster DeleteCluster) (*WaitGetClusterTerminated[any], error)

+ DeleteAndWait func(ctx context.Context, deleteCluster DeleteCluster, ...) (*ClusterDetails, error)

+ DeleteByClusterId func(ctx context.Context, clusterId string) error

+ DeleteByClusterIdAndWait func(ctx context.Context, clusterId string, ...) (*ClusterDetails, error)

+ Edit func(ctx context.Context, editCluster EditCluster) (*WaitGetClusterRunning[any], error)

+ EditAndWait func(ctx context.Context, editCluster EditCluster, ...) (*ClusterDetails, error)

+ Events func(ctx context.Context, request GetEvents) *listing.PaginatingIterator[GetEvents, *GetEventsResponse, ClusterEvent]

+ EventsAll func(ctx context.Context, request GetEvents) ([]ClusterEvent, error)

+ Get func(ctx context.Context, request GetClusterRequest) (*ClusterDetails, error)

+ GetByClusterId func(ctx context.Context, clusterId string) (*ClusterDetails, error)

+ GetByClusterName func(ctx context.Context, name string) (*ClusterDetails, error)

+ GetPermissionLevels func(ctx context.Context, request GetClusterPermissionLevelsRequest) (*GetClusterPermissionLevelsResponse, error)

+ GetPermissionLevelsByClusterId func(ctx context.Context, clusterId string) (*GetClusterPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetClusterPermissionsRequest) (*ClusterPermissions, error)

+ GetPermissionsByClusterId func(ctx context.Context, clusterId string) (*ClusterPermissions, error)

+ Impl func() ClustersService

+ List func(ctx context.Context, request ListClustersRequest) ...

+ ListAll func(ctx context.Context, request ListClustersRequest) ([]ClusterDetails, error)

+ ListByCanUseClient func(ctx context.Context, canUseClient string) (*ListClustersResponse, error)

+ ListNodeTypes func(ctx context.Context) (*ListNodeTypesResponse, error)

+ ListZones func(ctx context.Context) (*ListAvailableZonesResponse, error)

+ PermanentDelete func(ctx context.Context, request PermanentDeleteCluster) error

+ PermanentDeleteByClusterId func(ctx context.Context, clusterId string) error

+ Pin func(ctx context.Context, request PinCluster) error

+ PinByClusterId func(ctx context.Context, clusterId string) error

+ Resize func(ctx context.Context, resizeCluster ResizeCluster) (*WaitGetClusterRunning[any], error)

+ ResizeAndWait func(ctx context.Context, resizeCluster ResizeCluster, ...) (*ClusterDetails, error)

+ Restart func(ctx context.Context, restartCluster RestartCluster) (*WaitGetClusterRunning[any], error)

+ RestartAndWait func(ctx context.Context, restartCluster RestartCluster, ...) (*ClusterDetails, error)

+ SetPermissions func(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

+ SparkVersions func(ctx context.Context) (*GetSparkVersionsResponse, error)

+ Start func(ctx context.Context, startCluster StartCluster) (*WaitGetClusterRunning[any], error)

+ StartAndWait func(ctx context.Context, startCluster StartCluster, ...) (*ClusterDetails, error)

+ StartByClusterId func(ctx context.Context, clusterId string) error

+ StartByClusterIdAndWait func(ctx context.Context, clusterId string, ...) (*ClusterDetails, error)

+ Unpin func(ctx context.Context, request UnpinCluster) error

+ UnpinByClusterId func(ctx context.Context, clusterId string) error

+ UpdatePermissions func(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

+ WaitGetClusterRunning func(ctx context.Context, clusterId string, timeout time.Duration, ...) (*ClusterDetails, error)

+ WaitGetClusterTerminated func(ctx context.Context, clusterId string, timeout time.Duration, ...) (*ClusterDetails, error)

+ WithImpl func(impl ClustersService) ClustersInterface

+ type CommandExecutionInterface interface

+ Cancel func(ctx context.Context, cancelCommand CancelCommand) (*WaitCommandStatusCommandExecutionCancelled[any], error)

+ CancelAndWait func(ctx context.Context, cancelCommand CancelCommand, ...) (*CommandStatusResponse, error)

+ CommandStatus func(ctx context.Context, request CommandStatusRequest) (*CommandStatusResponse, error)

+ ContextStatus func(ctx context.Context, request ContextStatusRequest) (*ContextStatusResponse, error)

+ Create func(ctx context.Context, createContext CreateContext) (*WaitContextStatusCommandExecutionRunning[Created], error)

+ CreateAndWait func(ctx context.Context, createContext CreateContext, ...) (*ContextStatusResponse, error)

+ Destroy func(ctx context.Context, request DestroyContext) error

+ Execute func(ctx context.Context, command Command) (*WaitCommandStatusCommandExecutionFinishedOrError[Created], error)

+ ExecuteAndWait func(ctx context.Context, command Command, ...) (*CommandStatusResponse, error)

+ Impl func() CommandExecutionService

+ WaitCommandStatusCommandExecutionCancelled func(ctx context.Context, clusterId string, commandId string, contextId string, ...) (*CommandStatusResponse, error)

+ WaitCommandStatusCommandExecutionFinishedOrError func(ctx context.Context, clusterId string, commandId string, contextId string, ...) (*CommandStatusResponse, error)

+ WaitContextStatusCommandExecutionRunning func(ctx context.Context, clusterId string, contextId string, timeout time.Duration, ...) (*ContextStatusResponse, error)

+ WithImpl func(impl CommandExecutionService) CommandExecutionInterface

+ type GlobalInitScriptsInterface interface

+ Create func(ctx context.Context, request GlobalInitScriptCreateRequest) (*CreateResponse, error)

+ Delete func(ctx context.Context, request DeleteGlobalInitScriptRequest) error

+ DeleteByScriptId func(ctx context.Context, scriptId string) error

+ Get func(ctx context.Context, request GetGlobalInitScriptRequest) (*GlobalInitScriptDetailsWithContent, error)

+ GetByName func(ctx context.Context, name string) (*GlobalInitScriptDetails, error)

+ GetByScriptId func(ctx context.Context, scriptId string) (*GlobalInitScriptDetailsWithContent, error)

+ GlobalInitScriptDetailsNameToScriptIdMap func(ctx context.Context) (map[string]string, error)

+ Impl func() GlobalInitScriptsService

+ List func(ctx context.Context) ...

+ ListAll func(ctx context.Context) ([]GlobalInitScriptDetails, error)

+ Update func(ctx context.Context, request GlobalInitScriptUpdateRequest) error

+ WithImpl func(impl GlobalInitScriptsService) GlobalInitScriptsInterface

+ type InstancePoolsInterface interface

+ Create func(ctx context.Context, request CreateInstancePool) (*CreateInstancePoolResponse, error)

+ Delete func(ctx context.Context, request DeleteInstancePool) error

+ DeleteByInstancePoolId func(ctx context.Context, instancePoolId string) error

+ Edit func(ctx context.Context, request EditInstancePool) error

+ Get func(ctx context.Context, request GetInstancePoolRequest) (*GetInstancePool, error)

+ GetByInstancePoolId func(ctx context.Context, instancePoolId string) (*GetInstancePool, error)

+ GetByInstancePoolName func(ctx context.Context, name string) (*InstancePoolAndStats, error)

+ GetPermissionLevels func(ctx context.Context, request GetInstancePoolPermissionLevelsRequest) (*GetInstancePoolPermissionLevelsResponse, error)

+ GetPermissionLevelsByInstancePoolId func(ctx context.Context, instancePoolId string) (*GetInstancePoolPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetInstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ GetPermissionsByInstancePoolId func(ctx context.Context, instancePoolId string) (*InstancePoolPermissions, error)

+ Impl func() InstancePoolsService

+ InstancePoolAndStatsInstancePoolNameToInstancePoolIdMap func(ctx context.Context) (map[string]string, error)

+ List func(ctx context.Context) ...

+ ListAll func(ctx context.Context) ([]InstancePoolAndStats, error)

+ SetPermissions func(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ UpdatePermissions func(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ WithImpl func(impl InstancePoolsService) InstancePoolsInterface

+ type InstanceProfilesInterface interface

+ Add func(ctx context.Context, request AddInstanceProfile) error

+ Edit func(ctx context.Context, request InstanceProfile) error

+ Impl func() InstanceProfilesService

+ List func(ctx context.Context) ...

+ ListAll func(ctx context.Context) ([]InstanceProfile, error)

+ Remove func(ctx context.Context, request RemoveInstanceProfile) error

+ RemoveByInstanceProfileArn func(ctx context.Context, instanceProfileArn string) error

+ WithImpl func(impl InstanceProfilesService) InstanceProfilesInterface

+ type LibrariesInterface interface

+ AllClusterStatuses func(ctx context.Context) (*ListAllClusterLibraryStatusesResponse, error)

+ ClusterStatus func(ctx context.Context, request ClusterStatusRequest) ...

+ ClusterStatusAll func(ctx context.Context, request ClusterStatusRequest) ([]LibraryFullStatus, error)

+ ClusterStatusByClusterId func(ctx context.Context, clusterId string) (*ClusterLibraryStatuses, error)

+ Impl func() LibrariesService

+ Install func(ctx context.Context, request InstallLibraries) error

+ Uninstall func(ctx context.Context, request UninstallLibraries) error

+ WithImpl func(impl LibrariesService) LibrariesInterface

+ type PolicyFamiliesInterface interface

+ Get func(ctx context.Context, request GetPolicyFamilyRequest) (*PolicyFamily, error)

+ GetByPolicyFamilyId func(ctx context.Context, policyFamilyId string) (*PolicyFamily, error)

+ Impl func() PolicyFamiliesService

+ List func(ctx context.Context, request ListPolicyFamiliesRequest) ...

+ ListAll func(ctx context.Context, request ListPolicyFamiliesRequest) ([]PolicyFamily, error)

+ WithImpl func(impl PolicyFamiliesService) PolicyFamiliesInterface

Nov 10, 2023

Changes in this version

type CreatePolicy

+ Libraries []Library

type EditPolicy

+ Libraries []Library

type EventDetails

+ InitScripts *InitScriptEventDetails

+ type InitScriptEventDetails struct

+ Cluster []InitScriptInfoAndExecutionDetails

+ ForceSendFields []string

+ Global []InitScriptInfoAndExecutionDetails

+ ReportedForNode string

+ func (s *InitScriptEventDetails) UnmarshalJSON(b []byte) error

+ func (s InitScriptEventDetails) MarshalJSON() ([]byte, error)

+ type InitScriptExecutionDetails struct

+ ErrorMessage string

+ ExecutionDurationSeconds int

+ ForceSendFields []string

+ Status InitScriptExecutionDetailsStatus

+ func (s *InitScriptExecutionDetails) UnmarshalJSON(b []byte) error

+ func (s InitScriptExecutionDetails) MarshalJSON() ([]byte, error)

+ type InitScriptExecutionDetailsStatus string

+ const InitScriptExecutionDetailsStatusFailedExecution

+ const InitScriptExecutionDetailsStatusFailedFetch

+ const InitScriptExecutionDetailsStatusNotExecuted

+ const InitScriptExecutionDetailsStatusSkipped

+ const InitScriptExecutionDetailsStatusSucceeded

+ const InitScriptExecutionDetailsStatusUnknown

+ func (f *InitScriptExecutionDetailsStatus) Set(v string) error

+ func (f *InitScriptExecutionDetailsStatus) String() string

+ func (f *InitScriptExecutionDetailsStatus) Type() string

type InitScriptInfo

+ File *LocalFileInfo

+ type InitScriptInfoAndExecutionDetails struct

+ ExecutionDetails *InitScriptExecutionDetails

+ Script *InitScriptInfo

type InstancePoolGcpAttributes

+ ZoneId string

+ type LocalFileInfo struct

+ Destination string

+ ForceSendFields []string

+ func (s *LocalFileInfo) UnmarshalJSON(b []byte) error

+ func (s LocalFileInfo) MarshalJSON() ([]byte, error)

type Policy

+ Libraries []Library

Oct 24, 2023

Changes in this version

type ClusterPoliciesAPI

+ func (a *ClusterPoliciesAPI) List(ctx context.Context, request ListClusterPoliciesRequest) ...

type ClustersAPI

+ func (a *ClustersAPI) Events(ctx context.Context, request GetEvents) *listing.PaginatingIterator[GetEvents, *GetEventsResponse, ClusterEvent]

+ func (a *ClustersAPI) List(ctx context.Context, request ListClustersRequest) ...

type GlobalInitScriptsAPI

+ func (a *GlobalInitScriptsAPI) List(ctx context.Context) ...

type InstancePoolsAPI

+ func (a *InstancePoolsAPI) List(ctx context.Context) ...

type InstanceProfilesAPI

+ func (a *InstanceProfilesAPI) List(ctx context.Context) ...

type PolicyFamiliesAPI

+ func (a *PolicyFamiliesAPI) List(ctx context.Context, request ListPolicyFamiliesRequest) ...

Oct 12, 2023

Changes in this version

type AddInstanceProfile

+ ForceSendFields []string

+ func (s *AddInstanceProfile) UnmarshalJSON(b []byte) error

+ func (s AddInstanceProfile) MarshalJSON() ([]byte, error)

type AwsAttributes

+ ForceSendFields []string

+ func (s *AwsAttributes) UnmarshalJSON(b []byte) error

+ func (s AwsAttributes) MarshalJSON() ([]byte, error)

type AzureAttributes

+ ForceSendFields []string

+ func (s *AzureAttributes) UnmarshalJSON(b []byte) error

+ func (s AzureAttributes) MarshalJSON() ([]byte, error)

type CancelCommand

+ ForceSendFields []string

+ func (s *CancelCommand) UnmarshalJSON(b []byte) error

+ func (s CancelCommand) MarshalJSON() ([]byte, error)

type ClientsTypes

+ ForceSendFields []string

+ func (s *ClientsTypes) UnmarshalJSON(b []byte) error

+ func (s ClientsTypes) MarshalJSON() ([]byte, error)

type ClusterAccessControlRequest

+ ForceSendFields []string

+ func (s *ClusterAccessControlRequest) UnmarshalJSON(b []byte) error

+ func (s ClusterAccessControlRequest) MarshalJSON() ([]byte, error)

type ClusterAccessControlResponse

+ ForceSendFields []string

+ func (s *ClusterAccessControlResponse) UnmarshalJSON(b []byte) error

+ func (s ClusterAccessControlResponse) MarshalJSON() ([]byte, error)

type ClusterAttributes

+ ForceSendFields []string

+ func (s *ClusterAttributes) UnmarshalJSON(b []byte) error

+ func (s ClusterAttributes) MarshalJSON() ([]byte, error)

type ClusterDetails

+ ForceSendFields []string

+ Spec *CreateCluster

+ func (s *ClusterDetails) UnmarshalJSON(b []byte) error

+ func (s ClusterDetails) MarshalJSON() ([]byte, error)

type ClusterEvent

+ ForceSendFields []string

+ func (s *ClusterEvent) UnmarshalJSON(b []byte) error

+ func (s ClusterEvent) MarshalJSON() ([]byte, error)

type ClusterLibraryStatuses

+ ForceSendFields []string

+ func (s *ClusterLibraryStatuses) UnmarshalJSON(b []byte) error

+ func (s ClusterLibraryStatuses) MarshalJSON() ([]byte, error)

type ClusterPermission

+ ForceSendFields []string

+ func (s *ClusterPermission) UnmarshalJSON(b []byte) error

+ func (s ClusterPermission) MarshalJSON() ([]byte, error)

type ClusterPermissions

+ ForceSendFields []string

+ func (s *ClusterPermissions) UnmarshalJSON(b []byte) error

+ func (s ClusterPermissions) MarshalJSON() ([]byte, error)

type ClusterPermissionsDescription

+ ForceSendFields []string

+ func (s *ClusterPermissionsDescription) UnmarshalJSON(b []byte) error

+ func (s ClusterPermissionsDescription) MarshalJSON() ([]byte, error)

type ClusterPolicyAccessControlRequest

+ ForceSendFields []string

+ func (s *ClusterPolicyAccessControlRequest) UnmarshalJSON(b []byte) error

+ func (s ClusterPolicyAccessControlRequest) MarshalJSON() ([]byte, error)

type ClusterPolicyAccessControlResponse

+ ForceSendFields []string

+ func (s *ClusterPolicyAccessControlResponse) UnmarshalJSON(b []byte) error

+ func (s ClusterPolicyAccessControlResponse) MarshalJSON() ([]byte, error)

type ClusterPolicyPermission

+ ForceSendFields []string

+ func (s *ClusterPolicyPermission) UnmarshalJSON(b []byte) error

+ func (s ClusterPolicyPermission) MarshalJSON() ([]byte, error)

type ClusterPolicyPermissions

+ ForceSendFields []string

+ func (s *ClusterPolicyPermissions) UnmarshalJSON(b []byte) error

+ func (s ClusterPolicyPermissions) MarshalJSON() ([]byte, error)

type ClusterPolicyPermissionsDescription

+ ForceSendFields []string

+ func (s *ClusterPolicyPermissionsDescription) UnmarshalJSON(b []byte) error

+ func (s ClusterPolicyPermissionsDescription) MarshalJSON() ([]byte, error)

type ClusterSize

+ ForceSendFields []string

+ func (s *ClusterSize) UnmarshalJSON(b []byte) error

+ func (s ClusterSize) MarshalJSON() ([]byte, error)

type ClusterSpec

+ ApplyPolicyDefaultValues bool

+ ForceSendFields []string

+ func (s *ClusterSpec) UnmarshalJSON(b []byte) error

+ func (s ClusterSpec) MarshalJSON() ([]byte, error)

type Command

+ ForceSendFields []string

+ func (s *Command) UnmarshalJSON(b []byte) error

+ func (s Command) MarshalJSON() ([]byte, error)

type CommandStatusResponse

+ ForceSendFields []string

+ func (s *CommandStatusResponse) UnmarshalJSON(b []byte) error

+ func (s CommandStatusResponse) MarshalJSON() ([]byte, error)

type ContextStatusResponse

+ ForceSendFields []string

+ func (s *ContextStatusResponse) UnmarshalJSON(b []byte) error

+ func (s ContextStatusResponse) MarshalJSON() ([]byte, error)

type CreateCluster

+ ForceSendFields []string

+ func (s *CreateCluster) UnmarshalJSON(b []byte) error

+ func (s CreateCluster) MarshalJSON() ([]byte, error)

type CreateClusterResponse

+ ForceSendFields []string

+ func (s *CreateClusterResponse) UnmarshalJSON(b []byte) error

+ func (s CreateClusterResponse) MarshalJSON() ([]byte, error)

type CreateContext

+ ForceSendFields []string

+ func (s *CreateContext) UnmarshalJSON(b []byte) error

+ func (s CreateContext) MarshalJSON() ([]byte, error)

type CreateInstancePool

+ ForceSendFields []string

+ func (s *CreateInstancePool) UnmarshalJSON(b []byte) error

+ func (s CreateInstancePool) MarshalJSON() ([]byte, error)

type CreateInstancePoolResponse

+ ForceSendFields []string

+ func (s *CreateInstancePoolResponse) UnmarshalJSON(b []byte) error

+ func (s CreateInstancePoolResponse) MarshalJSON() ([]byte, error)

type CreatePolicy

+ ForceSendFields []string

+ func (s *CreatePolicy) UnmarshalJSON(b []byte) error

+ func (s CreatePolicy) MarshalJSON() ([]byte, error)

type CreatePolicyResponse

+ ForceSendFields []string

+ func (s *CreatePolicyResponse) UnmarshalJSON(b []byte) error

+ func (s CreatePolicyResponse) MarshalJSON() ([]byte, error)

type CreateResponse

+ ForceSendFields []string

+ func (s *CreateResponse) UnmarshalJSON(b []byte) error

+ func (s CreateResponse) MarshalJSON() ([]byte, error)

type Created

+ ForceSendFields []string

+ func (s *Created) UnmarshalJSON(b []byte) error

+ func (s Created) MarshalJSON() ([]byte, error)

type DataPlaneEventDetails

+ ForceSendFields []string

+ func (s *DataPlaneEventDetails) UnmarshalJSON(b []byte) error

+ func (s DataPlaneEventDetails) MarshalJSON() ([]byte, error)

type DbfsStorageInfo

+ ForceSendFields []string

+ func (s *DbfsStorageInfo) UnmarshalJSON(b []byte) error

+ func (s DbfsStorageInfo) MarshalJSON() ([]byte, error)

type DiskSpec

+ ForceSendFields []string

+ func (s *DiskSpec) UnmarshalJSON(b []byte) error

+ func (s DiskSpec) MarshalJSON() ([]byte, error)

type DockerBasicAuth

+ ForceSendFields []string

+ func (s *DockerBasicAuth) UnmarshalJSON(b []byte) error

+ func (s DockerBasicAuth) MarshalJSON() ([]byte, error)

type DockerImage

+ ForceSendFields []string

+ func (s *DockerImage) UnmarshalJSON(b []byte) error

+ func (s DockerImage) MarshalJSON() ([]byte, error)

type EditCluster

+ ForceSendFields []string

+ func (s *EditCluster) UnmarshalJSON(b []byte) error

+ func (s EditCluster) MarshalJSON() ([]byte, error)

type EditInstancePool

+ ForceSendFields []string

+ func (s *EditInstancePool) UnmarshalJSON(b []byte) error

+ func (s EditInstancePool) MarshalJSON() ([]byte, error)

type EditPolicy

+ ForceSendFields []string

+ func (s *EditPolicy) UnmarshalJSON(b []byte) error

+ func (s EditPolicy) MarshalJSON() ([]byte, error)

type EventDetails

+ ForceSendFields []string

+ func (s *EventDetails) UnmarshalJSON(b []byte) error

+ func (s EventDetails) MarshalJSON() ([]byte, error)

type GcpAttributes

+ ForceSendFields []string

+ func (s *GcpAttributes) UnmarshalJSON(b []byte) error

+ func (s GcpAttributes) MarshalJSON() ([]byte, error)

type GetEvents

+ ForceSendFields []string

+ func (s *GetEvents) UnmarshalJSON(b []byte) error

+ func (s GetEvents) MarshalJSON() ([]byte, error)

type GetEventsResponse

+ ForceSendFields []string

+ func (s *GetEventsResponse) UnmarshalJSON(b []byte) error

+ func (s GetEventsResponse) MarshalJSON() ([]byte, error)

type GetInstancePool

+ ForceSendFields []string

+ func (s *GetInstancePool) UnmarshalJSON(b []byte) error

+ func (s GetInstancePool) MarshalJSON() ([]byte, error)

type GlobalInitScriptCreateRequest

+ ForceSendFields []string

+ func (s *GlobalInitScriptCreateRequest) UnmarshalJSON(b []byte) error

+ func (s GlobalInitScriptCreateRequest) MarshalJSON() ([]byte, error)

type GlobalInitScriptDetails

+ ForceSendFields []string

+ func (s *GlobalInitScriptDetails) UnmarshalJSON(b []byte) error

+ func (s GlobalInitScriptDetails) MarshalJSON() ([]byte, error)

type GlobalInitScriptDetailsWithContent

+ ForceSendFields []string

+ func (s *GlobalInitScriptDetailsWithContent) UnmarshalJSON(b []byte) error

+ func (s GlobalInitScriptDetailsWithContent) MarshalJSON() ([]byte, error)

type GlobalInitScriptUpdateRequest

+ ForceSendFields []string

+ func (s *GlobalInitScriptUpdateRequest) UnmarshalJSON(b []byte) error

+ func (s GlobalInitScriptUpdateRequest) MarshalJSON() ([]byte, error)

type InstancePoolAccessControlRequest

+ ForceSendFields []string

+ func (s *InstancePoolAccessControlRequest) UnmarshalJSON(b []byte) error

+ func (s InstancePoolAccessControlRequest) MarshalJSON() ([]byte, error)

type InstancePoolAccessControlResponse

+ ForceSendFields []string

+ func (s *InstancePoolAccessControlResponse) UnmarshalJSON(b []byte) error

+ func (s InstancePoolAccessControlResponse) MarshalJSON() ([]byte, error)

type InstancePoolAndStats

+ ForceSendFields []string

+ func (s *InstancePoolAndStats) UnmarshalJSON(b []byte) error

+ func (s InstancePoolAndStats) MarshalJSON() ([]byte, error)

type InstancePoolAwsAttributes

+ ForceSendFields []string

+ func (s *InstancePoolAwsAttributes) UnmarshalJSON(b []byte) error

+ func (s InstancePoolAwsAttributes) MarshalJSON() ([]byte, error)

type InstancePoolAzureAttributes

+ ForceSendFields []string

+ func (s *InstancePoolAzureAttributes) UnmarshalJSON(b []byte) error

+ func (s InstancePoolAzureAttributes) MarshalJSON() ([]byte, error)

type InstancePoolGcpAttributes

+ ForceSendFields []string

+ func (s *InstancePoolGcpAttributes) UnmarshalJSON(b []byte) error

+ func (s InstancePoolGcpAttributes) MarshalJSON() ([]byte, error)

type InstancePoolPermission

+ ForceSendFields []string

+ func (s *InstancePoolPermission) UnmarshalJSON(b []byte) error

+ func (s InstancePoolPermission) MarshalJSON() ([]byte, error)

type InstancePoolPermissions

+ ForceSendFields []string

+ func (s *InstancePoolPermissions) UnmarshalJSON(b []byte) error

+ func (s InstancePoolPermissions) MarshalJSON() ([]byte, error)

type InstancePoolPermissionsDescription

+ ForceSendFields []string

+ func (s *InstancePoolPermissionsDescription) UnmarshalJSON(b []byte) error

+ func (s InstancePoolPermissionsDescription) MarshalJSON() ([]byte, error)

type InstancePoolStats

+ ForceSendFields []string

+ func (s *InstancePoolStats) UnmarshalJSON(b []byte) error

+ func (s InstancePoolStats) MarshalJSON() ([]byte, error)

type InstanceProfile

+ ForceSendFields []string

+ func (s *InstanceProfile) UnmarshalJSON(b []byte) error

+ func (s InstanceProfile) MarshalJSON() ([]byte, error)

type Library

+ ForceSendFields []string

+ func (s *Library) UnmarshalJSON(b []byte) error

+ func (s Library) MarshalJSON() ([]byte, error)

type LibraryFullStatus

+ ForceSendFields []string

+ func (s *LibraryFullStatus) UnmarshalJSON(b []byte) error

+ func (s LibraryFullStatus) MarshalJSON() ([]byte, error)

type ListAvailableZonesResponse

+ ForceSendFields []string

+ func (s *ListAvailableZonesResponse) UnmarshalJSON(b []byte) error

+ func (s ListAvailableZonesResponse) MarshalJSON() ([]byte, error)

type ListClustersRequest

+ ForceSendFields []string

+ func (s *ListClustersRequest) UnmarshalJSON(b []byte) error

+ func (s ListClustersRequest) MarshalJSON() ([]byte, error)

type ListPolicyFamiliesRequest

+ ForceSendFields []string

+ func (s *ListPolicyFamiliesRequest) UnmarshalJSON(b []byte) error

+ func (s ListPolicyFamiliesRequest) MarshalJSON() ([]byte, error)

type ListPolicyFamiliesResponse

+ ForceSendFields []string

+ func (s *ListPolicyFamiliesResponse) UnmarshalJSON(b []byte) error

+ func (s ListPolicyFamiliesResponse) MarshalJSON() ([]byte, error)

type LogAnalyticsInfo

+ ForceSendFields []string

+ func (s *LogAnalyticsInfo) UnmarshalJSON(b []byte) error

+ func (s LogAnalyticsInfo) MarshalJSON() ([]byte, error)

type LogSyncStatus

+ ForceSendFields []string

+ func (s *LogSyncStatus) UnmarshalJSON(b []byte) error

+ func (s LogSyncStatus) MarshalJSON() ([]byte, error)

type MavenLibrary

+ ForceSendFields []string

+ func (s *MavenLibrary) UnmarshalJSON(b []byte) error

+ func (s MavenLibrary) MarshalJSON() ([]byte, error)

type NodeInstanceType

+ ForceSendFields []string

+ func (s *NodeInstanceType) UnmarshalJSON(b []byte) error

+ func (s NodeInstanceType) MarshalJSON() ([]byte, error)

type NodeType

+ ForceSendFields []string

+ func (s *NodeType) UnmarshalJSON(b []byte) error

+ func (s NodeType) MarshalJSON() ([]byte, error)

type PendingInstanceError

+ ForceSendFields []string

+ func (s *PendingInstanceError) UnmarshalJSON(b []byte) error

+ func (s PendingInstanceError) MarshalJSON() ([]byte, error)

type Policy

+ ForceSendFields []string

+ func (s *Policy) UnmarshalJSON(b []byte) error

+ func (s Policy) MarshalJSON() ([]byte, error)

type PythonPyPiLibrary

+ ForceSendFields []string

+ func (s *PythonPyPiLibrary) UnmarshalJSON(b []byte) error

+ func (s PythonPyPiLibrary) MarshalJSON() ([]byte, error)

type RCranLibrary

+ ForceSendFields []string

+ func (s *RCranLibrary) UnmarshalJSON(b []byte) error

+ func (s RCranLibrary) MarshalJSON() ([]byte, error)

type ResizeCluster

+ ForceSendFields []string

+ func (s *ResizeCluster) UnmarshalJSON(b []byte) error

+ func (s ResizeCluster) MarshalJSON() ([]byte, error)

type RestartCluster

+ ForceSendFields []string

+ func (s *RestartCluster) UnmarshalJSON(b []byte) error

+ func (s RestartCluster) MarshalJSON() ([]byte, error)

type Results

+ ForceSendFields []string

+ func (s *Results) UnmarshalJSON(b []byte) error

+ func (s Results) MarshalJSON() ([]byte, error)

type S3StorageInfo

+ ForceSendFields []string

+ func (s *S3StorageInfo) UnmarshalJSON(b []byte) error

+ func (s S3StorageInfo) MarshalJSON() ([]byte, error)

type SparkNode

+ ForceSendFields []string

+ func (s *SparkNode) UnmarshalJSON(b []byte) error

+ func (s SparkNode) MarshalJSON() ([]byte, error)

type SparkNodeAwsAttributes

+ ForceSendFields []string

+ func (s *SparkNodeAwsAttributes) UnmarshalJSON(b []byte) error

+ func (s SparkNodeAwsAttributes) MarshalJSON() ([]byte, error)

type SparkVersion

+ ForceSendFields []string

+ func (s *SparkVersion) UnmarshalJSON(b []byte) error

+ func (s SparkVersion) MarshalJSON() ([]byte, error)

type VolumesStorageInfo

+ ForceSendFields []string

+ func (s *VolumesStorageInfo) UnmarshalJSON(b []byte) error

+ func (s VolumesStorageInfo) MarshalJSON() ([]byte, error)

type WorkspaceStorageInfo

+ ForceSendFields []string

+ func (s *WorkspaceStorageInfo) UnmarshalJSON(b []byte) error

+ func (s WorkspaceStorageInfo) MarshalJSON() ([]byte, error)

Sep 4, 2023

Changes in this version

type ClusterPoliciesAPI

+ func (a *ClusterPoliciesAPI) GetPermissionLevels(ctx context.Context, request GetClusterPolicyPermissionLevelsRequest) (*GetClusterPolicyPermissionLevelsResponse, error)

+ func (a *ClusterPoliciesAPI) GetPermissionLevelsByClusterPolicyId(ctx context.Context, clusterPolicyId string) (*GetClusterPolicyPermissionLevelsResponse, error)

+ func (a *ClusterPoliciesAPI) GetPermissions(ctx context.Context, request GetClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ func (a *ClusterPoliciesAPI) GetPermissionsByClusterPolicyId(ctx context.Context, clusterPolicyId string) (*ClusterPolicyPermissions, error)

+ func (a *ClusterPoliciesAPI) SetPermissions(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ func (a *ClusterPoliciesAPI) UpdatePermissions(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

type ClusterPoliciesService

+ GetPermissionLevels func(ctx context.Context, request GetClusterPolicyPermissionLevelsRequest) (*GetClusterPolicyPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ SetPermissions func(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ UpdatePermissions func(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

type ClustersAPI

+ func (a *ClustersAPI) GetPermissionLevels(ctx context.Context, request GetClusterPermissionLevelsRequest) (*GetClusterPermissionLevelsResponse, error)

+ func (a *ClustersAPI) GetPermissionLevelsByClusterId(ctx context.Context, clusterId string) (*GetClusterPermissionLevelsResponse, error)

+ func (a *ClustersAPI) GetPermissions(ctx context.Context, request GetClusterPermissionsRequest) (*ClusterPermissions, error)

+ func (a *ClustersAPI) GetPermissionsByClusterId(ctx context.Context, clusterId string) (*ClusterPermissions, error)

+ func (a *ClustersAPI) SetPermissions(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

+ func (a *ClustersAPI) UpdatePermissions(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

type ClustersService

+ GetPermissionLevels func(ctx context.Context, request GetClusterPermissionLevelsRequest) (*GetClusterPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetClusterPermissionsRequest) (*ClusterPermissions, error)

+ SetPermissions func(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

+ UpdatePermissions func(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

type InstancePoolsAPI

+ func (a *InstancePoolsAPI) GetPermissionLevels(ctx context.Context, request GetInstancePoolPermissionLevelsRequest) (*GetInstancePoolPermissionLevelsResponse, error)

+ func (a *InstancePoolsAPI) GetPermissionLevelsByInstancePoolId(ctx context.Context, instancePoolId string) (*GetInstancePoolPermissionLevelsResponse, error)

+ func (a *InstancePoolsAPI) GetPermissions(ctx context.Context, request GetInstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ func (a *InstancePoolsAPI) GetPermissionsByInstancePoolId(ctx context.Context, instancePoolId string) (*InstancePoolPermissions, error)

+ func (a *InstancePoolsAPI) SetPermissions(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ func (a *InstancePoolsAPI) UpdatePermissions(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

type InstancePoolsService

+ GetPermissionLevels func(ctx context.Context, request GetInstancePoolPermissionLevelsRequest) (*GetInstancePoolPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetInstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ SetPermissions func(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ UpdatePermissions func(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

type NodeType

+ SupportsElasticDisk bool

Aug 29, 2023

Changes in this version

type InitScriptInfo

+ Volumes *VolumesStorageInfo

type LibrariesAPI

+ func (a *LibrariesAPI) ClusterStatusAll(ctx context.Context, request ClusterStatusRequest) ([]LibraryFullStatus, error)

+ type VolumesStorageInfo struct

+ Destination string

Aug 14, 2023

Changes in this version

type CreateCluster

+ DataSecurityMode DataSecurityMode

+ DockerImage *DockerImage

+ SingleUserName string

Aug 7, 2023

Changes in this version

+ type ClusterAccessControlRequest struct

+ GroupName string

+ PermissionLevel ClusterPermissionLevel

+ ServicePrincipalName string

+ UserName string

+ type ClusterAccessControlResponse struct

+ AllPermissions []ClusterPermission

+ DisplayName string

+ GroupName string

+ ServicePrincipalName string

+ UserName string

+ type ClusterPermission struct

+ Inherited bool

+ InheritedFromObject []string

+ PermissionLevel ClusterPermissionLevel

+ type ClusterPermissionLevel string

+ const ClusterPermissionLevelCanAttachTo

+ const ClusterPermissionLevelCanManage

+ const ClusterPermissionLevelCanRestart

+ func (f *ClusterPermissionLevel) Set(v string) error

+ func (f *ClusterPermissionLevel) String() string

+ func (f *ClusterPermissionLevel) Type() string

+ type ClusterPermissions struct

+ AccessControlList []ClusterAccessControlResponse

+ ObjectId string

+ ObjectType string

+ type ClusterPermissionsDescription struct

+ Description string

+ PermissionLevel ClusterPermissionLevel

+ type ClusterPermissionsRequest struct

+ AccessControlList []ClusterAccessControlRequest

+ ClusterId string

type ClusterPoliciesAPI

+ func (a *ClusterPoliciesAPI) GetClusterPolicyPermissionLevels(ctx context.Context, request GetClusterPolicyPermissionLevelsRequest) (*GetClusterPolicyPermissionLevelsResponse, error)

+ func (a *ClusterPoliciesAPI) GetClusterPolicyPermissionLevelsByClusterPolicyId(ctx context.Context, clusterPolicyId string) (*GetClusterPolicyPermissionLevelsResponse, error)

+ func (a *ClusterPoliciesAPI) GetClusterPolicyPermissions(ctx context.Context, request GetClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ func (a *ClusterPoliciesAPI) GetClusterPolicyPermissionsByClusterPolicyId(ctx context.Context, clusterPolicyId string) (*ClusterPolicyPermissions, error)

+ func (a *ClusterPoliciesAPI) SetClusterPolicyPermissions(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ func (a *ClusterPoliciesAPI) UpdateClusterPolicyPermissions(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

type ClusterPoliciesService

+ GetClusterPolicyPermissionLevels func(ctx context.Context, request GetClusterPolicyPermissionLevelsRequest) (*GetClusterPolicyPermissionLevelsResponse, error)

+ GetClusterPolicyPermissions func(ctx context.Context, request GetClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ SetClusterPolicyPermissions func(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ UpdateClusterPolicyPermissions func(ctx context.Context, request ClusterPolicyPermissionsRequest) (*ClusterPolicyPermissions, error)

+ type ClusterPolicyAccessControlRequest struct

+ GroupName string

+ PermissionLevel ClusterPolicyPermissionLevel

+ ServicePrincipalName string

+ UserName string

+ type ClusterPolicyAccessControlResponse struct

+ AllPermissions []ClusterPolicyPermission

+ DisplayName string

+ GroupName string

+ ServicePrincipalName string

+ UserName string

+ type ClusterPolicyPermission struct

+ Inherited bool

+ InheritedFromObject []string

+ PermissionLevel ClusterPolicyPermissionLevel

+ type ClusterPolicyPermissionLevel string

+ const ClusterPolicyPermissionLevelCanUse

+ func (f *ClusterPolicyPermissionLevel) Set(v string) error

+ func (f *ClusterPolicyPermissionLevel) String() string

+ func (f *ClusterPolicyPermissionLevel) Type() string

+ type ClusterPolicyPermissions struct

+ AccessControlList []ClusterPolicyAccessControlResponse

+ ObjectId string

+ ObjectType string

+ type ClusterPolicyPermissionsDescription struct

+ Description string

+ PermissionLevel ClusterPolicyPermissionLevel

+ type ClusterPolicyPermissionsRequest struct

+ AccessControlList []ClusterPolicyAccessControlRequest

+ ClusterPolicyId string

type ClustersAPI

+ func (a *ClustersAPI) GetClusterPermissionLevels(ctx context.Context, request GetClusterPermissionLevelsRequest) (*GetClusterPermissionLevelsResponse, error)

+ func (a *ClustersAPI) GetClusterPermissionLevelsByClusterId(ctx context.Context, clusterId string) (*GetClusterPermissionLevelsResponse, error)

+ func (a *ClustersAPI) GetClusterPermissions(ctx context.Context, request GetClusterPermissionsRequest) (*ClusterPermissions, error)

+ func (a *ClustersAPI) GetClusterPermissionsByClusterId(ctx context.Context, clusterId string) (*ClusterPermissions, error)

+ func (a *ClustersAPI) SetClusterPermissions(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

+ func (a *ClustersAPI) UpdateClusterPermissions(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

type ClustersService

+ GetClusterPermissionLevels func(ctx context.Context, request GetClusterPermissionLevelsRequest) (*GetClusterPermissionLevelsResponse, error)

+ GetClusterPermissions func(ctx context.Context, request GetClusterPermissionsRequest) (*ClusterPermissions, error)

+ SetClusterPermissions func(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

+ UpdateClusterPermissions func(ctx context.Context, request ClusterPermissionsRequest) (*ClusterPermissions, error)

+ type GetClusterPermissionLevelsRequest struct

+ ClusterId string

+ type GetClusterPermissionLevelsResponse struct

+ PermissionLevels []ClusterPermissionsDescription

+ type GetClusterPermissionsRequest struct

+ ClusterId string

+ type GetClusterPolicyPermissionLevelsRequest struct

+ ClusterPolicyId string

+ type GetClusterPolicyPermissionLevelsResponse struct

+ PermissionLevels []ClusterPolicyPermissionsDescription

+ type GetClusterPolicyPermissionsRequest struct

+ ClusterPolicyId string

+ type GetInstancePoolPermissionLevelsRequest struct

+ InstancePoolId string

+ type GetInstancePoolPermissionLevelsResponse struct

+ PermissionLevels []InstancePoolPermissionsDescription

+ type GetInstancePoolPermissionsRequest struct

+ InstancePoolId string

+ type InstancePoolAccessControlRequest struct

+ GroupName string

+ PermissionLevel InstancePoolPermissionLevel

+ ServicePrincipalName string

+ UserName string

+ type InstancePoolAccessControlResponse struct

+ AllPermissions []InstancePoolPermission

+ DisplayName string

+ GroupName string

+ ServicePrincipalName string

+ UserName string

+ type InstancePoolPermission struct

+ Inherited bool

+ InheritedFromObject []string

+ PermissionLevel InstancePoolPermissionLevel

+ type InstancePoolPermissionLevel string

+ const InstancePoolPermissionLevelCanAttachTo

+ const InstancePoolPermissionLevelCanManage

+ func (f *InstancePoolPermissionLevel) Set(v string) error

+ func (f *InstancePoolPermissionLevel) String() string

+ func (f *InstancePoolPermissionLevel) Type() string

+ type InstancePoolPermissions struct

+ AccessControlList []InstancePoolAccessControlResponse

+ ObjectId string

+ ObjectType string

+ type InstancePoolPermissionsDescription struct

+ Description string

+ PermissionLevel InstancePoolPermissionLevel

+ type InstancePoolPermissionsRequest struct

+ AccessControlList []InstancePoolAccessControlRequest

+ InstancePoolId string

type InstancePoolsAPI

+ func (a *InstancePoolsAPI) GetInstancePoolPermissionLevels(ctx context.Context, request GetInstancePoolPermissionLevelsRequest) (*GetInstancePoolPermissionLevelsResponse, error)

+ func (a *InstancePoolsAPI) GetInstancePoolPermissionLevelsByInstancePoolId(ctx context.Context, instancePoolId string) (*GetInstancePoolPermissionLevelsResponse, error)

+ func (a *InstancePoolsAPI) GetInstancePoolPermissions(ctx context.Context, request GetInstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ func (a *InstancePoolsAPI) GetInstancePoolPermissionsByInstancePoolId(ctx context.Context, instancePoolId string) (*InstancePoolPermissions, error)

+ func (a *InstancePoolsAPI) SetInstancePoolPermissions(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ func (a *InstancePoolsAPI) UpdateInstancePoolPermissions(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

type InstancePoolsService

+ GetInstancePoolPermissionLevels func(ctx context.Context, request GetInstancePoolPermissionLevelsRequest) (*GetInstancePoolPermissionLevelsResponse, error)

+ GetInstancePoolPermissions func(ctx context.Context, request GetInstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ SetInstancePoolPermissions func(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

+ UpdateInstancePoolPermissions func(ctx context.Context, request InstancePoolPermissionsRequest) (*InstancePoolPermissions, error)

Jul 18, 2023

Changes in this version

type CloudProviderNodeStatus

+ const CloudProviderNodeStatusNotAvailableInRegion

+ const CloudProviderNodeStatusNotEnabledOnSubscription

type TerminationReasonCode

+ const TerminationReasonCodeK8sAutoscalingFailure

+ const TerminationReasonCodeK8sDbrClusterLaunchTimeout

Jun 28, 2023

Changes in this version

+ 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 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 ClustersAPI

+ func (a *ClustersAPI) ClusterDetailsClusterNameToClusterIdMap(ctx context.Context, request ListClustersRequest) (map[string]string, error)

+ 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

Jun 15, 2023

Changes in this version

type BaseClusterInfo

+ DataSecurityMode DataSecurityMode

+ DockerImage *DockerImage

+ SingleUserName string

type ClusterAttributes

+ DataSecurityMode DataSecurityMode

+ DockerImage *DockerImage

+ SingleUserName string

type ClusterInfo

+ DockerImage *DockerImage

type ClustersAPI

+ func (a *ClustersAPI) WaitGetClusterRunning(ctx context.Context, clusterId string, timeout time.Duration, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) WaitGetClusterTerminated(ctx context.Context, clusterId string, timeout time.Duration, ...) (*ClusterInfo, error)

type CommandExecutionAPI

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

+ type CommandExecutorV2 struct

+ func (c *CommandExecutorV2) Destroy(ctx context.Context) error

+ func (c *CommandExecutorV2) Execute(ctx context.Context, command string) (*Results, error)

type CreateInstancePool

+ GcpAttributes *InstancePoolGcpAttributes

type EditCluster

+ DataSecurityMode DataSecurityMode

+ DockerImage *DockerImage

+ SingleUserName string

type EditInstancePool

+ GcpAttributes *InstancePoolGcpAttributes

type GcpAttributes

+ LocalSsdCount int

type GetInstancePool

+ GcpAttributes *InstancePoolGcpAttributes

type InstancePoolAndStats

+ GcpAttributes *InstancePoolGcpAttributes

+ type InstancePoolGcpAttributes struct

+ GcpAvailability GcpAvailability

+ LocalSsdCount int

+ 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() (*ClusterInfo, error)

+ func (w *WaitGetClusterRunning[R]) GetWithTimeout(timeout time.Duration) (*ClusterInfo, error)

+ func (w *WaitGetClusterRunning[R]) OnProgress(callback func(*ClusterInfo)) *WaitGetClusterRunning[R]

+ type WaitGetClusterTerminated struct

+ ClusterId string

+ Response *R

+ func (w *WaitGetClusterTerminated[R]) Get() (*ClusterInfo, error)

+ func (w *WaitGetClusterTerminated[R]) GetWithTimeout(timeout time.Duration) (*ClusterInfo, error)

+ func (w *WaitGetClusterTerminated[R]) OnProgress(callback func(*ClusterInfo)) *WaitGetClusterTerminated[R]

May 22, 2023

Changes in this version

type BaseClusterInfo

+ InitScripts []InitScriptInfo

type ClusterAttributes

+ InitScripts []InitScriptInfo

type ClusterInfo

+ InitScripts []InitScriptInfo

type ClustersAPI

+ func (a *ClustersAPI) EnsureClusterIsRunning(ctx context.Context, clusterId string) error

+ func (a *ClustersAPI) SelectNodeType(ctx context.Context, r NodeTypeRequest) (string, error)

+ func (a *ClustersAPI) SelectSparkVersion(ctx context.Context, r SparkVersionRequest) (string, error)

type CreateCluster

+ InitScripts []InitScriptInfo

type EditCluster

+ InitScripts []InitScriptInfo

+ type InitScriptInfo struct

+ Dbfs *DbfsStorageInfo

+ S3 *S3StorageInfo

+ Workspace *WorkspaceStorageInfo

+ type WorkspaceStorageInfo struct

+ Destination string

Apr 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 (aa *AwsAvailability) Set(v string) error

+ func (aa *AwsAvailability) String() string

+ func (aa *AwsAvailability) Type() string

+ type AzureAttributes struct

+ Availability AzureAvailability

+ FirstOnDemand int

+ LogAnalyticsInfo *LogAnalyticsInfo

+ SpotBidMaxPrice float64

+ type AzureAvailability string

+ const AzureAvailabilityOnDemandAzure

+ const AzureAvailabilitySpotAzure

+ const AzureAvailabilitySpotWithFallbackAzure

+ func (aa *AzureAvailability) Set(v string) error

+ func (aa *AzureAvailability) String() string

+ func (aa *AzureAvailability) Type() string

+ type BaseClusterInfo struct

+ 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

+ 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 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 (cpns *CloudProviderNodeStatus) Set(v string) error

+ func (cpns *CloudProviderNodeStatus) String() string

+ func (cpns *CloudProviderNodeStatus) Type() string

+ type ClusterAttributes struct

+ 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

+ InstancePoolId string

+ NodeTypeId string

+ PolicyId string

+ RuntimeEngine RuntimeEngine

+ SparkConf map[string]string

+ SparkEnvVars map[string]string

+ SparkVersion string

+ SshPublicKeys []string

+ WorkloadType *WorkloadType

+ type ClusterEvent struct

+ ClusterId string

+ DataPlaneEventDetails *DataPlaneEventDetails

+ Details *EventDetails

+ Timestamp int64

+ Type EventType

+ type ClusterInfo 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

+ Driver *SparkNode

+ DriverInstancePoolId string

+ DriverNodeTypeId string

+ EnableElasticDisk bool

+ EnableLocalDiskEncryption bool

+ Executors []SparkNode

+ GcpAttributes *GcpAttributes

+ 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 (ci *ClusterInfo) IsRunningOrResizing() bool

+ 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 (cs *ClusterSource) Set(v string) error

+ func (cs *ClusterSource) String() string

+ func (cs *ClusterSource) Type() string

+ 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) ClusterInfoClusterNameToClusterIdMap(ctx context.Context, request ListClustersRequest) (map[string]string, error)

+ func (a *ClustersAPI) Create(ctx context.Context, request CreateCluster) (*CreateClusterResponse, error)

+ func (a *ClustersAPI) CreateAndWait(ctx context.Context, createCluster CreateCluster, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) Delete(ctx context.Context, request DeleteCluster) error

+ func (a *ClustersAPI) DeleteAndWait(ctx context.Context, deleteCluster DeleteCluster, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) DeleteByClusterId(ctx context.Context, clusterId string) error

+ func (a *ClustersAPI) DeleteByClusterIdAndWait(ctx context.Context, clusterId string, options ...retries.Option[ClusterInfo]) (*ClusterInfo, error)

+ func (a *ClustersAPI) Edit(ctx context.Context, request EditCluster) error

+ func (a *ClustersAPI) EditAndWait(ctx context.Context, editCluster EditCluster, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) EventsAll(ctx context.Context, request GetEvents) ([]ClusterEvent, error)

+ func (a *ClustersAPI) Get(ctx context.Context, request GetClusterRequest) (*ClusterInfo, error)

+ func (a *ClustersAPI) GetAndWait(ctx context.Context, getClusterRequest GetClusterRequest, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) GetByClusterId(ctx context.Context, clusterId string) (*ClusterInfo, error)

+ func (a *ClustersAPI) GetByClusterIdAndWait(ctx context.Context, clusterId string, options ...retries.Option[ClusterInfo]) (*ClusterInfo, error)

+ func (a *ClustersAPI) GetByClusterName(ctx context.Context, name string) (*ClusterInfo, error)

+ func (a *ClustersAPI) GetOrCreateRunningCluster(ctx context.Context, name string, custom ...CreateCluster) (c *ClusterInfo, err error)

+ func (a *ClustersAPI) Impl() ClustersService

+ func (a *ClustersAPI) ListAll(ctx context.Context, request ListClustersRequest) ([]ClusterInfo, 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, request ResizeCluster) error

+ func (a *ClustersAPI) ResizeAndWait(ctx context.Context, resizeCluster ResizeCluster, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) Restart(ctx context.Context, request RestartCluster) error

+ func (a *ClustersAPI) RestartAndWait(ctx context.Context, restartCluster RestartCluster, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) SparkVersions(ctx context.Context) (*GetSparkVersionsResponse, error)

+ func (a *ClustersAPI) Start(ctx context.Context, request StartCluster) error

+ func (a *ClustersAPI) StartAndWait(ctx context.Context, startCluster StartCluster, ...) (*ClusterInfo, error)

+ func (a *ClustersAPI) StartByClusterId(ctx context.Context, clusterId string) error

+ func (a *ClustersAPI) StartByClusterIdAndWait(ctx context.Context, clusterId string, options ...retries.Option[ClusterInfo]) (*ClusterInfo, error)

+ func (a *ClustersAPI) Unpin(ctx context.Context, request UnpinCluster) error

+ func (a *ClustersAPI) UnpinByClusterId(ctx context.Context, clusterId string) 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) (*ClusterInfo, 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, request CancelCommand) 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, request CreateContext) (*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, request Command) (*Created, error)

+ func (a *CommandExecutionAPI) ExecuteAndWait(ctx context.Context, command Command, ...) (*CommandStatusResponse, error)

+ func (a *CommandExecutionAPI) Impl() CommandExecutionService

+ 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 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 (cs *CommandStatus) Set(v string) error

+ func (cs *CommandStatus) String() string

+ func (cs *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 ContextStatus string

+ const ContextStatusError

+ const ContextStatusPending

+ const ContextStatusRunning

+ func (cs *ContextStatus) Set(v string) error

+ func (cs *ContextStatus) String() string

+ func (cs *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

+ 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

+ 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 (dpedet *DataPlaneEventDetailsEventType) Set(v string) error

+ func (dpedet *DataPlaneEventDetailsEventType) String() string

+ func (dpedet *DataPlaneEventDetailsEventType) Type() string

+ type DataSecurityMode string

+ const DataSecurityModeLegacyPassthrough

+ const DataSecurityModeLegacySingleUser

+ const DataSecurityModeLegacyTableAcl

+ const DataSecurityModeNone

+ const DataSecurityModeSingleUser

+ const DataSecurityModeUserIsolation

+ func (dsm *DataSecurityMode) Set(v string) error

+ func (dsm *DataSecurityMode) String() string

+ func (dsm *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 (dtadvt *DiskTypeAzureDiskVolumeType) Set(v string) error

+ func (dtadvt *DiskTypeAzureDiskVolumeType) String() string

+ func (dtadvt *DiskTypeAzureDiskVolumeType) Type() string

+ type DiskTypeEbsVolumeType string

+ const DiskTypeEbsVolumeTypeGeneralPurposeSsd

+ const DiskTypeEbsVolumeTypeThroughputOptimizedHdd

+ func (dtevt *DiskTypeEbsVolumeType) Set(v string) error

+ func (dtevt *DiskTypeEbsVolumeType) String() string

+ func (dtevt *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 (evt *EbsVolumeType) Set(v string) error

+ func (evt *EbsVolumeType) String() string

+ func (evt *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

+ DriverInstancePoolId string

+ DriverNodeTypeId string

+ EnableElasticDisk bool

+ EnableLocalDiskEncryption bool

+ GcpAttributes *GcpAttributes

+ 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 EditInstancePool struct

+ AwsAttributes *InstancePoolAwsAttributes

+ AzureAttributes *InstancePoolAzureAttributes

+ CustomTags map[string]string

+ DiskSpec *DiskSpec

+ EnableElasticDisk bool

+ 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 (edc *EventDetailsCause) Set(v string) error

+ func (edc *EventDetailsCause) String() string

+ func (edc *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 (et *EventType) Set(v string) error

+ func (et *EventType) String() string

+ func (et *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 (fodoas *FleetOnDemandOptionAllocationStrategy) Set(v string) error

+ func (fodoas *FleetOnDemandOptionAllocationStrategy) String() string

+ func (fodoas *FleetOnDemandOptionAllocationStrategy) Type() string

+ type FleetSpotOption struct

+ AllocationStrategy FleetSpotOptionAllocationStrategy

+ InstancePoolsToUseCount int

+ MaxTotalPrice float64

+ type FleetSpotOptionAllocationStrategy string

+ const FleetSpotOptionAllocationStrategyCapacityOptimized

+ const FleetSpotOptionAllocationStrategyDiversified

+ const FleetSpotOptionAllocationStrategyLowestPrice

+ const FleetSpotOptionAllocationStrategyPrioritized

+ func (fsoas *FleetSpotOptionAllocationStrategy) Set(v string) error

+ func (fsoas *FleetSpotOptionAllocationStrategy) String() string

+ func (fsoas *FleetSpotOptionAllocationStrategy) Type() string

+ type GcpAttributes struct

+ Availability GcpAvailability

+ BootDiskSize int

+ GoogleServiceAccount string

+ type GcpAvailability string

+ const GcpAvailabilityOnDemandGcp

+ const GcpAvailabilityPreemptibleGcp

+ const GcpAvailabilityPreemptibleWithFallbackGcp

+ func (ga *GcpAvailability) Set(v string) error

+ func (ga *GcpAvailability) String() string

+ func (ga *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 (geo *GetEventsOrder) Set(v string) error

+ func (geo *GetEventsOrder) String() string

+ func (geo *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

+ 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 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

+ 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 (ipaaa *InstancePoolAwsAttributesAvailability) Set(v string) error

+ func (ipaaa *InstancePoolAwsAttributesAvailability) String() string

+ func (ipaaa *InstancePoolAwsAttributesAvailability) Type() string

+ type InstancePoolAzureAttributes struct

+ Availability InstancePoolAzureAttributesAvailability

+ SpotBidMaxPrice float64

+ type InstancePoolAzureAttributesAvailability string

+ const InstancePoolAzureAttributesAvailabilityOnDemandAzure

+ const InstancePoolAzureAttributesAvailabilitySpotAzure

+ const InstancePoolAzureAttributesAvailabilitySpotWithFallbackAzure

+ func (ipaaa *InstancePoolAzureAttributesAvailability) Set(v string) error

+ func (ipaaa *InstancePoolAzureAttributesAvailability) String() string

+ func (ipaaa *InstancePoolAzureAttributesAvailability) Type() string

+ type InstancePoolFleetAttributes struct

+ FleetOnDemandOption *FleetOnDemandOption

+ FleetSpotOption *FleetSpotOption

+ LaunchTemplateOverrides []FleetLaunchTemplateOverride

+ type InstancePoolState string

+ const InstancePoolStateActive

+ const InstancePoolStateDeleted

+ const InstancePoolStateStopped

+ func (ips *InstancePoolState) Set(v string) error

+ func (ips *InstancePoolState) String() string

+ func (ips *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 (l *Language) Set(v string) error

+ func (l *Language) String() string

+ func (l *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 (lfss *LibraryFullStatusStatus) Set(v string) error

+ func (lfss *LibraryFullStatusStatus) String() string

+ func (lfss *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 []ClusterInfo

+ 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 (lsc *ListSortColumn) Set(v string) error

+ func (lsc *ListSortColumn) String() string

+ func (lsc *ListSortColumn) Type() string

+ type ListSortOrder string

+ const ListSortOrderAsc

+ const ListSortOrderDesc

+ func (lso *ListSortOrder) Set(v string) error

+ func (lso *ListSortOrder) String() string

+ func (lso *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 (rt *ResultType) Set(v string) error

+ func (rt *ResultType) String() string

+ func (rt *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 (re *RuntimeEngine) Set(v string) error

+ func (re *RuntimeEngine) String() string

+ func (re *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 (s *State) Set(v string) error

+ func (s *State) String() string

+ func (s *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 TerminationReasonCodeKsAutoscalingFailure

+ const TerminationReasonCodeKsDbrClusterLaunchTimeout

+ 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 (trc *TerminationReasonCode) Set(v string) error

+ func (trc *TerminationReasonCode) String() string

+ func (trc *TerminationReasonCode) Type() string

+ type TerminationReasonType string

+ const TerminationReasonTypeClientError

+ const TerminationReasonTypeCloudFailure

+ const TerminationReasonTypeServiceFault

+ const TerminationReasonTypeSuccess

+ func (trt *TerminationReasonType) Set(v string) error

+ func (trt *TerminationReasonType) String() string

+ func (trt *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 WorkloadType struct

+ Clients *ClientsTypes