v1alpha1

package
v1.0.18 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package Package v1alpha1 is the v1alpha1 version of the emrcontainers.services.k8s.aws API. +groupName=emrcontainers.services.k8s.aws

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: "emrcontainers.services.k8s.aws", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type CertificateProviderType added in v1.0.16 

type CertificateProviderType string
const (
	CertificateProviderType_PEM CertificateProviderType = "PEM"
)

type CloudWatchMonitoringConfiguration added in v0.0.6 

type CloudWatchMonitoringConfiguration struct {
	LogStreamNamePrefix *string `json:"logStreamNamePrefix,omitempty"`
}

A configuration for CloudWatch monitoring. You can configure your jobs to send log information to CloudWatch Logs.

func (*CloudWatchMonitoringConfiguration) DeepCopy added in v0.0.6 

func (in *CloudWatchMonitoringConfiguration) DeepCopy() *CloudWatchMonitoringConfiguration

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

func (*CloudWatchMonitoringConfiguration) DeepCopyInto added in v0.0.6 

func (in *CloudWatchMonitoringConfiguration) DeepCopyInto(out *CloudWatchMonitoringConfiguration)

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

type Configuration 

type Configuration struct {
	Classification *string `json:"classification,omitempty"`
}

A configuration specification to be used when provisioning virtual clusters, which can include configurations for applications and software bundled with Amazon EMR on EKS. A configuration consists of a classification, properties, and optional nested configurations. A classification refers to an application-specific configuration file. Properties are the settings you want to change in that file.

func (*Configuration) DeepCopy 

func (in *Configuration) DeepCopy() *Configuration

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

func (*Configuration) DeepCopyInto 

func (in *Configuration) DeepCopyInto(out *Configuration)

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

type ContainerInfo 

type ContainerInfo struct {
	// The information about the Amazon EKS cluster.
	EKSInfo *EKSInfo `json:"eksInfo,omitempty"`
}

The information about the container used for a job run or a managed endpoint.

func (*ContainerInfo) DeepCopy 

func (in *ContainerInfo) DeepCopy() *ContainerInfo

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

func (*ContainerInfo) DeepCopyInto 

func (in *ContainerInfo) DeepCopyInto(out *ContainerInfo)

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

type ContainerProvider 

type ContainerProvider struct {
	ID *string `json:"id,omitempty"`
	// The information about the container used for a job run or a managed endpoint.
	Info *ContainerInfo `json:"info,omitempty"`
	Type *string        `json:"type_,omitempty"`
}

The information about the container provider.

func (*ContainerProvider) DeepCopy 

func (in *ContainerProvider) DeepCopy() *ContainerProvider

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

func (*ContainerProvider) DeepCopyInto 

func (in *ContainerProvider) DeepCopyInto(out *ContainerProvider)

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

type ContainerProviderType 

type ContainerProviderType string
const (
	ContainerProviderType_EKS ContainerProviderType = "EKS"
)

type EKSInfo 

type EKSInfo struct {
	Namespace *string `json:"namespace,omitempty"`
}

The information about the Amazon EKS cluster.

func (*EKSInfo) DeepCopy 

func (in *EKSInfo) DeepCopy() *EKSInfo

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

func (*EKSInfo) DeepCopyInto 

func (in *EKSInfo) DeepCopyInto(out *EKSInfo)

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

type Endpoint 

type Endpoint struct {
	CreatedAt        *metav1.Time       `json:"createdAt,omitempty"`
	ExecutionRoleARN *string            `json:"executionRoleARN,omitempty"`
	FailureReason    *string            `json:"failureReason,omitempty"`
	ID               *string            `json:"id,omitempty"`
	Name             *string            `json:"name,omitempty"`
	ReleaseLabel     *string            `json:"releaseLabel,omitempty"`
	SecurityGroup    *string            `json:"securityGroup,omitempty"`
	StateDetails     *string            `json:"stateDetails,omitempty"`
	Tags             map[string]*string `json:"tags,omitempty"`
	VirtualClusterID *string            `json:"virtualClusterID,omitempty"`
}

This entity represents the endpoint that is managed by Amazon EMR on EKS.

func (*Endpoint) DeepCopy 

func (in *Endpoint) DeepCopy() *Endpoint

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

func (*Endpoint) DeepCopyInto 

func (in *Endpoint) DeepCopyInto(out *Endpoint)

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

type EndpointState 

type EndpointState string
const (
	EndpointState_ACTIVE                 EndpointState = "ACTIVE"
	EndpointState_CREATING               EndpointState = "CREATING"
	EndpointState_TERMINATED             EndpointState = "TERMINATED"
	EndpointState_TERMINATED_WITH_ERRORS EndpointState = "TERMINATED_WITH_ERRORS"
	EndpointState_TERMINATING            EndpointState = "TERMINATING"
)

type FailureReason 

type FailureReason string
const (
	FailureReason_CLUSTER_UNAVAILABLE FailureReason = "CLUSTER_UNAVAILABLE"
	FailureReason_INTERNAL_ERROR      FailureReason = "INTERNAL_ERROR"
	FailureReason_USER_ERROR          FailureReason = "USER_ERROR"
	FailureReason_VALIDATION_ERROR    FailureReason = "VALIDATION_ERROR"
)

type JobDriver added in v0.0.6 

type JobDriver struct {
	// The information about job driver for Spark submit.
	SparkSubmitJobDriver *SparkSubmitJobDriver `json:"sparkSubmitJobDriver,omitempty"`
}

Specify the driver that the job runs on. Exactly one of the two available job drivers is required, either sparkSqlJobDriver or sparkSubmitJobDriver.

func (*JobDriver) DeepCopy added in v0.0.6 

func (in *JobDriver) DeepCopy() *JobDriver

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

func (*JobDriver) DeepCopyInto added in v0.0.6 

func (in *JobDriver) DeepCopyInto(out *JobDriver)

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

type JobRun 

type JobRun struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobRunSpec   `json:"spec,omitempty"`
	Status            JobRunStatus `json:"status,omitempty"`
}

JobRun is the Schema for the JobRuns API +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Job-ID",type=string,priority=0,JSONPath=`.status.id` +kubebuilder:printcolumn:name="STATE",type=string,priority=0,JSONPath=`.status.state`

func (*JobRun) DeepCopy 

func (in *JobRun) DeepCopy() *JobRun

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

func (*JobRun) DeepCopyInto 

func (in *JobRun) DeepCopyInto(out *JobRun)

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

func (*JobRun) DeepCopyObject added in v0.0.6 

func (in *JobRun) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type JobRunList added in v0.0.6 

type JobRunList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []JobRun `json:"items"`
}

JobRunList contains a list of JobRun +kubebuilder:object:root=true

func (*JobRunList) DeepCopy added in v0.0.6 

func (in *JobRunList) DeepCopy() *JobRunList

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

func (*JobRunList) DeepCopyInto added in v0.0.6 

func (in *JobRunList) DeepCopyInto(out *JobRunList)

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

func (*JobRunList) DeepCopyObject added in v0.0.6 

func (in *JobRunList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type JobRunSpec added in v0.0.6 

type JobRunSpec struct {

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	ConfigurationOverrides *string `json:"configurationOverrides,omitempty"`
	// The execution role ARN for the job run.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	ExecutionRoleARN *string `json:"executionRoleARN,omitempty"`
	// The job driver for the job run.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	JobDriver *JobDriver `json:"jobDriver,omitempty"`
	// The name of the job run.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	Name *string `json:"name,omitempty"`
	// The Amazon EMR release version to use for the job run.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	ReleaseLabel *string `json:"releaseLabel,omitempty"`
	// The tags assigned to job runs.
	Tags map[string]*string `json:"tags,omitempty"`
	// The virtual cluster ID for which the job run request is submitted.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	VirtualClusterID  *string                                  `json:"virtualClusterID,omitempty"`
	VirtualClusterRef *ackv1alpha1.AWSResourceReferenceWrapper `json:"virtualClusterRef,omitempty"`
}

JobRunSpec defines the desired state of JobRun.

This entity describes a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.

func (*JobRunSpec) DeepCopy added in v0.0.6 

func (in *JobRunSpec) DeepCopy() *JobRunSpec

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

func (*JobRunSpec) DeepCopyInto added in v0.0.6 

func (in *JobRunSpec) DeepCopyInto(out *JobRunSpec)

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

type JobRunState 

type JobRunState string
const (
	JobRunState_CANCELLED      JobRunState = "CANCELLED"
	JobRunState_CANCEL_PENDING JobRunState = "CANCEL_PENDING"
	JobRunState_COMPLETED      JobRunState = "COMPLETED"
	JobRunState_FAILED         JobRunState = "FAILED"
	JobRunState_PENDING        JobRunState = "PENDING"
	JobRunState_RUNNING        JobRunState = "RUNNING"
	JobRunState_SUBMITTED      JobRunState = "SUBMITTED"
)

type JobRunStatus added in v0.0.6 

type JobRunStatus struct {
	// All CRs managed by ACK have a common `Status.ACKResourceMetadata` member
	// that is used to contain resource sync state, account ownership,
	// constructed ARN for the resource
	// +kubebuilder:validation:Optional
	ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"`
	// All CRs managed by ACK have a common `Status.Conditions` member that
	// contains a collection of `ackv1alpha1.Condition` objects that describe
	// the various terminal states of the CR and its backend AWS service API
	// resource
	// +kubebuilder:validation:Optional
	Conditions []*ackv1alpha1.Condition `json:"conditions"`
	// This output displays the started job run ID.
	// +kubebuilder:validation:Optional
	ID *string `json:"id,omitempty"`
	// The state of the job run.
	// +kubebuilder:validation:Optional
	State *string `json:"state,omitempty"`
}

JobRunStatus defines the observed state of JobRun

func (*JobRunStatus) DeepCopy added in v0.0.6 

func (in *JobRunStatus) DeepCopy() *JobRunStatus

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

func (*JobRunStatus) DeepCopyInto added in v0.0.6 

func (in *JobRunStatus) DeepCopyInto(out *JobRunStatus)

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

type JobRun_SDK added in v0.0.6 

type JobRun_SDK struct {
	ARN              *string      `json:"arn,omitempty"`
	ClientToken      *string      `json:"clientToken,omitempty"`
	CreatedAt        *metav1.Time `json:"createdAt,omitempty"`
	CreatedBy        *string      `json:"createdBy,omitempty"`
	ExecutionRoleARN *string      `json:"executionRoleARN,omitempty"`
	FailureReason    *string      `json:"failureReason,omitempty"`
	FinishedAt       *metav1.Time `json:"finishedAt,omitempty"`
	ID               *string      `json:"id,omitempty"`
	// Specify the driver that the job runs on. Exactly one of the two available
	// job drivers is required, either sparkSqlJobDriver or sparkSubmitJobDriver.
	JobDriver    *JobDriver `json:"jobDriver,omitempty"`
	Name         *string    `json:"name,omitempty"`
	ReleaseLabel *string    `json:"releaseLabel,omitempty"`
	// The configuration of the retry policy that the job runs on.
	RetryPolicyConfiguration *RetryPolicyConfiguration `json:"retryPolicyConfiguration,omitempty"`
	// The current status of the retry policy executed on the job.
	RetryPolicyExecution *RetryPolicyExecution `json:"retryPolicyExecution,omitempty"`
	State                *string               `json:"state,omitempty"`
	StateDetails         *string               `json:"stateDetails,omitempty"`
	Tags                 map[string]*string    `json:"tags,omitempty"`
	VirtualClusterID     *string               `json:"virtualClusterID,omitempty"`
}

This entity describes a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.

func (*JobRun_SDK) DeepCopy added in v0.0.6 

func (in *JobRun_SDK) DeepCopy() *JobRun_SDK

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

func (*JobRun_SDK) DeepCopyInto added in v0.0.6 

func (in *JobRun_SDK) DeepCopyInto(out *JobRun_SDK)

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

type JobTemplate added in v1.0.16 

type JobTemplate struct {
	CreatedAt *metav1.Time       `json:"createdAt,omitempty"`
	CreatedBy *string            `json:"createdBy,omitempty"`
	ID        *string            `json:"id,omitempty"`
	Name      *string            `json:"name,omitempty"`
	Tags      map[string]*string `json:"tags,omitempty"`
}

This entity describes a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.

func (*JobTemplate) DeepCopy added in v1.0.16 

func (in *JobTemplate) DeepCopy() *JobTemplate

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

func (*JobTemplate) DeepCopyInto added in v1.0.16 

func (in *JobTemplate) DeepCopyInto(out *JobTemplate)

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

type JobTemplateData added in v1.0.16 

type JobTemplateData struct {
	// Specify the driver that the job runs on. Exactly one of the two available
	// job drivers is required, either sparkSqlJobDriver or sparkSubmitJobDriver.
	JobDriver *JobDriver         `json:"jobDriver,omitempty"`
	JobTags   map[string]*string `json:"jobTags,omitempty"`
}

The values of StartJobRun API requests used in job runs started using the job template.

func (*JobTemplateData) DeepCopy added in v1.0.16 

func (in *JobTemplateData) DeepCopy() *JobTemplateData

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

func (*JobTemplateData) DeepCopyInto added in v1.0.16 

func (in *JobTemplateData) DeepCopyInto(out *JobTemplateData)

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

type LakeFormationConfiguration added in v1.0.16 

type LakeFormationConfiguration struct {
	QueryEngineRoleARN *string `json:"queryEngineRoleARN,omitempty"`
}

Lake Formation related configuration inputs for the security configuration.

func (*LakeFormationConfiguration) DeepCopy added in v1.0.16 

func (in *LakeFormationConfiguration) DeepCopy() *LakeFormationConfiguration

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

func (*LakeFormationConfiguration) DeepCopyInto added in v1.0.16 

func (in *LakeFormationConfiguration) DeepCopyInto(out *LakeFormationConfiguration)

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

type ParametricCloudWatchMonitoringConfiguration added in v1.0.16 

type ParametricCloudWatchMonitoringConfiguration struct {
	LogStreamNamePrefix *string `json:"logStreamNamePrefix,omitempty"`
}

A configuration for CloudWatch monitoring. You can configure your jobs to send log information to CloudWatch Logs. This data type allows job template parameters to be specified within.

func (*ParametricCloudWatchMonitoringConfiguration) DeepCopy added in v1.0.16 

func (in *ParametricCloudWatchMonitoringConfiguration) DeepCopy() *ParametricCloudWatchMonitoringConfiguration

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

func (*ParametricCloudWatchMonitoringConfiguration) DeepCopyInto added in v1.0.16 

func (in *ParametricCloudWatchMonitoringConfiguration) DeepCopyInto(out *ParametricCloudWatchMonitoringConfiguration)

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

type PersistentAppUI 

type PersistentAppUI string
const (
	PersistentAppUI_DISABLED PersistentAppUI = "DISABLED"
	PersistentAppUI_ENABLED  PersistentAppUI = "ENABLED"
)

type RetryPolicyConfiguration added in v1.0.16 

type RetryPolicyConfiguration struct {
	MaxAttempts *int64 `json:"maxAttempts,omitempty"`
}

The configuration of the retry policy that the job runs on.

func (*RetryPolicyConfiguration) DeepCopy added in v1.0.16 

func (in *RetryPolicyConfiguration) DeepCopy() *RetryPolicyConfiguration

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

func (*RetryPolicyConfiguration) DeepCopyInto added in v1.0.16 

func (in *RetryPolicyConfiguration) DeepCopyInto(out *RetryPolicyConfiguration)

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

type RetryPolicyExecution added in v1.0.16 

type RetryPolicyExecution struct {
	CurrentAttemptCount *int64 `json:"currentAttemptCount,omitempty"`
}

The current status of the retry policy executed on the job.

func (*RetryPolicyExecution) DeepCopy added in v1.0.16 

func (in *RetryPolicyExecution) DeepCopy() *RetryPolicyExecution

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

func (*RetryPolicyExecution) DeepCopyInto added in v1.0.16 

func (in *RetryPolicyExecution) DeepCopyInto(out *RetryPolicyExecution)

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

type SecureNamespaceInfo added in v1.0.16 

type SecureNamespaceInfo struct {
	ClusterID *string `json:"clusterID,omitempty"`
	Namespace *string `json:"namespace,omitempty"`
}

Namespace inputs for the system job.

func (*SecureNamespaceInfo) DeepCopy added in v1.0.16 

func (in *SecureNamespaceInfo) DeepCopy() *SecureNamespaceInfo

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

func (*SecureNamespaceInfo) DeepCopyInto added in v1.0.16 

func (in *SecureNamespaceInfo) DeepCopyInto(out *SecureNamespaceInfo)

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

type SecurityConfiguration added in v1.0.16 

type SecurityConfiguration struct {
	CreatedAt *metav1.Time       `json:"createdAt,omitempty"`
	CreatedBy *string            `json:"createdBy,omitempty"`
	ID        *string            `json:"id,omitempty"`
	Name      *string            `json:"name,omitempty"`
	Tags      map[string]*string `json:"tags,omitempty"`
}

Inputs related to the security configuration. Security configurations in Amazon EMR on EKS are templates for different security setups. You can use security configurations to configure the Lake Formation integration setup. You can also create a security configuration to re-use a security setup each time you create a virtual cluster.

func (*SecurityConfiguration) DeepCopy added in v1.0.16 

func (in *SecurityConfiguration) DeepCopy() *SecurityConfiguration

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

func (*SecurityConfiguration) DeepCopyInto added in v1.0.16 

func (in *SecurityConfiguration) DeepCopyInto(out *SecurityConfiguration)

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

type SparkSQLJobDriver added in v1.0.16 

type SparkSQLJobDriver struct {
	EntryPoint *string `json:"entryPoint,omitempty"`
}

The job driver for job type.

func (*SparkSQLJobDriver) DeepCopy added in v1.0.16 

func (in *SparkSQLJobDriver) DeepCopy() *SparkSQLJobDriver

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

func (*SparkSQLJobDriver) DeepCopyInto added in v1.0.16 

func (in *SparkSQLJobDriver) DeepCopyInto(out *SparkSQLJobDriver)

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

type SparkSubmitJobDriver added in v0.0.6 

type SparkSubmitJobDriver struct {
	EntryPoint            *string   `json:"entryPoint,omitempty"`
	EntryPointArguments   []*string `json:"entryPointArguments,omitempty"`
	SparkSubmitParameters *string   `json:"sparkSubmitParameters,omitempty"`
}

The information about job driver for Spark submit.

func (*SparkSubmitJobDriver) DeepCopy added in v0.0.6 

func (in *SparkSubmitJobDriver) DeepCopy() *SparkSubmitJobDriver

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

func (*SparkSubmitJobDriver) DeepCopyInto added in v0.0.6 

func (in *SparkSubmitJobDriver) DeepCopyInto(out *SparkSubmitJobDriver)

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

type TemplateParameterConfiguration added in v1.0.16 

type TemplateParameterConfiguration struct {
	DefaultValue *string `json:"defaultValue,omitempty"`
}

The configuration of a job template parameter.

func (*TemplateParameterConfiguration) DeepCopy added in v1.0.16 

func (in *TemplateParameterConfiguration) DeepCopy() *TemplateParameterConfiguration

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

func (*TemplateParameterConfiguration) DeepCopyInto added in v1.0.16 

func (in *TemplateParameterConfiguration) DeepCopyInto(out *TemplateParameterConfiguration)

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

type TemplateParameterDataType added in v1.0.16 

type TemplateParameterDataType string
const (
	TemplateParameterDataType_NUMBER TemplateParameterDataType = "NUMBER"
	TemplateParameterDataType_STRING TemplateParameterDataType = "STRING"
)

type VirtualCluster 

type VirtualCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              VirtualClusterSpec   `json:"spec,omitempty"`
	Status            VirtualClusterStatus `json:"status,omitempty"`
}

VirtualCluster is the Schema for the VirtualClusters API +kubebuilder:object:root=true +kubebuilder:subresource:status

func (*VirtualCluster) DeepCopy 

func (in *VirtualCluster) DeepCopy() *VirtualCluster

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

func (*VirtualCluster) DeepCopyInto 

func (in *VirtualCluster) DeepCopyInto(out *VirtualCluster)

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

func (*VirtualCluster) DeepCopyObject 

func (in *VirtualCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type VirtualClusterList 

type VirtualClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []VirtualCluster `json:"items"`
}

VirtualClusterList contains a list of VirtualCluster +kubebuilder:object:root=true

func (*VirtualClusterList) DeepCopy 

func (in *VirtualClusterList) DeepCopy() *VirtualClusterList

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

func (*VirtualClusterList) DeepCopyInto 

func (in *VirtualClusterList) DeepCopyInto(out *VirtualClusterList)

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

func (*VirtualClusterList) DeepCopyObject 

func (in *VirtualClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type VirtualClusterSpec 

type VirtualClusterSpec struct {

	// The container provider of the virtual cluster.
	// +kubebuilder:validation:Required
	ContainerProvider *ContainerProvider `json:"containerProvider"`
	// The specified name of the virtual cluster.
	// +kubebuilder:validation:Required
	Name *string `json:"name"`
	// The tags assigned to the virtual cluster.
	Tags map[string]*string `json:"tags,omitempty"`
}

VirtualClusterSpec defines the desired state of VirtualCluster.

This entity describes a virtual cluster. A virtual cluster is a Kubernetes namespace that Amazon EMR is registered with. Amazon EMR uses virtual clusters to run jobs and host endpoints. Multiple virtual clusters can be backed by the same physical cluster. However, each virtual cluster maps to one namespace on an Amazon EKS cluster. Virtual clusters do not create any active resources that contribute to your bill or that require lifecycle management outside the service.

func (*VirtualClusterSpec) DeepCopy 

func (in *VirtualClusterSpec) DeepCopy() *VirtualClusterSpec

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

func (*VirtualClusterSpec) DeepCopyInto 

func (in *VirtualClusterSpec) DeepCopyInto(out *VirtualClusterSpec)

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

type VirtualClusterState 

type VirtualClusterState string
const (
	VirtualClusterState_ARRESTED    VirtualClusterState = "ARRESTED"
	VirtualClusterState_RUNNING     VirtualClusterState = "RUNNING"
	VirtualClusterState_TERMINATED  VirtualClusterState = "TERMINATED"
	VirtualClusterState_TERMINATING VirtualClusterState = "TERMINATING"
)

type VirtualClusterStatus 

type VirtualClusterStatus struct {
	// All CRs managed by ACK have a common `Status.ACKResourceMetadata` member
	// that is used to contain resource sync state, account ownership,
	// constructed ARN for the resource
	// +kubebuilder:validation:Optional
	ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"`
	// All CRs managed by ACK have a common `Status.Conditions` member that
	// contains a collection of `ackv1alpha1.Condition` objects that describe
	// the various terminal states of the CR and its backend AWS service API
	// resource
	// +kubebuilder:validation:Optional
	Conditions []*ackv1alpha1.Condition `json:"conditions"`
	// This output contains the virtual cluster ID.
	// +kubebuilder:validation:Optional
	ID *string `json:"id,omitempty"`
}

VirtualClusterStatus defines the observed state of VirtualCluster

func (*VirtualClusterStatus) DeepCopy 

func (in *VirtualClusterStatus) DeepCopy() *VirtualClusterStatus

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

func (*VirtualClusterStatus) DeepCopyInto 

func (in *VirtualClusterStatus) DeepCopyInto(out *VirtualClusterStatus)

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

type VirtualCluster_SDK 

type VirtualCluster_SDK struct {
	ARN *string `json:"arn,omitempty"`
	// The information about the container provider.
	ContainerProvider       *ContainerProvider `json:"containerProvider,omitempty"`
	CreatedAt               *metav1.Time       `json:"createdAt,omitempty"`
	ID                      *string            `json:"id,omitempty"`
	Name                    *string            `json:"name,omitempty"`
	SecurityConfigurationID *string            `json:"securityConfigurationID,omitempty"`
	State                   *string            `json:"state,omitempty"`
	Tags                    map[string]*string `json:"tags,omitempty"`
}

This entity describes a virtual cluster. A virtual cluster is a Kubernetes namespace that Amazon EMR is registered with. Amazon EMR uses virtual clusters to run jobs and host endpoints. Multiple virtual clusters can be backed by the same physical cluster. However, each virtual cluster maps to one namespace on an Amazon EKS cluster. Virtual clusters do not create any active resources that contribute to your bill or that require lifecycle management outside the service.

func (*VirtualCluster_SDK) DeepCopy 

func (in *VirtualCluster_SDK) DeepCopy() *VirtualCluster_SDK

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

func (*VirtualCluster_SDK) DeepCopyInto 

func (in *VirtualCluster_SDK) DeepCopyInto(out *VirtualCluster_SDK)

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

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.