-
Notifications
You must be signed in to change notification settings - Fork 202
/
dataflowjob_types.go
150 lines (118 loc) · 5.43 KB
/
dataflowjob_types.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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
// Copyright 2020 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License 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.
// ----------------------------------------------------------------------------
//
// *** AUTO GENERATED CODE *** AUTO GENERATED CODE ***
//
// ----------------------------------------------------------------------------
//
// This file is automatically generated by Config Connector and manual
// changes will be clobbered when the file is regenerated.
//
// ----------------------------------------------------------------------------
// *** DISCLAIMER ***
// Config Connector's go-client for CRDs is currently in ALPHA, which means
// that future versions of the go-client may include breaking changes.
// Please try it out and give us feedback!
package v1beta1
import (
"github.com/GoogleCloudPlatform/k8s-config-connector/pkg/clients/generated/apis/k8s/v1alpha1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
type JobParameters struct {
}
type JobTransformNameMapping struct {
}
type DataflowJobSpec struct {
/* List of experiments that should be used by the job. An example value is ["enable_stackdriver_agent_metrics"]. */
// +optional
AdditionalExperiments []string `json:"additionalExperiments,omitempty"`
/* Indicates if the job should use the streaming engine feature. */
// +optional
EnableStreamingEngine *bool `json:"enableStreamingEngine,omitempty"`
/* The configuration for VM IPs. Options are "WORKER_IP_PUBLIC" or "WORKER_IP_PRIVATE". */
// +optional
IpConfiguration *string `json:"ipConfiguration,omitempty"`
/* The name for the Cloud KMS key for the job. */
// +optional
KmsKeyRef *v1alpha1.ResourceRef `json:"kmsKeyRef,omitempty"`
/* The machine type to use for the job. */
// +optional
MachineType *string `json:"machineType,omitempty"`
/* Immutable. The number of workers permitted to work on the job. More workers may improve processing speed at additional cost. */
// +optional
MaxWorkers *int `json:"maxWorkers,omitempty"`
// +optional
NetworkRef *v1alpha1.ResourceRef `json:"networkRef,omitempty"`
/* Key/Value pairs to be passed to the Dataflow job (as used in the template). */
// +optional
Parameters *JobParameters `json:"parameters,omitempty"`
/* Immutable. The region in which the created job should run. */
// +optional
Region *string `json:"region,omitempty"`
/* Immutable. Optional. The name of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
// +optional
ResourceID *string `json:"resourceID,omitempty"`
// +optional
ServiceAccountRef *v1alpha1.ResourceRef `json:"serviceAccountRef,omitempty"`
// +optional
SubnetworkRef *v1alpha1.ResourceRef `json:"subnetworkRef,omitempty"`
/* A writeable location on Google Cloud Storage for the Dataflow job to dump its temporary data. */
TempGcsLocation string `json:"tempGcsLocation"`
/* The Google Cloud Storage path to the Dataflow job template. */
TemplateGcsPath string `json:"templateGcsPath"`
/* Only applicable when updating a pipeline. Map of transform name prefixes of the job to be replaced with the corresponding name prefixes of the new job. */
// +optional
TransformNameMapping *JobTransformNameMapping `json:"transformNameMapping,omitempty"`
/* Immutable. The zone in which the created job should run. If it is not provided, the provider zone is used. */
// +optional
Zone *string `json:"zone,omitempty"`
}
type DataflowJobStatus struct {
/* Conditions represent the latest available observations of the
DataflowJob's current state. */
Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
/* The unique ID of this job. */
// +optional
JobId *string `json:"jobId,omitempty"`
/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
// +optional
ObservedGeneration *int `json:"observedGeneration,omitempty"`
/* The current state of the resource, selected from the JobState enum. */
// +optional
State *string `json:"state,omitempty"`
/* The type of this job, selected from the JobType enum. */
// +optional
Type *string `json:"type,omitempty"`
}
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// DataflowJob is the Schema for the dataflow API
// +k8s:openapi-gen=true
type DataflowJob struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec DataflowJobSpec `json:"spec,omitempty"`
Status DataflowJobStatus `json:"status,omitempty"`
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// DataflowJobList contains a list of DataflowJob
type DataflowJobList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []DataflowJob `json:"items"`
}
func init() {
SchemeBuilder.Register(&DataflowJob{}, &DataflowJobList{})
}