clusters

package
v0.0.0-...-6c95da2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2020 License: MIT Imports: 7 Imported by: 1

Documentation

Overview

Package clusters implements the Azure ARM Clusters service API version 0.1.0.

Databricks REST API

Index

Constants

View Source 
const (
	// DefaultBaseURI is the default URI used for the service Clusters
	DefaultBaseURI = "/api/2.0"
)

Variables

This section is empty.

Functions

func UserAgent 

func UserAgent() string

UserAgent returns the UserAgent string to use when sending http.Requests.

func Version 

func Version() string

Version returns the semantic version (see http://semver.org) of the client.

Types

type Attributes 

type Attributes struct {
	NumWorkers             *int32             `json:"num_workers,omitempty"`
	Autoscale              *AutoScale         `json:"autoscale,omitempty"`
	ClusterName            *string            `json:"cluster_name,omitempty"`
	SparkVersion           *string            `json:"spark_version,omitempty"`
	SparkConf              map[string]*string `json:"spark_conf"`
	AwsAttributes          *AwsAttributes     `json:"aws_attributes,omitempty"`
	NodeTypeID             *string            `json:"node_type_id,omitempty"`
	DriverNodeTypeID       *string            `json:"driver_node_type_id,omitempty"`
	SSHPublicKeys          *[]string          `json:"ssh_public_keys,omitempty"`
	CustomTags             map[string]*string `json:"custom_tags"`
	ClusterLogConf         *LogConf           `json:"cluster_log_conf,omitempty"`
	InitScripts            *[]InitScriptInfo  `json:"init_scripts,omitempty"`
	DockerImage            *DockerImage       `json:"docker_image,omitempty"`
	SparkEnvVars           map[string]*string `json:"spark_env_vars"`
	AutoterminationMinutes *int32             `json:"autotermination_minutes,omitempty"`
	EnableElasticDisk      *bool              `json:"enable_elastic_disk,omitempty"`
	InstancePoolID         *string            `json:"instance_pool_id,omitempty"`
	IdempotencyToken       *string            `json:"idempotency_token,omitempty"`
}

Attributes ...

func (Attributes) MarshalJSON 

func (a Attributes) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Attributes.

type AutoScale 

type AutoScale struct {
	MinWorkers *int32 `json:"min_workers,omitempty"`
	MaxWorkers *int32 `json:"max_workers,omitempty"`
}

AutoScale ...

type Availability 

type Availability string

Availability enumerates the values for availability. 

const (
	// ONDEMAND ...
	ONDEMAND Availability = "ON_DEMAND"
	// SPOT ...
	SPOT Availability = "SPOT"
	// SPOTWITHFALLBACK ...
	SPOTWITHFALLBACK Availability = "SPOT_WITH_FALLBACK"
)

func PossibleAvailabilityValues 

func PossibleAvailabilityValues() []Availability

PossibleAvailabilityValues returns an array of possible values for the Availability const type.

type AwsAttributes 

type AwsAttributes struct {
	FirstOnDemand *int32 `json:"first_on_demand,omitempty"`
	// Availability - Possible values include: 'SPOT', 'ONDEMAND', 'SPOTWITHFALLBACK'
	Availability        Availability `json:"availability,omitempty"`
	ZoneID              *string      `json:"zone_id,omitempty"`
	InstanceProfileArn  *string      `json:"instance_profile_arn,omitempty"`
	SpotBidPricePercent *int32       `json:"spot_bid_price_percent,omitempty"`
	// EbsVolumeType - Possible values include: 'GENERALPURPOSESSD', 'THROUGHPUTOPTIMIZEDHDD'
	EbsVolumeType  EbsVolumeType `json:"ebs_volume_type,omitempty"`
	EbsVolumeCount *int32        `json:"ebs_volume_count,omitempty"`
	EbsVolumeSize  *int32        `json:"ebs_volume_size,omitempty"`
}

AwsAttributes ...

type BaseClient 

type BaseClient struct {
	autorest.Client
	BaseURI string
}

BaseClient is the base client for Clusters.

func New 

func New() BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI 

func NewWithBaseURI(baseURI string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (BaseClient) Create 

func (client BaseClient) Create(ctx context.Context, body Attributes) (result CreateResult, err error)

Create sends the create request.

func (BaseClient) CreatePreparer 

func (client BaseClient) CreatePreparer(ctx context.Context, body Attributes) (*http.Request, error)

CreatePreparer prepares the Create request.

func (BaseClient) CreateResponder 

func (client BaseClient) CreateResponder(resp *http.Response) (result CreateResult, err error)

CreateResponder handles the response to the Create request. The method always closes the http.Response Body.

func (BaseClient) CreateSender 

func (client BaseClient) CreateSender(req *http.Request) (*http.Response, error)

CreateSender sends the Create request. The method will close the http.Response Body if it receives an error.

func (BaseClient) Delete 

func (client BaseClient) Delete(ctx context.Context, body DeleteAttributes) (result autorest.Response, err error)

Delete sends the delete request.

func (BaseClient) DeletePreparer 

func (client BaseClient) DeletePreparer(ctx context.Context, body DeleteAttributes) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (BaseClient) DeleteResponder 

func (client BaseClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (BaseClient) DeleteSender 

func (client BaseClient) DeleteSender(req *http.Request) (*http.Response, error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (BaseClient) Edit 

func (client BaseClient) Edit(ctx context.Context, body EditAttributes) (result autorest.Response, err error)

Edit sends the edit request.

func (BaseClient) EditPreparer 

func (client BaseClient) EditPreparer(ctx context.Context, body EditAttributes) (*http.Request, error)

EditPreparer prepares the Edit request.

func (BaseClient) EditResponder 

func (client BaseClient) EditResponder(resp *http.Response) (result autorest.Response, err error)

EditResponder handles the response to the Edit request. The method always closes the http.Response Body.

func (BaseClient) EditSender 

func (client BaseClient) EditSender(req *http.Request) (*http.Response, error)

EditSender sends the Edit request. The method will close the http.Response Body if it receives an error.

func (BaseClient) Get 

func (client BaseClient) Get(ctx context.Context, clusterID string) (result Info, err error)

Get sends the get request.

func (BaseClient) GetPreparer 

func (client BaseClient) GetPreparer(ctx context.Context, clusterID string) (*http.Request, error)

GetPreparer prepares the Get request.

func (BaseClient) GetResponder 

func (client BaseClient) GetResponder(resp *http.Response) (result Info, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (BaseClient) GetSender 

func (client BaseClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (BaseClient) List 

func (client BaseClient) List(ctx context.Context) (result ListInfo, err error)

List sends the list request.

func (BaseClient) ListNodeTypes 

func (client BaseClient) ListNodeTypes(ctx context.Context) (result ListNodeType, err error)

ListNodeTypes sends the list node types request.

func (BaseClient) ListNodeTypesPreparer 

func (client BaseClient) ListNodeTypesPreparer(ctx context.Context) (*http.Request, error)

ListNodeTypesPreparer prepares the ListNodeTypes request.

func (BaseClient) ListNodeTypesResponder 

func (client BaseClient) ListNodeTypesResponder(resp *http.Response) (result ListNodeType, err error)

ListNodeTypesResponder handles the response to the ListNodeTypes request. The method always closes the http.Response Body.

func (BaseClient) ListNodeTypesSender 

func (client BaseClient) ListNodeTypesSender(req *http.Request) (*http.Response, error)

ListNodeTypesSender sends the ListNodeTypes request. The method will close the http.Response Body if it receives an error.

func (BaseClient) ListPreparer 

func (client BaseClient) ListPreparer(ctx context.Context) (*http.Request, error)

ListPreparer prepares the List request.

func (BaseClient) ListResponder 

func (client BaseClient) ListResponder(resp *http.Response) (result ListInfo, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (BaseClient) ListSender 

func (client BaseClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

func (BaseClient) PermanentDelete 

func (client BaseClient) PermanentDelete(ctx context.Context, body PermanentDeleteAttributes) (result autorest.Response, err error)

PermanentDelete sends the permanent delete request.

func (BaseClient) PermanentDeletePreparer 

func (client BaseClient) PermanentDeletePreparer(ctx context.Context, body PermanentDeleteAttributes) (*http.Request, error)

PermanentDeletePreparer prepares the PermanentDelete request.

func (BaseClient) PermanentDeleteResponder 

func (client BaseClient) PermanentDeleteResponder(resp *http.Response) (result autorest.Response, err error)

PermanentDeleteResponder handles the response to the PermanentDelete request. The method always closes the http.Response Body.

func (BaseClient) PermanentDeleteSender 

func (client BaseClient) PermanentDeleteSender(req *http.Request) (*http.Response, error)

PermanentDeleteSender sends the PermanentDelete request. The method will close the http.Response Body if it receives an error.

func (BaseClient) Resize 

func (client BaseClient) Resize(ctx context.Context, body ResizeAttributes) (result autorest.Response, err error)

Resize sends the resize request.

func (BaseClient) ResizePreparer 

func (client BaseClient) ResizePreparer(ctx context.Context, body ResizeAttributes) (*http.Request, error)

ResizePreparer prepares the Resize request.

func (BaseClient) ResizeResponder 

func (client BaseClient) ResizeResponder(resp *http.Response) (result autorest.Response, err error)

ResizeResponder handles the response to the Resize request. The method always closes the http.Response Body.

func (BaseClient) ResizeSender 

func (client BaseClient) ResizeSender(req *http.Request) (*http.Response, error)

ResizeSender sends the Resize request. The method will close the http.Response Body if it receives an error.

func (BaseClient) Restart 

func (client BaseClient) Restart(ctx context.Context, body RestartAttributes) (result autorest.Response, err error)

Restart sends the restart request.

func (BaseClient) RestartPreparer 

func (client BaseClient) RestartPreparer(ctx context.Context, body RestartAttributes) (*http.Request, error)

RestartPreparer prepares the Restart request.

func (BaseClient) RestartResponder 

func (client BaseClient) RestartResponder(resp *http.Response) (result autorest.Response, err error)

RestartResponder handles the response to the Restart request. The method always closes the http.Response Body.

func (BaseClient) RestartSender 

func (client BaseClient) RestartSender(req *http.Request) (*http.Response, error)

RestartSender sends the Restart request. The method will close the http.Response Body if it receives an error.

type CloudProviderNodeInfo 

type CloudProviderNodeInfo struct {
	// Status - Possible values include: 'NotEnabledOnSubscription', 'NotAvailableInRegion'
	Status             Status `json:"status,omitempty"`
	AvailableCoreQuota *int32 `json:"available_core_quota,omitempty"`
	TotalCoreQuota     *int32 `json:"total_core_quota,omitempty"`
}

CloudProviderNodeInfo ...

type Code 

type Code string

Code enumerates the values for code. 

const (
	// CLOUDPROVIDERLAUNCHFAILURE ...
	CLOUDPROVIDERLAUNCHFAILURE Code = "CLOUD_PROVIDER_LAUNCH_FAILURE"
	// CLOUDPROVIDERSHUTDOWN ...
	CLOUDPROVIDERSHUTDOWN Code = "CLOUD_PROVIDER_SHUTDOWN"
	// COMMUNICATIONLOST ...
	COMMUNICATIONLOST Code = "COMMUNICATION_LOST"
	// CONTAINERLAUNCHFAILURE ...
	CONTAINERLAUNCHFAILURE Code = "CONTAINER_LAUNCH_FAILURE"
	// DBFSCOMPONENTUNHEALTHY ...
	DBFSCOMPONENTUNHEALTHY Code = "DBFS_COMPONENT_UNHEALTHY"
	// DRIVERUNREACHABLE ...
	DRIVERUNREACHABLE Code = "DRIVER_UNREACHABLE"
	// DRIVERUNRESPONSIVE ...
	DRIVERUNRESPONSIVE Code = "DRIVER_UNRESPONSIVE"
	// INACTIVITY ...
	INACTIVITY Code = "INACTIVITY"
	// INITSCRIPTFAILURE ...
	INITSCRIPTFAILURE Code = "INIT_SCRIPT_FAILURE"
	// INSTANCEPOOLCLUSTERFAILURE ...
	INSTANCEPOOLCLUSTERFAILURE Code = "INSTANCE_POOL_CLUSTER_FAILURE"
	// INSTANCEUNREACHABLE ...
	INSTANCEUNREACHABLE Code = "INSTANCE_UNREACHABLE"
	// INTERNALERROR ...
	INTERNALERROR Code = "INTERNAL_ERROR"
	// INVALIDARGUMENT ...
	INVALIDARGUMENT Code = "INVALID_ARGUMENT"
	// JOBFINISHED ...
	JOBFINISHED Code = "JOB_FINISHED"
	// METASTORECOMPONENTUNHEALTHY ...
	METASTORECOMPONENTUNHEALTHY Code = "METASTORE_COMPONENT_UNHEALTHY"
	// REQUESTREJECTED ...
	REQUESTREJECTED Code = "REQUEST_REJECTED"
	// SPARKERROR ...
	SPARKERROR Code = "SPARK_ERROR"
	// SPARKSTARTUPFAILURE ...
	SPARKSTARTUPFAILURE Code = "SPARK_STARTUP_FAILURE"
	// TRIALEXPIRED ...
	TRIALEXPIRED Code = "TRIAL_EXPIRED"
	// UNEXPECTEDLAUNCHFAILURE ...
	UNEXPECTEDLAUNCHFAILURE Code = "UNEXPECTED_LAUNCH_FAILURE"
	// USERREQUEST ...
	USERREQUEST Code = "USER_REQUEST"
)

func PossibleCodeValues 

func PossibleCodeValues() []Code

PossibleCodeValues returns an array of possible values for the Code const type.

type CreateResult 

type CreateResult struct {
	autorest.Response `json:"-"`
	ClusterID         *string `json:"cluster_id,omitempty"`
}

CreateResult ...

type DbfsStorageInfo 

type DbfsStorageInfo struct {
	Destination *string `json:"destination,omitempty"`
}

DbfsStorageInfo ...

type DeleteAttributes 

type DeleteAttributes struct {
	ClusterID *string `json:"cluster_id,omitempty"`
}

DeleteAttributes ...

type DockerBasicAuth 

type DockerBasicAuth struct {
	Username *string `json:"username,omitempty"`
	Password *string `json:"password,omitempty"`
}

DockerBasicAuth ...

type DockerImage 

type DockerImage struct {
	URL       *string          `json:"url,omitempty"`
	BasicAuth *DockerBasicAuth `json:"basic_auth,omitempty"`
}

DockerImage ...

type EbsVolumeType 

type EbsVolumeType string

EbsVolumeType enumerates the values for ebs volume type. 

const (
	// GENERALPURPOSESSD ...
	GENERALPURPOSESSD EbsVolumeType = "GENERAL_PURPOSE_SSD"
	// THROUGHPUTOPTIMIZEDHDD ...
	THROUGHPUTOPTIMIZEDHDD EbsVolumeType = "THROUGHPUT_OPTIMIZED_HDD"
)

func PossibleEbsVolumeTypeValues 

func PossibleEbsVolumeTypeValues() []EbsVolumeType

PossibleEbsVolumeTypeValues returns an array of possible values for the EbsVolumeType const type.

type EditAttributes 

type EditAttributes struct {
	NumWorkers             *int32             `json:"num_workers,omitempty"`
	Autoscale              *AutoScale         `json:"autoscale,omitempty"`
	ClusterID              *string            `json:"cluster_id,omitempty"`
	ClusterName            *string            `json:"cluster_name,omitempty"`
	SparkVersion           *string            `json:"spark_version,omitempty"`
	SparkConf              map[string]*string `json:"spark_conf"`
	AwsAttributes          *AwsAttributes     `json:"aws_attributes,omitempty"`
	NodeTypeID             *string            `json:"node_type_id,omitempty"`
	DriverNodeTypeID       *string            `json:"driver_node_type_id,omitempty"`
	SSHPublicKeys          *[]string          `json:"ssh_public_keys,omitempty"`
	CustomTags             map[string]*string `json:"custom_tags"`
	ClusterLogConf         *LogConf           `json:"cluster_log_conf,omitempty"`
	InitScripts            *[]InitScriptInfo  `json:"init_scripts,omitempty"`
	DockerImage            *DockerImage       `json:"docker_image,omitempty"`
	SparkEnvVars           map[string]*string `json:"spark_env_vars"`
	AutoterminationMinutes *int32             `json:"autotermination_minutes,omitempty"`
	EnableElasticDisk      *bool              `json:"enable_elastic_disk,omitempty"`
	InstancePoolID         *string            `json:"instance_pool_id,omitempty"`
}

EditAttributes ...

func (EditAttributes) MarshalJSON 

func (ea EditAttributes) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EditAttributes.

type Error 

type Error struct {
	// ErrorCode - Possible values include: 'ErrorCodeBADREQUEST', 'ErrorCodeCOULDNOTACQUIRELOCK', 'ErrorCodeCUSTOMERUNAUTHORIZED', 'ErrorCodeDIRECTORYNOTEMPTY', 'ErrorCodeDIRECTORYPROTECTED', 'ErrorCodeDRYRUNFAILED', 'ErrorCodeENDPOINTNOTFOUND', 'ErrorCodeFEATUREDISABLED', 'ErrorCodeINTERNALERROR', 'ErrorCodeINVALIDPARAMETERVALUE', 'ErrorCodeINVALIDSTATE', 'ErrorCodeINVALIDSTATETRANSITION', 'ErrorCodeIOERROR', 'ErrorCodeMALFORMEDREQUEST', 'ErrorCodeMAXBLOCKSIZEEXCEEDED', 'ErrorCodeMAXNOTEBOOKSIZEEXCEEDED', 'ErrorCodeMAXREADSIZEEXCEEDED', 'ErrorCodePERMISSIONDENIED', 'ErrorCodeQUOTAEXCEEDED', 'ErrorCodeREQUESTLIMITEXCEEDED', 'ErrorCodeRESOURCEALREADYEXISTS', 'ErrorCodeRESOURCEDOESNOTEXIST', 'ErrorCodeRESOURCELIMITEXCEEDED', 'ErrorCodeTEMPORARILYUNAVAILABLE'
	ErrorCode ErrorCode `json:"error_code,omitempty"`
	Message   *string   `json:"message,omitempty"`
}

Error ...

type ErrorCode 

type ErrorCode string

ErrorCode enumerates the values for error code. 

const (
	// ErrorCodeBADREQUEST ...
	ErrorCodeBADREQUEST ErrorCode = "BAD_REQUEST"
	// ErrorCodeCOULDNOTACQUIRELOCK ...
	ErrorCodeCOULDNOTACQUIRELOCK ErrorCode = "COULD_NOT_ACQUIRE_LOCK"
	// ErrorCodeCUSTOMERUNAUTHORIZED ...
	ErrorCodeCUSTOMERUNAUTHORIZED ErrorCode = "CUSTOMER_UNAUTHORIZED"
	// ErrorCodeDIRECTORYNOTEMPTY ...
	ErrorCodeDIRECTORYNOTEMPTY ErrorCode = "DIRECTORY_NOT_EMPTY"
	// ErrorCodeDIRECTORYPROTECTED ...
	ErrorCodeDIRECTORYPROTECTED ErrorCode = "DIRECTORY_PROTECTED"
	// ErrorCodeDRYRUNFAILED ...
	ErrorCodeDRYRUNFAILED ErrorCode = "DRY_RUN_FAILED"
	// ErrorCodeENDPOINTNOTFOUND ...
	ErrorCodeENDPOINTNOTFOUND ErrorCode = "ENDPOINT_NOT_FOUND"
	// ErrorCodeFEATUREDISABLED ...
	ErrorCodeFEATUREDISABLED ErrorCode = "FEATURE_DISABLED"
	// ErrorCodeINTERNALERROR ...
	ErrorCodeINTERNALERROR ErrorCode = "INTERNAL_ERROR"
	// ErrorCodeINVALIDPARAMETERVALUE ...
	ErrorCodeINVALIDPARAMETERVALUE ErrorCode = "INVALID_PARAMETER_VALUE"
	// ErrorCodeINVALIDSTATE ...
	ErrorCodeINVALIDSTATE ErrorCode = "INVALID_STATE"
	// ErrorCodeINVALIDSTATETRANSITION ...
	ErrorCodeINVALIDSTATETRANSITION ErrorCode = "INVALID_STATE_TRANSITION"
	// ErrorCodeIOERROR ...
	ErrorCodeIOERROR ErrorCode = "IO_ERROR"
	// ErrorCodeMALFORMEDREQUEST ...
	ErrorCodeMALFORMEDREQUEST ErrorCode = "MALFORMED_REQUEST"
	// ErrorCodeMAXBLOCKSIZEEXCEEDED ...
	ErrorCodeMAXBLOCKSIZEEXCEEDED ErrorCode = "MAX_BLOCK_SIZE_EXCEEDED"
	// ErrorCodeMAXNOTEBOOKSIZEEXCEEDED ...
	ErrorCodeMAXNOTEBOOKSIZEEXCEEDED ErrorCode = "MAX_NOTEBOOK_SIZE_EXCEEDED"
	// ErrorCodeMAXREADSIZEEXCEEDED ...
	ErrorCodeMAXREADSIZEEXCEEDED ErrorCode = "MAX_READ_SIZE_EXCEEDED"
	// ErrorCodePERMISSIONDENIED ...
	ErrorCodePERMISSIONDENIED ErrorCode = "PERMISSION_DENIED"
	// ErrorCodeQUOTAEXCEEDED ...
	ErrorCodeQUOTAEXCEEDED ErrorCode = "QUOTA_EXCEEDED"
	// ErrorCodeREQUESTLIMITEXCEEDED ...
	ErrorCodeREQUESTLIMITEXCEEDED ErrorCode = "REQUEST_LIMIT_EXCEEDED"
	// ErrorCodeRESOURCEALREADYEXISTS ...
	ErrorCodeRESOURCEALREADYEXISTS ErrorCode = "RESOURCE_ALREADY_EXISTS"
	// ErrorCodeRESOURCEDOESNOTEXIST ...
	ErrorCodeRESOURCEDOESNOTEXIST ErrorCode = "RESOURCE_DOES_NOT_EXIST"
	// ErrorCodeRESOURCELIMITEXCEEDED ...
	ErrorCodeRESOURCELIMITEXCEEDED ErrorCode = "RESOURCE_LIMIT_EXCEEDED"
	// ErrorCodeTEMPORARILYUNAVAILABLE ...
	ErrorCodeTEMPORARILYUNAVAILABLE ErrorCode = "TEMPORARILY_UNAVAILABLE"
)

func PossibleErrorCodeValues 

func PossibleErrorCodeValues() []ErrorCode

PossibleErrorCodeValues returns an array of possible values for the ErrorCode const type.

type Info 

type Info struct {
	autorest.Response      `json:"-"`
	NumWorkers             *int32             `json:"num_workers,omitempty"`
	Autoscale              *AutoScale         `json:"autoscale,omitempty"`
	ClusterID              *string            `json:"cluster_id,omitempty"`
	CreatorUserName        *string            `json:"creator_user_name,omitempty"`
	Driver                 *SparkNode         `json:"driver,omitempty"`
	Executors              *[]SparkNode       `json:"executors,omitempty"`
	SparkContextID         *int64             `json:"spark_context_id,omitempty"`
	JdbcPort               *int32             `json:"jdbc_port,omitempty"`
	ClusterName            *string            `json:"cluster_name,omitempty"`
	SparkVersion           *string            `json:"spark_version,omitempty"`
	SparkConf              map[string]*string `json:"spark_conf"`
	AwsAttributes          *AwsAttributes     `json:"aws_attributes,omitempty"`
	NodeTypeID             *string            `json:"node_type_id,omitempty"`
	DriverNodeTypeID       *string            `json:"driver_node_type_id,omitempty"`
	SSHPublicKeys          *[]string          `json:"ssh_public_keys,omitempty"`
	CustomTags             map[string]*string `json:"custom_tags"`
	ClusterLogConf         *LogConf           `json:"cluster_log_conf,omitempty"`
	InitScripts            *[]InitScriptInfo  `json:"init_scripts,omitempty"`
	DockerImage            *DockerImage       `json:"docker_image,omitempty"`
	SparkEnvVars           map[string]*string `json:"spark_env_vars"`
	AutoterminationMinutes *int32             `json:"autotermination_minutes,omitempty"`
	EnableElasticDisk      *bool              `json:"enable_elastic_disk,omitempty"`
	InstancePoolID         *string            `json:"instance_pool_id,omitempty"`
	// ClusterSource - Possible values include: 'UI', 'JOB', 'API'
	ClusterSource Source `json:"cluster_source,omitempty"`
	// State - Possible values include: 'PENDING', 'RUNNING', 'RESTARTING', 'RESIZING', 'TERMINATING', 'TERMINATED', 'ERROR', 'UNKNOWN'
	State             State              `json:"state,omitempty"`
	StateMessage      *string            `json:"state_message,omitempty"`
	StartTime         *int64             `json:"start_time,omitempty"`
	TerminatedTime    *int64             `json:"terminated_time,omitempty"`
	LastStateLossTime *int64             `json:"last_state_loss_time,omitempty"`
	LastActivityTime  *int64             `json:"last_activity_time,omitempty"`
	ClusterMemoryMb   *int64             `json:"cluster_memory_mb,omitempty"`
	ClusterCores      *float64           `json:"cluster_cores,omitempty"`
	DefaultTags       map[string]*string `json:"default_tags"`
	ClusterLogStatus  *LogSyncStatus     `json:"cluster_log_status,omitempty"`
	TerminationReason *TerminationReason `json:"termination_reason,omitempty"`
}

Info ...

func (Info) MarshalJSON 

func (i Info) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Info.

type InitScriptInfo 

type InitScriptInfo struct {
	Dbfs *DbfsStorageInfo `json:"dbfs,omitempty"`
	S3   *S3StorageInfo   `json:"s3,omitempty"`
}

InitScriptInfo ...

type ListInfo 

type ListInfo struct {
	autorest.Response `json:"-"`
	Value             *[]Info `json:"value,omitempty"`
}

ListInfo ...

type ListNodeType 

type ListNodeType struct {
	autorest.Response `json:"-"`
	Value             *[]NodeType `json:"value,omitempty"`
}

ListNodeType ...

type LogConf 

type LogConf struct {
	Dbfs *DbfsStorageInfo `json:"dbfs,omitempty"`
	S3   *S3StorageInfo   `json:"s3,omitempty"`
}

LogConf ...

type LogSyncStatus 

type LogSyncStatus struct {
	LastAttempted *int64  `json:"last_attempted,omitempty"`
	LastException *string `json:"last_exception,omitempty"`
}

LogSyncStatus ...

type NodeType 

type NodeType struct {
	NodeTypeID     *string                `json:"node_type_id,omitempty"`
	MemoryMb       *int32                 `json:"memory_mb,omitempty"`
	NumCores       *float64               `json:"num_cores,omitempty"`
	Description    *string                `json:"description,omitempty"`
	InstanceTypeID *string                `json:"instance_type_id,omitempty"`
	IsDeprecated   *bool                  `json:"is_deprecated,omitempty"`
	NodeInfo       *CloudProviderNodeInfo `json:"node_info,omitempty"`
}

NodeType ...

type ParameterPair 

type ParameterPair struct {
	Username                 *string `json:"username,omitempty"`
	AwsAPIErrorCode          *string `json:"aws_api_error_code,omitempty"`
	AwsInstanceStateReason   *string `json:"aws_instance_state_reason,omitempty"`
	AwsSpotRequestStatus     *string `json:"aws_spot_request_status,omitempty"`
	AwsSpotRequestFaultCode  *string `json:"aws_spot_request_fault_code,omitempty"`
	AwsImpairedStatusDetails *string `json:"aws_impaired_status_details,omitempty"`
	AwsInstanceStatusEvent   *string `json:"aws_instance_status_event,omitempty"`
	AwsErrorMessage          *string `json:"aws_error_message,omitempty"`
	DatabricksErrorMessage   *string `json:"databricks_error_message,omitempty"`
	InactivityDurationMin    *string `json:"inactivity_duration_min,omitempty"`
	InstanceID               *string `json:"instance_id,omitempty"`
	InstancePoolID           *string `json:"instance_pool_id,omitempty"`
	InstancePoolErrorCode    *string `json:"instance_pool_error_code,omitempty"`
}

ParameterPair ...

type PermanentDeleteAttributes 

type PermanentDeleteAttributes struct {
	ClusterID *string `json:"cluster_id,omitempty"`
}

PermanentDeleteAttributes ...

type ResizeAttributes 

type ResizeAttributes struct {
	NumWorkers *int32     `json:"num_workers,omitempty"`
	Autoscale  *AutoScale `json:"autoscale,omitempty"`
	ClusterID  *string    `json:"cluster_id,omitempty"`
}

ResizeAttributes ...

type RestartAttributes 

type RestartAttributes struct {
	ClusterID *string `json:"cluster_id,omitempty"`
}

RestartAttributes ...

type S3StorageInfo 

type S3StorageInfo struct {
	Destination      *string `json:"destination,omitempty"`
	Region           *string `json:"region,omitempty"`
	Endpoint         *string `json:"endpoint,omitempty"`
	EnableEncryption *bool   `json:"enable_encryption,omitempty"`
	EncryptionType   *string `json:"encryption_type,omitempty"`
	KmsKey           *string `json:"kms_key,omitempty"`
	CannedACL        *string `json:"canned_acl,omitempty"`
}

S3StorageInfo ...

type Source 

type Source string

Source enumerates the values for source. 

const (
	// API ...
	API Source = "API"
	// JOB ...
	JOB Source = "JOB"
	// UI ...
	UI Source = "UI"
)

func PossibleSourceValues 

func PossibleSourceValues() []Source

PossibleSourceValues returns an array of possible values for the Source const type.

type SparkNode 

type SparkNode struct {
	PrivateIP         *string                 `json:"private_ip,omitempty"`
	PublicDNS         *string                 `json:"public_dns,omitempty"`
	NodeID            *string                 `json:"node_id,omitempty"`
	InstanceID        *string                 `json:"instance_id,omitempty"`
	StartTimestamp    *int64                  `json:"start_timestamp,omitempty"`
	NodeAwsAttributes *SparkNodeAwsAttributes `json:"node_aws_attributes,omitempty"`
	HostPrivateIP     *string                 `json:"host_private_ip,omitempty"`
}

SparkNode ...

type SparkNodeAwsAttributes 

type SparkNodeAwsAttributes struct {
	IsSpot *bool `json:"is_spot,omitempty"`
}

SparkNodeAwsAttributes ...

type State 

type State string

State enumerates the values for state. 

const (
	// ERROR ...
	ERROR State = "ERROR"
	// PENDING ...
	PENDING State = "PENDING"
	// RESIZING ...
	RESIZING State = "RESIZING"
	// RESTARTING ...
	RESTARTING State = "RESTARTING"
	// RUNNING ...
	RUNNING State = "RUNNING"
	// TERMINATED ...
	TERMINATED State = "TERMINATED"
	// TERMINATING ...
	TERMINATING State = "TERMINATING"
	// UNKNOWN ...
	UNKNOWN State = "UNKNOWN"
)

func PossibleStateValues 

func PossibleStateValues() []State

PossibleStateValues returns an array of possible values for the State const type.

type Status 

type Status string

Status enumerates the values for status. 

const (
	// NotAvailableInRegion ...
	NotAvailableInRegion Status = "NotAvailableInRegion"
	// NotEnabledOnSubscription ...
	NotEnabledOnSubscription Status = "NotEnabledOnSubscription"
)

func PossibleStatusValues 

func PossibleStatusValues() []Status

PossibleStatusValues returns an array of possible values for the Status const type.

type TerminationReason 

type TerminationReason struct {
	// Code - Possible values include: 'USERREQUEST', 'JOBFINISHED', 'INACTIVITY', 'CLOUDPROVIDERSHUTDOWN', 'COMMUNICATIONLOST', 'CLOUDPROVIDERLAUNCHFAILURE', 'SPARKSTARTUPFAILURE', 'INVALIDARGUMENT', 'UNEXPECTEDLAUNCHFAILURE', 'INTERNALERROR', 'SPARKERROR', 'METASTORECOMPONENTUNHEALTHY', 'DBFSCOMPONENTUNHEALTHY', 'DRIVERUNREACHABLE', 'DRIVERUNRESPONSIVE', 'INSTANCEUNREACHABLE', 'CONTAINERLAUNCHFAILURE', 'INSTANCEPOOLCLUSTERFAILURE', 'REQUESTREJECTED', 'INITSCRIPTFAILURE', 'TRIALEXPIRED'
	Code       Code           `json:"code,omitempty"`
	Parameters *ParameterPair `json:"parameters,omitempty"`
}

TerminationReason ...

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.