v1alpha1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2023 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 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 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 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_CREATING               EndpointState = "CREATING"
	EndpointState_ACTIVE                 EndpointState = "ACTIVE"
	EndpointState_TERMINATING            EndpointState = "TERMINATING"
	EndpointState_TERMINATED             EndpointState = "TERMINATED"
	EndpointState_TERMINATED_WITH_ERRORS EndpointState = "TERMINATED_WITH_ERRORS"
)

type FailureReason 

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

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.

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 {
	ConfigurationOverrides *string `json:"configurationOverrides,omitempty"`
	// The execution role ARN for the job run.
	// +kubebuilder:validation:Required
	ExecutionRoleARN *string `json:"executionRoleARN"`
	// The job driver for the job run.
	// +kubebuilder:validation:Required
	JobDriver *JobDriver `json:"jobDriver"`
	// The name of the job run.
	Name *string `json:"name,omitempty"`
	// The Amazon EMR release version to use for the job run.
	// +kubebuilder:validation:Required
	ReleaseLabel *string `json:"releaseLabel"`
	// 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.
	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_PENDING        JobRunState = "PENDING"
	JobRunState_SUBMITTED      JobRunState = "SUBMITTED"
	JobRunState_RUNNING        JobRunState = "RUNNING"
	JobRunState_FAILED         JobRunState = "FAILED"
	JobRunState_CANCELLED      JobRunState = "CANCELLED"
	JobRunState_CANCEL_PENDING JobRunState = "CANCEL_PENDING"
	JobRunState_COMPLETED      JobRunState = "COMPLETED"
)

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.
	JobDriver        *JobDriver         `json:"jobDriver,omitempty"`
	Name             *string            `json:"name,omitempty"`
	ReleaseLabel     *string            `json:"releaseLabel,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 PersistentAppUI 

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

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 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 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_RUNNING     VirtualClusterState = "RUNNING"
	VirtualClusterState_TERMINATING VirtualClusterState = "TERMINATING"
	VirtualClusterState_TERMINATED  VirtualClusterState = "TERMINATED"
	VirtualClusterState_ARRESTED    VirtualClusterState = "ARRESTED"
)

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"`
	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 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.