1// Copyright 2019 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 16// Code generated by protoc-gen-go. DO NOT EDIT. 17// versions: 18// protoc-gen-go v1.25.0 19// protoc v3.13.0 20// source: google/cloud/scheduler/v1beta1/cloudscheduler.proto 21 22package scheduler 23 24import ( 25 context "context" 26 reflect "reflect" 27 sync "sync" 28 29 proto "github.com/golang/protobuf/proto" 30 _ "google.golang.org/genproto/googleapis/api/annotations" 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 listing jobs using [ListJobs][google.cloud.scheduler.v1beta1.CloudScheduler.ListJobs]. 52type ListJobsRequest struct { 53 state protoimpl.MessageState 54 sizeCache protoimpl.SizeCache 55 unknownFields protoimpl.UnknownFields 56 57 // Required. The location name. For example: 58 // `projects/PROJECT_ID/locations/LOCATION_ID`. 59 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 60 // Requested page size. 61 // 62 // The maximum page size is 500. If unspecified, the page size will 63 // be the maximum. Fewer jobs than requested might be returned, 64 // even if more jobs exist; use next_page_token to determine if more 65 // jobs exist. 66 PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 67 // A token identifying a page of results the server will return. To 68 // request the first page results, page_token must be empty. To 69 // request the next page of results, page_token must be the value of 70 // [next_page_token][google.cloud.scheduler.v1beta1.ListJobsResponse.next_page_token] returned from 71 // the previous call to [ListJobs][google.cloud.scheduler.v1beta1.CloudScheduler.ListJobs]. It is an error to 72 // switch the value of [filter][google.cloud.scheduler.v1beta1.ListJobsRequest.filter] or 73 // [order_by][google.cloud.scheduler.v1beta1.ListJobsRequest.order_by] while iterating through pages. 74 PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 75} 76 77func (x *ListJobsRequest) Reset() { 78 *x = ListJobsRequest{} 79 if protoimpl.UnsafeEnabled { 80 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[0] 81 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 82 ms.StoreMessageInfo(mi) 83 } 84} 85 86func (x *ListJobsRequest) String() string { 87 return protoimpl.X.MessageStringOf(x) 88} 89 90func (*ListJobsRequest) ProtoMessage() {} 91 92func (x *ListJobsRequest) ProtoReflect() protoreflect.Message { 93 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[0] 94 if protoimpl.UnsafeEnabled && x != nil { 95 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 96 if ms.LoadMessageInfo() == nil { 97 ms.StoreMessageInfo(mi) 98 } 99 return ms 100 } 101 return mi.MessageOf(x) 102} 103 104// Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead. 105func (*ListJobsRequest) Descriptor() ([]byte, []int) { 106 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{0} 107} 108 109func (x *ListJobsRequest) GetParent() string { 110 if x != nil { 111 return x.Parent 112 } 113 return "" 114} 115 116func (x *ListJobsRequest) GetPageSize() int32 { 117 if x != nil { 118 return x.PageSize 119 } 120 return 0 121} 122 123func (x *ListJobsRequest) GetPageToken() string { 124 if x != nil { 125 return x.PageToken 126 } 127 return "" 128} 129 130// Response message for listing jobs using [ListJobs][google.cloud.scheduler.v1beta1.CloudScheduler.ListJobs]. 131type ListJobsResponse struct { 132 state protoimpl.MessageState 133 sizeCache protoimpl.SizeCache 134 unknownFields protoimpl.UnknownFields 135 136 // The list of jobs. 137 Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` 138 // A token to retrieve next page of results. Pass this value in the 139 // [page_token][google.cloud.scheduler.v1beta1.ListJobsRequest.page_token] field in the subsequent call to 140 // [ListJobs][google.cloud.scheduler.v1beta1.CloudScheduler.ListJobs] to retrieve the next page of results. 141 // If this is empty it indicates that there are no more results 142 // through which to paginate. 143 // 144 // The page token is valid for only 2 hours. 145 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 146} 147 148func (x *ListJobsResponse) Reset() { 149 *x = ListJobsResponse{} 150 if protoimpl.UnsafeEnabled { 151 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[1] 152 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 153 ms.StoreMessageInfo(mi) 154 } 155} 156 157func (x *ListJobsResponse) String() string { 158 return protoimpl.X.MessageStringOf(x) 159} 160 161func (*ListJobsResponse) ProtoMessage() {} 162 163func (x *ListJobsResponse) ProtoReflect() protoreflect.Message { 164 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[1] 165 if protoimpl.UnsafeEnabled && x != nil { 166 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 167 if ms.LoadMessageInfo() == nil { 168 ms.StoreMessageInfo(mi) 169 } 170 return ms 171 } 172 return mi.MessageOf(x) 173} 174 175// Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead. 176func (*ListJobsResponse) Descriptor() ([]byte, []int) { 177 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{1} 178} 179 180func (x *ListJobsResponse) GetJobs() []*Job { 181 if x != nil { 182 return x.Jobs 183 } 184 return nil 185} 186 187func (x *ListJobsResponse) GetNextPageToken() string { 188 if x != nil { 189 return x.NextPageToken 190 } 191 return "" 192} 193 194// Request message for [GetJob][google.cloud.scheduler.v1beta1.CloudScheduler.GetJob]. 195type GetJobRequest struct { 196 state protoimpl.MessageState 197 sizeCache protoimpl.SizeCache 198 unknownFields protoimpl.UnknownFields 199 200 // Required. The job name. For example: 201 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 202 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 203} 204 205func (x *GetJobRequest) Reset() { 206 *x = GetJobRequest{} 207 if protoimpl.UnsafeEnabled { 208 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[2] 209 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 210 ms.StoreMessageInfo(mi) 211 } 212} 213 214func (x *GetJobRequest) String() string { 215 return protoimpl.X.MessageStringOf(x) 216} 217 218func (*GetJobRequest) ProtoMessage() {} 219 220func (x *GetJobRequest) ProtoReflect() protoreflect.Message { 221 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[2] 222 if protoimpl.UnsafeEnabled && x != nil { 223 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 224 if ms.LoadMessageInfo() == nil { 225 ms.StoreMessageInfo(mi) 226 } 227 return ms 228 } 229 return mi.MessageOf(x) 230} 231 232// Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead. 233func (*GetJobRequest) Descriptor() ([]byte, []int) { 234 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{2} 235} 236 237func (x *GetJobRequest) GetName() string { 238 if x != nil { 239 return x.Name 240 } 241 return "" 242} 243 244// Request message for [CreateJob][google.cloud.scheduler.v1beta1.CloudScheduler.CreateJob]. 245type CreateJobRequest struct { 246 state protoimpl.MessageState 247 sizeCache protoimpl.SizeCache 248 unknownFields protoimpl.UnknownFields 249 250 // Required. The location name. For example: 251 // `projects/PROJECT_ID/locations/LOCATION_ID`. 252 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 253 // Required. The job to add. The user can optionally specify a name for the 254 // job in [name][google.cloud.scheduler.v1beta1.Job.name]. [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an 255 // existing job. If a name is not specified then the system will 256 // generate a random unique name that will be returned 257 // ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response. 258 Job *Job `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"` 259} 260 261func (x *CreateJobRequest) Reset() { 262 *x = CreateJobRequest{} 263 if protoimpl.UnsafeEnabled { 264 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[3] 265 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 266 ms.StoreMessageInfo(mi) 267 } 268} 269 270func (x *CreateJobRequest) String() string { 271 return protoimpl.X.MessageStringOf(x) 272} 273 274func (*CreateJobRequest) ProtoMessage() {} 275 276func (x *CreateJobRequest) ProtoReflect() protoreflect.Message { 277 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[3] 278 if protoimpl.UnsafeEnabled && x != nil { 279 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 280 if ms.LoadMessageInfo() == nil { 281 ms.StoreMessageInfo(mi) 282 } 283 return ms 284 } 285 return mi.MessageOf(x) 286} 287 288// Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead. 289func (*CreateJobRequest) Descriptor() ([]byte, []int) { 290 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{3} 291} 292 293func (x *CreateJobRequest) GetParent() string { 294 if x != nil { 295 return x.Parent 296 } 297 return "" 298} 299 300func (x *CreateJobRequest) GetJob() *Job { 301 if x != nil { 302 return x.Job 303 } 304 return nil 305} 306 307// Request message for [UpdateJob][google.cloud.scheduler.v1beta1.CloudScheduler.UpdateJob]. 308type UpdateJobRequest struct { 309 state protoimpl.MessageState 310 sizeCache protoimpl.SizeCache 311 unknownFields protoimpl.UnknownFields 312 313 // Required. The new job properties. [name][google.cloud.scheduler.v1beta1.Job.name] must be specified. 314 // 315 // Output only fields cannot be modified using UpdateJob. 316 // Any value specified for an output only field will be ignored. 317 Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` 318 // A mask used to specify which fields of the job are being updated. 319 UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 320} 321 322func (x *UpdateJobRequest) Reset() { 323 *x = UpdateJobRequest{} 324 if protoimpl.UnsafeEnabled { 325 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[4] 326 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 327 ms.StoreMessageInfo(mi) 328 } 329} 330 331func (x *UpdateJobRequest) String() string { 332 return protoimpl.X.MessageStringOf(x) 333} 334 335func (*UpdateJobRequest) ProtoMessage() {} 336 337func (x *UpdateJobRequest) ProtoReflect() protoreflect.Message { 338 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[4] 339 if protoimpl.UnsafeEnabled && x != nil { 340 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 341 if ms.LoadMessageInfo() == nil { 342 ms.StoreMessageInfo(mi) 343 } 344 return ms 345 } 346 return mi.MessageOf(x) 347} 348 349// Deprecated: Use UpdateJobRequest.ProtoReflect.Descriptor instead. 350func (*UpdateJobRequest) Descriptor() ([]byte, []int) { 351 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{4} 352} 353 354func (x *UpdateJobRequest) GetJob() *Job { 355 if x != nil { 356 return x.Job 357 } 358 return nil 359} 360 361func (x *UpdateJobRequest) GetUpdateMask() *fieldmaskpb.FieldMask { 362 if x != nil { 363 return x.UpdateMask 364 } 365 return nil 366} 367 368// Request message for deleting a job using 369// [DeleteJob][google.cloud.scheduler.v1beta1.CloudScheduler.DeleteJob]. 370type DeleteJobRequest struct { 371 state protoimpl.MessageState 372 sizeCache protoimpl.SizeCache 373 unknownFields protoimpl.UnknownFields 374 375 // Required. The job name. For example: 376 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 377 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 378} 379 380func (x *DeleteJobRequest) Reset() { 381 *x = DeleteJobRequest{} 382 if protoimpl.UnsafeEnabled { 383 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[5] 384 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 385 ms.StoreMessageInfo(mi) 386 } 387} 388 389func (x *DeleteJobRequest) String() string { 390 return protoimpl.X.MessageStringOf(x) 391} 392 393func (*DeleteJobRequest) ProtoMessage() {} 394 395func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message { 396 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[5] 397 if protoimpl.UnsafeEnabled && x != nil { 398 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 399 if ms.LoadMessageInfo() == nil { 400 ms.StoreMessageInfo(mi) 401 } 402 return ms 403 } 404 return mi.MessageOf(x) 405} 406 407// Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead. 408func (*DeleteJobRequest) Descriptor() ([]byte, []int) { 409 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{5} 410} 411 412func (x *DeleteJobRequest) GetName() string { 413 if x != nil { 414 return x.Name 415 } 416 return "" 417} 418 419// Request message for [PauseJob][google.cloud.scheduler.v1beta1.CloudScheduler.PauseJob]. 420type PauseJobRequest struct { 421 state protoimpl.MessageState 422 sizeCache protoimpl.SizeCache 423 unknownFields protoimpl.UnknownFields 424 425 // Required. The job name. For example: 426 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 427 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 428} 429 430func (x *PauseJobRequest) Reset() { 431 *x = PauseJobRequest{} 432 if protoimpl.UnsafeEnabled { 433 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[6] 434 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 435 ms.StoreMessageInfo(mi) 436 } 437} 438 439func (x *PauseJobRequest) String() string { 440 return protoimpl.X.MessageStringOf(x) 441} 442 443func (*PauseJobRequest) ProtoMessage() {} 444 445func (x *PauseJobRequest) ProtoReflect() protoreflect.Message { 446 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[6] 447 if protoimpl.UnsafeEnabled && x != nil { 448 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 449 if ms.LoadMessageInfo() == nil { 450 ms.StoreMessageInfo(mi) 451 } 452 return ms 453 } 454 return mi.MessageOf(x) 455} 456 457// Deprecated: Use PauseJobRequest.ProtoReflect.Descriptor instead. 458func (*PauseJobRequest) Descriptor() ([]byte, []int) { 459 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{6} 460} 461 462func (x *PauseJobRequest) GetName() string { 463 if x != nil { 464 return x.Name 465 } 466 return "" 467} 468 469// Request message for [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. 470type ResumeJobRequest struct { 471 state protoimpl.MessageState 472 sizeCache protoimpl.SizeCache 473 unknownFields protoimpl.UnknownFields 474 475 // Required. The job name. For example: 476 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 477 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 478} 479 480func (x *ResumeJobRequest) Reset() { 481 *x = ResumeJobRequest{} 482 if protoimpl.UnsafeEnabled { 483 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[7] 484 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 485 ms.StoreMessageInfo(mi) 486 } 487} 488 489func (x *ResumeJobRequest) String() string { 490 return protoimpl.X.MessageStringOf(x) 491} 492 493func (*ResumeJobRequest) ProtoMessage() {} 494 495func (x *ResumeJobRequest) ProtoReflect() protoreflect.Message { 496 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[7] 497 if protoimpl.UnsafeEnabled && x != nil { 498 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 499 if ms.LoadMessageInfo() == nil { 500 ms.StoreMessageInfo(mi) 501 } 502 return ms 503 } 504 return mi.MessageOf(x) 505} 506 507// Deprecated: Use ResumeJobRequest.ProtoReflect.Descriptor instead. 508func (*ResumeJobRequest) Descriptor() ([]byte, []int) { 509 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{7} 510} 511 512func (x *ResumeJobRequest) GetName() string { 513 if x != nil { 514 return x.Name 515 } 516 return "" 517} 518 519// Request message for forcing a job to run now using 520// [RunJob][google.cloud.scheduler.v1beta1.CloudScheduler.RunJob]. 521type RunJobRequest struct { 522 state protoimpl.MessageState 523 sizeCache protoimpl.SizeCache 524 unknownFields protoimpl.UnknownFields 525 526 // Required. The job name. For example: 527 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 528 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 529} 530 531func (x *RunJobRequest) Reset() { 532 *x = RunJobRequest{} 533 if protoimpl.UnsafeEnabled { 534 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[8] 535 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 536 ms.StoreMessageInfo(mi) 537 } 538} 539 540func (x *RunJobRequest) String() string { 541 return protoimpl.X.MessageStringOf(x) 542} 543 544func (*RunJobRequest) ProtoMessage() {} 545 546func (x *RunJobRequest) ProtoReflect() protoreflect.Message { 547 mi := &file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[8] 548 if protoimpl.UnsafeEnabled && x != nil { 549 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 550 if ms.LoadMessageInfo() == nil { 551 ms.StoreMessageInfo(mi) 552 } 553 return ms 554 } 555 return mi.MessageOf(x) 556} 557 558// Deprecated: Use RunJobRequest.ProtoReflect.Descriptor instead. 559func (*RunJobRequest) Descriptor() ([]byte, []int) { 560 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP(), []int{8} 561} 562 563func (x *RunJobRequest) GetName() string { 564 if x != nil { 565 return x.Name 566 } 567 return "" 568} 569 570var File_google_cloud_scheduler_v1beta1_cloudscheduler_proto protoreflect.FileDescriptor 571 572var file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDesc = []byte{ 573 0x0a, 0x33, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x73, 574 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 575 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 576 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 577 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 578 0x62, 0x65, 0x74, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 579 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 580 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 581 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 582 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 583 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 584 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 585 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x28, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 586 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 587 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x6a, 0x6f, 0x62, 0x2e, 0x70, 0x72, 0x6f, 588 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 589 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 590 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 591 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 592 0x6f, 0x22, 0x90, 0x01, 0x0a, 0x0f, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 593 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 594 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x12, 0x21, 0x63, 595 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 596 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 597 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 598 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 599 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 600 0x6b, 0x65, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 601 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x73, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 602 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x37, 0x0a, 0x04, 0x6a, 0x6f, 0x62, 0x73, 603 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 604 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 605 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6a, 0x6f, 0x62, 606 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 607 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 608 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x4e, 0x0a, 0x0d, 0x47, 0x65, 0x74, 609 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 610 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 611 0x0a, 0x21, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 612 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 613 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x91, 0x01, 0x0a, 0x10, 0x43, 0x72, 614 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 615 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 616 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x12, 0x21, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 617 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 618 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 619 0x74, 0x12, 0x3a, 0x0a, 0x03, 0x6a, 0x6f, 0x62, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 620 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 621 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 622 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x03, 0x6a, 0x6f, 0x62, 0x22, 0x8b, 0x01, 623 0x0a, 0x10, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 624 0x73, 0x74, 0x12, 0x3a, 0x0a, 0x03, 0x6a, 0x6f, 0x62, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 625 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 626 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 627 0x2e, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x03, 0x6a, 0x6f, 0x62, 0x12, 0x3b, 628 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 629 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 630 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x52, 631 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0x51, 0x0a, 0x10, 0x44, 632 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 633 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 634 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 635 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 636 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x50, 637 0x0a, 0x0f, 0x50, 0x61, 0x75, 0x73, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 638 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 639 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 640 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 641 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 642 0x22, 0x51, 0x0a, 0x10, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 643 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 644 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x63, 0x6c, 0x6f, 0x75, 645 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 646 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 647 0x61, 0x6d, 0x65, 0x22, 0x4e, 0x0a, 0x0d, 0x52, 0x75, 0x6e, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 648 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 649 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x63, 0x6c, 0x6f, 0x75, 650 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 651 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 652 0x61, 0x6d, 0x65, 0x32, 0xa6, 0x0b, 0x0a, 0x0e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x53, 0x63, 0x68, 653 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x12, 0xad, 0x01, 0x0a, 0x08, 0x4c, 0x69, 0x73, 0x74, 0x4a, 654 0x6f, 0x62, 0x73, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 655 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 656 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x71, 657 0x75, 0x65, 0x73, 0x74, 0x1a, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 658 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 659 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 660 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x3e, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2f, 0x12, 0x2d, 661 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 662 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 663 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0xda, 0x41, 0x06, 664 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x9a, 0x01, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x4a, 0x6f, 665 0x62, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 666 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 667 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 668 0x1a, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 669 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 670 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x3c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2f, 0x12, 0x2d, 0x2f, 671 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 672 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 673 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 674 0x61, 0x6d, 0x65, 0x12, 0xab, 0x01, 0x0a, 0x09, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 675 0x62, 0x12, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 676 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 677 0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 678 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 679 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 680 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x47, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 681 0x22, 0x2d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 682 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 683 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x3a, 684 0x03, 0x6a, 0x6f, 0x62, 0xda, 0x41, 0x0a, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x6a, 0x6f, 685 0x62, 0x12, 0xb4, 0x01, 0x0a, 0x09, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x12, 686 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 687 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 688 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 689 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 690 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 691 0x61, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x50, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x38, 0x32, 0x31, 692 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6a, 0x6f, 0x62, 0x2e, 0x6e, 0x61, 693 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 694 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 695 0x7d, 0x3a, 0x03, 0x6a, 0x6f, 0x62, 0xda, 0x41, 0x0f, 0x6a, 0x6f, 0x62, 0x2c, 0x75, 0x70, 0x64, 696 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x12, 0x93, 0x01, 0x0a, 0x09, 0x44, 0x65, 0x6c, 697 0x65, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 698 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 699 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4a, 0x6f, 700 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 701 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 702 0x22, 0x3c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2f, 0x2a, 0x2d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 703 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 704 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 705 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xa7, 706 0x01, 0x0a, 0x08, 0x50, 0x61, 0x75, 0x73, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 707 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 708 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x50, 0x61, 0x75, 709 0x73, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 710 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 711 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4a, 0x6f, 712 0x62, 0x22, 0x45, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x38, 0x22, 0x33, 0x2f, 0x76, 0x31, 0x62, 0x65, 713 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 714 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 715 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x70, 0x61, 0x75, 0x73, 0x65, 0x3a, 0x01, 716 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xaa, 0x01, 0x0a, 0x09, 0x52, 0x65, 0x73, 717 0x75, 0x6d, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 718 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 719 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x4a, 0x6f, 720 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 721 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 722 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x46, 0x82, 723 0xd3, 0xe4, 0x93, 0x02, 0x39, 0x22, 0x34, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 724 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 725 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 726 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x3a, 0x01, 0x2a, 0xda, 0x41, 727 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xa1, 0x01, 0x0a, 0x06, 0x52, 0x75, 0x6e, 0x4a, 0x6f, 0x62, 728 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 729 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 730 0x31, 0x2e, 0x52, 0x75, 0x6e, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 731 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 732 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 733 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x43, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x36, 0x22, 0x31, 0x2f, 0x76, 734 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 735 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 736 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x75, 0x6e, 0x3a, 737 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x51, 0xca, 0x41, 0x1d, 0x63, 0x6c, 738 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 739 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 0x74, 740 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 741 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 742 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x8b, 0x01, 0x0a, 743 0x22, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 744 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 745 0x74, 0x61, 0x31, 0x42, 0x0e, 0x53, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x50, 0x72, 746 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x47, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 747 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 748 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 749 0x75, 0x64, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2f, 0x76, 0x31, 0x62, 750 0x65, 0x74, 0x61, 0x31, 0x3b, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0xa2, 0x02, 751 0x09, 0x53, 0x43, 0x48, 0x45, 0x44, 0x55, 0x4c, 0x45, 0x52, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 752 0x6f, 0x33, 753} 754 755var ( 756 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescOnce sync.Once 757 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescData = file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDesc 758) 759 760func file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescGZIP() []byte { 761 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescOnce.Do(func() { 762 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescData) 763 }) 764 return file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDescData 765} 766 767var file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes = make([]protoimpl.MessageInfo, 9) 768var file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_goTypes = []interface{}{ 769 (*ListJobsRequest)(nil), // 0: google.cloud.scheduler.v1beta1.ListJobsRequest 770 (*ListJobsResponse)(nil), // 1: google.cloud.scheduler.v1beta1.ListJobsResponse 771 (*GetJobRequest)(nil), // 2: google.cloud.scheduler.v1beta1.GetJobRequest 772 (*CreateJobRequest)(nil), // 3: google.cloud.scheduler.v1beta1.CreateJobRequest 773 (*UpdateJobRequest)(nil), // 4: google.cloud.scheduler.v1beta1.UpdateJobRequest 774 (*DeleteJobRequest)(nil), // 5: google.cloud.scheduler.v1beta1.DeleteJobRequest 775 (*PauseJobRequest)(nil), // 6: google.cloud.scheduler.v1beta1.PauseJobRequest 776 (*ResumeJobRequest)(nil), // 7: google.cloud.scheduler.v1beta1.ResumeJobRequest 777 (*RunJobRequest)(nil), // 8: google.cloud.scheduler.v1beta1.RunJobRequest 778 (*Job)(nil), // 9: google.cloud.scheduler.v1beta1.Job 779 (*fieldmaskpb.FieldMask)(nil), // 10: google.protobuf.FieldMask 780 (*emptypb.Empty)(nil), // 11: google.protobuf.Empty 781} 782var file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_depIdxs = []int32{ 783 9, // 0: google.cloud.scheduler.v1beta1.ListJobsResponse.jobs:type_name -> google.cloud.scheduler.v1beta1.Job 784 9, // 1: google.cloud.scheduler.v1beta1.CreateJobRequest.job:type_name -> google.cloud.scheduler.v1beta1.Job 785 9, // 2: google.cloud.scheduler.v1beta1.UpdateJobRequest.job:type_name -> google.cloud.scheduler.v1beta1.Job 786 10, // 3: google.cloud.scheduler.v1beta1.UpdateJobRequest.update_mask:type_name -> google.protobuf.FieldMask 787 0, // 4: google.cloud.scheduler.v1beta1.CloudScheduler.ListJobs:input_type -> google.cloud.scheduler.v1beta1.ListJobsRequest 788 2, // 5: google.cloud.scheduler.v1beta1.CloudScheduler.GetJob:input_type -> google.cloud.scheduler.v1beta1.GetJobRequest 789 3, // 6: google.cloud.scheduler.v1beta1.CloudScheduler.CreateJob:input_type -> google.cloud.scheduler.v1beta1.CreateJobRequest 790 4, // 7: google.cloud.scheduler.v1beta1.CloudScheduler.UpdateJob:input_type -> google.cloud.scheduler.v1beta1.UpdateJobRequest 791 5, // 8: google.cloud.scheduler.v1beta1.CloudScheduler.DeleteJob:input_type -> google.cloud.scheduler.v1beta1.DeleteJobRequest 792 6, // 9: google.cloud.scheduler.v1beta1.CloudScheduler.PauseJob:input_type -> google.cloud.scheduler.v1beta1.PauseJobRequest 793 7, // 10: google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob:input_type -> google.cloud.scheduler.v1beta1.ResumeJobRequest 794 8, // 11: google.cloud.scheduler.v1beta1.CloudScheduler.RunJob:input_type -> google.cloud.scheduler.v1beta1.RunJobRequest 795 1, // 12: google.cloud.scheduler.v1beta1.CloudScheduler.ListJobs:output_type -> google.cloud.scheduler.v1beta1.ListJobsResponse 796 9, // 13: google.cloud.scheduler.v1beta1.CloudScheduler.GetJob:output_type -> google.cloud.scheduler.v1beta1.Job 797 9, // 14: google.cloud.scheduler.v1beta1.CloudScheduler.CreateJob:output_type -> google.cloud.scheduler.v1beta1.Job 798 9, // 15: google.cloud.scheduler.v1beta1.CloudScheduler.UpdateJob:output_type -> google.cloud.scheduler.v1beta1.Job 799 11, // 16: google.cloud.scheduler.v1beta1.CloudScheduler.DeleteJob:output_type -> google.protobuf.Empty 800 9, // 17: google.cloud.scheduler.v1beta1.CloudScheduler.PauseJob:output_type -> google.cloud.scheduler.v1beta1.Job 801 9, // 18: google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob:output_type -> google.cloud.scheduler.v1beta1.Job 802 9, // 19: google.cloud.scheduler.v1beta1.CloudScheduler.RunJob:output_type -> google.cloud.scheduler.v1beta1.Job 803 12, // [12:20] is the sub-list for method output_type 804 4, // [4:12] is the sub-list for method input_type 805 4, // [4:4] is the sub-list for extension type_name 806 4, // [4:4] is the sub-list for extension extendee 807 0, // [0:4] is the sub-list for field type_name 808} 809 810func init() { file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_init() } 811func file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_init() { 812 if File_google_cloud_scheduler_v1beta1_cloudscheduler_proto != nil { 813 return 814 } 815 file_google_cloud_scheduler_v1beta1_job_proto_init() 816 if !protoimpl.UnsafeEnabled { 817 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 818 switch v := v.(*ListJobsRequest); i { 819 case 0: 820 return &v.state 821 case 1: 822 return &v.sizeCache 823 case 2: 824 return &v.unknownFields 825 default: 826 return nil 827 } 828 } 829 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 830 switch v := v.(*ListJobsResponse); i { 831 case 0: 832 return &v.state 833 case 1: 834 return &v.sizeCache 835 case 2: 836 return &v.unknownFields 837 default: 838 return nil 839 } 840 } 841 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 842 switch v := v.(*GetJobRequest); i { 843 case 0: 844 return &v.state 845 case 1: 846 return &v.sizeCache 847 case 2: 848 return &v.unknownFields 849 default: 850 return nil 851 } 852 } 853 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 854 switch v := v.(*CreateJobRequest); i { 855 case 0: 856 return &v.state 857 case 1: 858 return &v.sizeCache 859 case 2: 860 return &v.unknownFields 861 default: 862 return nil 863 } 864 } 865 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 866 switch v := v.(*UpdateJobRequest); i { 867 case 0: 868 return &v.state 869 case 1: 870 return &v.sizeCache 871 case 2: 872 return &v.unknownFields 873 default: 874 return nil 875 } 876 } 877 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 878 switch v := v.(*DeleteJobRequest); i { 879 case 0: 880 return &v.state 881 case 1: 882 return &v.sizeCache 883 case 2: 884 return &v.unknownFields 885 default: 886 return nil 887 } 888 } 889 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 890 switch v := v.(*PauseJobRequest); i { 891 case 0: 892 return &v.state 893 case 1: 894 return &v.sizeCache 895 case 2: 896 return &v.unknownFields 897 default: 898 return nil 899 } 900 } 901 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 902 switch v := v.(*ResumeJobRequest); i { 903 case 0: 904 return &v.state 905 case 1: 906 return &v.sizeCache 907 case 2: 908 return &v.unknownFields 909 default: 910 return nil 911 } 912 } 913 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 914 switch v := v.(*RunJobRequest); i { 915 case 0: 916 return &v.state 917 case 1: 918 return &v.sizeCache 919 case 2: 920 return &v.unknownFields 921 default: 922 return nil 923 } 924 } 925 } 926 type x struct{} 927 out := protoimpl.TypeBuilder{ 928 File: protoimpl.DescBuilder{ 929 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 930 RawDescriptor: file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDesc, 931 NumEnums: 0, 932 NumMessages: 9, 933 NumExtensions: 0, 934 NumServices: 1, 935 }, 936 GoTypes: file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_goTypes, 937 DependencyIndexes: file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_depIdxs, 938 MessageInfos: file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_msgTypes, 939 }.Build() 940 File_google_cloud_scheduler_v1beta1_cloudscheduler_proto = out.File 941 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_rawDesc = nil 942 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_goTypes = nil 943 file_google_cloud_scheduler_v1beta1_cloudscheduler_proto_depIdxs = nil 944} 945 946// Reference imports to suppress errors if they are not otherwise used. 947var _ context.Context 948var _ grpc.ClientConnInterface 949 950// This is a compile-time assertion to ensure that this generated file 951// is compatible with the grpc package it is being compiled against. 952const _ = grpc.SupportPackageIsVersion6 953 954// CloudSchedulerClient is the client API for CloudScheduler service. 955// 956// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 957type CloudSchedulerClient interface { 958 // Lists jobs. 959 ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) 960 // Gets a job. 961 GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) 962 // Creates a job. 963 CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) 964 // Updates a job. 965 // 966 // If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job does 967 // not exist, `NOT_FOUND` is returned. 968 // 969 // If UpdateJob does not successfully return, it is possible for the 970 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job in this state may 971 // not be executed. If this happens, retry the UpdateJob request 972 // until a successful response is received. 973 UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) 974 // Deletes a job. 975 DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 976 // Pauses a job. 977 // 978 // If a job is paused then the system will stop executing the job 979 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The 980 // state of the job is stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it 981 // will be set to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] 982 // to be paused. 983 PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) 984 // Resume a job. 985 // 986 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The 987 // state of a job is stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it 988 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job must be in 989 // [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. 990 ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) 991 // Forces a job to run now. 992 // 993 // When this method is called, Cloud Scheduler will dispatch the job, even 994 // if the job is already running. 995 RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) 996} 997 998type cloudSchedulerClient struct { 999 cc grpc.ClientConnInterface 1000} 1001 1002func NewCloudSchedulerClient(cc grpc.ClientConnInterface) CloudSchedulerClient { 1003 return &cloudSchedulerClient{cc} 1004} 1005 1006func (c *cloudSchedulerClient) ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) { 1007 out := new(ListJobsResponse) 1008 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/ListJobs", in, out, opts...) 1009 if err != nil { 1010 return nil, err 1011 } 1012 return out, nil 1013} 1014 1015func (c *cloudSchedulerClient) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) { 1016 out := new(Job) 1017 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/GetJob", in, out, opts...) 1018 if err != nil { 1019 return nil, err 1020 } 1021 return out, nil 1022} 1023 1024func (c *cloudSchedulerClient) CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) { 1025 out := new(Job) 1026 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/CreateJob", in, out, opts...) 1027 if err != nil { 1028 return nil, err 1029 } 1030 return out, nil 1031} 1032 1033func (c *cloudSchedulerClient) UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) { 1034 out := new(Job) 1035 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/UpdateJob", in, out, opts...) 1036 if err != nil { 1037 return nil, err 1038 } 1039 return out, nil 1040} 1041 1042func (c *cloudSchedulerClient) DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1043 out := new(emptypb.Empty) 1044 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob", in, out, opts...) 1045 if err != nil { 1046 return nil, err 1047 } 1048 return out, nil 1049} 1050 1051func (c *cloudSchedulerClient) PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) { 1052 out := new(Job) 1053 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob", in, out, opts...) 1054 if err != nil { 1055 return nil, err 1056 } 1057 return out, nil 1058} 1059 1060func (c *cloudSchedulerClient) ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) { 1061 out := new(Job) 1062 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob", in, out, opts...) 1063 if err != nil { 1064 return nil, err 1065 } 1066 return out, nil 1067} 1068 1069func (c *cloudSchedulerClient) RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) { 1070 out := new(Job) 1071 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/RunJob", in, out, opts...) 1072 if err != nil { 1073 return nil, err 1074 } 1075 return out, nil 1076} 1077 1078// CloudSchedulerServer is the server API for CloudScheduler service. 1079type CloudSchedulerServer interface { 1080 // Lists jobs. 1081 ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) 1082 // Gets a job. 1083 GetJob(context.Context, *GetJobRequest) (*Job, error) 1084 // Creates a job. 1085 CreateJob(context.Context, *CreateJobRequest) (*Job, error) 1086 // Updates a job. 1087 // 1088 // If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job does 1089 // not exist, `NOT_FOUND` is returned. 1090 // 1091 // If UpdateJob does not successfully return, it is possible for the 1092 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job in this state may 1093 // not be executed. If this happens, retry the UpdateJob request 1094 // until a successful response is received. 1095 UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) 1096 // Deletes a job. 1097 DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error) 1098 // Pauses a job. 1099 // 1100 // If a job is paused then the system will stop executing the job 1101 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The 1102 // state of the job is stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it 1103 // will be set to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] 1104 // to be paused. 1105 PauseJob(context.Context, *PauseJobRequest) (*Job, error) 1106 // Resume a job. 1107 // 1108 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The 1109 // state of a job is stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it 1110 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job must be in 1111 // [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. 1112 ResumeJob(context.Context, *ResumeJobRequest) (*Job, error) 1113 // Forces a job to run now. 1114 // 1115 // When this method is called, Cloud Scheduler will dispatch the job, even 1116 // if the job is already running. 1117 RunJob(context.Context, *RunJobRequest) (*Job, error) 1118} 1119 1120// UnimplementedCloudSchedulerServer can be embedded to have forward compatible implementations. 1121type UnimplementedCloudSchedulerServer struct { 1122} 1123 1124func (*UnimplementedCloudSchedulerServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) { 1125 return nil, status.Errorf(codes.Unimplemented, "method ListJobs not implemented") 1126} 1127func (*UnimplementedCloudSchedulerServer) GetJob(context.Context, *GetJobRequest) (*Job, error) { 1128 return nil, status.Errorf(codes.Unimplemented, "method GetJob not implemented") 1129} 1130func (*UnimplementedCloudSchedulerServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error) { 1131 return nil, status.Errorf(codes.Unimplemented, "method CreateJob not implemented") 1132} 1133func (*UnimplementedCloudSchedulerServer) UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) { 1134 return nil, status.Errorf(codes.Unimplemented, "method UpdateJob not implemented") 1135} 1136func (*UnimplementedCloudSchedulerServer) DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error) { 1137 return nil, status.Errorf(codes.Unimplemented, "method DeleteJob not implemented") 1138} 1139func (*UnimplementedCloudSchedulerServer) PauseJob(context.Context, *PauseJobRequest) (*Job, error) { 1140 return nil, status.Errorf(codes.Unimplemented, "method PauseJob not implemented") 1141} 1142func (*UnimplementedCloudSchedulerServer) ResumeJob(context.Context, *ResumeJobRequest) (*Job, error) { 1143 return nil, status.Errorf(codes.Unimplemented, "method ResumeJob not implemented") 1144} 1145func (*UnimplementedCloudSchedulerServer) RunJob(context.Context, *RunJobRequest) (*Job, error) { 1146 return nil, status.Errorf(codes.Unimplemented, "method RunJob not implemented") 1147} 1148 1149func RegisterCloudSchedulerServer(s *grpc.Server, srv CloudSchedulerServer) { 1150 s.RegisterService(&_CloudScheduler_serviceDesc, srv) 1151} 1152 1153func _CloudScheduler_ListJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1154 in := new(ListJobsRequest) 1155 if err := dec(in); err != nil { 1156 return nil, err 1157 } 1158 if interceptor == nil { 1159 return srv.(CloudSchedulerServer).ListJobs(ctx, in) 1160 } 1161 info := &grpc.UnaryServerInfo{ 1162 Server: srv, 1163 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/ListJobs", 1164 } 1165 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1166 return srv.(CloudSchedulerServer).ListJobs(ctx, req.(*ListJobsRequest)) 1167 } 1168 return interceptor(ctx, in, info, handler) 1169} 1170 1171func _CloudScheduler_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1172 in := new(GetJobRequest) 1173 if err := dec(in); err != nil { 1174 return nil, err 1175 } 1176 if interceptor == nil { 1177 return srv.(CloudSchedulerServer).GetJob(ctx, in) 1178 } 1179 info := &grpc.UnaryServerInfo{ 1180 Server: srv, 1181 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/GetJob", 1182 } 1183 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1184 return srv.(CloudSchedulerServer).GetJob(ctx, req.(*GetJobRequest)) 1185 } 1186 return interceptor(ctx, in, info, handler) 1187} 1188 1189func _CloudScheduler_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1190 in := new(CreateJobRequest) 1191 if err := dec(in); err != nil { 1192 return nil, err 1193 } 1194 if interceptor == nil { 1195 return srv.(CloudSchedulerServer).CreateJob(ctx, in) 1196 } 1197 info := &grpc.UnaryServerInfo{ 1198 Server: srv, 1199 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/CreateJob", 1200 } 1201 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1202 return srv.(CloudSchedulerServer).CreateJob(ctx, req.(*CreateJobRequest)) 1203 } 1204 return interceptor(ctx, in, info, handler) 1205} 1206 1207func _CloudScheduler_UpdateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1208 in := new(UpdateJobRequest) 1209 if err := dec(in); err != nil { 1210 return nil, err 1211 } 1212 if interceptor == nil { 1213 return srv.(CloudSchedulerServer).UpdateJob(ctx, in) 1214 } 1215 info := &grpc.UnaryServerInfo{ 1216 Server: srv, 1217 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/UpdateJob", 1218 } 1219 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1220 return srv.(CloudSchedulerServer).UpdateJob(ctx, req.(*UpdateJobRequest)) 1221 } 1222 return interceptor(ctx, in, info, handler) 1223} 1224 1225func _CloudScheduler_DeleteJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1226 in := new(DeleteJobRequest) 1227 if err := dec(in); err != nil { 1228 return nil, err 1229 } 1230 if interceptor == nil { 1231 return srv.(CloudSchedulerServer).DeleteJob(ctx, in) 1232 } 1233 info := &grpc.UnaryServerInfo{ 1234 Server: srv, 1235 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob", 1236 } 1237 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1238 return srv.(CloudSchedulerServer).DeleteJob(ctx, req.(*DeleteJobRequest)) 1239 } 1240 return interceptor(ctx, in, info, handler) 1241} 1242 1243func _CloudScheduler_PauseJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1244 in := new(PauseJobRequest) 1245 if err := dec(in); err != nil { 1246 return nil, err 1247 } 1248 if interceptor == nil { 1249 return srv.(CloudSchedulerServer).PauseJob(ctx, in) 1250 } 1251 info := &grpc.UnaryServerInfo{ 1252 Server: srv, 1253 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob", 1254 } 1255 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1256 return srv.(CloudSchedulerServer).PauseJob(ctx, req.(*PauseJobRequest)) 1257 } 1258 return interceptor(ctx, in, info, handler) 1259} 1260 1261func _CloudScheduler_ResumeJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1262 in := new(ResumeJobRequest) 1263 if err := dec(in); err != nil { 1264 return nil, err 1265 } 1266 if interceptor == nil { 1267 return srv.(CloudSchedulerServer).ResumeJob(ctx, in) 1268 } 1269 info := &grpc.UnaryServerInfo{ 1270 Server: srv, 1271 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob", 1272 } 1273 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1274 return srv.(CloudSchedulerServer).ResumeJob(ctx, req.(*ResumeJobRequest)) 1275 } 1276 return interceptor(ctx, in, info, handler) 1277} 1278 1279func _CloudScheduler_RunJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1280 in := new(RunJobRequest) 1281 if err := dec(in); err != nil { 1282 return nil, err 1283 } 1284 if interceptor == nil { 1285 return srv.(CloudSchedulerServer).RunJob(ctx, in) 1286 } 1287 info := &grpc.UnaryServerInfo{ 1288 Server: srv, 1289 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/RunJob", 1290 } 1291 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1292 return srv.(CloudSchedulerServer).RunJob(ctx, req.(*RunJobRequest)) 1293 } 1294 return interceptor(ctx, in, info, handler) 1295} 1296 1297var _CloudScheduler_serviceDesc = grpc.ServiceDesc{ 1298 ServiceName: "google.cloud.scheduler.v1beta1.CloudScheduler", 1299 HandlerType: (*CloudSchedulerServer)(nil), 1300 Methods: []grpc.MethodDesc{ 1301 { 1302 MethodName: "ListJobs", 1303 Handler: _CloudScheduler_ListJobs_Handler, 1304 }, 1305 { 1306 MethodName: "GetJob", 1307 Handler: _CloudScheduler_GetJob_Handler, 1308 }, 1309 { 1310 MethodName: "CreateJob", 1311 Handler: _CloudScheduler_CreateJob_Handler, 1312 }, 1313 { 1314 MethodName: "UpdateJob", 1315 Handler: _CloudScheduler_UpdateJob_Handler, 1316 }, 1317 { 1318 MethodName: "DeleteJob", 1319 Handler: _CloudScheduler_DeleteJob_Handler, 1320 }, 1321 { 1322 MethodName: "PauseJob", 1323 Handler: _CloudScheduler_PauseJob_Handler, 1324 }, 1325 { 1326 MethodName: "ResumeJob", 1327 Handler: _CloudScheduler_ResumeJob_Handler, 1328 }, 1329 { 1330 MethodName: "RunJob", 1331 Handler: _CloudScheduler_RunJob_Handler, 1332 }, 1333 }, 1334 Streams: []grpc.StreamDesc{}, 1335 Metadata: "google/cloud/scheduler/v1beta1/cloudscheduler.proto", 1336} 1337