v1

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: May 26, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ProcessingJob

type ProcessingJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ProcessingJobSpec   `json:"spec,omitempty"`
	Status ProcessingJobStatus `json:"status,omitempty"`
}

ProcessingJob is the Schema for the processingjobs API

func (*ProcessingJob) DeepCopy

func (in *ProcessingJob) DeepCopy() *ProcessingJob

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

func (*ProcessingJob) DeepCopyInto

func (in *ProcessingJob) DeepCopyInto(out *ProcessingJob)

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

func (*ProcessingJob) DeepCopyObject

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

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

type ProcessingJobList

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

ProcessingJobList contains a list of ProcessingJob

func (*ProcessingJobList) DeepCopy

func (in *ProcessingJobList) DeepCopy() *ProcessingJobList

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

func (*ProcessingJobList) DeepCopyInto

func (in *ProcessingJobList) DeepCopyInto(out *ProcessingJobList)

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

func (*ProcessingJobList) DeepCopyObject

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

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

type ProcessingJobSpec

type ProcessingJobSpec struct {
	AppSpecification *commonv1.AppSpecification `json:"appSpecification"`

	// +kubebuilder:validation:MaxItems=100
	Environment []*commonv1.KeyValuePair `json:"environment,omitempty"`

	NetworkConfig *commonv1.ProcessingNetworkConfig `json:"networkConfig,omitempty"`

	// +kubebuilder:validation:MaxItems=10
	ProcessingInputs []*commonv1.ProcessingInput `json:"processingInputs,omitempty"`

	ProcessingOutputConfig *commonv1.ProcessingOutputConfig `json:"processingOutputConfig,omitempty"`

	ProcessingResources *commonv1.ProcessingResources `json:"processingResources"`

	// +kubebuilder:validation:MinLength=20
	// +kubebuilder:validation:MaxLength=2048
	RoleArn *string `json:"roleArn"`

	// +kubebuilder:validation:MinLength=1
	Region *string `json:"region"`

	StoppingCondition *commonv1.StoppingConditionNoSpot `json:"stoppingCondition,omitempty"`

	// +kubebuilder:validation:MaxItems=50
	Tags []*commonv1.Tag `json:"tags,omitempty"`

	// A custom SageMaker endpoint to use when communicating with SageMaker.
	// +kubebuilder:validation:Pattern="^(https|http)://.*$"
	SageMakerEndpoint *string `json:"sageMakerEndpoint,omitempty"`
}

ProcessingJobSpec defines the desired state of ProcessingJob

func (*ProcessingJobSpec) DeepCopy

func (in *ProcessingJobSpec) DeepCopy() *ProcessingJobSpec

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

func (*ProcessingJobSpec) DeepCopyInto

func (in *ProcessingJobSpec) DeepCopyInto(out *ProcessingJobSpec)

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

type ProcessingJobStatus

type ProcessingJobStatus struct {

	// The status of the processing job.
	// https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_DescribeProcessingJob.html#sagemaker-DescribeProcessingJob-response-ProcessingJobStatus
	ProcessingJobStatus string `json:"processingJobStatus,omitempty"`

	// Field to store additional information, for example if
	// we are unable to check the status we update this.
	Additional string `json:"additional,omitempty"`

	// The last time that we checked the status of the SageMaker job.
	LastCheckTime *metav1.Time `json:"lastCheckTime,omitempty"`

	// CloudWatch URL for log
	CloudWatchLogURL string `json:"cloudWatchLogUrl,omitempty"`

	//SageMaker processing job name
	SageMakerProcessingJobName string `json:"sageMakerProcessingJobName,omitempty"`
}

ProcessingJobStatus defines the observed state of ProcessingJob

func (*ProcessingJobStatus) DeepCopy

func (in *ProcessingJobStatus) DeepCopy() *ProcessingJobStatus

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

func (*ProcessingJobStatus) DeepCopyInto

func (in *ProcessingJobStatus) DeepCopyInto(out *ProcessingJobStatus)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL