v1alpha1

package
v0.47.2 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CRDGroup   = "emrcontainers.aws.crossplane.io"
	CRDVersion = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// 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
)
View Source 
var (
	JobRunKind             = "JobRun"
	JobRunGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: JobRunKind}.String()
	JobRunKindAPIVersion   = JobRunKind + "." + GroupVersion.String()
	JobRunGroupVersionKind = GroupVersion.WithKind(JobRunKind)
)

Repository type metadata.

View Source 
var (
	VirtualClusterKind             = "VirtualCluster"
	VirtualClusterGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: VirtualClusterKind}.String()
	VirtualClusterKindAPIVersion   = VirtualClusterKind + "." + GroupVersion.String()
	VirtualClusterGroupVersionKind = GroupVersion.WithKind(VirtualClusterKind)
)

Repository type metadata.

Functions

This section is empty.

Types

type CloudWatchMonitoringConfiguration 

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

+kubebuilder:skipversion

func (*CloudWatchMonitoringConfiguration) DeepCopy 

func (in *CloudWatchMonitoringConfiguration) DeepCopy() *CloudWatchMonitoringConfiguration

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

func (*CloudWatchMonitoringConfiguration) DeepCopyInto 

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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 CustomJobRunParameters 

type CustomJobRunParameters struct {
	// The virtual cluster ID for which the job run request is submitted.
	// +kubebuilder:validation:Required
	// +crossplane:generate:reference:type=VirtualCluster
	VirtualClusterID *string `json:"virtualClusterId,omitempty"`
	// VirtualClusterIdRef is a reference to an API used to set
	// the VirtualClusterId.
	// +optional
	VirtualClusterIDRef *xpv1.Reference `json:"virtualClusterIdRef,omitempty"`
	// VirtualClusterIdSelector is a reference to an API used to set
	// the VirtualClusterIdSelector.
	// +optional
	VirtualClusterIDSelector *xpv1.Selector `json:"virtualClusterIdSelector,omitempty"`
}

CustomJobRunParameters includes the custom fields of JobRun.

func (*CustomJobRunParameters) DeepCopy 

func (in *CustomJobRunParameters) DeepCopy() *CustomJobRunParameters

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

func (*CustomJobRunParameters) DeepCopyInto 

func (in *CustomJobRunParameters) DeepCopyInto(out *CustomJobRunParameters)

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

type CustomVirtualClusterParameters 

type CustomVirtualClusterParameters struct{}

CustomVirtualClusterParameters includes the custom fields of VirtualCluster.

func (*CustomVirtualClusterParameters) DeepCopy 

func (in *CustomVirtualClusterParameters) DeepCopy() *CustomVirtualClusterParameters

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

func (*CustomVirtualClusterParameters) DeepCopyInto 

func (in *CustomVirtualClusterParameters) DeepCopyInto(out *CustomVirtualClusterParameters)

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

type EKSInfo 

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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 

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

+kubebuilder:skipversion

func (*JobDriver) DeepCopy 

func (in *JobDriver) DeepCopy() *JobDriver

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

func (*JobDriver) DeepCopyInto 

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"`
	Status            JobRunStatus `json:"status,omitempty"`
}

JobRun is the Schema for the JobRuns API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

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 

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

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

func (*JobRun) GetCondition 

func (mg *JobRun) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this JobRun.

func (*JobRun) GetDeletionPolicy 

func (mg *JobRun) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this JobRun.

func (*JobRun) GetManagementPolicies added in v0.43.0 

func (mg *JobRun) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this JobRun.

func (*JobRun) GetProviderConfigReference 

func (mg *JobRun) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this JobRun.

func (*JobRun) GetPublishConnectionDetailsTo 

func (mg *JobRun) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this JobRun.

func (*JobRun) GetWriteConnectionSecretToReference 

func (mg *JobRun) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this JobRun.

func (*JobRun) ResolveReferences 

func (mg *JobRun) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this JobRun.

func (*JobRun) SetConditions 

func (mg *JobRun) SetConditions(c ...xpv1.Condition)

SetConditions of this JobRun.

func (*JobRun) SetDeletionPolicy 

func (mg *JobRun) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this JobRun.

func (*JobRun) SetManagementPolicies added in v0.43.0 

func (mg *JobRun) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this JobRun.

func (*JobRun) SetProviderConfigReference 

func (mg *JobRun) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this JobRun.

func (*JobRun) SetPublishConnectionDetailsTo 

func (mg *JobRun) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this JobRun.

func (*JobRun) SetWriteConnectionSecretToReference 

func (mg *JobRun) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this JobRun.

type JobRunList 

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

JobRunList contains a list of JobRuns

func (*JobRunList) DeepCopy 

func (in *JobRunList) DeepCopy() *JobRunList

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

func (*JobRunList) DeepCopyInto 

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 

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

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

func (*JobRunList) GetItems 

func (l *JobRunList) GetItems() []resource.Managed

GetItems of this JobRunList.

type JobRunObservation 

type JobRunObservation struct {
	// This output lists the ARN of job run.
	ARN *string `json:"arn,omitempty"`
	// The reasons why the job run has failed.
	FailureReason *string `json:"failureReason,omitempty"`
	// This output displays the started job run ID.
	ID *string `json:"id,omitempty"`
	// This output displays the name of the started job run.
	Name *string `json:"name,omitempty"`
	// The state of the job run.
	State *string `json:"state,omitempty"`
	// Additional details of the job run state.
	StateDetails *string `json:"stateDetails,omitempty"`
	// This output displays the virtual cluster ID for which the job run was submitted.
	VirtualClusterID *string `json:"virtualClusterID,omitempty"`
}

JobRunObservation defines the observed state of JobRun

func (*JobRunObservation) DeepCopy 

func (in *JobRunObservation) DeepCopy() *JobRunObservation

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

func (*JobRunObservation) DeepCopyInto 

func (in *JobRunObservation) DeepCopyInto(out *JobRunObservation)

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

type JobRunParameters 

type JobRunParameters struct {
	// Region is which region the JobRun will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`

	ConfigurationOverrides *string `json:"configurationOverrides,omitempty"`
	// The execution role ARN for the job run.
	ExecutionRoleARN *string `json:"executionRoleARN,omitempty"`
	// The job driver for the job run.
	JobDriver *JobDriver `json:"jobDriver,omitempty"`
	// The job template ID to be used to start the job run.
	JobTemplateID *string `json:"jobTemplateID,omitempty"`
	// The values of job template parameters to start a job run.
	JobTemplateParameters map[string]*string `json:"jobTemplateParameters,omitempty"`
	// The Amazon EMR release version to use for the job run.
	ReleaseLabel *string `json:"releaseLabel,omitempty"`
	// The retry policy configuration for the job run.
	RetryPolicyConfiguration *RetryPolicyConfiguration `json:"retryPolicyConfiguration,omitempty"`
	// The tags assigned to job runs.
	Tags                   map[string]*string `json:"tags,omitempty"`
	CustomJobRunParameters `json:",inline"`
}

JobRunParameters defines the desired state of JobRun

func (*JobRunParameters) DeepCopy 

func (in *JobRunParameters) DeepCopy() *JobRunParameters

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

func (*JobRunParameters) DeepCopyInto 

func (in *JobRunParameters) DeepCopyInto(out *JobRunParameters)

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

type JobRunSpec 

type JobRunSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       JobRunParameters `json:"forProvider"`
}

JobRunSpec defines the desired state of JobRun

func (*JobRunSpec) DeepCopy 

func (in *JobRunSpec) DeepCopy() *JobRunSpec

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

func (*JobRunSpec) DeepCopyInto 

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 

type JobRunStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          JobRunObservation `json:"atProvider,omitempty"`
}

JobRunStatus defines the observed state of JobRun.

func (*JobRunStatus) DeepCopy 

func (in *JobRunStatus) DeepCopy() *JobRunStatus

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

func (*JobRunStatus) DeepCopyInto 

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 

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

+kubebuilder:skipversion

func (*JobRun_SDK) DeepCopy 

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 

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 v0.38.0 

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

+kubebuilder:skipversion

func (*JobTemplate) DeepCopy added in v0.38.0 

func (in *JobTemplate) DeepCopy() *JobTemplate

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

func (*JobTemplate) DeepCopyInto added in v0.38.0 

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 v0.38.0 

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

+kubebuilder:skipversion

func (*JobTemplateData) DeepCopy added in v0.38.0 

func (in *JobTemplateData) DeepCopy() *JobTemplateData

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

func (*JobTemplateData) DeepCopyInto added in v0.38.0 

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

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

type ParametricCloudWatchMonitoringConfiguration added in v0.38.0 

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

+kubebuilder:skipversion

func (*ParametricCloudWatchMonitoringConfiguration) DeepCopy added in v0.38.0 

func (in *ParametricCloudWatchMonitoringConfiguration) DeepCopy() *ParametricCloudWatchMonitoringConfiguration

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

func (*ParametricCloudWatchMonitoringConfiguration) DeepCopyInto added in v0.38.0 

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_ENABLED  PersistentAppUI = "ENABLED"
	PersistentAppUI_DISABLED PersistentAppUI = "DISABLED"
)

type RetryPolicyConfiguration added in v0.44.0 

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

+kubebuilder:skipversion

func (*RetryPolicyConfiguration) DeepCopy added in v0.44.0 

func (in *RetryPolicyConfiguration) DeepCopy() *RetryPolicyConfiguration

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

func (*RetryPolicyConfiguration) DeepCopyInto added in v0.44.0 

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 v0.44.0 

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

+kubebuilder:skipversion

func (*RetryPolicyExecution) DeepCopy added in v0.44.0 

func (in *RetryPolicyExecution) DeepCopy() *RetryPolicyExecution

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

func (*RetryPolicyExecution) DeepCopyInto added in v0.44.0 

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

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

type SparkSQLJobDriver added in v0.39.0 

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

	SparkSQLParameters *string `json:"sparkSQLParameters,omitempty"`
}

+kubebuilder:skipversion

func (*SparkSQLJobDriver) DeepCopy added in v0.39.0 

func (in *SparkSQLJobDriver) DeepCopy() *SparkSQLJobDriver

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

func (*SparkSQLJobDriver) DeepCopyInto added in v0.39.0 

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 

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

	EntryPointArguments []*string `json:"entryPointArguments,omitempty"`

	SparkSubmitParameters *string `json:"sparkSubmitParameters,omitempty"`
}

+kubebuilder:skipversion

func (*SparkSubmitJobDriver) DeepCopy 

func (in *SparkSubmitJobDriver) DeepCopy() *SparkSubmitJobDriver

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

func (*SparkSubmitJobDriver) DeepCopyInto 

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 v0.38.0 

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

+kubebuilder:skipversion

func (*TemplateParameterConfiguration) DeepCopy added in v0.38.0 

func (in *TemplateParameterConfiguration) DeepCopy() *TemplateParameterConfiguration

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

func (*TemplateParameterConfiguration) DeepCopyInto added in v0.38.0 

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 v0.38.0 

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"`
	Status            VirtualClusterStatus `json:"status,omitempty"`
}

VirtualCluster is the Schema for the VirtualClusters API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

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.

func (*VirtualCluster) GetCondition 

func (mg *VirtualCluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this VirtualCluster.

func (*VirtualCluster) GetDeletionPolicy 

func (mg *VirtualCluster) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this VirtualCluster.

func (*VirtualCluster) GetManagementPolicies added in v0.43.0 

func (mg *VirtualCluster) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this VirtualCluster.

func (*VirtualCluster) GetProviderConfigReference 

func (mg *VirtualCluster) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this VirtualCluster.

func (*VirtualCluster) GetPublishConnectionDetailsTo 

func (mg *VirtualCluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this VirtualCluster.

func (*VirtualCluster) GetWriteConnectionSecretToReference 

func (mg *VirtualCluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this VirtualCluster.

func (*VirtualCluster) SetConditions 

func (mg *VirtualCluster) SetConditions(c ...xpv1.Condition)

SetConditions of this VirtualCluster.

func (*VirtualCluster) SetDeletionPolicy 

func (mg *VirtualCluster) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this VirtualCluster.

func (*VirtualCluster) SetManagementPolicies added in v0.43.0 

func (mg *VirtualCluster) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this VirtualCluster.

func (*VirtualCluster) SetProviderConfigReference 

func (mg *VirtualCluster) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this VirtualCluster.

func (*VirtualCluster) SetPublishConnectionDetailsTo 

func (mg *VirtualCluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this VirtualCluster.

func (*VirtualCluster) SetWriteConnectionSecretToReference 

func (mg *VirtualCluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this VirtualCluster.

type VirtualClusterList 

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

VirtualClusterList contains a list of VirtualClusters

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.

func (*VirtualClusterList) GetItems 

func (l *VirtualClusterList) GetItems() []resource.Managed

GetItems of this VirtualClusterList.

type VirtualClusterObservation 

type VirtualClusterObservation struct {
	// This output contains the ARN of virtual cluster.
	ARN *string `json:"arn,omitempty"`
	// This output contains the virtual cluster ID.
	ID *string `json:"id,omitempty"`
	// This output contains the name of the virtual cluster.
	Name *string `json:"name,omitempty"`
}

VirtualClusterObservation defines the observed state of VirtualCluster

func (*VirtualClusterObservation) DeepCopy 

func (in *VirtualClusterObservation) DeepCopy() *VirtualClusterObservation

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

func (*VirtualClusterObservation) DeepCopyInto 

func (in *VirtualClusterObservation) DeepCopyInto(out *VirtualClusterObservation)

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

type VirtualClusterParameters 

type VirtualClusterParameters struct {
	// Region is which region the VirtualCluster will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// The container provider of the virtual cluster.
	// +kubebuilder:validation:Required
	ContainerProvider *ContainerProvider `json:"containerProvider"`
	// The tags assigned to the virtual cluster.
	Tags                           map[string]*string `json:"tags,omitempty"`
	CustomVirtualClusterParameters `json:",inline"`
}

VirtualClusterParameters defines the desired state of VirtualCluster

func (*VirtualClusterParameters) DeepCopy 

func (in *VirtualClusterParameters) DeepCopy() *VirtualClusterParameters

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

func (*VirtualClusterParameters) DeepCopyInto 

func (in *VirtualClusterParameters) DeepCopyInto(out *VirtualClusterParameters)

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

type VirtualClusterSpec 

type VirtualClusterSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       VirtualClusterParameters `json:"forProvider"`
}

VirtualClusterSpec defines the desired state of VirtualCluster

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 {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          VirtualClusterObservation `json:"atProvider,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"`
}

+kubebuilder:skipversion

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.