1// Copyright 2021 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/cloud/aiplatform/v1beta1/pipeline_service.proto 20 21package aiplatform 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 _ "google.golang.org/genproto/googleapis/api/annotations" 29 longrunning "google.golang.org/genproto/googleapis/longrunning" 30 grpc "google.golang.org/grpc" 31 codes "google.golang.org/grpc/codes" 32 status "google.golang.org/grpc/status" 33 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 34 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 35 emptypb "google.golang.org/protobuf/types/known/emptypb" 36 fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb" 37) 38 39const ( 40 // Verify that this generated code is sufficiently up-to-date. 41 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 42 // Verify that runtime/protoimpl is sufficiently up-to-date. 43 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 44) 45 46// Request message for [PipelineService.CreateTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.CreateTrainingPipeline]. 47type CreateTrainingPipelineRequest struct { 48 state protoimpl.MessageState 49 sizeCache protoimpl.SizeCache 50 unknownFields protoimpl.UnknownFields 51 52 // Required. The resource name of the Location to create the TrainingPipeline in. 53 // Format: `projects/{project}/locations/{location}` 54 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 55 // Required. The TrainingPipeline to create. 56 TrainingPipeline *TrainingPipeline `protobuf:"bytes,2,opt,name=training_pipeline,json=trainingPipeline,proto3" json:"training_pipeline,omitempty"` 57} 58 59func (x *CreateTrainingPipelineRequest) Reset() { 60 *x = CreateTrainingPipelineRequest{} 61 if protoimpl.UnsafeEnabled { 62 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[0] 63 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 64 ms.StoreMessageInfo(mi) 65 } 66} 67 68func (x *CreateTrainingPipelineRequest) String() string { 69 return protoimpl.X.MessageStringOf(x) 70} 71 72func (*CreateTrainingPipelineRequest) ProtoMessage() {} 73 74func (x *CreateTrainingPipelineRequest) ProtoReflect() protoreflect.Message { 75 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[0] 76 if protoimpl.UnsafeEnabled && x != nil { 77 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 78 if ms.LoadMessageInfo() == nil { 79 ms.StoreMessageInfo(mi) 80 } 81 return ms 82 } 83 return mi.MessageOf(x) 84} 85 86// Deprecated: Use CreateTrainingPipelineRequest.ProtoReflect.Descriptor instead. 87func (*CreateTrainingPipelineRequest) Descriptor() ([]byte, []int) { 88 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{0} 89} 90 91func (x *CreateTrainingPipelineRequest) GetParent() string { 92 if x != nil { 93 return x.Parent 94 } 95 return "" 96} 97 98func (x *CreateTrainingPipelineRequest) GetTrainingPipeline() *TrainingPipeline { 99 if x != nil { 100 return x.TrainingPipeline 101 } 102 return nil 103} 104 105// Request message for [PipelineService.GetTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.GetTrainingPipeline]. 106type GetTrainingPipelineRequest struct { 107 state protoimpl.MessageState 108 sizeCache protoimpl.SizeCache 109 unknownFields protoimpl.UnknownFields 110 111 // Required. The name of the TrainingPipeline resource. 112 // Format: 113 // `projects/{project}/locations/{location}/trainingPipelines/{training_pipeline}` 114 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 115} 116 117func (x *GetTrainingPipelineRequest) Reset() { 118 *x = GetTrainingPipelineRequest{} 119 if protoimpl.UnsafeEnabled { 120 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[1] 121 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 122 ms.StoreMessageInfo(mi) 123 } 124} 125 126func (x *GetTrainingPipelineRequest) String() string { 127 return protoimpl.X.MessageStringOf(x) 128} 129 130func (*GetTrainingPipelineRequest) ProtoMessage() {} 131 132func (x *GetTrainingPipelineRequest) ProtoReflect() protoreflect.Message { 133 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[1] 134 if protoimpl.UnsafeEnabled && x != nil { 135 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 136 if ms.LoadMessageInfo() == nil { 137 ms.StoreMessageInfo(mi) 138 } 139 return ms 140 } 141 return mi.MessageOf(x) 142} 143 144// Deprecated: Use GetTrainingPipelineRequest.ProtoReflect.Descriptor instead. 145func (*GetTrainingPipelineRequest) Descriptor() ([]byte, []int) { 146 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{1} 147} 148 149func (x *GetTrainingPipelineRequest) GetName() string { 150 if x != nil { 151 return x.Name 152 } 153 return "" 154} 155 156// Request message for [PipelineService.ListTrainingPipelines][google.cloud.aiplatform.v1beta1.PipelineService.ListTrainingPipelines]. 157type ListTrainingPipelinesRequest struct { 158 state protoimpl.MessageState 159 sizeCache protoimpl.SizeCache 160 unknownFields protoimpl.UnknownFields 161 162 // Required. The resource name of the Location to list the TrainingPipelines from. 163 // Format: `projects/{project}/locations/{location}` 164 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 165 // Lists the PipelineJobs that match the filter expression. The following 166 // fields are supported: 167 // 168 // * `pipeline_name`: Supports `=` and `!=` comparisons. 169 // * `create_time`: Supports `=`, `!=`, `<`, `>`, `<=`, and `>=` comparisons. 170 // Values must be in RFC 3339 format. 171 // * `update_time`: Supports `=`, `!=`, `<`, `>`, `<=`, and `>=` comparisons. 172 // Values must be in RFC 3339 format. 173 // * `end_time`: Supports `=`, `!=`, `<`, `>`, `<=`, and `>=` comparisons. 174 // Values must be in RFC 3339 format. 175 // * `labels`: Supports key-value equality and key presence. 176 // 177 // Filter expressions can be combined together using logical operators 178 // (`AND` & `OR`). 179 // For example: `pipeline_name="test" AND create_time>"2020-05-18T13:30:00Z"`. 180 // 181 // The syntax to define filter expression is based on 182 // https://google.aip.dev/160. 183 // 184 // Examples: 185 // 186 // * `create_time>"2021-05-18T00:00:00Z" OR 187 // update_time>"2020-05-18T00:00:00Z"` PipelineJobs created or updated 188 // after 2020-05-18 00:00:00 UTC. 189 // * `labels.env = "prod"` 190 // PipelineJobs with label "env" set to "prod". 191 Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` 192 // The standard list page size. 193 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 194 // The standard list page token. 195 // Typically obtained via 196 // [ListTrainingPipelinesResponse.next_page_token][google.cloud.aiplatform.v1beta1.ListTrainingPipelinesResponse.next_page_token] of the previous 197 // [PipelineService.ListTrainingPipelines][google.cloud.aiplatform.v1beta1.PipelineService.ListTrainingPipelines] call. 198 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 199 // Mask specifying which fields to read. 200 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,5,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 201} 202 203func (x *ListTrainingPipelinesRequest) Reset() { 204 *x = ListTrainingPipelinesRequest{} 205 if protoimpl.UnsafeEnabled { 206 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[2] 207 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 208 ms.StoreMessageInfo(mi) 209 } 210} 211 212func (x *ListTrainingPipelinesRequest) String() string { 213 return protoimpl.X.MessageStringOf(x) 214} 215 216func (*ListTrainingPipelinesRequest) ProtoMessage() {} 217 218func (x *ListTrainingPipelinesRequest) ProtoReflect() protoreflect.Message { 219 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[2] 220 if protoimpl.UnsafeEnabled && x != nil { 221 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 222 if ms.LoadMessageInfo() == nil { 223 ms.StoreMessageInfo(mi) 224 } 225 return ms 226 } 227 return mi.MessageOf(x) 228} 229 230// Deprecated: Use ListTrainingPipelinesRequest.ProtoReflect.Descriptor instead. 231func (*ListTrainingPipelinesRequest) Descriptor() ([]byte, []int) { 232 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{2} 233} 234 235func (x *ListTrainingPipelinesRequest) GetParent() string { 236 if x != nil { 237 return x.Parent 238 } 239 return "" 240} 241 242func (x *ListTrainingPipelinesRequest) GetFilter() string { 243 if x != nil { 244 return x.Filter 245 } 246 return "" 247} 248 249func (x *ListTrainingPipelinesRequest) GetPageSize() int32 { 250 if x != nil { 251 return x.PageSize 252 } 253 return 0 254} 255 256func (x *ListTrainingPipelinesRequest) GetPageToken() string { 257 if x != nil { 258 return x.PageToken 259 } 260 return "" 261} 262 263func (x *ListTrainingPipelinesRequest) GetReadMask() *fieldmaskpb.FieldMask { 264 if x != nil { 265 return x.ReadMask 266 } 267 return nil 268} 269 270// Response message for [PipelineService.ListTrainingPipelines][google.cloud.aiplatform.v1beta1.PipelineService.ListTrainingPipelines] 271type ListTrainingPipelinesResponse struct { 272 state protoimpl.MessageState 273 sizeCache protoimpl.SizeCache 274 unknownFields protoimpl.UnknownFields 275 276 // List of TrainingPipelines in the requested page. 277 TrainingPipelines []*TrainingPipeline `protobuf:"bytes,1,rep,name=training_pipelines,json=trainingPipelines,proto3" json:"training_pipelines,omitempty"` 278 // A token to retrieve the next page of results. 279 // Pass to [ListTrainingPipelinesRequest.page_token][google.cloud.aiplatform.v1beta1.ListTrainingPipelinesRequest.page_token] to obtain that page. 280 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 281} 282 283func (x *ListTrainingPipelinesResponse) Reset() { 284 *x = ListTrainingPipelinesResponse{} 285 if protoimpl.UnsafeEnabled { 286 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[3] 287 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 288 ms.StoreMessageInfo(mi) 289 } 290} 291 292func (x *ListTrainingPipelinesResponse) String() string { 293 return protoimpl.X.MessageStringOf(x) 294} 295 296func (*ListTrainingPipelinesResponse) ProtoMessage() {} 297 298func (x *ListTrainingPipelinesResponse) ProtoReflect() protoreflect.Message { 299 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[3] 300 if protoimpl.UnsafeEnabled && x != nil { 301 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 302 if ms.LoadMessageInfo() == nil { 303 ms.StoreMessageInfo(mi) 304 } 305 return ms 306 } 307 return mi.MessageOf(x) 308} 309 310// Deprecated: Use ListTrainingPipelinesResponse.ProtoReflect.Descriptor instead. 311func (*ListTrainingPipelinesResponse) Descriptor() ([]byte, []int) { 312 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{3} 313} 314 315func (x *ListTrainingPipelinesResponse) GetTrainingPipelines() []*TrainingPipeline { 316 if x != nil { 317 return x.TrainingPipelines 318 } 319 return nil 320} 321 322func (x *ListTrainingPipelinesResponse) GetNextPageToken() string { 323 if x != nil { 324 return x.NextPageToken 325 } 326 return "" 327} 328 329// Request message for [PipelineService.DeleteTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.DeleteTrainingPipeline]. 330type DeleteTrainingPipelineRequest struct { 331 state protoimpl.MessageState 332 sizeCache protoimpl.SizeCache 333 unknownFields protoimpl.UnknownFields 334 335 // Required. The name of the TrainingPipeline resource to be deleted. 336 // Format: 337 // `projects/{project}/locations/{location}/trainingPipelines/{training_pipeline}` 338 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 339} 340 341func (x *DeleteTrainingPipelineRequest) Reset() { 342 *x = DeleteTrainingPipelineRequest{} 343 if protoimpl.UnsafeEnabled { 344 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[4] 345 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 346 ms.StoreMessageInfo(mi) 347 } 348} 349 350func (x *DeleteTrainingPipelineRequest) String() string { 351 return protoimpl.X.MessageStringOf(x) 352} 353 354func (*DeleteTrainingPipelineRequest) ProtoMessage() {} 355 356func (x *DeleteTrainingPipelineRequest) ProtoReflect() protoreflect.Message { 357 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[4] 358 if protoimpl.UnsafeEnabled && x != nil { 359 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 360 if ms.LoadMessageInfo() == nil { 361 ms.StoreMessageInfo(mi) 362 } 363 return ms 364 } 365 return mi.MessageOf(x) 366} 367 368// Deprecated: Use DeleteTrainingPipelineRequest.ProtoReflect.Descriptor instead. 369func (*DeleteTrainingPipelineRequest) Descriptor() ([]byte, []int) { 370 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{4} 371} 372 373func (x *DeleteTrainingPipelineRequest) GetName() string { 374 if x != nil { 375 return x.Name 376 } 377 return "" 378} 379 380// Request message for [PipelineService.CancelTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.CancelTrainingPipeline]. 381type CancelTrainingPipelineRequest struct { 382 state protoimpl.MessageState 383 sizeCache protoimpl.SizeCache 384 unknownFields protoimpl.UnknownFields 385 386 // Required. The name of the TrainingPipeline to cancel. 387 // Format: 388 // `projects/{project}/locations/{location}/trainingPipelines/{training_pipeline}` 389 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 390} 391 392func (x *CancelTrainingPipelineRequest) Reset() { 393 *x = CancelTrainingPipelineRequest{} 394 if protoimpl.UnsafeEnabled { 395 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[5] 396 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 397 ms.StoreMessageInfo(mi) 398 } 399} 400 401func (x *CancelTrainingPipelineRequest) String() string { 402 return protoimpl.X.MessageStringOf(x) 403} 404 405func (*CancelTrainingPipelineRequest) ProtoMessage() {} 406 407func (x *CancelTrainingPipelineRequest) ProtoReflect() protoreflect.Message { 408 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[5] 409 if protoimpl.UnsafeEnabled && x != nil { 410 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 411 if ms.LoadMessageInfo() == nil { 412 ms.StoreMessageInfo(mi) 413 } 414 return ms 415 } 416 return mi.MessageOf(x) 417} 418 419// Deprecated: Use CancelTrainingPipelineRequest.ProtoReflect.Descriptor instead. 420func (*CancelTrainingPipelineRequest) Descriptor() ([]byte, []int) { 421 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{5} 422} 423 424func (x *CancelTrainingPipelineRequest) GetName() string { 425 if x != nil { 426 return x.Name 427 } 428 return "" 429} 430 431// Request message for [PipelineService.CreatePipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.CreatePipelineJob]. 432type CreatePipelineJobRequest struct { 433 state protoimpl.MessageState 434 sizeCache protoimpl.SizeCache 435 unknownFields protoimpl.UnknownFields 436 437 // Required. The resource name of the Location to create the PipelineJob in. 438 // Format: `projects/{project}/locations/{location}` 439 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 440 // Required. The PipelineJob to create. 441 PipelineJob *PipelineJob `protobuf:"bytes,2,opt,name=pipeline_job,json=pipelineJob,proto3" json:"pipeline_job,omitempty"` 442 // The ID to use for the PipelineJob, which will become the final component of 443 // the PipelineJob name. If not provided, an ID will be automatically 444 // generated. 445 // 446 // This value should be less than 128 characters, and valid characters 447 // are /[a-z][0-9]-/. 448 PipelineJobId string `protobuf:"bytes,3,opt,name=pipeline_job_id,json=pipelineJobId,proto3" json:"pipeline_job_id,omitempty"` 449} 450 451func (x *CreatePipelineJobRequest) Reset() { 452 *x = CreatePipelineJobRequest{} 453 if protoimpl.UnsafeEnabled { 454 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[6] 455 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 456 ms.StoreMessageInfo(mi) 457 } 458} 459 460func (x *CreatePipelineJobRequest) String() string { 461 return protoimpl.X.MessageStringOf(x) 462} 463 464func (*CreatePipelineJobRequest) ProtoMessage() {} 465 466func (x *CreatePipelineJobRequest) ProtoReflect() protoreflect.Message { 467 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[6] 468 if protoimpl.UnsafeEnabled && x != nil { 469 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 470 if ms.LoadMessageInfo() == nil { 471 ms.StoreMessageInfo(mi) 472 } 473 return ms 474 } 475 return mi.MessageOf(x) 476} 477 478// Deprecated: Use CreatePipelineJobRequest.ProtoReflect.Descriptor instead. 479func (*CreatePipelineJobRequest) Descriptor() ([]byte, []int) { 480 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{6} 481} 482 483func (x *CreatePipelineJobRequest) GetParent() string { 484 if x != nil { 485 return x.Parent 486 } 487 return "" 488} 489 490func (x *CreatePipelineJobRequest) GetPipelineJob() *PipelineJob { 491 if x != nil { 492 return x.PipelineJob 493 } 494 return nil 495} 496 497func (x *CreatePipelineJobRequest) GetPipelineJobId() string { 498 if x != nil { 499 return x.PipelineJobId 500 } 501 return "" 502} 503 504// Request message for [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.GetPipelineJob]. 505type GetPipelineJobRequest struct { 506 state protoimpl.MessageState 507 sizeCache protoimpl.SizeCache 508 unknownFields protoimpl.UnknownFields 509 510 // Required. The name of the PipelineJob resource. 511 // Format: 512 // `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}` 513 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 514} 515 516func (x *GetPipelineJobRequest) Reset() { 517 *x = GetPipelineJobRequest{} 518 if protoimpl.UnsafeEnabled { 519 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[7] 520 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 521 ms.StoreMessageInfo(mi) 522 } 523} 524 525func (x *GetPipelineJobRequest) String() string { 526 return protoimpl.X.MessageStringOf(x) 527} 528 529func (*GetPipelineJobRequest) ProtoMessage() {} 530 531func (x *GetPipelineJobRequest) ProtoReflect() protoreflect.Message { 532 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[7] 533 if protoimpl.UnsafeEnabled && x != nil { 534 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 535 if ms.LoadMessageInfo() == nil { 536 ms.StoreMessageInfo(mi) 537 } 538 return ms 539 } 540 return mi.MessageOf(x) 541} 542 543// Deprecated: Use GetPipelineJobRequest.ProtoReflect.Descriptor instead. 544func (*GetPipelineJobRequest) Descriptor() ([]byte, []int) { 545 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{7} 546} 547 548func (x *GetPipelineJobRequest) GetName() string { 549 if x != nil { 550 return x.Name 551 } 552 return "" 553} 554 555// Request message for [PipelineService.ListPipelineJobs][google.cloud.aiplatform.v1beta1.PipelineService.ListPipelineJobs]. 556type ListPipelineJobsRequest struct { 557 state protoimpl.MessageState 558 sizeCache protoimpl.SizeCache 559 unknownFields protoimpl.UnknownFields 560 561 // Required. The resource name of the Location to list the PipelineJobs from. 562 // Format: `projects/{project}/locations/{location}` 563 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 564 // The standard list filter. 565 // Supported fields: 566 // 567 // * `display_name` supports `=` and `!=`. 568 // * `state` supports `=` and `!=`. 569 // 570 // The following examples demonstrate how to filter the list of PipelineJobs: 571 // 572 // * `state="PIPELINE_STATE_SUCCEEDED" AND display_name="my_pipeline"` 573 // * `state="PIPELINE_STATE_RUNNING" OR display_name="my_pipeline"` 574 // * `NOT display_name="my_pipeline"` 575 // * `state="PIPELINE_STATE_FAILED"` 576 Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` 577 // The standard list page size. 578 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 579 // The standard list page token. 580 // Typically obtained via 581 // [ListPipelineJobsResponse.next_page_token][google.cloud.aiplatform.v1beta1.ListPipelineJobsResponse.next_page_token] of the previous 582 // [PipelineService.ListPipelineJobs][google.cloud.aiplatform.v1beta1.PipelineService.ListPipelineJobs] call. 583 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 584} 585 586func (x *ListPipelineJobsRequest) Reset() { 587 *x = ListPipelineJobsRequest{} 588 if protoimpl.UnsafeEnabled { 589 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[8] 590 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 591 ms.StoreMessageInfo(mi) 592 } 593} 594 595func (x *ListPipelineJobsRequest) String() string { 596 return protoimpl.X.MessageStringOf(x) 597} 598 599func (*ListPipelineJobsRequest) ProtoMessage() {} 600 601func (x *ListPipelineJobsRequest) ProtoReflect() protoreflect.Message { 602 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[8] 603 if protoimpl.UnsafeEnabled && x != nil { 604 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 605 if ms.LoadMessageInfo() == nil { 606 ms.StoreMessageInfo(mi) 607 } 608 return ms 609 } 610 return mi.MessageOf(x) 611} 612 613// Deprecated: Use ListPipelineJobsRequest.ProtoReflect.Descriptor instead. 614func (*ListPipelineJobsRequest) Descriptor() ([]byte, []int) { 615 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{8} 616} 617 618func (x *ListPipelineJobsRequest) GetParent() string { 619 if x != nil { 620 return x.Parent 621 } 622 return "" 623} 624 625func (x *ListPipelineJobsRequest) GetFilter() string { 626 if x != nil { 627 return x.Filter 628 } 629 return "" 630} 631 632func (x *ListPipelineJobsRequest) GetPageSize() int32 { 633 if x != nil { 634 return x.PageSize 635 } 636 return 0 637} 638 639func (x *ListPipelineJobsRequest) GetPageToken() string { 640 if x != nil { 641 return x.PageToken 642 } 643 return "" 644} 645 646// Response message for [PipelineService.ListPipelineJobs][google.cloud.aiplatform.v1beta1.PipelineService.ListPipelineJobs] 647type ListPipelineJobsResponse struct { 648 state protoimpl.MessageState 649 sizeCache protoimpl.SizeCache 650 unknownFields protoimpl.UnknownFields 651 652 // List of PipelineJobs in the requested page. 653 PipelineJobs []*PipelineJob `protobuf:"bytes,1,rep,name=pipeline_jobs,json=pipelineJobs,proto3" json:"pipeline_jobs,omitempty"` 654 // A token to retrieve the next page of results. 655 // Pass to [ListPipelineJobsRequest.page_token][google.cloud.aiplatform.v1beta1.ListPipelineJobsRequest.page_token] to obtain that page. 656 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 657} 658 659func (x *ListPipelineJobsResponse) Reset() { 660 *x = ListPipelineJobsResponse{} 661 if protoimpl.UnsafeEnabled { 662 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[9] 663 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 664 ms.StoreMessageInfo(mi) 665 } 666} 667 668func (x *ListPipelineJobsResponse) String() string { 669 return protoimpl.X.MessageStringOf(x) 670} 671 672func (*ListPipelineJobsResponse) ProtoMessage() {} 673 674func (x *ListPipelineJobsResponse) ProtoReflect() protoreflect.Message { 675 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[9] 676 if protoimpl.UnsafeEnabled && x != nil { 677 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 678 if ms.LoadMessageInfo() == nil { 679 ms.StoreMessageInfo(mi) 680 } 681 return ms 682 } 683 return mi.MessageOf(x) 684} 685 686// Deprecated: Use ListPipelineJobsResponse.ProtoReflect.Descriptor instead. 687func (*ListPipelineJobsResponse) Descriptor() ([]byte, []int) { 688 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{9} 689} 690 691func (x *ListPipelineJobsResponse) GetPipelineJobs() []*PipelineJob { 692 if x != nil { 693 return x.PipelineJobs 694 } 695 return nil 696} 697 698func (x *ListPipelineJobsResponse) GetNextPageToken() string { 699 if x != nil { 700 return x.NextPageToken 701 } 702 return "" 703} 704 705// Request message for [PipelineService.DeletePipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.DeletePipelineJob]. 706type DeletePipelineJobRequest struct { 707 state protoimpl.MessageState 708 sizeCache protoimpl.SizeCache 709 unknownFields protoimpl.UnknownFields 710 711 // Required. The name of the PipelineJob resource to be deleted. 712 // Format: 713 // `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}` 714 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 715} 716 717func (x *DeletePipelineJobRequest) Reset() { 718 *x = DeletePipelineJobRequest{} 719 if protoimpl.UnsafeEnabled { 720 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[10] 721 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 722 ms.StoreMessageInfo(mi) 723 } 724} 725 726func (x *DeletePipelineJobRequest) String() string { 727 return protoimpl.X.MessageStringOf(x) 728} 729 730func (*DeletePipelineJobRequest) ProtoMessage() {} 731 732func (x *DeletePipelineJobRequest) ProtoReflect() protoreflect.Message { 733 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[10] 734 if protoimpl.UnsafeEnabled && x != nil { 735 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 736 if ms.LoadMessageInfo() == nil { 737 ms.StoreMessageInfo(mi) 738 } 739 return ms 740 } 741 return mi.MessageOf(x) 742} 743 744// Deprecated: Use DeletePipelineJobRequest.ProtoReflect.Descriptor instead. 745func (*DeletePipelineJobRequest) Descriptor() ([]byte, []int) { 746 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{10} 747} 748 749func (x *DeletePipelineJobRequest) GetName() string { 750 if x != nil { 751 return x.Name 752 } 753 return "" 754} 755 756// Request message for [PipelineService.CancelPipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.CancelPipelineJob]. 757type CancelPipelineJobRequest struct { 758 state protoimpl.MessageState 759 sizeCache protoimpl.SizeCache 760 unknownFields protoimpl.UnknownFields 761 762 // Required. The name of the PipelineJob to cancel. 763 // Format: 764 // `projects/{project}/locations/{location}/pipelineJobs/{pipeline_job}` 765 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 766} 767 768func (x *CancelPipelineJobRequest) Reset() { 769 *x = CancelPipelineJobRequest{} 770 if protoimpl.UnsafeEnabled { 771 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[11] 772 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 773 ms.StoreMessageInfo(mi) 774 } 775} 776 777func (x *CancelPipelineJobRequest) String() string { 778 return protoimpl.X.MessageStringOf(x) 779} 780 781func (*CancelPipelineJobRequest) ProtoMessage() {} 782 783func (x *CancelPipelineJobRequest) ProtoReflect() protoreflect.Message { 784 mi := &file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[11] 785 if protoimpl.UnsafeEnabled && x != nil { 786 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 787 if ms.LoadMessageInfo() == nil { 788 ms.StoreMessageInfo(mi) 789 } 790 return ms 791 } 792 return mi.MessageOf(x) 793} 794 795// Deprecated: Use CancelPipelineJobRequest.ProtoReflect.Descriptor instead. 796func (*CancelPipelineJobRequest) Descriptor() ([]byte, []int) { 797 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP(), []int{11} 798} 799 800func (x *CancelPipelineJobRequest) GetName() string { 801 if x != nil { 802 return x.Name 803 } 804 return "" 805} 806 807var File_google_cloud_aiplatform_v1beta1_pipeline_service_proto protoreflect.FileDescriptor 808 809var file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDesc = []byte{ 810 0x0a, 0x36, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x61, 811 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 812 0x31, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 813 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 814 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 815 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 816 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 817 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 818 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 819 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 820 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 821 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 822 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x32, 0x67, 0x6f, 823 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x61, 0x69, 0x70, 0x6c, 0x61, 824 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x70, 0x69, 825 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 826 0x1a, 0x37, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x61, 827 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 828 0x31, 0x2f, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x69, 0x70, 0x65, 0x6c, 829 0x69, 0x6e, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x23, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 830 0x65, 0x2f, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2f, 0x6f, 0x70, 831 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 832 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 833 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x67, 0x6f, 0x6f, 834 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x66, 0x69, 0x65, 835 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xc7, 0x01, 836 0x0a, 0x1d, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 837 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 838 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 839 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 840 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 841 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 842 0x6e, 0x74, 0x12, 0x63, 0x0a, 0x11, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x5f, 0x70, 843 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 844 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 845 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 846 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 847 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x10, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 848 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x22, 0x64, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x54, 0x72, 849 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 850 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x46, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 851 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x61, 0x69, 0x70, 852 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 853 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 854 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xee, 0x01, 855 0x0a, 0x1c, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 856 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 857 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 858 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 859 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 860 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 861 0x74, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 862 0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 863 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 864 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 865 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 866 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x37, 0x0a, 0x09, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6d, 0x61, 867 0x73, 0x6b, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 868 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 869 0x4d, 0x61, 0x73, 0x6b, 0x52, 0x08, 0x72, 0x65, 0x61, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0xa9, 870 0x01, 0x0a, 0x1d, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 871 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 872 0x12, 0x60, 0x0a, 0x12, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x69, 0x70, 873 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 874 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 875 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x54, 876 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 877 0x11, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 878 0x65, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 879 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 880 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x67, 0x0a, 0x1d, 0x44, 0x65, 881 0x6c, 0x65, 0x74, 0x65, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 882 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x46, 0x0a, 0x04, 0x6e, 883 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 884 0x2c, 0x0a, 0x2a, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 885 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x72, 0x61, 886 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x04, 0x6e, 887 0x61, 0x6d, 0x65, 0x22, 0x67, 0x0a, 0x1d, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x54, 0x72, 0x61, 888 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 889 0x75, 0x65, 0x73, 0x74, 0x12, 0x46, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 890 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x61, 0x69, 0x70, 0x6c, 891 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 892 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 893 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xdb, 0x01, 0x0a, 894 0x18, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 895 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 896 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 897 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 898 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 899 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x54, 0x0a, 0x0c, 900 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x02, 0x20, 0x01, 901 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 902 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 903 0x65, 0x74, 0x61, 0x31, 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 904 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0b, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 905 0x6f, 0x62, 0x12, 0x26, 0x0a, 0x0f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x6a, 906 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x70, 0x69, 0x70, 907 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x49, 0x64, 0x22, 0x5a, 0x0a, 0x15, 0x47, 0x65, 908 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 909 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 910 0x09, 0x42, 0x2d, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x27, 0x0a, 0x25, 0x61, 0x69, 0x70, 0x6c, 0x61, 911 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 912 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 913 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xb0, 0x01, 0x0a, 0x17, 0x4c, 0x69, 0x73, 0x74, 0x50, 914 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 915 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 916 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 917 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 918 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 919 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 920 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x1b, 0x0a, 921 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 922 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 923 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 924 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x95, 0x01, 0x0a, 0x18, 0x4c, 0x69, 925 0x73, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 926 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x51, 0x0a, 0x0d, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 927 0x6e, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 928 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 929 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 930 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x0c, 0x70, 0x69, 0x70, 931 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 932 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 933 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 934 0x6e, 0x22, 0x5d, 0x0a, 0x18, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 935 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 936 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x2d, 0xe0, 0x41, 0x02, 937 0xfa, 0x41, 0x27, 0x0a, 0x25, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 938 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 939 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 940 0x22, 0x5d, 0x0a, 0x18, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 941 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x04, 942 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x2d, 0xe0, 0x41, 0x02, 0xfa, 943 0x41, 0x27, 0x0a, 0x25, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 944 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x69, 945 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x32, 946 0xfe, 0x11, 0x0a, 0x0f, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x53, 0x65, 0x72, 0x76, 947 0x69, 0x63, 0x65, 0x12, 0xfd, 0x01, 0x0a, 0x16, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x72, 948 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x3e, 949 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 950 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 951 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 952 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 953 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 954 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 955 0x2e, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 956 0x65, 0x22, 0x70, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x4f, 0x22, 0x3a, 0x2f, 0x76, 0x31, 0x62, 0x65, 957 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 958 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 959 0x2f, 0x2a, 0x7d, 0x2f, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 960 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x3a, 0x11, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x5f, 961 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0xda, 0x41, 0x18, 0x70, 0x61, 0x72, 0x65, 0x6e, 962 0x74, 0x2c, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x69, 0x70, 0x65, 0x6c, 963 0x69, 0x6e, 0x65, 0x12, 0xd0, 0x01, 0x0a, 0x13, 0x47, 0x65, 0x74, 0x54, 0x72, 0x61, 0x69, 0x6e, 964 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x3b, 0x2e, 0x67, 0x6f, 965 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 966 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x47, 0x65, 967 0x74, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 968 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 969 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 970 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x54, 0x72, 0x61, 0x69, 0x6e, 971 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x22, 0x49, 0x82, 0xd3, 0xe4, 972 0x93, 0x02, 0x3c, 0x12, 0x3a, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 973 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 974 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x72, 0x61, 0x69, 0x6e, 975 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 976 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xe3, 0x01, 0x0a, 0x15, 0x4c, 0x69, 0x73, 0x74, 0x54, 977 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 978 0x12, 0x3d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 979 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 980 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 981 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 982 0x3e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 983 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 984 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 985 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 986 0x4b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3c, 0x12, 0x3a, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 987 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 988 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 989 0x7d, 0x2f, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 990 0x6e, 0x65, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0xf5, 0x01, 0x0a, 991 0x16, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 992 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x3e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 993 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 994 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 995 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 996 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 997 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 998 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x7c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3c, 0x2a, 0x3a, 999 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 1000 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 1001 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 1002 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 1003 0x65, 0xca, 0x41, 0x30, 0x0a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 1004 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x17, 0x44, 0x65, 0x6c, 1005 0x65, 0x74, 0x65, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 1006 0x64, 0x61, 0x74, 0x61, 0x12, 0xc5, 0x01, 0x0a, 0x16, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x54, 1007 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x12, 1008 0x3e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 1009 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 1010 0x31, 0x2e, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x54, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 1011 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 1012 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 1013 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x53, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x46, 0x22, 1014 0x41, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 1015 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 1016 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x50, 1017 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x63, 0x61, 0x6e, 0x63, 1018 0x65, 0x6c, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xef, 0x01, 0x0a, 1019 0x11, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 1020 0x6f, 0x62, 0x12, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 1021 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 1022 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 1023 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2c, 0x2e, 1024 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 1025 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 1026 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x22, 0x71, 0x82, 0xd3, 0xe4, 1027 0x93, 0x02, 0x45, 0x22, 0x35, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x70, 1028 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 1029 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x70, 0x69, 1030 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x3a, 0x0c, 0x70, 0x69, 0x70, 0x65, 1031 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0xda, 0x41, 0x23, 0x70, 0x61, 0x72, 0x65, 0x6e, 1032 0x74, 0x2c, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x2c, 0x70, 1033 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x12, 0xbc, 1034 0x01, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 1035 0x62, 0x12, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 1036 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 1037 0x74, 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 1038 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1039 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 1040 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x50, 0x69, 0x70, 0x65, 1041 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x22, 0x44, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x37, 0x12, 1042 0x35, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 1043 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 1044 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 1045 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xcf, 0x01, 1046 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 1047 0x62, 0x73, 0x12, 0x38, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 1048 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 1049 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 1050 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x39, 0x2e, 0x67, 1051 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 1052 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 1053 0x69, 0x73, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x52, 1054 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x46, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x37, 0x12, 1055 0x35, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 1056 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 1057 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 1058 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 1059 0xe6, 0x01, 0x0a, 0x11, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 1060 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 1061 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 1062 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x50, 0x69, 1063 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 1064 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 1065 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 1066 0x77, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x37, 0x2a, 0x35, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 1067 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 1068 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x70, 1069 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 1070 0x04, 0x6e, 0x61, 0x6d, 0x65, 0xca, 0x41, 0x30, 0x0a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1071 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 1072 0x17, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 1073 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0xb6, 0x01, 0x0a, 0x11, 0x43, 0x61, 0x6e, 1074 0x63, 0x65, 0x6c, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x39, 1075 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 1076 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 1077 0x2e, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 1078 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1079 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 1080 0x79, 0x22, 0x4e, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x41, 0x22, 0x3c, 0x2f, 0x76, 0x31, 0x62, 0x65, 1081 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 1082 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 1083 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 1084 0x3a, 0x63, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 1085 0x65, 0x1a, 0x4d, 0xca, 0x41, 0x19, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 1086 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 1087 0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 1088 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 1089 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 1090 0x42, 0xf1, 0x01, 0x0a, 0x23, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1091 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 1092 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x42, 0x14, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 1093 0x6e, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 1094 0x5a, 0x49, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 1095 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 1096 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x61, 0x69, 1097 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 1098 0x3b, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0xaa, 0x02, 0x1f, 0x47, 0x6f, 1099 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x41, 0x49, 0x50, 0x6c, 0x61, 1100 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x56, 0x31, 0x42, 0x65, 0x74, 0x61, 0x31, 0xca, 0x02, 0x1f, 1101 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x41, 0x49, 0x50, 1102 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x5c, 0x56, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0xea, 1103 0x02, 0x22, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x3a, 1104 0x3a, 0x41, 0x49, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x3a, 0x3a, 0x56, 0x31, 0x62, 1105 0x65, 0x74, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 1106} 1107 1108var ( 1109 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescOnce sync.Once 1110 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescData = file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDesc 1111) 1112 1113func file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescGZIP() []byte { 1114 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescOnce.Do(func() { 1115 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescData) 1116 }) 1117 return file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDescData 1118} 1119 1120var file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes = make([]protoimpl.MessageInfo, 12) 1121var file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_goTypes = []interface{}{ 1122 (*CreateTrainingPipelineRequest)(nil), // 0: google.cloud.aiplatform.v1beta1.CreateTrainingPipelineRequest 1123 (*GetTrainingPipelineRequest)(nil), // 1: google.cloud.aiplatform.v1beta1.GetTrainingPipelineRequest 1124 (*ListTrainingPipelinesRequest)(nil), // 2: google.cloud.aiplatform.v1beta1.ListTrainingPipelinesRequest 1125 (*ListTrainingPipelinesResponse)(nil), // 3: google.cloud.aiplatform.v1beta1.ListTrainingPipelinesResponse 1126 (*DeleteTrainingPipelineRequest)(nil), // 4: google.cloud.aiplatform.v1beta1.DeleteTrainingPipelineRequest 1127 (*CancelTrainingPipelineRequest)(nil), // 5: google.cloud.aiplatform.v1beta1.CancelTrainingPipelineRequest 1128 (*CreatePipelineJobRequest)(nil), // 6: google.cloud.aiplatform.v1beta1.CreatePipelineJobRequest 1129 (*GetPipelineJobRequest)(nil), // 7: google.cloud.aiplatform.v1beta1.GetPipelineJobRequest 1130 (*ListPipelineJobsRequest)(nil), // 8: google.cloud.aiplatform.v1beta1.ListPipelineJobsRequest 1131 (*ListPipelineJobsResponse)(nil), // 9: google.cloud.aiplatform.v1beta1.ListPipelineJobsResponse 1132 (*DeletePipelineJobRequest)(nil), // 10: google.cloud.aiplatform.v1beta1.DeletePipelineJobRequest 1133 (*CancelPipelineJobRequest)(nil), // 11: google.cloud.aiplatform.v1beta1.CancelPipelineJobRequest 1134 (*TrainingPipeline)(nil), // 12: google.cloud.aiplatform.v1beta1.TrainingPipeline 1135 (*fieldmaskpb.FieldMask)(nil), // 13: google.protobuf.FieldMask 1136 (*PipelineJob)(nil), // 14: google.cloud.aiplatform.v1beta1.PipelineJob 1137 (*longrunning.Operation)(nil), // 15: google.longrunning.Operation 1138 (*emptypb.Empty)(nil), // 16: google.protobuf.Empty 1139} 1140var file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_depIdxs = []int32{ 1141 12, // 0: google.cloud.aiplatform.v1beta1.CreateTrainingPipelineRequest.training_pipeline:type_name -> google.cloud.aiplatform.v1beta1.TrainingPipeline 1142 13, // 1: google.cloud.aiplatform.v1beta1.ListTrainingPipelinesRequest.read_mask:type_name -> google.protobuf.FieldMask 1143 12, // 2: google.cloud.aiplatform.v1beta1.ListTrainingPipelinesResponse.training_pipelines:type_name -> google.cloud.aiplatform.v1beta1.TrainingPipeline 1144 14, // 3: google.cloud.aiplatform.v1beta1.CreatePipelineJobRequest.pipeline_job:type_name -> google.cloud.aiplatform.v1beta1.PipelineJob 1145 14, // 4: google.cloud.aiplatform.v1beta1.ListPipelineJobsResponse.pipeline_jobs:type_name -> google.cloud.aiplatform.v1beta1.PipelineJob 1146 0, // 5: google.cloud.aiplatform.v1beta1.PipelineService.CreateTrainingPipeline:input_type -> google.cloud.aiplatform.v1beta1.CreateTrainingPipelineRequest 1147 1, // 6: google.cloud.aiplatform.v1beta1.PipelineService.GetTrainingPipeline:input_type -> google.cloud.aiplatform.v1beta1.GetTrainingPipelineRequest 1148 2, // 7: google.cloud.aiplatform.v1beta1.PipelineService.ListTrainingPipelines:input_type -> google.cloud.aiplatform.v1beta1.ListTrainingPipelinesRequest 1149 4, // 8: google.cloud.aiplatform.v1beta1.PipelineService.DeleteTrainingPipeline:input_type -> google.cloud.aiplatform.v1beta1.DeleteTrainingPipelineRequest 1150 5, // 9: google.cloud.aiplatform.v1beta1.PipelineService.CancelTrainingPipeline:input_type -> google.cloud.aiplatform.v1beta1.CancelTrainingPipelineRequest 1151 6, // 10: google.cloud.aiplatform.v1beta1.PipelineService.CreatePipelineJob:input_type -> google.cloud.aiplatform.v1beta1.CreatePipelineJobRequest 1152 7, // 11: google.cloud.aiplatform.v1beta1.PipelineService.GetPipelineJob:input_type -> google.cloud.aiplatform.v1beta1.GetPipelineJobRequest 1153 8, // 12: google.cloud.aiplatform.v1beta1.PipelineService.ListPipelineJobs:input_type -> google.cloud.aiplatform.v1beta1.ListPipelineJobsRequest 1154 10, // 13: google.cloud.aiplatform.v1beta1.PipelineService.DeletePipelineJob:input_type -> google.cloud.aiplatform.v1beta1.DeletePipelineJobRequest 1155 11, // 14: google.cloud.aiplatform.v1beta1.PipelineService.CancelPipelineJob:input_type -> google.cloud.aiplatform.v1beta1.CancelPipelineJobRequest 1156 12, // 15: google.cloud.aiplatform.v1beta1.PipelineService.CreateTrainingPipeline:output_type -> google.cloud.aiplatform.v1beta1.TrainingPipeline 1157 12, // 16: google.cloud.aiplatform.v1beta1.PipelineService.GetTrainingPipeline:output_type -> google.cloud.aiplatform.v1beta1.TrainingPipeline 1158 3, // 17: google.cloud.aiplatform.v1beta1.PipelineService.ListTrainingPipelines:output_type -> google.cloud.aiplatform.v1beta1.ListTrainingPipelinesResponse 1159 15, // 18: google.cloud.aiplatform.v1beta1.PipelineService.DeleteTrainingPipeline:output_type -> google.longrunning.Operation 1160 16, // 19: google.cloud.aiplatform.v1beta1.PipelineService.CancelTrainingPipeline:output_type -> google.protobuf.Empty 1161 14, // 20: google.cloud.aiplatform.v1beta1.PipelineService.CreatePipelineJob:output_type -> google.cloud.aiplatform.v1beta1.PipelineJob 1162 14, // 21: google.cloud.aiplatform.v1beta1.PipelineService.GetPipelineJob:output_type -> google.cloud.aiplatform.v1beta1.PipelineJob 1163 9, // 22: google.cloud.aiplatform.v1beta1.PipelineService.ListPipelineJobs:output_type -> google.cloud.aiplatform.v1beta1.ListPipelineJobsResponse 1164 15, // 23: google.cloud.aiplatform.v1beta1.PipelineService.DeletePipelineJob:output_type -> google.longrunning.Operation 1165 16, // 24: google.cloud.aiplatform.v1beta1.PipelineService.CancelPipelineJob:output_type -> google.protobuf.Empty 1166 15, // [15:25] is the sub-list for method output_type 1167 5, // [5:15] is the sub-list for method input_type 1168 5, // [5:5] is the sub-list for extension type_name 1169 5, // [5:5] is the sub-list for extension extendee 1170 0, // [0:5] is the sub-list for field type_name 1171} 1172 1173func init() { file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_init() } 1174func file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_init() { 1175 if File_google_cloud_aiplatform_v1beta1_pipeline_service_proto != nil { 1176 return 1177 } 1178 file_google_cloud_aiplatform_v1beta1_pipeline_job_proto_init() 1179 file_google_cloud_aiplatform_v1beta1_training_pipeline_proto_init() 1180 if !protoimpl.UnsafeEnabled { 1181 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1182 switch v := v.(*CreateTrainingPipelineRequest); i { 1183 case 0: 1184 return &v.state 1185 case 1: 1186 return &v.sizeCache 1187 case 2: 1188 return &v.unknownFields 1189 default: 1190 return nil 1191 } 1192 } 1193 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1194 switch v := v.(*GetTrainingPipelineRequest); i { 1195 case 0: 1196 return &v.state 1197 case 1: 1198 return &v.sizeCache 1199 case 2: 1200 return &v.unknownFields 1201 default: 1202 return nil 1203 } 1204 } 1205 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1206 switch v := v.(*ListTrainingPipelinesRequest); i { 1207 case 0: 1208 return &v.state 1209 case 1: 1210 return &v.sizeCache 1211 case 2: 1212 return &v.unknownFields 1213 default: 1214 return nil 1215 } 1216 } 1217 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1218 switch v := v.(*ListTrainingPipelinesResponse); i { 1219 case 0: 1220 return &v.state 1221 case 1: 1222 return &v.sizeCache 1223 case 2: 1224 return &v.unknownFields 1225 default: 1226 return nil 1227 } 1228 } 1229 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1230 switch v := v.(*DeleteTrainingPipelineRequest); i { 1231 case 0: 1232 return &v.state 1233 case 1: 1234 return &v.sizeCache 1235 case 2: 1236 return &v.unknownFields 1237 default: 1238 return nil 1239 } 1240 } 1241 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1242 switch v := v.(*CancelTrainingPipelineRequest); i { 1243 case 0: 1244 return &v.state 1245 case 1: 1246 return &v.sizeCache 1247 case 2: 1248 return &v.unknownFields 1249 default: 1250 return nil 1251 } 1252 } 1253 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1254 switch v := v.(*CreatePipelineJobRequest); i { 1255 case 0: 1256 return &v.state 1257 case 1: 1258 return &v.sizeCache 1259 case 2: 1260 return &v.unknownFields 1261 default: 1262 return nil 1263 } 1264 } 1265 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1266 switch v := v.(*GetPipelineJobRequest); i { 1267 case 0: 1268 return &v.state 1269 case 1: 1270 return &v.sizeCache 1271 case 2: 1272 return &v.unknownFields 1273 default: 1274 return nil 1275 } 1276 } 1277 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1278 switch v := v.(*ListPipelineJobsRequest); i { 1279 case 0: 1280 return &v.state 1281 case 1: 1282 return &v.sizeCache 1283 case 2: 1284 return &v.unknownFields 1285 default: 1286 return nil 1287 } 1288 } 1289 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 1290 switch v := v.(*ListPipelineJobsResponse); i { 1291 case 0: 1292 return &v.state 1293 case 1: 1294 return &v.sizeCache 1295 case 2: 1296 return &v.unknownFields 1297 default: 1298 return nil 1299 } 1300 } 1301 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { 1302 switch v := v.(*DeletePipelineJobRequest); i { 1303 case 0: 1304 return &v.state 1305 case 1: 1306 return &v.sizeCache 1307 case 2: 1308 return &v.unknownFields 1309 default: 1310 return nil 1311 } 1312 } 1313 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { 1314 switch v := v.(*CancelPipelineJobRequest); i { 1315 case 0: 1316 return &v.state 1317 case 1: 1318 return &v.sizeCache 1319 case 2: 1320 return &v.unknownFields 1321 default: 1322 return nil 1323 } 1324 } 1325 } 1326 type x struct{} 1327 out := protoimpl.TypeBuilder{ 1328 File: protoimpl.DescBuilder{ 1329 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1330 RawDescriptor: file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDesc, 1331 NumEnums: 0, 1332 NumMessages: 12, 1333 NumExtensions: 0, 1334 NumServices: 1, 1335 }, 1336 GoTypes: file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_goTypes, 1337 DependencyIndexes: file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_depIdxs, 1338 MessageInfos: file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_msgTypes, 1339 }.Build() 1340 File_google_cloud_aiplatform_v1beta1_pipeline_service_proto = out.File 1341 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_rawDesc = nil 1342 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_goTypes = nil 1343 file_google_cloud_aiplatform_v1beta1_pipeline_service_proto_depIdxs = nil 1344} 1345 1346// Reference imports to suppress errors if they are not otherwise used. 1347var _ context.Context 1348var _ grpc.ClientConnInterface 1349 1350// This is a compile-time assertion to ensure that this generated file 1351// is compatible with the grpc package it is being compiled against. 1352const _ = grpc.SupportPackageIsVersion6 1353 1354// PipelineServiceClient is the client API for PipelineService service. 1355// 1356// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1357type PipelineServiceClient interface { 1358 // Creates a TrainingPipeline. A created TrainingPipeline right away will be 1359 // attempted to be run. 1360 CreateTrainingPipeline(ctx context.Context, in *CreateTrainingPipelineRequest, opts ...grpc.CallOption) (*TrainingPipeline, error) 1361 // Gets a TrainingPipeline. 1362 GetTrainingPipeline(ctx context.Context, in *GetTrainingPipelineRequest, opts ...grpc.CallOption) (*TrainingPipeline, error) 1363 // Lists TrainingPipelines in a Location. 1364 ListTrainingPipelines(ctx context.Context, in *ListTrainingPipelinesRequest, opts ...grpc.CallOption) (*ListTrainingPipelinesResponse, error) 1365 // Deletes a TrainingPipeline. 1366 DeleteTrainingPipeline(ctx context.Context, in *DeleteTrainingPipelineRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1367 // Cancels a TrainingPipeline. 1368 // Starts asynchronous cancellation on the TrainingPipeline. The server 1369 // makes a best effort to cancel the pipeline, but success is not 1370 // guaranteed. Clients can use [PipelineService.GetTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.GetTrainingPipeline] or 1371 // other methods to check whether the cancellation succeeded or whether the 1372 // pipeline completed despite cancellation. On successful cancellation, 1373 // the TrainingPipeline is not deleted; instead it becomes a pipeline with 1374 // a [TrainingPipeline.error][google.cloud.aiplatform.v1beta1.TrainingPipeline.error] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, 1375 // corresponding to `Code.CANCELLED`, and [TrainingPipeline.state][google.cloud.aiplatform.v1beta1.TrainingPipeline.state] is set to 1376 // `CANCELLED`. 1377 CancelTrainingPipeline(ctx context.Context, in *CancelTrainingPipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1378 // Creates a PipelineJob. A PipelineJob will run immediately when created. 1379 CreatePipelineJob(ctx context.Context, in *CreatePipelineJobRequest, opts ...grpc.CallOption) (*PipelineJob, error) 1380 // Gets a PipelineJob. 1381 GetPipelineJob(ctx context.Context, in *GetPipelineJobRequest, opts ...grpc.CallOption) (*PipelineJob, error) 1382 // Lists PipelineJobs in a Location. 1383 ListPipelineJobs(ctx context.Context, in *ListPipelineJobsRequest, opts ...grpc.CallOption) (*ListPipelineJobsResponse, error) 1384 // Deletes a PipelineJob. 1385 DeletePipelineJob(ctx context.Context, in *DeletePipelineJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1386 // Cancels a PipelineJob. 1387 // Starts asynchronous cancellation on the PipelineJob. The server 1388 // makes a best effort to cancel the pipeline, but success is not 1389 // guaranteed. Clients can use [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.GetPipelineJob] or 1390 // other methods to check whether the cancellation succeeded or whether the 1391 // pipeline completed despite cancellation. On successful cancellation, 1392 // the PipelineJob is not deleted; instead it becomes a pipeline with 1393 // a [PipelineJob.error][google.cloud.aiplatform.v1beta1.PipelineJob.error] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, 1394 // corresponding to `Code.CANCELLED`, and [PipelineJob.state][google.cloud.aiplatform.v1beta1.PipelineJob.state] is set to 1395 // `CANCELLED`. 1396 CancelPipelineJob(ctx context.Context, in *CancelPipelineJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1397} 1398 1399type pipelineServiceClient struct { 1400 cc grpc.ClientConnInterface 1401} 1402 1403func NewPipelineServiceClient(cc grpc.ClientConnInterface) PipelineServiceClient { 1404 return &pipelineServiceClient{cc} 1405} 1406 1407func (c *pipelineServiceClient) CreateTrainingPipeline(ctx context.Context, in *CreateTrainingPipelineRequest, opts ...grpc.CallOption) (*TrainingPipeline, error) { 1408 out := new(TrainingPipeline) 1409 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/CreateTrainingPipeline", in, out, opts...) 1410 if err != nil { 1411 return nil, err 1412 } 1413 return out, nil 1414} 1415 1416func (c *pipelineServiceClient) GetTrainingPipeline(ctx context.Context, in *GetTrainingPipelineRequest, opts ...grpc.CallOption) (*TrainingPipeline, error) { 1417 out := new(TrainingPipeline) 1418 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/GetTrainingPipeline", in, out, opts...) 1419 if err != nil { 1420 return nil, err 1421 } 1422 return out, nil 1423} 1424 1425func (c *pipelineServiceClient) ListTrainingPipelines(ctx context.Context, in *ListTrainingPipelinesRequest, opts ...grpc.CallOption) (*ListTrainingPipelinesResponse, error) { 1426 out := new(ListTrainingPipelinesResponse) 1427 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/ListTrainingPipelines", in, out, opts...) 1428 if err != nil { 1429 return nil, err 1430 } 1431 return out, nil 1432} 1433 1434func (c *pipelineServiceClient) DeleteTrainingPipeline(ctx context.Context, in *DeleteTrainingPipelineRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1435 out := new(longrunning.Operation) 1436 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/DeleteTrainingPipeline", in, out, opts...) 1437 if err != nil { 1438 return nil, err 1439 } 1440 return out, nil 1441} 1442 1443func (c *pipelineServiceClient) CancelTrainingPipeline(ctx context.Context, in *CancelTrainingPipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1444 out := new(emptypb.Empty) 1445 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/CancelTrainingPipeline", in, out, opts...) 1446 if err != nil { 1447 return nil, err 1448 } 1449 return out, nil 1450} 1451 1452func (c *pipelineServiceClient) CreatePipelineJob(ctx context.Context, in *CreatePipelineJobRequest, opts ...grpc.CallOption) (*PipelineJob, error) { 1453 out := new(PipelineJob) 1454 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/CreatePipelineJob", in, out, opts...) 1455 if err != nil { 1456 return nil, err 1457 } 1458 return out, nil 1459} 1460 1461func (c *pipelineServiceClient) GetPipelineJob(ctx context.Context, in *GetPipelineJobRequest, opts ...grpc.CallOption) (*PipelineJob, error) { 1462 out := new(PipelineJob) 1463 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/GetPipelineJob", in, out, opts...) 1464 if err != nil { 1465 return nil, err 1466 } 1467 return out, nil 1468} 1469 1470func (c *pipelineServiceClient) ListPipelineJobs(ctx context.Context, in *ListPipelineJobsRequest, opts ...grpc.CallOption) (*ListPipelineJobsResponse, error) { 1471 out := new(ListPipelineJobsResponse) 1472 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/ListPipelineJobs", in, out, opts...) 1473 if err != nil { 1474 return nil, err 1475 } 1476 return out, nil 1477} 1478 1479func (c *pipelineServiceClient) DeletePipelineJob(ctx context.Context, in *DeletePipelineJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1480 out := new(longrunning.Operation) 1481 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/DeletePipelineJob", in, out, opts...) 1482 if err != nil { 1483 return nil, err 1484 } 1485 return out, nil 1486} 1487 1488func (c *pipelineServiceClient) CancelPipelineJob(ctx context.Context, in *CancelPipelineJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1489 out := new(emptypb.Empty) 1490 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.PipelineService/CancelPipelineJob", in, out, opts...) 1491 if err != nil { 1492 return nil, err 1493 } 1494 return out, nil 1495} 1496 1497// PipelineServiceServer is the server API for PipelineService service. 1498type PipelineServiceServer interface { 1499 // Creates a TrainingPipeline. A created TrainingPipeline right away will be 1500 // attempted to be run. 1501 CreateTrainingPipeline(context.Context, *CreateTrainingPipelineRequest) (*TrainingPipeline, error) 1502 // Gets a TrainingPipeline. 1503 GetTrainingPipeline(context.Context, *GetTrainingPipelineRequest) (*TrainingPipeline, error) 1504 // Lists TrainingPipelines in a Location. 1505 ListTrainingPipelines(context.Context, *ListTrainingPipelinesRequest) (*ListTrainingPipelinesResponse, error) 1506 // Deletes a TrainingPipeline. 1507 DeleteTrainingPipeline(context.Context, *DeleteTrainingPipelineRequest) (*longrunning.Operation, error) 1508 // Cancels a TrainingPipeline. 1509 // Starts asynchronous cancellation on the TrainingPipeline. The server 1510 // makes a best effort to cancel the pipeline, but success is not 1511 // guaranteed. Clients can use [PipelineService.GetTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.GetTrainingPipeline] or 1512 // other methods to check whether the cancellation succeeded or whether the 1513 // pipeline completed despite cancellation. On successful cancellation, 1514 // the TrainingPipeline is not deleted; instead it becomes a pipeline with 1515 // a [TrainingPipeline.error][google.cloud.aiplatform.v1beta1.TrainingPipeline.error] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, 1516 // corresponding to `Code.CANCELLED`, and [TrainingPipeline.state][google.cloud.aiplatform.v1beta1.TrainingPipeline.state] is set to 1517 // `CANCELLED`. 1518 CancelTrainingPipeline(context.Context, *CancelTrainingPipelineRequest) (*emptypb.Empty, error) 1519 // Creates a PipelineJob. A PipelineJob will run immediately when created. 1520 CreatePipelineJob(context.Context, *CreatePipelineJobRequest) (*PipelineJob, error) 1521 // Gets a PipelineJob. 1522 GetPipelineJob(context.Context, *GetPipelineJobRequest) (*PipelineJob, error) 1523 // Lists PipelineJobs in a Location. 1524 ListPipelineJobs(context.Context, *ListPipelineJobsRequest) (*ListPipelineJobsResponse, error) 1525 // Deletes a PipelineJob. 1526 DeletePipelineJob(context.Context, *DeletePipelineJobRequest) (*longrunning.Operation, error) 1527 // Cancels a PipelineJob. 1528 // Starts asynchronous cancellation on the PipelineJob. The server 1529 // makes a best effort to cancel the pipeline, but success is not 1530 // guaranteed. Clients can use [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.GetPipelineJob] or 1531 // other methods to check whether the cancellation succeeded or whether the 1532 // pipeline completed despite cancellation. On successful cancellation, 1533 // the PipelineJob is not deleted; instead it becomes a pipeline with 1534 // a [PipelineJob.error][google.cloud.aiplatform.v1beta1.PipelineJob.error] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, 1535 // corresponding to `Code.CANCELLED`, and [PipelineJob.state][google.cloud.aiplatform.v1beta1.PipelineJob.state] is set to 1536 // `CANCELLED`. 1537 CancelPipelineJob(context.Context, *CancelPipelineJobRequest) (*emptypb.Empty, error) 1538} 1539 1540// UnimplementedPipelineServiceServer can be embedded to have forward compatible implementations. 1541type UnimplementedPipelineServiceServer struct { 1542} 1543 1544func (*UnimplementedPipelineServiceServer) CreateTrainingPipeline(context.Context, *CreateTrainingPipelineRequest) (*TrainingPipeline, error) { 1545 return nil, status.Errorf(codes.Unimplemented, "method CreateTrainingPipeline not implemented") 1546} 1547func (*UnimplementedPipelineServiceServer) GetTrainingPipeline(context.Context, *GetTrainingPipelineRequest) (*TrainingPipeline, error) { 1548 return nil, status.Errorf(codes.Unimplemented, "method GetTrainingPipeline not implemented") 1549} 1550func (*UnimplementedPipelineServiceServer) ListTrainingPipelines(context.Context, *ListTrainingPipelinesRequest) (*ListTrainingPipelinesResponse, error) { 1551 return nil, status.Errorf(codes.Unimplemented, "method ListTrainingPipelines not implemented") 1552} 1553func (*UnimplementedPipelineServiceServer) DeleteTrainingPipeline(context.Context, *DeleteTrainingPipelineRequest) (*longrunning.Operation, error) { 1554 return nil, status.Errorf(codes.Unimplemented, "method DeleteTrainingPipeline not implemented") 1555} 1556func (*UnimplementedPipelineServiceServer) CancelTrainingPipeline(context.Context, *CancelTrainingPipelineRequest) (*emptypb.Empty, error) { 1557 return nil, status.Errorf(codes.Unimplemented, "method CancelTrainingPipeline not implemented") 1558} 1559func (*UnimplementedPipelineServiceServer) CreatePipelineJob(context.Context, *CreatePipelineJobRequest) (*PipelineJob, error) { 1560 return nil, status.Errorf(codes.Unimplemented, "method CreatePipelineJob not implemented") 1561} 1562func (*UnimplementedPipelineServiceServer) GetPipelineJob(context.Context, *GetPipelineJobRequest) (*PipelineJob, error) { 1563 return nil, status.Errorf(codes.Unimplemented, "method GetPipelineJob not implemented") 1564} 1565func (*UnimplementedPipelineServiceServer) ListPipelineJobs(context.Context, *ListPipelineJobsRequest) (*ListPipelineJobsResponse, error) { 1566 return nil, status.Errorf(codes.Unimplemented, "method ListPipelineJobs not implemented") 1567} 1568func (*UnimplementedPipelineServiceServer) DeletePipelineJob(context.Context, *DeletePipelineJobRequest) (*longrunning.Operation, error) { 1569 return nil, status.Errorf(codes.Unimplemented, "method DeletePipelineJob not implemented") 1570} 1571func (*UnimplementedPipelineServiceServer) CancelPipelineJob(context.Context, *CancelPipelineJobRequest) (*emptypb.Empty, error) { 1572 return nil, status.Errorf(codes.Unimplemented, "method CancelPipelineJob not implemented") 1573} 1574 1575func RegisterPipelineServiceServer(s *grpc.Server, srv PipelineServiceServer) { 1576 s.RegisterService(&_PipelineService_serviceDesc, srv) 1577} 1578 1579func _PipelineService_CreateTrainingPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1580 in := new(CreateTrainingPipelineRequest) 1581 if err := dec(in); err != nil { 1582 return nil, err 1583 } 1584 if interceptor == nil { 1585 return srv.(PipelineServiceServer).CreateTrainingPipeline(ctx, in) 1586 } 1587 info := &grpc.UnaryServerInfo{ 1588 Server: srv, 1589 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/CreateTrainingPipeline", 1590 } 1591 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1592 return srv.(PipelineServiceServer).CreateTrainingPipeline(ctx, req.(*CreateTrainingPipelineRequest)) 1593 } 1594 return interceptor(ctx, in, info, handler) 1595} 1596 1597func _PipelineService_GetTrainingPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1598 in := new(GetTrainingPipelineRequest) 1599 if err := dec(in); err != nil { 1600 return nil, err 1601 } 1602 if interceptor == nil { 1603 return srv.(PipelineServiceServer).GetTrainingPipeline(ctx, in) 1604 } 1605 info := &grpc.UnaryServerInfo{ 1606 Server: srv, 1607 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/GetTrainingPipeline", 1608 } 1609 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1610 return srv.(PipelineServiceServer).GetTrainingPipeline(ctx, req.(*GetTrainingPipelineRequest)) 1611 } 1612 return interceptor(ctx, in, info, handler) 1613} 1614 1615func _PipelineService_ListTrainingPipelines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1616 in := new(ListTrainingPipelinesRequest) 1617 if err := dec(in); err != nil { 1618 return nil, err 1619 } 1620 if interceptor == nil { 1621 return srv.(PipelineServiceServer).ListTrainingPipelines(ctx, in) 1622 } 1623 info := &grpc.UnaryServerInfo{ 1624 Server: srv, 1625 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/ListTrainingPipelines", 1626 } 1627 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1628 return srv.(PipelineServiceServer).ListTrainingPipelines(ctx, req.(*ListTrainingPipelinesRequest)) 1629 } 1630 return interceptor(ctx, in, info, handler) 1631} 1632 1633func _PipelineService_DeleteTrainingPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1634 in := new(DeleteTrainingPipelineRequest) 1635 if err := dec(in); err != nil { 1636 return nil, err 1637 } 1638 if interceptor == nil { 1639 return srv.(PipelineServiceServer).DeleteTrainingPipeline(ctx, in) 1640 } 1641 info := &grpc.UnaryServerInfo{ 1642 Server: srv, 1643 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/DeleteTrainingPipeline", 1644 } 1645 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1646 return srv.(PipelineServiceServer).DeleteTrainingPipeline(ctx, req.(*DeleteTrainingPipelineRequest)) 1647 } 1648 return interceptor(ctx, in, info, handler) 1649} 1650 1651func _PipelineService_CancelTrainingPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1652 in := new(CancelTrainingPipelineRequest) 1653 if err := dec(in); err != nil { 1654 return nil, err 1655 } 1656 if interceptor == nil { 1657 return srv.(PipelineServiceServer).CancelTrainingPipeline(ctx, in) 1658 } 1659 info := &grpc.UnaryServerInfo{ 1660 Server: srv, 1661 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/CancelTrainingPipeline", 1662 } 1663 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1664 return srv.(PipelineServiceServer).CancelTrainingPipeline(ctx, req.(*CancelTrainingPipelineRequest)) 1665 } 1666 return interceptor(ctx, in, info, handler) 1667} 1668 1669func _PipelineService_CreatePipelineJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1670 in := new(CreatePipelineJobRequest) 1671 if err := dec(in); err != nil { 1672 return nil, err 1673 } 1674 if interceptor == nil { 1675 return srv.(PipelineServiceServer).CreatePipelineJob(ctx, in) 1676 } 1677 info := &grpc.UnaryServerInfo{ 1678 Server: srv, 1679 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/CreatePipelineJob", 1680 } 1681 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1682 return srv.(PipelineServiceServer).CreatePipelineJob(ctx, req.(*CreatePipelineJobRequest)) 1683 } 1684 return interceptor(ctx, in, info, handler) 1685} 1686 1687func _PipelineService_GetPipelineJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1688 in := new(GetPipelineJobRequest) 1689 if err := dec(in); err != nil { 1690 return nil, err 1691 } 1692 if interceptor == nil { 1693 return srv.(PipelineServiceServer).GetPipelineJob(ctx, in) 1694 } 1695 info := &grpc.UnaryServerInfo{ 1696 Server: srv, 1697 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/GetPipelineJob", 1698 } 1699 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1700 return srv.(PipelineServiceServer).GetPipelineJob(ctx, req.(*GetPipelineJobRequest)) 1701 } 1702 return interceptor(ctx, in, info, handler) 1703} 1704 1705func _PipelineService_ListPipelineJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1706 in := new(ListPipelineJobsRequest) 1707 if err := dec(in); err != nil { 1708 return nil, err 1709 } 1710 if interceptor == nil { 1711 return srv.(PipelineServiceServer).ListPipelineJobs(ctx, in) 1712 } 1713 info := &grpc.UnaryServerInfo{ 1714 Server: srv, 1715 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/ListPipelineJobs", 1716 } 1717 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1718 return srv.(PipelineServiceServer).ListPipelineJobs(ctx, req.(*ListPipelineJobsRequest)) 1719 } 1720 return interceptor(ctx, in, info, handler) 1721} 1722 1723func _PipelineService_DeletePipelineJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1724 in := new(DeletePipelineJobRequest) 1725 if err := dec(in); err != nil { 1726 return nil, err 1727 } 1728 if interceptor == nil { 1729 return srv.(PipelineServiceServer).DeletePipelineJob(ctx, in) 1730 } 1731 info := &grpc.UnaryServerInfo{ 1732 Server: srv, 1733 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/DeletePipelineJob", 1734 } 1735 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1736 return srv.(PipelineServiceServer).DeletePipelineJob(ctx, req.(*DeletePipelineJobRequest)) 1737 } 1738 return interceptor(ctx, in, info, handler) 1739} 1740 1741func _PipelineService_CancelPipelineJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1742 in := new(CancelPipelineJobRequest) 1743 if err := dec(in); err != nil { 1744 return nil, err 1745 } 1746 if interceptor == nil { 1747 return srv.(PipelineServiceServer).CancelPipelineJob(ctx, in) 1748 } 1749 info := &grpc.UnaryServerInfo{ 1750 Server: srv, 1751 FullMethod: "/google.cloud.aiplatform.v1beta1.PipelineService/CancelPipelineJob", 1752 } 1753 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1754 return srv.(PipelineServiceServer).CancelPipelineJob(ctx, req.(*CancelPipelineJobRequest)) 1755 } 1756 return interceptor(ctx, in, info, handler) 1757} 1758 1759var _PipelineService_serviceDesc = grpc.ServiceDesc{ 1760 ServiceName: "google.cloud.aiplatform.v1beta1.PipelineService", 1761 HandlerType: (*PipelineServiceServer)(nil), 1762 Methods: []grpc.MethodDesc{ 1763 { 1764 MethodName: "CreateTrainingPipeline", 1765 Handler: _PipelineService_CreateTrainingPipeline_Handler, 1766 }, 1767 { 1768 MethodName: "GetTrainingPipeline", 1769 Handler: _PipelineService_GetTrainingPipeline_Handler, 1770 }, 1771 { 1772 MethodName: "ListTrainingPipelines", 1773 Handler: _PipelineService_ListTrainingPipelines_Handler, 1774 }, 1775 { 1776 MethodName: "DeleteTrainingPipeline", 1777 Handler: _PipelineService_DeleteTrainingPipeline_Handler, 1778 }, 1779 { 1780 MethodName: "CancelTrainingPipeline", 1781 Handler: _PipelineService_CancelTrainingPipeline_Handler, 1782 }, 1783 { 1784 MethodName: "CreatePipelineJob", 1785 Handler: _PipelineService_CreatePipelineJob_Handler, 1786 }, 1787 { 1788 MethodName: "GetPipelineJob", 1789 Handler: _PipelineService_GetPipelineJob_Handler, 1790 }, 1791 { 1792 MethodName: "ListPipelineJobs", 1793 Handler: _PipelineService_ListPipelineJobs_Handler, 1794 }, 1795 { 1796 MethodName: "DeletePipelineJob", 1797 Handler: _PipelineService_DeletePipelineJob_Handler, 1798 }, 1799 { 1800 MethodName: "CancelPipelineJob", 1801 Handler: _PipelineService_CancelPipelineJob_Handler, 1802 }, 1803 }, 1804 Streams: []grpc.StreamDesc{}, 1805 Metadata: "google/cloud/aiplatform/v1beta1/pipeline_service.proto", 1806} 1807