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