models

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2021 License: Apache-2.0 Imports: 0 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package

Index

Constants

View Source 
const (
	AclPermissionRead   = "READ"
	AclPermissionWrite  = "WRITE"
	AclPermissionManage = "MANAGE"
)
View Source 
const (
	AwsAvailabilitySpot             = "SPOT"
	AwsAvailabilityOnDemand         = "ON_DEMAND"
	AwsAvailabilitySpotWithFallback = "SPOT_WITH_FALLBACK"
)
View Source 
const (
	ClusterCloudProviderNodeStatusNotEnabledOnSubscription = "NotEnabledOnSubscription"
	ClusterCloudProviderNodeStatusNotAvailableInRegion     = "NotAvailableInRegion"
)
View Source 
const (
	ClusterEventTypeCreating               = "CREATING"
	ClusterEventTypeDidNotExpandDisk       = "DID_NOT_EXPAND_DISK"
	ClusterEventTypeExpandedDisk           = "EXPANDED_DISK"
	ClusterEventTypeFailedToExpandDisk     = "FAILED_TO_EXPAND_DISK"
	ClusterEventTypeInitScriptStarting     = "INIT_SCRIPTS_STARTING"
	ClusterEventTypeInitScriptFinished     = "INIT_SCRIPTS_FINISHED"
	ClusterEventTypeStarting               = "STARTING"
	ClusterEventTypeRestarting             = "RESTARTING"
	ClusterEventTypeTerminating            = "TERMINATING"
	ClusterEventTypeEdited                 = "EDITED"
	ClusterEventTypeRunning                = "RUNNING"
	ClusterEventTypeResizing               = "RESIZING"
	ClusterEventTypeUpsizeCompleted        = "UPSIZE_COMPLETED"
	ClusterEventTypeNodesLost              = "NODES_LOST"
	ClusterEventTypeDriverHealthy          = "DRIVER_HEALTHY"
	ClusterEventTypeDriverUnavailable      = "DRIVER_UNAVAILABLE"
	ClusterEventTypeSparkException         = "SPARK_EXCEPTION"
	ClusterEventTypeDriverNotResponding    = "DRIVER_NOT_RESPONDING"
	ClusterEventTypeDbfsDown               = "DBFS_DOWN"
	ClusterEventTypeMetastoreDown          = "METASTORE_DOWN"
	ClusterEventTypeAutoscalingStatsReport = "AUTOSCALING_STATS_REPORT"
)
View Source 
const (
	ClusterSourceUI  = "UI"
	ClusterSourceJob = "JOB"
	ClusterSourceAPI = "API"
)
View Source 
const (
	ClusterStatePending     = "PENDING"
	ClusterStateRunning     = "RUNNING"
	ClusterStateRestarting  = "RESTARTING"
	ClusterStateResizing    = "RESIZING"
	ClusterStateTerminating = "TERMINATING"
	ClusterStateError       = "ERROR"
	ClusterStateUnknown     = "UNKNOWN"
)
View Source 
const (
	EbsVolumeTypeGeneralPurposeSsd      = "GENERAL_PURPOSE_SSD"
	EbsVolumeTypeThroughputOptimizedHdd = "THROUGHPUT_OPTIMIZED_HDD"
)
View Source 
const (
	ExportFormatSource  = "SOURCE"
	ExportFormatHtml    = "HTML"
	ExportFormatJupyter = "JUPYTER"
	ExportFormatDbc     = "DBC"
)
View Source 
const (
	InstancePoolStateActive  = "ACTIVE"
	InstancePoolStateDeleted = "DELETED"
)
View Source 
const (
	LanguageScala  = "SCALA"
	LanguagePython = "PYTHON"
	LanguageSQL    = "SQL"
	LanguageR      = "R"
)
View Source 
const (
	LibraryInstallStatusPending            = "PENDING"
	LibraryInstallStatusResolving          = "RESOLVING"
	LibraryInstallStatusInstalling         = "INSTALLING"
	LibraryInstallStatusInstalled          = "INSTALLED"
	LibraryInstallStatusFailed             = "FAILED"
	LibraryInstallStatusUninstallOnRestart = "UNINSTALL_ON_RESTART"
)
View Source 
const (
	ListOrderDesc = "DESC"
	ListOrderAsc  = "ASC"
)
View Source 
const (
	ObjectTypeNotebook  = "NOTEBOOK"
	ObjectTypeDirectory = "DIRECTORY"
	ObjectTypeLibrary   = "LIBRARY"
)
View Source 
const (
	ResizeCauseAutoscale    = "AUTOSCALE"
	ResizeCauseUserRequest  = "USER_REQUEST"
	ResizeCauseAutorecovery = "AUTORECOVERY"
)
View Source 
const (
	RunLifeCycleStatePending       = "PENDING"
	RunLifeCycleStateRunning       = "RUNNING"
	RunLifeCycleStateTerminating   = "TERMINATING"
	RunLifeCycleStateTerminated    = "TERMINATED"
	RunLifeCycleStateSkipped       = "SKIPPED"
	RunLifeCycleStateInternalError = "INTERNAL_ERROR"
)
View Source 
const (
	RunResultStateSuccess  = "SUCCESS"
	RunResultStateFailed   = "FAILED"
	RunResultStateTimedout = "TIMEDOUT"
	RunResultStateCanceled = "CANCELED"
)
View Source 
const (
	TerminationCodeUserRequest                = "USER_REQUEST"
	TerminationCodeJobFinished                = "JOB_FINISHED"
	TerminationCodeInactivity                 = "INACTIVITY"
	TerminationCodeCloudProviderShutdown      = "CLOUD_PROVIDER_SHUTDOWN"
	TerminationCodeCommunicationLost          = "COMMUNICATION_LOST"
	TerminationCodeCloudProviderLaunchFailure = "CLOUD_PROVIDER_LAUNCH_FAILURE"
	TerminationCodeSparkStartupFailure        = "SPARK_STARTUP_FAILURE"
	TerminationCodeInvalidArgument            = "INVALID_ARGUMENT"
	TerminationCodeUnexpectedLaunchFailure    = "UNEXPECTED_LAUNCH_FAILURE"
	TerminationCodeInternalError              = "INTERNAL_ERROR"
	TerminationCodeInstanceUnreachable        = "INSTANCE_UNREACHABLE"
	TerminationCodeRequestRejected            = "REQUEST_REJECTED"
	TerminationCodeInitScriptFailure          = "INIT_SCRIPT_FAILURE"
	TerminationCodeTrialExpired               = "TRIAL_EXPIRED"
)
View Source 
const (
	TerminationParameterUsername                 = "username"
	TerminationParameterAwsAPIErrorCode          = "aws_api_error_code"
	TerminationParameterAwsInstanceStateReason   = "aws_instance_state_reason"
	TerminationParameterAwsSpotRequestStatus     = "aws_spot_request_status"
	TerminationParameterAwsSpotRequestFaultCode  = "aws_spot_request_fault_code"
	TerminationParameterAwsImpairedStatusDetails = "aws_impaired_status_details"
	TerminationParameterAwsInstanceStatusEvent   = "aws_instance_status_event"
	TerminationParameterAwsErrorMessage          = "aws_error_message"
	TerminationParameterDatabricksErrorMessage   = "databricks_error_message"
	TerminationParameterInactivityDurationMin    = "inactivity_duration_min"
	TerminationParameterInstanceID               = "instance_id"
)
View Source 
const (
	TriggerTypePeriodic = "PERIODIC"
	TriggerTypeOneTime  = "ONE_TIME"
	TriggerTypeRetry    = "RETRY"
)
View Source 
const (
	ViewTypeNotebook  = "NOTEBOOK"
	ViewTypeDashboard = "DASHBOARD"
)
View Source 
const (
	ViewsToExportCode       = "CODE"
	ViewsToExportDashboards = "DASHBOARDS"
	ViewsToExportAll        = "ALL"
)
View Source 
const (
	ScopeBackendTypeDatabricks = "DATABRICKS"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AclItem 

type AclItem struct {
	Principal  string         `json:"principal,omitempty" url:"principal,omitempty"`
	Permission *AclPermission `json:"permission,omitempty" url:"permission,omitempty"`
}

func (*AclItem) DeepCopy 

func (in *AclItem) DeepCopy() *AclItem

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AclItem.

func (*AclItem) DeepCopyInto 

func (in *AclItem) DeepCopyInto(out *AclItem)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AclPermission 

type AclPermission string

type AutoScale 

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

func (*AutoScale) DeepCopy 

func (in *AutoScale) DeepCopy() *AutoScale

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AutoScale.

func (*AutoScale) DeepCopyInto 

func (in *AutoScale) DeepCopyInto(out *AutoScale)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AwsAttributes 

type AwsAttributes struct {
	FirstOnDemand       int32            `json:"first_on_demand,omitempty" url:"first_on_demand,omitempty"`
	Availability        *AwsAvailability `json:"availability,omitempty" url:"availability,omitempty"`
	ZoneID              string           `json:"zone_id,omitempty" url:"zone_id,omitempty"`
	InstanceProfileArn  string           `json:"instance_profile_arn,omitempty" url:"instance_profile_arn,omitempty"`
	SpotBidPricePercent int32            `json:"spot_bid_price_percent,omitempty" url:"spot_bid_price_percent,omitempty"`
	EbsVolumeType       *EbsVolumeType   `json:"ebs_volume_type,omitempty" url:"ebs_volume_type,omitempty"`
	EbsVolumeCount      int32            `json:"ebs_volume_count,omitempty" url:"ebs_volume_count,omitempty"`
	EbsVolumeSize       int32            `json:"ebs_volume_size,omitempty" url:"ebs_volume_size,omitempty"`
}

func (*AwsAttributes) DeepCopy 

func (in *AwsAttributes) DeepCopy() *AwsAttributes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsAttributes.

func (*AwsAttributes) DeepCopyInto 

func (in *AwsAttributes) DeepCopyInto(out *AwsAttributes)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AwsAvailability 

type AwsAvailability string

type BasicAuth 

type BasicAuth struct {
	Username string `json:"username,omitempty" url:"username,omitempty"`
	Password string `json:"password,omitempty" url:"password,omitempty"`
}

type ClusterAttributes 

type ClusterAttributes struct {
	ClusterName            string            `json:"cluster_name,omitempty" url:"cluster_name,omitempty"`
	SparkVersion           string            `json:"spark_version,omitempty" url:"spark_version,omitempty"`
	SparkConf              *SparkConfPair    `json:"spark_conf,omitempty" url:"spark_conf,omitempty"`
	AwsAttributes          *AwsAttributes    `json:"aws_attributes,omitempty" url:"aws_attributes,omitempty"`
	NodeTypeID             string            `json:"node_type_id,omitempty" url:"node_type_id,omitempty"`
	DriverNodeTypeID       string            `json:"driver_node_type_id,omitempty" url:"driver_node_type_id,omitempty"`
	SSHPublicKeys          []string          `json:"ssh_public_keys,omitempty" url:"ssh_public_keys,omitempty"`
	CustomTags             []ClusterTag      `json:"custom_tags,omitempty" url:"custom_tags,omitempty"`
	ClusterLogConf         *ClusterLogConf   `json:"cluster_log_conf,omitempty" url:"cluster_log_conf,omitempty"`
	InitScripts            []InitScriptInfo  `json:"init_scripts,omitempty" url:"init_scripts,omitempty"`
	SparkEnvVars           map[string]string `json:"spark_env_vars,omitempty" url:"spark_env_vars,omitempty"`
	AutoterminationMinutes int32             `json:"autotermination_minutes,omitempty" url:"autotermination_minutes,omitempty"`
	EnableElasticDisk      bool              `json:"enable_elastic_disk,omitempty" url:"enable_elastic_disk,omitempty"`
	ClusterSource          *AwsAvailability  `json:"cluster_source,omitempty" url:"cluster_source,omitempty"`
}

func (*ClusterAttributes) DeepCopy 

func (in *ClusterAttributes) DeepCopy() *ClusterAttributes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterAttributes.

func (*ClusterAttributes) DeepCopyInto 

func (in *ClusterAttributes) DeepCopyInto(out *ClusterAttributes)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterCloudProviderNodeInfo 

type ClusterCloudProviderNodeInfo struct {
	Status             *ClusterCloudProviderNodeStatus `json:"status,omitempty" url:"status,omitempty"`
	AvailableCoreQuota int32                           `json:"available_core_quota,omitempty" url:"available_core_quota,omitempty"`
	TotalCoreQuota     int32                           `json:"total_core_quota,omitempty" url:"total_core_quota,omitempty"`
}

func (*ClusterCloudProviderNodeInfo) DeepCopy 

func (in *ClusterCloudProviderNodeInfo) DeepCopy() *ClusterCloudProviderNodeInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterCloudProviderNodeInfo.

func (*ClusterCloudProviderNodeInfo) DeepCopyInto 

func (in *ClusterCloudProviderNodeInfo) DeepCopyInto(out *ClusterCloudProviderNodeInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterCloudProviderNodeStatus 

type ClusterCloudProviderNodeStatus string

type ClusterEvent 

type ClusterEvent struct {
	ClusterID string            `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	Timestamp int64             `json:"timestamp,omitempty" url:"timestamp,omitempty"`
	Type      *ClusterEventType `json:"type,omitempty" url:"type,omitempty"`
	Details   *AwsAttributes    `json:"details,omitempty" url:"details,omitempty"`
}

func (*ClusterEvent) DeepCopy 

func (in *ClusterEvent) DeepCopy() *ClusterEvent

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEvent.

func (*ClusterEvent) DeepCopyInto 

func (in *ClusterEvent) DeepCopyInto(out *ClusterEvent)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterEventType 

type ClusterEventType string

type ClusterInfo 

type ClusterInfo struct {
	NumWorkers             int32             `json:"num_workers,omitempty" url:"num_workers,omitempty"`
	AutoScale              *AutoScale        `json:"autoscale,omitempty" url:"autoscale,omitempty"`
	ClusterID              string            `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	CreatorUserName        string            `json:"creator_user_name,omitempty" url:"creator_user_name,omitempty"`
	Driver                 *SparkNode        `json:"driver,omitempty" url:"driver,omitempty"`
	Executors              []SparkNode       `json:"executors,omitempty" url:"executors,omitempty"`
	SparkContextID         int64             `json:"spark_context_id,omitempty" url:"spark_context_id,omitempty"`
	JdbcPort               int32             `json:"jdbc_port,omitempty" url:"jdbc_port,omitempty"`
	ClusterName            string            `json:"cluster_name,omitempty" url:"cluster_name,omitempty"`
	SparkVersion           string            `json:"spark_version,omitempty" url:"spark_version,omitempty"`
	SparkConf              *SparkConfPair    `json:"spark_conf,omitempty" url:"spark_conf,omitempty"`
	AwsAttributes          *AwsAttributes    `json:"aws_attributes,omitempty" url:"aws_attributes,omitempty"`
	NodeTypeID             string            `json:"node_type_id,omitempty" url:"node_type_id,omitempty"`
	DriverNodeTypeID       string            `json:"driver_node_type_id,omitempty" url:"driver_node_type_id,omitempty"`
	SSHPublicKeys          []string          `json:"ssh_public_keys,omitempty" url:"ssh_public_keys,omitempty"`
	CustomTags             []ClusterTag      `json:"custom_tags,omitempty" url:"custom_tags,omitempty"`
	ClusterLogConf         *ClusterLogConf   `json:"cluster_log_conf,omitempty" url:"cluster_log_conf,omitempty"`
	InitScripts            []InitScriptInfo  `json:"init_scripts,omitempty" url:"init_scripts,omitempty"`
	SparkEnvVars           map[string]string `json:"spark_env_vars,omitempty" url:"spark_env_vars,omitempty"`
	AutoterminationMinutes int32             `json:"autotermination_minutes,omitempty" url:"autotermination_minutes,omitempty"`
	EnableElasticDisk      bool              `json:"enable_elastic_disk,omitempty" url:"enable_elastic_disk,omitempty"`
	ClusterSource          *AwsAvailability  `json:"cluster_source,omitempty" url:"cluster_source,omitempty"`
	State                  *ClusterState     `json:"state,omitempty" url:"state,omitempty"`
	StateMessage           string            `json:"state_message,omitempty" url:"state_message,omitempty"`
	StartTime              int64             `json:"start_time,omitempty" url:"start_time,omitempty"`
	TerminateTime          int64             `json:"terminate_time,omitempty" url:"terminate_time,omitempty"`
	LastStateLossTime      int64             `json:"last_state_loss_time,omitempty" url:"last_state_loss_time,omitempty"`
	LastActivityTime       int64             `json:"last_activity_time,omitempty" url:"last_activity_time,omitempty"`
	ClusterMemoryMb        int64             `json:"cluster_memory_mb,omitempty" url:"cluster_memory_mb,omitempty"`
	ClusterCores           float32           `json:"cluster_cores,omitempty" url:"cluster_cores,omitempty"`
	DefaultTags            []ClusterTag      `json:"default_tags,omitempty" url:"default_tags,omitempty"`
	ClusterLogStatus       *LogSyncStatus    `json:"cluster_log_status,omitempty" url:"cluster_log_status,omitempty"`
	TerminationReason      *S3StorageInfo    `json:"termination_reason,omitempty" url:"termination_reason,omitempty"`
	DockerImage            *DockerImage      `json:"docker_image,omitempty" url:"docker_image,omitempty"`
}

func (*ClusterInfo) DeepCopy 

func (in *ClusterInfo) DeepCopy() *ClusterInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInfo.

func (*ClusterInfo) DeepCopyInto 

func (in *ClusterInfo) DeepCopyInto(out *ClusterInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterInstance 

type ClusterInstance struct {
	ClusterID      string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	SparkContextID string `json:"spark_context_id,omitempty" url:"spark_context_id,omitempty"`
}

func (*ClusterInstance) DeepCopy 

func (in *ClusterInstance) DeepCopy() *ClusterInstance

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInstance.

func (*ClusterInstance) DeepCopyInto 

func (in *ClusterInstance) DeepCopyInto(out *ClusterInstance)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterLibraryStatuses 

type ClusterLibraryStatuses struct {
	ClusterID       string              `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	LibraryStatuses []LibraryFullStatus `json:"library_statuses,omitempty" url:"library_statuses,omitempty"`
}

func (*ClusterLibraryStatuses) DeepCopy 

func (in *ClusterLibraryStatuses) DeepCopy() *ClusterLibraryStatuses

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterLibraryStatuses.

func (*ClusterLibraryStatuses) DeepCopyInto 

func (in *ClusterLibraryStatuses) DeepCopyInto(out *ClusterLibraryStatuses)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterLogConf 

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

func (*ClusterLogConf) DeepCopy 

func (in *ClusterLogConf) DeepCopy() *ClusterLogConf

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterLogConf.

func (*ClusterLogConf) DeepCopyInto 

func (in *ClusterLogConf) DeepCopyInto(out *ClusterLogConf)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSize 

type ClusterSize struct {
	NumWorkers int32      `json:"num_workers,omitempty" url:"num_workers,omitempty"`
	Autoscale  *AutoScale `json:"autoscale,omitempty" url:"autoscale,omitempty"`
}

func (*ClusterSize) DeepCopy 

func (in *ClusterSize) DeepCopy() *ClusterSize

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSize.

func (*ClusterSize) DeepCopyInto 

func (in *ClusterSize) DeepCopyInto(out *ClusterSize)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSource 

type ClusterSource string

type ClusterSpec 

type ClusterSpec struct {
	ExistingClusterID string      `json:"existing_cluster_id,omitempty" url:"existing_cluster_id,omitempty"`
	NewCluster        *NewCluster `json:"new_cluster,omitempty" url:"new_cluster,omitempty"`
	Libraries         []Library   `json:"libraries,omitempty" url:"libraries,omitempty"`
}

func (*ClusterSpec) DeepCopy 

func (in *ClusterSpec) DeepCopy() *ClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.

func (*ClusterSpec) DeepCopyInto 

func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterState 

type ClusterState string

type ClusterTag 

type ClusterTag struct {
	Key   string `json:"key,omitempty" url:"key,omitempty"`
	Value string `json:"value,omitempty" url:"value,omitempty"`
}

func (*ClusterTag) DeepCopy 

func (in *ClusterTag) DeepCopy() *ClusterTag

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterTag.

func (*ClusterTag) DeepCopyInto 

func (in *ClusterTag) DeepCopyInto(out *ClusterTag)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CronSchedule 

type CronSchedule struct {
	QuartzCronExpression string `json:"quartz_cron_expression,omitempty" url:"quartz_cron_expression,omitempty"`
	TimezoneID           string `json:"timezone_id,omitempty" url:"timezone_id,omitempty"`
}

func (*CronSchedule) DeepCopy 

func (in *CronSchedule) DeepCopy() *CronSchedule

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronSchedule.

func (*CronSchedule) DeepCopyInto 

func (in *CronSchedule) DeepCopyInto(out *CronSchedule)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DbfsStorageInfo 

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

func (*DbfsStorageInfo) DeepCopy 

func (in *DbfsStorageInfo) DeepCopy() *DbfsStorageInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DbfsStorageInfo.

func (*DbfsStorageInfo) DeepCopyInto 

func (in *DbfsStorageInfo) DeepCopyInto(out *DbfsStorageInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DiskSpec 

type DiskSpec struct {
	DiskType  *DiskType `json:"disk_type,omitempty" url:"disk_type,omitempty"`
	DiskCount int32     `json:"disk_count,omitempty" url:"disk_count,omitempty"`
	DiskSize  int32     `json:"disk_size,omitempty" url:"disk_size,omitempty"`
}

func (*DiskSpec) DeepCopy 

func (in *DiskSpec) DeepCopy() *DiskSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DiskSpec.

func (*DiskSpec) DeepCopyInto 

func (in *DiskSpec) DeepCopyInto(out *DiskSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DiskType 

type DiskType struct {
	EbsVolumeType EbsVolumeType `json:"ebs_volume_type,omitempty" url:"ebs_volume_type,omitempty"`
}

func (*DiskType) DeepCopy 

func (in *DiskType) DeepCopy() *DiskType

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DiskType.

func (*DiskType) DeepCopyInto 

func (in *DiskType) DeepCopyInto(out *DiskType)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DockerImage 

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

type EbsVolumeType 

type EbsVolumeType string

type EventDetails 

type EventDetails struct {
	CurrentNumWorkers   int32              `json:"current_num_workers,omitempty" url:"current_num_workers,omitempty"`
	TargetNumWorkers    int32              `json:"target_num_workers,omitempty" url:"target_num_workers,omitempty"`
	PreviousAttributes  *ClusterAttributes `json:"previous_attributes,omitempty" url:"previous_attributes,omitempty"`
	Attributes          *ClusterAttributes `json:"attributes,omitempty" url:"attributes,omitempty"`
	PreviousClusterSize *ClusterSize       `json:"previous_cluster_size,omitempty" url:"previous_cluster_size,omitempty"`
	ClusterSize         *ClusterSize       `json:"cluster_size,omitempty" url:"cluster_size,omitempty"`
}

func (*EventDetails) DeepCopy 

func (in *EventDetails) DeepCopy() *EventDetails

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventDetails.

func (*EventDetails) DeepCopyInto 

func (in *EventDetails) DeepCopyInto(out *EventDetails)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExportFormat 

type ExportFormat string

type FileInfo 

type FileInfo struct {
	Path     string `json:"path,omitempty" url:"path,omitempty"`
	IsDir    bool   `json:"is_dir,omitempty" url:"is_dir,omitempty"`
	FileSize int64  `json:"file_size,omitempty" url:"file_size,omitempty"`
}

func (*FileInfo) DeepCopy 

func (in *FileInfo) DeepCopy() *FileInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileInfo.

func (*FileInfo) DeepCopyInto 

func (in *FileInfo) DeepCopyInto(out *FileInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InitScriptInfo 

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

func (*InitScriptInfo) DeepCopy 

func (in *InitScriptInfo) DeepCopy() *InitScriptInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InitScriptInfo.

func (*InitScriptInfo) DeepCopyInto 

func (in *InitScriptInfo) DeepCopyInto(out *InitScriptInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InstancePoolAndStats 

type InstancePoolAndStats struct {
	InstancePoolName                   string                    `json:"instance_pool_name,omitempty" url:"instance_pool_name,omitempty"`
	MinIdleInstances                   int32                     `json:"min_idle_instances,omitempty" url:"min_idle_instances,omitempty"`
	MaxCapacity                        int32                     `json:"max_capacity,omitempty" url:"max_capacity,omitempty"`
	AwsAttributes                      InstancePoolAwsAttributes `json:"aws_attributes,omitempty" url:"aws_attributes,omitempty"`
	NodetypeID                         string                    `json:"node_type_id,omitempty" url:"node_type_id,omitempty"`
	CustomTags                         []ClusterTag              `json:"custom_tags,omitempty" url:"custom_tags,omitempty"`
	IdleInstanceAutoterminationMinutes int32                     `json:"idle_instance_autotermination_minutes,omitempty" url:"idle_instance_autotermination_minutes,omitempty"`
	EnableElasticDisk                  bool                      `json:"enable_elastic_disk,omitempty" url:"enable_elastic_disk,omitempty"`
	DiskSpec                           DiskSpec                  `json:"disk_spec,omitempty" url:"disk_spec,omitempty"`
	PreloadedSparkVersions             []string                  `json:"preloaded_spark_versions,omitempty" url:"preloaded_spark_versions,omitempty"`
	InstancePoolID                     string                    `json:"instance_pool_id,omitempty" url:"instance_pool_id,omitempty"`
	DefaultTags                        []ClusterTag              `json:"default_tags,omitempty" url:"default_tags,omitempty"`
	State                              InstancePoolState         `json:"state,omitempty" url:"state,omitempty"`
	Stats                              InstancePoolStats         `json:"stats,omitempty" url:"stats,omitempty"`
}

func (*InstancePoolAndStats) DeepCopy 

func (in *InstancePoolAndStats) DeepCopy() *InstancePoolAndStats

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InstancePoolAndStats.

func (*InstancePoolAndStats) DeepCopyInto 

func (in *InstancePoolAndStats) DeepCopyInto(out *InstancePoolAndStats)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InstancePoolAwsAttributes 

type InstancePoolAwsAttributes struct {
	Availability        AwsAvailability `json:"availability,omitempty" url:"availability,omitempty"`
	ZoneID              string          `json:"zone_id,omitempty" url:"zone_id,omitempty"`
	SpotBidPricePercent int32           `json:"spot_bid_price_percent,omitempty" url:"spot_bid_price_percent,omitempty"`
}

func (*InstancePoolAwsAttributes) DeepCopy 

func (in *InstancePoolAwsAttributes) DeepCopy() *InstancePoolAwsAttributes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InstancePoolAwsAttributes.

func (*InstancePoolAwsAttributes) DeepCopyInto 

func (in *InstancePoolAwsAttributes) DeepCopyInto(out *InstancePoolAwsAttributes)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InstancePoolState 

type InstancePoolState string

type InstancePoolStats 

type InstancePoolStats struct {
	UsedCount        int32 `json:"used_count,omitempty" url:"used_count,omitempty"`
	IdleCount        int32 `json:"idle_count,omitempty" url:"idle_count,omitempty"`
	PendingUsedCount int32 `json:"pending_used_count,omitempty" url:"pending_used_count,omitempty"`
	PendingIdleCount int32 `json:"pending_idle_count,omitempty" url:"pending_idle_count,omitempty"`
}

func (*InstancePoolStats) DeepCopy 

func (in *InstancePoolStats) DeepCopy() *InstancePoolStats

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InstancePoolStats.

func (*InstancePoolStats) DeepCopyInto 

func (in *InstancePoolStats) DeepCopyInto(out *InstancePoolStats)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InstanceProfile 

type InstanceProfile struct {
	InstanceProfileArn string `json:"instance_profile_arn,omitempty" url:"instance_profile_arn,omitempty"`
}

func (*InstanceProfile) DeepCopy 

func (in *InstanceProfile) DeepCopy() *InstanceProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InstanceProfile.

func (*InstanceProfile) DeepCopyInto 

func (in *InstanceProfile) DeepCopyInto(out *InstanceProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Job 

type Job struct {
	JobID           int64        `json:"job_id,omitempty" url:"job_id,omitempty"`
	CreatorUserName string       `json:"creator_user_name,omitempty" url:"creator_user_name,omitempty"`
	Settings        *JobSettings `json:"settings,omitempty" url:"settings,omitempty"`
	CreatedTime     int64        `json:"created_time,omitempty" url:"created_time,omitempty"`
}

func (*Job) DeepCopy 

func (in *Job) DeepCopy() *Job

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Job.

func (*Job) DeepCopyInto 

func (in *Job) DeepCopyInto(out *Job)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobEmailNotifications 

type JobEmailNotifications struct {
	OnStart               []string `json:"on_start,omitempty" url:"on_start,omitempty"`
	OnSuccess             []string `json:"on_success,omitempty" url:"on_success,omitempty"`
	OnFailure             []string `json:"on_failure,omitempty" url:"on_failure,omitempty"`
	NoAlertForSkippedRuns bool     `json:"no_alert_for_skipped_runs,omitempty" url:"no_alert_for_skipped_runs,omitempty"`
}

func (*JobEmailNotifications) DeepCopy 

func (in *JobEmailNotifications) DeepCopy() *JobEmailNotifications

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobEmailNotifications.

func (*JobEmailNotifications) DeepCopyInto 

func (in *JobEmailNotifications) DeepCopyInto(out *JobEmailNotifications)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobSettings 

type JobSettings struct {
	ExistingClusterID      string                 `json:"existing_cluster_id,omitempty" url:"existing_cluster_id,omitempty"`
	NewCluster             *NewCluster            `json:"new_cluster,omitempty" url:"new_cluster,omitempty"`
	NotebookTask           *NotebookTask          `json:"notebook_task,omitempty" url:"notebook_task,omitempty"`
	SparkJarTask           *SparkJarTask          `json:"spark_jar_task,omitempty" url:"spark_jar_task,omitempty"`
	SparkPythonTask        *SparkPythonTask       `json:"spark_python_task,omitempty" url:"spark_python_task,omitempty"`
	SparkSubmitTask        *SparkSubmitTask       `json:"spark_submit_task,omitempty" url:"spark_submit_task,omitempty"`
	Name                   string                 `json:"name,omitempty" url:"name,omitempty"`
	Libraries              []Library              `json:"libraries,omitempty" url:"libraries,omitempty"`
	EmailNotifications     *JobEmailNotifications `json:"email_notifications,omitempty" url:"email_notifications,omitempty"`
	TimeoutSeconds         int32                  `json:"timeout_seconds,omitempty" url:"timeout_seconds,omitempty"`
	MaxRetries             int32                  `json:"max_retries,omitempty" url:"max_retries,omitempty"`
	MinRetryIntervalMillis int32                  `json:"min_retry_interval_millis,omitempty" url:"min_retry_interval_millis,omitempty"`
	RetryOnTimeout         bool                   `json:"retry_on_timeout,omitempty" url:"retry_on_timeout,omitempty"`
	Schedule               *CronSchedule          `json:"schedule,omitempty" url:"schedule,omitempty"`
	MaxConcurrentRuns      int32                  `json:"max_concurrent_runs,omitempty" url:"max_concurrent_runs,omitempty"`
}

func (*JobSettings) DeepCopy 

func (in *JobSettings) DeepCopy() *JobSettings

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobSettings.

func (*JobSettings) DeepCopyInto 

func (in *JobSettings) DeepCopyInto(out *JobSettings)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobTask 

type JobTask struct {
	NotebookTask    *NotebookTask    `json:"notebook_task,omitempty" url:"notebook_task,omitempty"`
	SparkJarTask    *SparkJarTask    `json:"spark_jar_task,omitempty" url:"spark_jar_task,omitempty"`
	SparkPythonTask *SparkPythonTask `json:"spark_python_task,omitempty" url:"spark_python_task,omitempty"`
	SparkSubmitTask *SparkSubmitTask `json:"spark_submit_task,omitempty" url:"spark_submit_task,omitempty"`
}

func (*JobTask) DeepCopy 

func (in *JobTask) DeepCopy() *JobTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobTask.

func (*JobTask) DeepCopyInto 

func (in *JobTask) DeepCopyInto(out *JobTask)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Language 

type Language string

type Library 

type Library struct {
	Jar   string             `json:"jar,omitempty" url:"jar,omitempty"`
	Egg   string             `json:"egg,omitempty" url:"egg,omitempty"`
	Whl   string             `json:"whl,omitempty" url:"whl,omitempty"`
	Pypi  *PythonPyPiLibrary `json:"pypi,omitempty" url:"pypi,omitempty"`
	Maven *MavenLibrary      `json:"maven,omitempty" url:"maven,omitempty"`
	Cran  *RCranLibrary      `json:"cran,omitempty" url:"cran,omitempty"`
}

func (*Library) DeepCopy 

func (in *Library) DeepCopy() *Library

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Library.

func (*Library) DeepCopyInto 

func (in *Library) DeepCopyInto(out *Library)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LibraryFullStatus 

type LibraryFullStatus struct {
	Library                 *Library              `json:"library,omitempty" url:"library,omitempty"`
	Status                  *LibraryInstallStatus `json:"status,omitempty" url:"status,omitempty"`
	Messages                []string              `json:"messages,omitempty" url:"messages,omitempty"`
	IsLibraryForAllClusters bool                  `json:"is_library_for_all_clusters,omitempty" url:"is_library_for_all_clusters,omitempty"`
}

func (*LibraryFullStatus) DeepCopy 

func (in *LibraryFullStatus) DeepCopy() *LibraryFullStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LibraryFullStatus.

func (*LibraryFullStatus) DeepCopyInto 

func (in *LibraryFullStatus) DeepCopyInto(out *LibraryFullStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LibraryInstallStatus 

type LibraryInstallStatus string

type ListOrder 

type ListOrder string

type LogSyncStatus 

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

func (*LogSyncStatus) DeepCopy 

func (in *LogSyncStatus) DeepCopy() *LogSyncStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LogSyncStatus.

func (*LogSyncStatus) DeepCopyInto 

func (in *LogSyncStatus) DeepCopyInto(out *LogSyncStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MavenLibrary 

type MavenLibrary struct {
	Coordinates string   `json:"coordinates,omitempty" url:"coordinates,omitempty"`
	Repo        string   `json:"repo,omitempty" url:"repo,omitempty"`
	Exclusions  []string `json:"exclusions,omitempty" url:"exclusions,omitempty"`
}

func (*MavenLibrary) DeepCopy 

func (in *MavenLibrary) DeepCopy() *MavenLibrary

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MavenLibrary.

func (*MavenLibrary) DeepCopyInto 

func (in *MavenLibrary) DeepCopyInto(out *MavenLibrary)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NewCluster 

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

func (*NewCluster) DeepCopy 

func (in *NewCluster) DeepCopy() *NewCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NewCluster.

func (*NewCluster) DeepCopyInto 

func (in *NewCluster) DeepCopyInto(out *NewCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NodeType 

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

func (*NodeType) DeepCopy 

func (in *NodeType) DeepCopy() *NodeType

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeType.

func (*NodeType) DeepCopyInto 

func (in *NodeType) DeepCopyInto(out *NodeType)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NotebookOutput 

type NotebookOutput struct {
	Result    string `json:"result,omitempty" url:"result,omitempty"`
	Truncated bool   `json:"truncated,omitempty" url:"truncated,omitempty"`
}

func (*NotebookOutput) DeepCopy 

func (in *NotebookOutput) DeepCopy() *NotebookOutput

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NotebookOutput.

func (*NotebookOutput) DeepCopyInto 

func (in *NotebookOutput) DeepCopyInto(out *NotebookOutput)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NotebookTask 

type NotebookTask struct {
	NotebookPath   string            `json:"notebook_path,omitempty" url:"notebook_path,omitempty"`
	BaseParameters map[string]string `json:"base_parameters,omitempty" url:"base_parameters,omitempty"`
}

func (*NotebookTask) DeepCopy 

func (in *NotebookTask) DeepCopy() *NotebookTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NotebookTask.

func (*NotebookTask) DeepCopyInto 

func (in *NotebookTask) DeepCopyInto(out *NotebookTask)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ObjectInfo 

type ObjectInfo struct {
	ObjectType *ObjectType `json:"object_type,omitempty" url:"object_type,omitempty"`
	Path       string      `json:"path,omitempty" url:"path,omitempty"`
	Language   *Language   `json:"language,omitempty" url:"language,omitempty"`
}

func (*ObjectInfo) DeepCopy 

func (in *ObjectInfo) DeepCopy() *ObjectInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ObjectInfo.

func (*ObjectInfo) DeepCopyInto 

func (in *ObjectInfo) DeepCopyInto(out *ObjectInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ObjectType 

type ObjectType string

type ParamPair 

type ParamPair struct {
	Key   string `json:"key,omitempty" url:"key,omitempty"`
	Value string `json:"value,omitempty" url:"value,omitempty"`
}

func (*ParamPair) DeepCopy 

func (in *ParamPair) DeepCopy() *ParamPair

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParamPair.

func (*ParamPair) DeepCopyInto 

func (in *ParamPair) DeepCopyInto(out *ParamPair)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ParameterPair 

type ParameterPair struct {
	Key   string `json:"key,omitempty" url:"key,omitempty"`
	Value string `json:"value,omitempty" url:"value,omitempty"`
}

func (*ParameterPair) DeepCopy 

func (in *ParameterPair) DeepCopy() *ParameterPair

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParameterPair.

func (*ParameterPair) DeepCopyInto 

func (in *ParameterPair) DeepCopyInto(out *ParameterPair)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PrincipalName 

type PrincipalName struct {
	UserName  string `json:"user_name,omitempty" url:"user_name,omitempty"`
	GroupName string `json:"group_name,omitempty" url:"group_name,omitempty"`
}

func (*PrincipalName) DeepCopy 

func (in *PrincipalName) DeepCopy() *PrincipalName

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrincipalName.

func (*PrincipalName) DeepCopyInto 

func (in *PrincipalName) DeepCopyInto(out *PrincipalName)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PublicTokenInfo 

type PublicTokenInfo struct {
	TokenID      string `json:"token_id,omitempty" url:"token_id,omitempty"`
	CreationTime int64  `json:"creation_time,omitempty" url:"creation_time,omitempty"`
	ExpiryTime   int64  `json:"expiry_time,omitempty" url:"expiry_time,omitempty"`
	Comment      string `json:"comment,omitempty" url:"comment,omitempty"`
}

func (*PublicTokenInfo) DeepCopy 

func (in *PublicTokenInfo) DeepCopy() *PublicTokenInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicTokenInfo.

func (*PublicTokenInfo) DeepCopyInto 

func (in *PublicTokenInfo) DeepCopyInto(out *PublicTokenInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PythonPyPiLibrary 

type PythonPyPiLibrary struct {
	Package string `json:"package,omitempty" url:"package,omitempty"`
	Repo    string `json:"repo,omitempty" url:"repo,omitempty"`
}

func (*PythonPyPiLibrary) DeepCopy 

func (in *PythonPyPiLibrary) DeepCopy() *PythonPyPiLibrary

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PythonPyPiLibrary.

func (*PythonPyPiLibrary) DeepCopyInto 

func (in *PythonPyPiLibrary) DeepCopyInto(out *PythonPyPiLibrary)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RCranLibrary 

type RCranLibrary struct {
	Package string `json:"package,omitempty" url:"package,omitempty"`
	Repo    string `json:"repo,omitempty" url:"repo,omitempty"`
}

func (*RCranLibrary) DeepCopy 

func (in *RCranLibrary) DeepCopy() *RCranLibrary

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RCranLibrary.

func (*RCranLibrary) DeepCopyInto 

func (in *RCranLibrary) DeepCopyInto(out *RCranLibrary)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ResizeCause 

type ResizeCause string

type Run 

type Run struct {
	JobID                int64            `json:"job_id,omitempty" url:"job_id,omitempty"`
	RunID                int64            `json:"run_id,omitempty" url:"run_id,omitempty"`
	CreatorUserName      string           `json:"creator_user_name,omitempty" url:"creator_user_name,omitempty"`
	NumberInJob          int64            `json:"number_in_job,omitempty" url:"number_in_job,omitempty"`
	OriginalAttemptRunID int64            `json:"original_attempt_run_id,omitempty" url:"original_attempt_run_id,omitempty"`
	State                *RunState        `json:"state,omitempty" url:"state,omitempty"`
	Schedule             *CronSchedule    `json:"schedule,omitempty" url:"schedule,omitempty"`
	Task                 *JobTask         `json:"task,omitempty" url:"task,omitempty"`
	ClusterSpec          *ClusterSpec     `json:"cluster_spec,omitempty" url:"cluster_spec,omitempty"`
	ClusterInstance      *ClusterInstance `json:"cluster_instance,omitempty" url:"cluster_instance,omitempty"`
	OverridingParameters *RunParameters   `json:"overriding_parameters,omitempty" url:"overriding_parameters,omitempty"`
	StartTime            int64            `json:"start_time,omitempty" url:"start_time,omitempty"`
	SetupDuration        int64            `json:"setup_duration,omitempty" url:"setup_duration,omitempty"`
	ExecutionDuration    int64            `json:"execution_duration,omitempty" url:"execution_duration,omitempty"`
	CleanupDuration      int64            `json:"cleanup_duration,omitempty" url:"cleanup_duration,omitempty"`
	Trigger              *TriggerType     `json:"trigger,omitempty" url:"trigger,omitempty"`
}

func (*Run) DeepCopy 

func (in *Run) DeepCopy() *Run

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Run.

func (*Run) DeepCopyInto 

func (in *Run) DeepCopyInto(out *Run)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RunLifeCycleState 

type RunLifeCycleState string

type RunParameters 

type RunParameters struct {
	JarParams         []string          `json:"jar_params,omitempty" url:"jar_params,omitempty"`
	NotebookParams    map[string]string `json:"notebook_params,omitempty" url:"notebook_params,omitempty"`
	PythonParams      []string          `json:"python_params,omitempty" url:"python_params,omitempty"`
	SparkSubmitParams []string          `json:"spark_submit_params,omitempty" url:"spark_submit_params,omitempty"`
}

func (*RunParameters) DeepCopy 

func (in *RunParameters) DeepCopy() *RunParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RunParameters.

func (*RunParameters) DeepCopyInto 

func (in *RunParameters) DeepCopyInto(out *RunParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RunResultState 

type RunResultState string

type RunState 

type RunState struct {
	LifeCycleState *RunLifeCycleState `json:"life_cycle_state,omitempty" url:"life_cycle_state,omitempty"`
	ResultState    *RunResultState    `json:"result_state,omitempty" url:"result_state,omitempty"`
	StateMessage   string             `json:"state_message,omitempty" url:"state_message,omitempty"`
}

func (*RunState) DeepCopy 

func (in *RunState) DeepCopy() *RunState

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RunState.

func (*RunState) DeepCopyInto 

func (in *RunState) DeepCopyInto(out *RunState)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type S3StorageInfo 

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

func (*S3StorageInfo) DeepCopy 

func (in *S3StorageInfo) DeepCopy() *S3StorageInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3StorageInfo.

func (*S3StorageInfo) DeepCopyInto 

func (in *S3StorageInfo) DeepCopyInto(out *S3StorageInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ScopeBackendType 

type ScopeBackendType string

type SecretMetadata 

type SecretMetadata struct {
	Key                  string `json:"key,omitempty" url:"key,omitempty"`
	LastUpdatedTimestamp int64  `json:"last_updated_timestamp,omitempty" url:"last_updated_timestamp,omitempty"`
}

func (*SecretMetadata) DeepCopy 

func (in *SecretMetadata) DeepCopy() *SecretMetadata

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretMetadata.

func (*SecretMetadata) DeepCopyInto 

func (in *SecretMetadata) DeepCopyInto(out *SecretMetadata)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SecretScope 

type SecretScope struct {
	Name        string            `json:"name,omitempty" url:"name,omitempty"`
	BackendType *ScopeBackendType `json:"backend_type,omitempty" url:"backend_type,omitempty"`
}

func (*SecretScope) DeepCopy 

func (in *SecretScope) DeepCopy() *SecretScope

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretScope.

func (*SecretScope) DeepCopyInto 

func (in *SecretScope) DeepCopyInto(out *SecretScope)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkConfPair 

type SparkConfPair struct {
	Key   string `json:"key,omitempty" url:"key,omitempty"`
	Value string `json:"value,omitempty" url:"value,omitempty"`
}

func (*SparkConfPair) DeepCopy 

func (in *SparkConfPair) DeepCopy() *SparkConfPair

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkConfPair.

func (*SparkConfPair) DeepCopyInto 

func (in *SparkConfPair) DeepCopyInto(out *SparkConfPair)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkEnvPair 

type SparkEnvPair struct {
	Key   string `json:"key,omitempty" url:"key,omitempty"`
	Value string `json:"value,omitempty" url:"value,omitempty"`
}

func (*SparkEnvPair) DeepCopy 

func (in *SparkEnvPair) DeepCopy() *SparkEnvPair

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkEnvPair.

func (*SparkEnvPair) DeepCopyInto 

func (in *SparkEnvPair) DeepCopyInto(out *SparkEnvPair)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkJarTask 

type SparkJarTask struct {
	JarURI        string   `json:"jar_uri,omitempty" url:"jar_uri,omitempty"`
	MainClassName string   `json:"main_class_name,omitempty" url:"main_class_name,omitempty"`
	Parameters    []string `json:"parameters,omitempty" url:"parameters,omitempty"`
}

func (*SparkJarTask) DeepCopy 

func (in *SparkJarTask) DeepCopy() *SparkJarTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkJarTask.

func (*SparkJarTask) DeepCopyInto 

func (in *SparkJarTask) DeepCopyInto(out *SparkJarTask)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkNode 

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

func (*SparkNode) DeepCopy 

func (in *SparkNode) DeepCopy() *SparkNode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkNode.

func (*SparkNode) DeepCopyInto 

func (in *SparkNode) DeepCopyInto(out *SparkNode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkNodeAwsAttributes 

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

func (*SparkNodeAwsAttributes) DeepCopy 

func (in *SparkNodeAwsAttributes) DeepCopy() *SparkNodeAwsAttributes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkNodeAwsAttributes.

func (*SparkNodeAwsAttributes) DeepCopyInto 

func (in *SparkNodeAwsAttributes) DeepCopyInto(out *SparkNodeAwsAttributes)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkPythonTask 

type SparkPythonTask struct {
	PythonFile string   `json:"python_file,omitempty" url:"python_file,omitempty"`
	Parameters []string `json:"parameters,omitempty" url:"parameters,omitempty"`
}

func (*SparkPythonTask) DeepCopy 

func (in *SparkPythonTask) DeepCopy() *SparkPythonTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkPythonTask.

func (*SparkPythonTask) DeepCopyInto 

func (in *SparkPythonTask) DeepCopyInto(out *SparkPythonTask)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkSubmitTask 

type SparkSubmitTask struct {
	Parameters []string `json:"parameters,omitempty" url:"parameters,omitempty"`
}

func (*SparkSubmitTask) DeepCopy 

func (in *SparkSubmitTask) DeepCopy() *SparkSubmitTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkSubmitTask.

func (*SparkSubmitTask) DeepCopyInto 

func (in *SparkSubmitTask) DeepCopyInto(out *SparkSubmitTask)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkVersion 

type SparkVersion struct {
	Key  string `json:"key,omitempty" url:"key,omitempty"`
	Name string `json:"name,omitempty" url:"name,omitempty"`
}

func (*SparkVersion) DeepCopy 

func (in *SparkVersion) DeepCopy() *SparkVersion

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkVersion.

func (*SparkVersion) DeepCopyInto 

func (in *SparkVersion) DeepCopyInto(out *SparkVersion)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TerminationCode 

type TerminationCode string

type TerminationParameter 

type TerminationParameter string

type TerminationReason 

type TerminationReason struct {
	Code       *TerminationCode `json:"code,omitempty" url:"code,omitempty"`
	Parameters []ParameterPair  `json:"parameters,omitempty" url:"parameters,omitempty"`
}

func (*TerminationReason) DeepCopy 

func (in *TerminationReason) DeepCopy() *TerminationReason

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TerminationReason.

func (*TerminationReason) DeepCopyInto 

func (in *TerminationReason) DeepCopyInto(out *TerminationReason)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TriggerType 

type TriggerType string

type ViewItem 

type ViewItem struct {
	Content string    `json:"content,omitempty" url:"content,omitempty"`
	Name    string    `json:"name,omitempty" url:"name,omitempty"`
	Type    *ViewType `json:"type,omitempty" url:"type,omitempty"`
}

func (*ViewItem) DeepCopy 

func (in *ViewItem) DeepCopy() *ViewItem

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ViewItem.

func (*ViewItem) DeepCopyInto 

func (in *ViewItem) DeepCopyInto(out *ViewItem)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ViewType 

type ViewType string

type ViewsToExport 

type ViewsToExport string

Source Files

View all Source files

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.