clusters

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 5, 2023

v0.6.0

Apr 3, 2023

v0.5.0

Mar 14, 2023

Changes in this version

type SparkVersionRequest

+ Id string

v0.4.1

Mar 9, 2023

v0.4.0

Mar 8, 2023

Changes in this version

type NodeTypeRequest

+ Id string

v0.3.3

Feb 24, 2023

v0.3.2

Feb 17, 2023

v0.3.1

Feb 17, 2023

v0.3.0

Feb 3, 2023

Changes in this version

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

+ Fleet bool

+ LocalDiskMinSize int32

v0.2.0

Dec 23, 2022

Changes in this version

type AwsAvailability

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

+ func (aa *AwsAvailability) String() string

+ func (aa *AwsAvailability) Type() string

type AzureAvailability

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

+ func (aa *AzureAvailability) String() string

+ func (aa *AzureAvailability) Type() string

type CloudProviderNodeStatus

+ func (cpns *CloudProviderNodeStatus) Set(v string) error

+ func (cpns *CloudProviderNodeStatus) String() string

+ func (cpns *CloudProviderNodeStatus) Type() string

type ClusterSource

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

+ func (cs *ClusterSource) String() string

+ func (cs *ClusterSource) Type() string

type DataPlaneEventDetailsEventType

+ func (dpedet *DataPlaneEventDetailsEventType) Set(v string) error

+ func (dpedet *DataPlaneEventDetailsEventType) String() string

+ func (dpedet *DataPlaneEventDetailsEventType) Type() string

type DataSecurityMode

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

+ func (dsm *DataSecurityMode) String() string

+ func (dsm *DataSecurityMode) Type() string

type EbsVolumeType

+ func (evt *EbsVolumeType) Set(v string) error

+ func (evt *EbsVolumeType) String() string

+ func (evt *EbsVolumeType) Type() string

type EventDetailsCause

+ func (edc *EventDetailsCause) Set(v string) error

+ func (edc *EventDetailsCause) String() string

+ func (edc *EventDetailsCause) Type() string

type EventType

+ func (et *EventType) Set(v string) error

+ func (et *EventType) String() string

+ func (et *EventType) Type() string

type GcpAvailability

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

+ func (ga *GcpAvailability) String() string

+ func (ga *GcpAvailability) Type() string

type GetEventsOrder

+ func (geo *GetEventsOrder) Set(v string) error

+ func (geo *GetEventsOrder) String() string

+ func (geo *GetEventsOrder) Type() string

type RuntimeEngine

+ func (re *RuntimeEngine) Set(v string) error

+ func (re *RuntimeEngine) String() string

+ func (re *RuntimeEngine) Type() string

type State

+ func (s *State) Set(v string) error

+ func (s *State) String() string

+ func (s *State) Type() string

type TerminationReasonCode

+ func (trc *TerminationReasonCode) Set(v string) error

+ func (trc *TerminationReasonCode) String() string

+ func (trc *TerminationReasonCode) Type() string

type TerminationReasonType

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

+ func (trt *TerminationReasonType) String() string

+ func (trt *TerminationReasonType) Type() string

v0.1.1

Dec 2, 2022

v0.1.0

Nov 30, 2022

Changes in this version

+ 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

+ type AzureAttributes struct

+ Availability AzureAvailability

+ FirstOnDemand int

+ LogAnalyticsInfo *LogAnalyticsInfo

+ SpotBidMaxPrice float64

+ type AzureAvailability string

+ const AzureAvailabilityOnDemandAzure

+ const AzureAvailabilitySpotAzure

+ const AzureAvailabilitySpotWithFallbackAzure

+ 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

+ type ClusterAttributes struct

+ AutoterminationMinutes int

+ AwsAttributes *AwsAttributes

+ AzureAttributes *AzureAttributes

+ ClusterLogConf *ClusterLogConf

+ ClusterName string

+ ClusterSource ClusterSource

+ CustomTags map[string]string

+ DriverInstancePoolId string

+ DriverNodeTypeId string

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

+ EffectiveSparkVersion 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 ClusterLogConf struct

+ Dbfs *DbfsStorageInfo

+ S3 *S3StorageInfo

+ type ClusterSize struct

+ Autoscale *AutoScale

+ NumWorkers int

+ type ClusterSource string

+ const ClusterSourceApi

+ const ClusterSourceJob

+ const ClusterSourceModels

+ const ClusterSourcePipeline

+ const ClusterSourcePipelineMaintenance

+ const ClusterSourceSql

+ const ClusterSourceUi

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

+ func (a *ClustersAPI) GetAndWait(ctx context.Context, get Get, options ...retries.Option[ClusterInfo]) (*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 List) ([]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 Get) (*ClusterInfo, error)

+ List func(ctx context.Context, request List) (*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 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

+ EffectiveSparkVersion 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 DataPlaneEventDetails struct

+ EventType DataPlaneEventDetailsEventType

+ ExecutorFailures int

+ HostId string

+ Timestamp int64

+ type DataPlaneEventDetailsEventType string

+ const DataPlaneEventDetailsEventTypeNodeBlacklisted

+ const DataPlaneEventDetailsEventTypeNodeExcludedDecommissioned

+ type DataSecurityMode string

+ const DataSecurityModeLegacyPassthrough

+ const DataSecurityModeLegacySingleUser

+ const DataSecurityModeLegacyTableAcl

+ const DataSecurityModeNone

+ const DataSecurityModeSingleUser

+ const DataSecurityModeUserIsolation

+ type DbfsStorageInfo struct

+ Destination string

+ type DeleteCluster struct

+ ClusterId string

+ type EbsVolumeType string

+ const EbsVolumeTypeGeneralPurposeSsd

+ const EbsVolumeTypeThroughputOptimizedHdd

+ 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

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

+ 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

+ type GcpAttributes struct

+ Availability GcpAvailability

+ BootDiskSize int

+ GoogleServiceAccount string

+ type GcpAvailability string

+ const GcpAvailabilityOnDemandGcp

+ const GcpAvailabilityPreemptibleGcp

+ const GcpAvailabilityPreemptibleWithFallbackGcp

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

+ type GetEventsResponse struct

+ Events []ClusterEvent

+ NextPage *GetEvents

+ TotalCount int64

+ type GetSparkVersionsResponse struct

+ Versions []SparkVersion

+ func (sv GetSparkVersionsResponse) Select(req SparkVersionRequest) (string, 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 List struct

+ CanUseClient string

+ type ListAvailableZonesResponse struct

+ DefaultZone string

+ Zones []string

+ type ListClustersResponse struct

+ Clusters []ClusterInfo

+ type ListInstanceProfilesResponse struct

+ InstanceProfiles []InstanceProfile

+ type ListNodeTypesResponse struct

+ NodeTypes []NodeType

+ func (ntl *ListNodeTypesResponse) Smallest(r NodeTypeRequest) (string, error)

+ type LogAnalyticsInfo struct

+ LogAnalyticsPrimaryKey string

+ LogAnalyticsWorkspaceId string

+ type LogSyncStatus struct

+ LastAttempted int64

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

+ GBPerCore int32

+ Graviton bool

+ IsIOCacheEnabled bool

+ LocalDisk bool

+ MinCores int32

+ MinGPUs int32

+ MinMemoryGB int32

+ PhotonDriverCapable bool

+ PhotonWorkerCapable bool

+ SupportPortForwarding bool

+ VCPU bool

+ type PermanentDeleteCluster struct

+ ClusterId string

+ type PinCluster struct

+ ClusterId string

+ type RemoveInstanceProfile struct

+ InstanceProfileArn string

+ type ResizeCluster struct

+ Autoscale *AutoScale

+ ClusterId string

+ NumWorkers int

+ type RestartCluster struct

+ ClusterId string

+ RestartUser string

+ type RuntimeEngine string

+ const RuntimeEngineNull

+ const RuntimeEnginePhoton

+ const RuntimeEngineStandard

+ 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

+ 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

+ 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

+ type TerminationReasonType string

+ const TerminationReasonTypeClientError

+ const TerminationReasonTypeCloudFailure

+ const TerminationReasonTypeServiceFault

+ const TerminationReasonTypeSuccess

+ type UnpinCluster struct

+ ClusterId string

+ type WorkloadType struct

+ Clients *ClientsTypes

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