compute

package

Go to main page

Versions in this module

v0

v0.41.0

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)

v0.40.1

May 14, 2024

v0.40.0

May 2, 2024

Changes in this version

type ClusterStatusResponse

+ func (cls ClusterStatusResponse) ToLibraryList() InstallLibraries

v0.39.0

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

v0.38.0

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

v0.37.0

Mar 28, 2024

v0.36.0

Mar 20, 2024

v0.35.0

Mar 20, 2024

v0.34.0

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

v0.33.0

Feb 19, 2024

v0.32.0

Feb 14, 2024

v0.31.0

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

v0.30.1

Jan 25, 2024

v0.30.0

Jan 24, 2024

v0.29.1

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)

v0.29.0

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

v0.28.0

Dec 15, 2023

v0.27.0

Dec 12, 2023

v0.26.2

Dec 7, 2023

v0.26.1

Nov 30, 2023

v0.26.0

Nov 29, 2023

v0.25.0

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

v0.24.0

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

v0.23.0

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)

v0.22.0

Oct 3, 2023

v0.21.0

Sep 27, 2023

v0.20.0

Sep 21, 2023

v0.19.2

Sep 13, 2023

v0.19.1

Sep 7, 2023

v0.19.0

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

v0.18.0

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

v0.17.0

Aug 18, 2023

v0.16.0

Aug 14, 2023

Changes in this version

type CreateCluster

+ DataSecurityMode DataSecurityMode

+ DockerImage *DockerImage

+ SingleUserName string

v0.15.0

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)

v0.14.1

Jul 27, 2023

v0.14.0

Jul 26, 2023

v0.13.0

Jul 18, 2023

Changes in this version

type CloudProviderNodeStatus

+ const CloudProviderNodeStatusNotAvailableInRegion

+ const CloudProviderNodeStatusNotEnabledOnSubscription

type TerminationReasonCode

+ const TerminationReasonCodeK8sAutoscalingFailure

+ const TerminationReasonCodeK8sDbrClusterLaunchTimeout

v0.12.0

Jun 28, 2023

v0.11.0

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

v0.10.1

Jun 21, 2023

v0.10.0

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]

v0.9.0

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

v0.8.1

May 11, 2023

v0.8.0

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL