/
processing_job.go
109 lines (100 loc) · 5.16 KB
/
processing_job.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
// Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License"). You may
// not use this file except in compliance with the License. A copy of the
// License is located at
//
// http://aws.amazon.com/apache2.0/
//
// or in the "license" file accompanying this file. This file is distributed
// on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
// express or implied. See the License for the specific language governing
// permissions and limitations under the License.
// Code generated by ack-generate. DO NOT EDIT.
package v1alpha1
import (
ackv1alpha1 "github.com/aws-controllers-k8s/runtime/apis/core/v1alpha1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
// ProcessingJobSpec defines the desired state of ProcessingJob.
//
// An Amazon SageMaker processing job that is used to analyze data and evaluate
// models. For more information, see Process Data and Evaluate Models (https://docs.aws.amazon.com/sagemaker/latest/dg/processing-job.html).
type ProcessingJobSpec struct {
// Configures the processing job to run a specified Docker container image.
// +kubebuilder:validation:Required
AppSpecification *AppSpecification `json:"appSpecification"`
// The environment variables to set in the Docker container. Up to 100 key and
// values entries in the map are supported.
Environment map[string]*string `json:"environment,omitempty"`
ExperimentConfig *ExperimentConfig `json:"experimentConfig,omitempty"`
// Networking options for a processing job, such as whether to allow inbound
// and outbound network calls to and from processing containers, and the VPC
// subnets and security groups to use for VPC-enabled processing jobs.
NetworkConfig *NetworkConfig `json:"networkConfig,omitempty"`
// An array of inputs configuring the data to download into the processing container.
ProcessingInputs []*ProcessingInput `json:"processingInputs,omitempty"`
// The name of the processing job. The name must be unique within an Amazon
// Web Services Region in the Amazon Web Services account.
// +kubebuilder:validation:Required
ProcessingJobName *string `json:"processingJobName"`
// Output configuration for the processing job.
ProcessingOutputConfig *ProcessingOutputConfig `json:"processingOutputConfig,omitempty"`
// Identifies the resources, ML compute instances, and ML storage volumes to
// deploy for a processing job. In distributed training, you specify more than
// one instance.
// +kubebuilder:validation:Required
ProcessingResources *ProcessingResources `json:"processingResources"`
// The Amazon Resource Name (ARN) of an IAM role that Amazon SageMaker can assume
// to perform tasks on your behalf.
// +kubebuilder:validation:Required
RoleARN *string `json:"roleARN"`
// The time limit for how long the processing job is allowed to run.
StoppingCondition *ProcessingStoppingCondition `json:"stoppingCondition,omitempty"`
// (Optional) An array of key-value pairs. For more information, see Using Cost
// Allocation Tags (https://docs.aws.amazon.com/awsaccountbilling/latest/aboutv2/cost-alloc-tags.html#allocation-whatURL)
// in the Amazon Web Services Billing and Cost Management User Guide.
Tags []*Tag `json:"tags,omitempty"`
}
// ProcessingJobStatus defines the observed state of ProcessingJob
type ProcessingJobStatus 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"`
// A string, up to one KB in size, that contains the reason a processing job
// failed, if it failed.
// +kubebuilder:validation:Optional
FailureReason *string `json:"failureReason,omitempty"`
// Provides the status of a processing job.
// +kubebuilder:validation:Optional
ProcessingJobStatus *string `json:"processingJobStatus,omitempty"`
}
// ProcessingJob is the Schema for the ProcessingJobs API
// +kubebuilder:object:root=true
// +kubebuilder:subresource:status
// +kubebuilder:printcolumn:name="FAILURE-REASON",type=string,priority=1,JSONPath=`.status.failureReason`
// +kubebuilder:printcolumn:name="STATUS",type=string,priority=0,JSONPath=`.status.processingJobStatus`
type ProcessingJob struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ProcessingJobSpec `json:"spec,omitempty"`
Status ProcessingJobStatus `json:"status,omitempty"`
}
// ProcessingJobList contains a list of ProcessingJob
// +kubebuilder:object:root=true
type ProcessingJobList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ProcessingJob `json:"items"`
}
func init() {
SchemeBuilder.Register(&ProcessingJob{}, &ProcessingJobList{})
}