1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package logging
22
23 import (
24 reflect "reflect"
25 sync "sync"
26
27 status "google.golang.org/genproto/googleapis/rpc/status"
28 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
29 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
30 )
31
32 const (
33
34 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
35
36 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
37 )
38
39
40 type RequestLogEntry_RequestType int32
41
42 const (
43
44 RequestLogEntry_REQUEST_TYPE_UNSPECIFIED RequestLogEntry_RequestType = 0
45
46 RequestLogEntry_CREATE_PIPELINE RequestLogEntry_RequestType = 1
47
48 RequestLogEntry_UPDATE_PIPELINE RequestLogEntry_RequestType = 2
49
50 RequestLogEntry_DELETE_PIPELINE RequestLogEntry_RequestType = 3
51
52 RequestLogEntry_LIST_PIPELINES RequestLogEntry_RequestType = 4
53
54 RequestLogEntry_GET_PIPELINE RequestLogEntry_RequestType = 5
55
56 RequestLogEntry_STOP_PIPELINE RequestLogEntry_RequestType = 6
57
58 RequestLogEntry_RUN_PIPELINE RequestLogEntry_RequestType = 7
59
60 RequestLogEntry_LIST_JOBS RequestLogEntry_RequestType = 8
61 )
62
63
64 var (
65 RequestLogEntry_RequestType_name = map[int32]string{
66 0: "REQUEST_TYPE_UNSPECIFIED",
67 1: "CREATE_PIPELINE",
68 2: "UPDATE_PIPELINE",
69 3: "DELETE_PIPELINE",
70 4: "LIST_PIPELINES",
71 5: "GET_PIPELINE",
72 6: "STOP_PIPELINE",
73 7: "RUN_PIPELINE",
74 8: "LIST_JOBS",
75 }
76 RequestLogEntry_RequestType_value = map[string]int32{
77 "REQUEST_TYPE_UNSPECIFIED": 0,
78 "CREATE_PIPELINE": 1,
79 "UPDATE_PIPELINE": 2,
80 "DELETE_PIPELINE": 3,
81 "LIST_PIPELINES": 4,
82 "GET_PIPELINE": 5,
83 "STOP_PIPELINE": 6,
84 "RUN_PIPELINE": 7,
85 "LIST_JOBS": 8,
86 }
87 )
88
89 func (x RequestLogEntry_RequestType) Enum() *RequestLogEntry_RequestType {
90 p := new(RequestLogEntry_RequestType)
91 *p = x
92 return p
93 }
94
95 func (x RequestLogEntry_RequestType) String() string {
96 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
97 }
98
99 func (RequestLogEntry_RequestType) Descriptor() protoreflect.EnumDescriptor {
100 return file_google_cloud_datapipelines_logging_v1_logging_proto_enumTypes[0].Descriptor()
101 }
102
103 func (RequestLogEntry_RequestType) Type() protoreflect.EnumType {
104 return &file_google_cloud_datapipelines_logging_v1_logging_proto_enumTypes[0]
105 }
106
107 func (x RequestLogEntry_RequestType) Number() protoreflect.EnumNumber {
108 return protoreflect.EnumNumber(x)
109 }
110
111
112 func (RequestLogEntry_RequestType) EnumDescriptor() ([]byte, []int) {
113 return file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescGZIP(), []int{0, 0}
114 }
115
116
117 type RequestLogEntry_ErrorCause int32
118
119 const (
120
121 RequestLogEntry_ERROR_CAUSE_UNSPECIFIED RequestLogEntry_ErrorCause = 0
122
123 RequestLogEntry_INVALID_REQUEST RequestLogEntry_ErrorCause = 1
124
125 RequestLogEntry_PROJECT_NUMBER_NOT_FOUND RequestLogEntry_ErrorCause = 2
126
127 RequestLogEntry_PIPELINE_ID_ALREADY_EXISTS RequestLogEntry_ErrorCause = 3
128
129 RequestLogEntry_PIPELINE_QUOTA_ALLOCATION_FAILED RequestLogEntry_ErrorCause = 4
130
131 RequestLogEntry_PIPELINE_NOT_FOUND RequestLogEntry_ErrorCause = 5
132
133 RequestLogEntry_INVALID_PIPELINE_WORKLOAD RequestLogEntry_ErrorCause = 6
134
135 RequestLogEntry_DATAFLOW_WORKER_SERVICE_ACCOUNT_PERMISSION_DENIED RequestLogEntry_ErrorCause = 7
136
137 RequestLogEntry_CLOUD_SCHEDULER_SERVICE_ACCOUNT_PERMISSION_DENIED RequestLogEntry_ErrorCause = 8
138
139 RequestLogEntry_INTERNAL_DATA_PIPELINES_SERVICE_ACCOUNT_ISSUE RequestLogEntry_ErrorCause = 9
140
141 RequestLogEntry_CLOUD_SCHEDULER_INVALID_ARGUMENT RequestLogEntry_ErrorCause = 10
142
143 RequestLogEntry_CLOUD_SCHEDULER_RESOURCE_EXHAUSTED RequestLogEntry_ErrorCause = 11
144
145 RequestLogEntry_CLOUD_SCHEDULER_JOB_NOT_FOUND RequestLogEntry_ErrorCause = 12
146
147 RequestLogEntry_OTHER_CLOUD_SCHEDULER_ISSUE RequestLogEntry_ErrorCause = 13
148
149 RequestLogEntry_DATAFLOW_JOB_ALREADY_EXISTS RequestLogEntry_ErrorCause = 14
150
151 RequestLogEntry_DATAFLOW_INVALID_ARGUMENT RequestLogEntry_ErrorCause = 15
152
153 RequestLogEntry_DATAFLOW_RESOURCE_EXHAUSTED RequestLogEntry_ErrorCause = 16
154
155 RequestLogEntry_DATAFLOW_JOB_NOT_FOUND RequestLogEntry_ErrorCause = 17
156
157 RequestLogEntry_OTHER_DATAFLOW_ISSUE RequestLogEntry_ErrorCause = 18
158
159 RequestLogEntry_DATABASE_ERROR RequestLogEntry_ErrorCause = 19
160
161
162 RequestLogEntry_WRONG_PIPELINE_TYPE RequestLogEntry_ErrorCause = 20
163
164 RequestLogEntry_INTERNAL_ERROR RequestLogEntry_ErrorCause = 21
165
166 RequestLogEntry_PIPELINE_OR_PROJECT_NOT_FOUND RequestLogEntry_ErrorCause = 22
167 )
168
169
170 var (
171 RequestLogEntry_ErrorCause_name = map[int32]string{
172 0: "ERROR_CAUSE_UNSPECIFIED",
173 1: "INVALID_REQUEST",
174 2: "PROJECT_NUMBER_NOT_FOUND",
175 3: "PIPELINE_ID_ALREADY_EXISTS",
176 4: "PIPELINE_QUOTA_ALLOCATION_FAILED",
177 5: "PIPELINE_NOT_FOUND",
178 6: "INVALID_PIPELINE_WORKLOAD",
179 7: "DATAFLOW_WORKER_SERVICE_ACCOUNT_PERMISSION_DENIED",
180 8: "CLOUD_SCHEDULER_SERVICE_ACCOUNT_PERMISSION_DENIED",
181 9: "INTERNAL_DATA_PIPELINES_SERVICE_ACCOUNT_ISSUE",
182 10: "CLOUD_SCHEDULER_INVALID_ARGUMENT",
183 11: "CLOUD_SCHEDULER_RESOURCE_EXHAUSTED",
184 12: "CLOUD_SCHEDULER_JOB_NOT_FOUND",
185 13: "OTHER_CLOUD_SCHEDULER_ISSUE",
186 14: "DATAFLOW_JOB_ALREADY_EXISTS",
187 15: "DATAFLOW_INVALID_ARGUMENT",
188 16: "DATAFLOW_RESOURCE_EXHAUSTED",
189 17: "DATAFLOW_JOB_NOT_FOUND",
190 18: "OTHER_DATAFLOW_ISSUE",
191 19: "DATABASE_ERROR",
192 20: "WRONG_PIPELINE_TYPE",
193 21: "INTERNAL_ERROR",
194 22: "PIPELINE_OR_PROJECT_NOT_FOUND",
195 }
196 RequestLogEntry_ErrorCause_value = map[string]int32{
197 "ERROR_CAUSE_UNSPECIFIED": 0,
198 "INVALID_REQUEST": 1,
199 "PROJECT_NUMBER_NOT_FOUND": 2,
200 "PIPELINE_ID_ALREADY_EXISTS": 3,
201 "PIPELINE_QUOTA_ALLOCATION_FAILED": 4,
202 "PIPELINE_NOT_FOUND": 5,
203 "INVALID_PIPELINE_WORKLOAD": 6,
204 "DATAFLOW_WORKER_SERVICE_ACCOUNT_PERMISSION_DENIED": 7,
205 "CLOUD_SCHEDULER_SERVICE_ACCOUNT_PERMISSION_DENIED": 8,
206 "INTERNAL_DATA_PIPELINES_SERVICE_ACCOUNT_ISSUE": 9,
207 "CLOUD_SCHEDULER_INVALID_ARGUMENT": 10,
208 "CLOUD_SCHEDULER_RESOURCE_EXHAUSTED": 11,
209 "CLOUD_SCHEDULER_JOB_NOT_FOUND": 12,
210 "OTHER_CLOUD_SCHEDULER_ISSUE": 13,
211 "DATAFLOW_JOB_ALREADY_EXISTS": 14,
212 "DATAFLOW_INVALID_ARGUMENT": 15,
213 "DATAFLOW_RESOURCE_EXHAUSTED": 16,
214 "DATAFLOW_JOB_NOT_FOUND": 17,
215 "OTHER_DATAFLOW_ISSUE": 18,
216 "DATABASE_ERROR": 19,
217 "WRONG_PIPELINE_TYPE": 20,
218 "INTERNAL_ERROR": 21,
219 "PIPELINE_OR_PROJECT_NOT_FOUND": 22,
220 }
221 )
222
223 func (x RequestLogEntry_ErrorCause) Enum() *RequestLogEntry_ErrorCause {
224 p := new(RequestLogEntry_ErrorCause)
225 *p = x
226 return p
227 }
228
229 func (x RequestLogEntry_ErrorCause) String() string {
230 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
231 }
232
233 func (RequestLogEntry_ErrorCause) Descriptor() protoreflect.EnumDescriptor {
234 return file_google_cloud_datapipelines_logging_v1_logging_proto_enumTypes[1].Descriptor()
235 }
236
237 func (RequestLogEntry_ErrorCause) Type() protoreflect.EnumType {
238 return &file_google_cloud_datapipelines_logging_v1_logging_proto_enumTypes[1]
239 }
240
241 func (x RequestLogEntry_ErrorCause) Number() protoreflect.EnumNumber {
242 return protoreflect.EnumNumber(x)
243 }
244
245
246 func (RequestLogEntry_ErrorCause) EnumDescriptor() ([]byte, []int) {
247 return file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescGZIP(), []int{0, 1}
248 }
249
250
251
252 type RequestLogEntry struct {
253 state protoimpl.MessageState
254 sizeCache protoimpl.SizeCache
255 unknownFields protoimpl.UnknownFields
256
257
258 RequestType RequestLogEntry_RequestType `protobuf:"varint,1,opt,name=request_type,json=requestType,proto3,enum=google.cloud.datapipelines.logging.v1.RequestLogEntry_RequestType" json:"request_type,omitempty"`
259
260 Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
261
262 ErrorCause RequestLogEntry_ErrorCause `protobuf:"varint,3,opt,name=error_cause,json=errorCause,proto3,enum=google.cloud.datapipelines.logging.v1.RequestLogEntry_ErrorCause" json:"error_cause,omitempty"`
263 }
264
265 func (x *RequestLogEntry) Reset() {
266 *x = RequestLogEntry{}
267 if protoimpl.UnsafeEnabled {
268 mi := &file_google_cloud_datapipelines_logging_v1_logging_proto_msgTypes[0]
269 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
270 ms.StoreMessageInfo(mi)
271 }
272 }
273
274 func (x *RequestLogEntry) String() string {
275 return protoimpl.X.MessageStringOf(x)
276 }
277
278 func (*RequestLogEntry) ProtoMessage() {}
279
280 func (x *RequestLogEntry) ProtoReflect() protoreflect.Message {
281 mi := &file_google_cloud_datapipelines_logging_v1_logging_proto_msgTypes[0]
282 if protoimpl.UnsafeEnabled && x != nil {
283 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
284 if ms.LoadMessageInfo() == nil {
285 ms.StoreMessageInfo(mi)
286 }
287 return ms
288 }
289 return mi.MessageOf(x)
290 }
291
292
293 func (*RequestLogEntry) Descriptor() ([]byte, []int) {
294 return file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescGZIP(), []int{0}
295 }
296
297 func (x *RequestLogEntry) GetRequestType() RequestLogEntry_RequestType {
298 if x != nil {
299 return x.RequestType
300 }
301 return RequestLogEntry_REQUEST_TYPE_UNSPECIFIED
302 }
303
304 func (x *RequestLogEntry) GetStatus() *status.Status {
305 if x != nil {
306 return x.Status
307 }
308 return nil
309 }
310
311 func (x *RequestLogEntry) GetErrorCause() RequestLogEntry_ErrorCause {
312 if x != nil {
313 return x.ErrorCause
314 }
315 return RequestLogEntry_ERROR_CAUSE_UNSPECIFIED
316 }
317
318 var File_google_cloud_datapipelines_logging_v1_logging_proto protoreflect.FileDescriptor
319
320 var file_google_cloud_datapipelines_logging_v1_logging_proto_rawDesc = []byte{
321 0x0a, 0x33, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x64,
322 0x61, 0x74, 0x61, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, 0x6c, 0x6f, 0x67,
323 0x67, 0x69, 0x6e, 0x67, 0x2f, 0x76, 0x31, 0x2f, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e,
324 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
325 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65,
326 0x73, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x76, 0x31, 0x1a, 0x17, 0x67, 0x6f,
327 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x72, 0x70, 0x63, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e,
328 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xd9, 0x09, 0x0a, 0x0f, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
329 0x74, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x65, 0x0a, 0x0c, 0x72, 0x65, 0x71,
330 0x75, 0x65, 0x73, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32,
331 0x42, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64,
332 0x61, 0x74, 0x61, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2e, 0x6c, 0x6f, 0x67,
333 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x4c,
334 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x54,
335 0x79, 0x70, 0x65, 0x52, 0x0b, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x54, 0x79, 0x70, 0x65,
336 0x12, 0x2a, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
337 0x32, 0x12, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x74,
338 0x61, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x62, 0x0a, 0x0b,
339 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x63, 0x61, 0x75, 0x73, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28,
340 0x0e, 0x32, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
341 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2e, 0x6c,
342 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
343 0x74, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x43,
344 0x61, 0x75, 0x73, 0x65, 0x52, 0x0a, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x43, 0x61, 0x75, 0x73, 0x65,
345 0x22, 0xc4, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x54, 0x79, 0x70, 0x65,
346 0x12, 0x1c, 0x0a, 0x18, 0x52, 0x45, 0x51, 0x55, 0x45, 0x53, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45,
347 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x13,
348 0x0a, 0x0f, 0x43, 0x52, 0x45, 0x41, 0x54, 0x45, 0x5f, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e,
349 0x45, 0x10, 0x01, 0x12, 0x13, 0x0a, 0x0f, 0x55, 0x50, 0x44, 0x41, 0x54, 0x45, 0x5f, 0x50, 0x49,
350 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x10, 0x02, 0x12, 0x13, 0x0a, 0x0f, 0x44, 0x45, 0x4c, 0x45,
351 0x54, 0x45, 0x5f, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x10, 0x03, 0x12, 0x12, 0x0a,
352 0x0e, 0x4c, 0x49, 0x53, 0x54, 0x5f, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x53, 0x10,
353 0x04, 0x12, 0x10, 0x0a, 0x0c, 0x47, 0x45, 0x54, 0x5f, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e,
354 0x45, 0x10, 0x05, 0x12, 0x11, 0x0a, 0x0d, 0x53, 0x54, 0x4f, 0x50, 0x5f, 0x50, 0x49, 0x50, 0x45,
355 0x4c, 0x49, 0x4e, 0x45, 0x10, 0x06, 0x12, 0x10, 0x0a, 0x0c, 0x52, 0x55, 0x4e, 0x5f, 0x50, 0x49,
356 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x10, 0x07, 0x12, 0x0d, 0x0a, 0x09, 0x4c, 0x49, 0x53, 0x54,
357 0x5f, 0x4a, 0x4f, 0x42, 0x53, 0x10, 0x08, 0x22, 0x87, 0x06, 0x0a, 0x0a, 0x45, 0x72, 0x72, 0x6f,
358 0x72, 0x43, 0x61, 0x75, 0x73, 0x65, 0x12, 0x1b, 0x0a, 0x17, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x5f,
359 0x43, 0x41, 0x55, 0x53, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45,
360 0x44, 0x10, 0x00, 0x12, 0x13, 0x0a, 0x0f, 0x49, 0x4e, 0x56, 0x41, 0x4c, 0x49, 0x44, 0x5f, 0x52,
361 0x45, 0x51, 0x55, 0x45, 0x53, 0x54, 0x10, 0x01, 0x12, 0x1c, 0x0a, 0x18, 0x50, 0x52, 0x4f, 0x4a,
362 0x45, 0x43, 0x54, 0x5f, 0x4e, 0x55, 0x4d, 0x42, 0x45, 0x52, 0x5f, 0x4e, 0x4f, 0x54, 0x5f, 0x46,
363 0x4f, 0x55, 0x4e, 0x44, 0x10, 0x02, 0x12, 0x1e, 0x0a, 0x1a, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49,
364 0x4e, 0x45, 0x5f, 0x49, 0x44, 0x5f, 0x41, 0x4c, 0x52, 0x45, 0x41, 0x44, 0x59, 0x5f, 0x45, 0x58,
365 0x49, 0x53, 0x54, 0x53, 0x10, 0x03, 0x12, 0x24, 0x0a, 0x20, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49,
366 0x4e, 0x45, 0x5f, 0x51, 0x55, 0x4f, 0x54, 0x41, 0x5f, 0x41, 0x4c, 0x4c, 0x4f, 0x43, 0x41, 0x54,
367 0x49, 0x4f, 0x4e, 0x5f, 0x46, 0x41, 0x49, 0x4c, 0x45, 0x44, 0x10, 0x04, 0x12, 0x16, 0x0a, 0x12,
368 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x5f, 0x4e, 0x4f, 0x54, 0x5f, 0x46, 0x4f, 0x55,
369 0x4e, 0x44, 0x10, 0x05, 0x12, 0x1d, 0x0a, 0x19, 0x49, 0x4e, 0x56, 0x41, 0x4c, 0x49, 0x44, 0x5f,
370 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x5f, 0x57, 0x4f, 0x52, 0x4b, 0x4c, 0x4f, 0x41,
371 0x44, 0x10, 0x06, 0x12, 0x35, 0x0a, 0x31, 0x44, 0x41, 0x54, 0x41, 0x46, 0x4c, 0x4f, 0x57, 0x5f,
372 0x57, 0x4f, 0x52, 0x4b, 0x45, 0x52, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x49, 0x43, 0x45, 0x5f, 0x41,
373 0x43, 0x43, 0x4f, 0x55, 0x4e, 0x54, 0x5f, 0x50, 0x45, 0x52, 0x4d, 0x49, 0x53, 0x53, 0x49, 0x4f,
374 0x4e, 0x5f, 0x44, 0x45, 0x4e, 0x49, 0x45, 0x44, 0x10, 0x07, 0x12, 0x35, 0x0a, 0x31, 0x43, 0x4c,
375 0x4f, 0x55, 0x44, 0x5f, 0x53, 0x43, 0x48, 0x45, 0x44, 0x55, 0x4c, 0x45, 0x52, 0x5f, 0x53, 0x45,
376 0x52, 0x56, 0x49, 0x43, 0x45, 0x5f, 0x41, 0x43, 0x43, 0x4f, 0x55, 0x4e, 0x54, 0x5f, 0x50, 0x45,
377 0x52, 0x4d, 0x49, 0x53, 0x53, 0x49, 0x4f, 0x4e, 0x5f, 0x44, 0x45, 0x4e, 0x49, 0x45, 0x44, 0x10,
378 0x08, 0x12, 0x31, 0x0a, 0x2d, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x4e, 0x41, 0x4c, 0x5f, 0x44, 0x41,
379 0x54, 0x41, 0x5f, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x53, 0x5f, 0x53, 0x45, 0x52,
380 0x56, 0x49, 0x43, 0x45, 0x5f, 0x41, 0x43, 0x43, 0x4f, 0x55, 0x4e, 0x54, 0x5f, 0x49, 0x53, 0x53,
381 0x55, 0x45, 0x10, 0x09, 0x12, 0x24, 0x0a, 0x20, 0x43, 0x4c, 0x4f, 0x55, 0x44, 0x5f, 0x53, 0x43,
382 0x48, 0x45, 0x44, 0x55, 0x4c, 0x45, 0x52, 0x5f, 0x49, 0x4e, 0x56, 0x41, 0x4c, 0x49, 0x44, 0x5f,
383 0x41, 0x52, 0x47, 0x55, 0x4d, 0x45, 0x4e, 0x54, 0x10, 0x0a, 0x12, 0x26, 0x0a, 0x22, 0x43, 0x4c,
384 0x4f, 0x55, 0x44, 0x5f, 0x53, 0x43, 0x48, 0x45, 0x44, 0x55, 0x4c, 0x45, 0x52, 0x5f, 0x52, 0x45,
385 0x53, 0x4f, 0x55, 0x52, 0x43, 0x45, 0x5f, 0x45, 0x58, 0x48, 0x41, 0x55, 0x53, 0x54, 0x45, 0x44,
386 0x10, 0x0b, 0x12, 0x21, 0x0a, 0x1d, 0x43, 0x4c, 0x4f, 0x55, 0x44, 0x5f, 0x53, 0x43, 0x48, 0x45,
387 0x44, 0x55, 0x4c, 0x45, 0x52, 0x5f, 0x4a, 0x4f, 0x42, 0x5f, 0x4e, 0x4f, 0x54, 0x5f, 0x46, 0x4f,
388 0x55, 0x4e, 0x44, 0x10, 0x0c, 0x12, 0x1f, 0x0a, 0x1b, 0x4f, 0x54, 0x48, 0x45, 0x52, 0x5f, 0x43,
389 0x4c, 0x4f, 0x55, 0x44, 0x5f, 0x53, 0x43, 0x48, 0x45, 0x44, 0x55, 0x4c, 0x45, 0x52, 0x5f, 0x49,
390 0x53, 0x53, 0x55, 0x45, 0x10, 0x0d, 0x12, 0x1f, 0x0a, 0x1b, 0x44, 0x41, 0x54, 0x41, 0x46, 0x4c,
391 0x4f, 0x57, 0x5f, 0x4a, 0x4f, 0x42, 0x5f, 0x41, 0x4c, 0x52, 0x45, 0x41, 0x44, 0x59, 0x5f, 0x45,
392 0x58, 0x49, 0x53, 0x54, 0x53, 0x10, 0x0e, 0x12, 0x1d, 0x0a, 0x19, 0x44, 0x41, 0x54, 0x41, 0x46,
393 0x4c, 0x4f, 0x57, 0x5f, 0x49, 0x4e, 0x56, 0x41, 0x4c, 0x49, 0x44, 0x5f, 0x41, 0x52, 0x47, 0x55,
394 0x4d, 0x45, 0x4e, 0x54, 0x10, 0x0f, 0x12, 0x1f, 0x0a, 0x1b, 0x44, 0x41, 0x54, 0x41, 0x46, 0x4c,
395 0x4f, 0x57, 0x5f, 0x52, 0x45, 0x53, 0x4f, 0x55, 0x52, 0x43, 0x45, 0x5f, 0x45, 0x58, 0x48, 0x41,
396 0x55, 0x53, 0x54, 0x45, 0x44, 0x10, 0x10, 0x12, 0x1a, 0x0a, 0x16, 0x44, 0x41, 0x54, 0x41, 0x46,
397 0x4c, 0x4f, 0x57, 0x5f, 0x4a, 0x4f, 0x42, 0x5f, 0x4e, 0x4f, 0x54, 0x5f, 0x46, 0x4f, 0x55, 0x4e,
398 0x44, 0x10, 0x11, 0x12, 0x18, 0x0a, 0x14, 0x4f, 0x54, 0x48, 0x45, 0x52, 0x5f, 0x44, 0x41, 0x54,
399 0x41, 0x46, 0x4c, 0x4f, 0x57, 0x5f, 0x49, 0x53, 0x53, 0x55, 0x45, 0x10, 0x12, 0x12, 0x12, 0x0a,
400 0x0e, 0x44, 0x41, 0x54, 0x41, 0x42, 0x41, 0x53, 0x45, 0x5f, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x10,
401 0x13, 0x12, 0x17, 0x0a, 0x13, 0x57, 0x52, 0x4f, 0x4e, 0x47, 0x5f, 0x50, 0x49, 0x50, 0x45, 0x4c,
402 0x49, 0x4e, 0x45, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x10, 0x14, 0x12, 0x12, 0x0a, 0x0e, 0x49, 0x4e,
403 0x54, 0x45, 0x52, 0x4e, 0x41, 0x4c, 0x5f, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x10, 0x15, 0x12, 0x21,
404 0x0a, 0x1d, 0x50, 0x49, 0x50, 0x45, 0x4c, 0x49, 0x4e, 0x45, 0x5f, 0x4f, 0x52, 0x5f, 0x50, 0x52,
405 0x4f, 0x4a, 0x45, 0x43, 0x54, 0x5f, 0x4e, 0x4f, 0x54, 0x5f, 0x46, 0x4f, 0x55, 0x4e, 0x44, 0x10,
406 0x16, 0x42, 0x89, 0x01, 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
407 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x69, 0x70, 0x65, 0x6c,
408 0x69, 0x6e, 0x65, 0x73, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x76, 0x31, 0x42,
409 0x0c, 0x4c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a,
410 0x4c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f,
411 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67,
412 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x64, 0x61, 0x74,
413 0x61, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, 0x6c, 0x6f, 0x67, 0x67, 0x69,
414 0x6e, 0x67, 0x2f, 0x76, 0x31, 0x3b, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x62, 0x06, 0x70,
415 0x72, 0x6f, 0x74, 0x6f, 0x33,
416 }
417
418 var (
419 file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescOnce sync.Once
420 file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescData = file_google_cloud_datapipelines_logging_v1_logging_proto_rawDesc
421 )
422
423 func file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescGZIP() []byte {
424 file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescOnce.Do(func() {
425 file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescData)
426 })
427 return file_google_cloud_datapipelines_logging_v1_logging_proto_rawDescData
428 }
429
430 var file_google_cloud_datapipelines_logging_v1_logging_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
431 var file_google_cloud_datapipelines_logging_v1_logging_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
432 var file_google_cloud_datapipelines_logging_v1_logging_proto_goTypes = []interface{}{
433 (RequestLogEntry_RequestType)(0),
434 (RequestLogEntry_ErrorCause)(0),
435 (*RequestLogEntry)(nil),
436 (*status.Status)(nil),
437 }
438 var file_google_cloud_datapipelines_logging_v1_logging_proto_depIdxs = []int32{
439 0,
440 3,
441 1,
442 3,
443 3,
444 3,
445 3,
446 0,
447 }
448
449 func init() { file_google_cloud_datapipelines_logging_v1_logging_proto_init() }
450 func file_google_cloud_datapipelines_logging_v1_logging_proto_init() {
451 if File_google_cloud_datapipelines_logging_v1_logging_proto != nil {
452 return
453 }
454 if !protoimpl.UnsafeEnabled {
455 file_google_cloud_datapipelines_logging_v1_logging_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
456 switch v := v.(*RequestLogEntry); i {
457 case 0:
458 return &v.state
459 case 1:
460 return &v.sizeCache
461 case 2:
462 return &v.unknownFields
463 default:
464 return nil
465 }
466 }
467 }
468 type x struct{}
469 out := protoimpl.TypeBuilder{
470 File: protoimpl.DescBuilder{
471 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
472 RawDescriptor: file_google_cloud_datapipelines_logging_v1_logging_proto_rawDesc,
473 NumEnums: 2,
474 NumMessages: 1,
475 NumExtensions: 0,
476 NumServices: 0,
477 },
478 GoTypes: file_google_cloud_datapipelines_logging_v1_logging_proto_goTypes,
479 DependencyIndexes: file_google_cloud_datapipelines_logging_v1_logging_proto_depIdxs,
480 EnumInfos: file_google_cloud_datapipelines_logging_v1_logging_proto_enumTypes,
481 MessageInfos: file_google_cloud_datapipelines_logging_v1_logging_proto_msgTypes,
482 }.Build()
483 File_google_cloud_datapipelines_logging_v1_logging_proto = out.File
484 file_google_cloud_datapipelines_logging_v1_logging_proto_rawDesc = nil
485 file_google_cloud_datapipelines_logging_v1_logging_proto_goTypes = nil
486 file_google_cloud_datapipelines_logging_v1_logging_proto_depIdxs = nil
487 }
488
View as plain text