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