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/v1/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.v1.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.v1.ListJobsResponse.next_page_token] returned from 71 // the previous call to [ListJobs][google.cloud.scheduler.v1.CloudScheduler.ListJobs]. It is an error to 72 // switch the value of [filter][google.cloud.scheduler.v1.ListJobsRequest.filter] or 73 // [order_by][google.cloud.scheduler.v1.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_v1_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_v1_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_v1_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.v1.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.v1.ListJobsRequest.page_token] field in the subsequent call to 140 // [ListJobs][google.cloud.scheduler.v1.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_v1_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_v1_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_v1_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.v1.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_v1_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_v1_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_v1_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.v1.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.v1.Job.name]. [name][google.cloud.scheduler.v1.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.v1.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_v1_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_v1_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_v1_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.v1.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.v1.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_v1_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_v1_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_v1_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.v1.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_v1_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_v1_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_v1_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.v1.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_v1_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_v1_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_v1_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.v1.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_v1_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_v1_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_v1_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.v1.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_v1_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_v1_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_v1_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_v1_cloudscheduler_proto protoreflect.FileDescriptor 571 572var file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDesc = []byte{ 573 0x0a, 0x2e, 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, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 575 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 576 0x12, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 577 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 578 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 579 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 580 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 581 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 582 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 583 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 584 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x23, 585 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x73, 0x63, 0x68, 586 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2f, 0x76, 0x31, 0x2f, 0x6a, 0x6f, 0x62, 0x2e, 0x70, 0x72, 587 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 588 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 589 0x1a, 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 590 0x66, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x2e, 0x70, 0x72, 0x6f, 591 0x74, 0x6f, 0x22, 0x90, 0x01, 0x0a, 0x0f, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 592 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 593 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x12, 0x21, 594 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 595 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 596 0x62, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 597 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 598 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 599 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 600 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x6e, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 601 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x32, 0x0a, 0x04, 0x6a, 0x6f, 0x62, 602 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 603 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 604 0x2e, 0x76, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6a, 0x6f, 0x62, 0x73, 0x12, 0x26, 0x0a, 605 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 606 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 607 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x4e, 0x0a, 0x0d, 0x47, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x52, 608 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 609 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x63, 0x6c, 610 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 611 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 612 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x8c, 0x01, 0x0a, 0x10, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 613 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 614 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 615 0x41, 0x23, 0x12, 0x21, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 616 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 617 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x35, 0x0a, 618 0x03, 0x6a, 0x6f, 0x62, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 619 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 620 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 621 0x03, 0x6a, 0x6f, 0x62, 0x22, 0x8b, 0x01, 0x0a, 0x10, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4a, 622 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x35, 0x0a, 0x03, 0x6a, 0x6f, 0x62, 623 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 624 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 625 0x76, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x03, 0x6a, 0x6f, 0x62, 626 0x12, 0x40, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 627 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 628 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 629 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x61, 630 0x73, 0x6b, 0x22, 0x51, 0x0a, 0x10, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 631 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 632 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x63, 0x6c, 633 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 634 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 635 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x50, 0x0a, 0x0f, 0x50, 0x61, 0x75, 0x73, 0x65, 0x4a, 0x6f, 636 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 637 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 638 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x67, 639 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a, 0x6f, 640 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x51, 0x0a, 0x10, 0x52, 0x65, 0x73, 0x75, 0x6d, 641 0x65, 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, 0x22, 0x4e, 0x0a, 0x0d, 0x52, 0x75, 646 0x6e, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 647 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 648 0x23, 0x0a, 0x21, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 649 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 650 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x32, 0xb3, 0x0a, 0x0a, 0x0e, 0x43, 651 0x6c, 0x6f, 0x75, 0x64, 0x53, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x12, 0x9e, 0x01, 652 0x0a, 0x08, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x12, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 653 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 654 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 655 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 656 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 657 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 658 0x6e, 0x73, 0x65, 0x22, 0x39, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a, 0x12, 0x28, 0x2f, 0x76, 0x31, 659 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 660 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 661 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x8b, 662 0x01, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 663 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 664 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 665 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 666 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 667 0x4a, 0x6f, 0x62, 0x22, 0x37, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a, 0x12, 0x28, 0x2f, 0x76, 0x31, 668 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 669 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 670 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x9c, 0x01, 0x0a, 671 0x09, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 672 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 673 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 674 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 675 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 676 0x2e, 0x76, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x42, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2f, 0x22, 677 0x28, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 678 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 679 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x3a, 0x03, 0x6a, 0x6f, 0x62, 0xda, 0x41, 680 0x0a, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x6a, 0x6f, 0x62, 0x12, 0xa5, 0x01, 0x0a, 0x09, 681 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 682 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 683 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 684 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 685 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 686 0x76, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x4b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x33, 0x32, 0x2c, 687 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6a, 0x6f, 0x62, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 688 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 689 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x03, 0x6a, 0x6f, 690 0x62, 0xda, 0x41, 0x0f, 0x6a, 0x6f, 0x62, 0x2c, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 691 0x61, 0x73, 0x6b, 0x12, 0x89, 0x01, 0x0a, 0x09, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4a, 0x6f, 692 0x62, 0x12, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 693 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 694 0x6c, 0x65, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 695 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 696 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x37, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a, 0x2a, 0x28, 697 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 698 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 699 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 700 0x98, 0x01, 0x0a, 0x08, 0x50, 0x61, 0x75, 0x73, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x2a, 0x2e, 0x67, 701 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 702 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x61, 0x75, 0x73, 0x65, 0x4a, 0x6f, 703 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 704 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 705 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x40, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x33, 706 0x22, 0x2e, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 707 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 708 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x70, 0x61, 0x75, 0x73, 0x65, 709 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x9b, 0x01, 0x0a, 0x09, 0x52, 710 0x65, 0x73, 0x75, 0x6d, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 711 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 712 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 713 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 714 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 715 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x41, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x22, 0x2f, 0x2f, 716 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 717 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 718 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x3a, 0x01, 719 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x92, 0x01, 0x0a, 0x06, 0x52, 0x75, 0x6e, 720 0x4a, 0x6f, 0x62, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 721 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 722 0x52, 0x75, 0x6e, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 723 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 724 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x3e, 0x82, 725 0xd3, 0xe4, 0x93, 0x02, 0x31, 0x22, 0x2c, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 726 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 727 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 728 0x72, 0x75, 0x6e, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x51, 0xca, 729 0x41, 0x1d, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 730 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 731 0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 732 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 733 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 734 0x42, 0x81, 0x01, 0x0a, 0x1d, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 735 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2e, 736 0x76, 0x31, 0x42, 0x0e, 0x53, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x50, 0x72, 0x6f, 737 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x42, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 738 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 739 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 740 0x64, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0x2f, 0x76, 0x31, 0x3b, 0x73, 741 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x72, 0xa2, 0x02, 0x09, 0x53, 0x43, 0x48, 0x45, 0x44, 742 0x55, 0x4c, 0x45, 0x52, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 743} 744 745var ( 746 file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDescOnce sync.Once 747 file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDescData = file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDesc 748) 749 750func file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDescGZIP() []byte { 751 file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDescOnce.Do(func() { 752 file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDescData) 753 }) 754 return file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDescData 755} 756 757var file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes = make([]protoimpl.MessageInfo, 9) 758var file_google_cloud_scheduler_v1_cloudscheduler_proto_goTypes = []interface{}{ 759 (*ListJobsRequest)(nil), // 0: google.cloud.scheduler.v1.ListJobsRequest 760 (*ListJobsResponse)(nil), // 1: google.cloud.scheduler.v1.ListJobsResponse 761 (*GetJobRequest)(nil), // 2: google.cloud.scheduler.v1.GetJobRequest 762 (*CreateJobRequest)(nil), // 3: google.cloud.scheduler.v1.CreateJobRequest 763 (*UpdateJobRequest)(nil), // 4: google.cloud.scheduler.v1.UpdateJobRequest 764 (*DeleteJobRequest)(nil), // 5: google.cloud.scheduler.v1.DeleteJobRequest 765 (*PauseJobRequest)(nil), // 6: google.cloud.scheduler.v1.PauseJobRequest 766 (*ResumeJobRequest)(nil), // 7: google.cloud.scheduler.v1.ResumeJobRequest 767 (*RunJobRequest)(nil), // 8: google.cloud.scheduler.v1.RunJobRequest 768 (*Job)(nil), // 9: google.cloud.scheduler.v1.Job 769 (*fieldmaskpb.FieldMask)(nil), // 10: google.protobuf.FieldMask 770 (*emptypb.Empty)(nil), // 11: google.protobuf.Empty 771} 772var file_google_cloud_scheduler_v1_cloudscheduler_proto_depIdxs = []int32{ 773 9, // 0: google.cloud.scheduler.v1.ListJobsResponse.jobs:type_name -> google.cloud.scheduler.v1.Job 774 9, // 1: google.cloud.scheduler.v1.CreateJobRequest.job:type_name -> google.cloud.scheduler.v1.Job 775 9, // 2: google.cloud.scheduler.v1.UpdateJobRequest.job:type_name -> google.cloud.scheduler.v1.Job 776 10, // 3: google.cloud.scheduler.v1.UpdateJobRequest.update_mask:type_name -> google.protobuf.FieldMask 777 0, // 4: google.cloud.scheduler.v1.CloudScheduler.ListJobs:input_type -> google.cloud.scheduler.v1.ListJobsRequest 778 2, // 5: google.cloud.scheduler.v1.CloudScheduler.GetJob:input_type -> google.cloud.scheduler.v1.GetJobRequest 779 3, // 6: google.cloud.scheduler.v1.CloudScheduler.CreateJob:input_type -> google.cloud.scheduler.v1.CreateJobRequest 780 4, // 7: google.cloud.scheduler.v1.CloudScheduler.UpdateJob:input_type -> google.cloud.scheduler.v1.UpdateJobRequest 781 5, // 8: google.cloud.scheduler.v1.CloudScheduler.DeleteJob:input_type -> google.cloud.scheduler.v1.DeleteJobRequest 782 6, // 9: google.cloud.scheduler.v1.CloudScheduler.PauseJob:input_type -> google.cloud.scheduler.v1.PauseJobRequest 783 7, // 10: google.cloud.scheduler.v1.CloudScheduler.ResumeJob:input_type -> google.cloud.scheduler.v1.ResumeJobRequest 784 8, // 11: google.cloud.scheduler.v1.CloudScheduler.RunJob:input_type -> google.cloud.scheduler.v1.RunJobRequest 785 1, // 12: google.cloud.scheduler.v1.CloudScheduler.ListJobs:output_type -> google.cloud.scheduler.v1.ListJobsResponse 786 9, // 13: google.cloud.scheduler.v1.CloudScheduler.GetJob:output_type -> google.cloud.scheduler.v1.Job 787 9, // 14: google.cloud.scheduler.v1.CloudScheduler.CreateJob:output_type -> google.cloud.scheduler.v1.Job 788 9, // 15: google.cloud.scheduler.v1.CloudScheduler.UpdateJob:output_type -> google.cloud.scheduler.v1.Job 789 11, // 16: google.cloud.scheduler.v1.CloudScheduler.DeleteJob:output_type -> google.protobuf.Empty 790 9, // 17: google.cloud.scheduler.v1.CloudScheduler.PauseJob:output_type -> google.cloud.scheduler.v1.Job 791 9, // 18: google.cloud.scheduler.v1.CloudScheduler.ResumeJob:output_type -> google.cloud.scheduler.v1.Job 792 9, // 19: google.cloud.scheduler.v1.CloudScheduler.RunJob:output_type -> google.cloud.scheduler.v1.Job 793 12, // [12:20] is the sub-list for method output_type 794 4, // [4:12] is the sub-list for method input_type 795 4, // [4:4] is the sub-list for extension type_name 796 4, // [4:4] is the sub-list for extension extendee 797 0, // [0:4] is the sub-list for field type_name 798} 799 800func init() { file_google_cloud_scheduler_v1_cloudscheduler_proto_init() } 801func file_google_cloud_scheduler_v1_cloudscheduler_proto_init() { 802 if File_google_cloud_scheduler_v1_cloudscheduler_proto != nil { 803 return 804 } 805 file_google_cloud_scheduler_v1_job_proto_init() 806 if !protoimpl.UnsafeEnabled { 807 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 808 switch v := v.(*ListJobsRequest); i { 809 case 0: 810 return &v.state 811 case 1: 812 return &v.sizeCache 813 case 2: 814 return &v.unknownFields 815 default: 816 return nil 817 } 818 } 819 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 820 switch v := v.(*ListJobsResponse); i { 821 case 0: 822 return &v.state 823 case 1: 824 return &v.sizeCache 825 case 2: 826 return &v.unknownFields 827 default: 828 return nil 829 } 830 } 831 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 832 switch v := v.(*GetJobRequest); i { 833 case 0: 834 return &v.state 835 case 1: 836 return &v.sizeCache 837 case 2: 838 return &v.unknownFields 839 default: 840 return nil 841 } 842 } 843 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 844 switch v := v.(*CreateJobRequest); i { 845 case 0: 846 return &v.state 847 case 1: 848 return &v.sizeCache 849 case 2: 850 return &v.unknownFields 851 default: 852 return nil 853 } 854 } 855 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 856 switch v := v.(*UpdateJobRequest); i { 857 case 0: 858 return &v.state 859 case 1: 860 return &v.sizeCache 861 case 2: 862 return &v.unknownFields 863 default: 864 return nil 865 } 866 } 867 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 868 switch v := v.(*DeleteJobRequest); i { 869 case 0: 870 return &v.state 871 case 1: 872 return &v.sizeCache 873 case 2: 874 return &v.unknownFields 875 default: 876 return nil 877 } 878 } 879 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 880 switch v := v.(*PauseJobRequest); i { 881 case 0: 882 return &v.state 883 case 1: 884 return &v.sizeCache 885 case 2: 886 return &v.unknownFields 887 default: 888 return nil 889 } 890 } 891 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 892 switch v := v.(*ResumeJobRequest); i { 893 case 0: 894 return &v.state 895 case 1: 896 return &v.sizeCache 897 case 2: 898 return &v.unknownFields 899 default: 900 return nil 901 } 902 } 903 file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 904 switch v := v.(*RunJobRequest); i { 905 case 0: 906 return &v.state 907 case 1: 908 return &v.sizeCache 909 case 2: 910 return &v.unknownFields 911 default: 912 return nil 913 } 914 } 915 } 916 type x struct{} 917 out := protoimpl.TypeBuilder{ 918 File: protoimpl.DescBuilder{ 919 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 920 RawDescriptor: file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDesc, 921 NumEnums: 0, 922 NumMessages: 9, 923 NumExtensions: 0, 924 NumServices: 1, 925 }, 926 GoTypes: file_google_cloud_scheduler_v1_cloudscheduler_proto_goTypes, 927 DependencyIndexes: file_google_cloud_scheduler_v1_cloudscheduler_proto_depIdxs, 928 MessageInfos: file_google_cloud_scheduler_v1_cloudscheduler_proto_msgTypes, 929 }.Build() 930 File_google_cloud_scheduler_v1_cloudscheduler_proto = out.File 931 file_google_cloud_scheduler_v1_cloudscheduler_proto_rawDesc = nil 932 file_google_cloud_scheduler_v1_cloudscheduler_proto_goTypes = nil 933 file_google_cloud_scheduler_v1_cloudscheduler_proto_depIdxs = nil 934} 935 936// Reference imports to suppress errors if they are not otherwise used. 937var _ context.Context 938var _ grpc.ClientConnInterface 939 940// This is a compile-time assertion to ensure that this generated file 941// is compatible with the grpc package it is being compiled against. 942const _ = grpc.SupportPackageIsVersion6 943 944// CloudSchedulerClient is the client API for CloudScheduler service. 945// 946// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 947type CloudSchedulerClient interface { 948 // Lists jobs. 949 ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) 950 // Gets a job. 951 GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) 952 // Creates a job. 953 CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) 954 // Updates a job. 955 // 956 // If successful, the updated [Job][google.cloud.scheduler.v1.Job] is returned. If the job does 957 // not exist, `NOT_FOUND` is returned. 958 // 959 // If UpdateJob does not successfully return, it is possible for the 960 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1.Job.State.UPDATE_FAILED] state. A job in this state may 961 // not be executed. If this happens, retry the UpdateJob request 962 // until a successful response is received. 963 UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) 964 // Deletes a job. 965 DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 966 // Pauses a job. 967 // 968 // If a job is paused then the system will stop executing the job 969 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1.CloudScheduler.ResumeJob]. The 970 // state of the job is stored in [state][google.cloud.scheduler.v1.Job.state]; if paused it 971 // 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] 972 // to be paused. 973 PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) 974 // Resume a job. 975 // 976 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED]. The 977 // state of a job is stored in [Job.state][google.cloud.scheduler.v1.Job.state]; after calling this method it 978 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1.Job.State.ENABLED]. A job must be in 979 // [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED] to be resumed. 980 ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) 981 // Forces a job to run now. 982 // 983 // When this method is called, Cloud Scheduler will dispatch the job, even 984 // if the job is already running. 985 RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) 986} 987 988type cloudSchedulerClient struct { 989 cc grpc.ClientConnInterface 990} 991 992func NewCloudSchedulerClient(cc grpc.ClientConnInterface) CloudSchedulerClient { 993 return &cloudSchedulerClient{cc} 994} 995 996func (c *cloudSchedulerClient) ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) { 997 out := new(ListJobsResponse) 998 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/ListJobs", in, out, opts...) 999 if err != nil { 1000 return nil, err 1001 } 1002 return out, nil 1003} 1004 1005func (c *cloudSchedulerClient) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) { 1006 out := new(Job) 1007 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/GetJob", in, out, opts...) 1008 if err != nil { 1009 return nil, err 1010 } 1011 return out, nil 1012} 1013 1014func (c *cloudSchedulerClient) CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) { 1015 out := new(Job) 1016 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/CreateJob", in, out, opts...) 1017 if err != nil { 1018 return nil, err 1019 } 1020 return out, nil 1021} 1022 1023func (c *cloudSchedulerClient) UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) { 1024 out := new(Job) 1025 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/UpdateJob", in, out, opts...) 1026 if err != nil { 1027 return nil, err 1028 } 1029 return out, nil 1030} 1031 1032func (c *cloudSchedulerClient) DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1033 out := new(emptypb.Empty) 1034 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/DeleteJob", in, out, opts...) 1035 if err != nil { 1036 return nil, err 1037 } 1038 return out, nil 1039} 1040 1041func (c *cloudSchedulerClient) PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) { 1042 out := new(Job) 1043 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/PauseJob", in, out, opts...) 1044 if err != nil { 1045 return nil, err 1046 } 1047 return out, nil 1048} 1049 1050func (c *cloudSchedulerClient) ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) { 1051 out := new(Job) 1052 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/ResumeJob", in, out, opts...) 1053 if err != nil { 1054 return nil, err 1055 } 1056 return out, nil 1057} 1058 1059func (c *cloudSchedulerClient) RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) { 1060 out := new(Job) 1061 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/RunJob", in, out, opts...) 1062 if err != nil { 1063 return nil, err 1064 } 1065 return out, nil 1066} 1067 1068// CloudSchedulerServer is the server API for CloudScheduler service. 1069type CloudSchedulerServer interface { 1070 // Lists jobs. 1071 ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) 1072 // Gets a job. 1073 GetJob(context.Context, *GetJobRequest) (*Job, error) 1074 // Creates a job. 1075 CreateJob(context.Context, *CreateJobRequest) (*Job, error) 1076 // Updates a job. 1077 // 1078 // If successful, the updated [Job][google.cloud.scheduler.v1.Job] is returned. If the job does 1079 // not exist, `NOT_FOUND` is returned. 1080 // 1081 // If UpdateJob does not successfully return, it is possible for the 1082 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1.Job.State.UPDATE_FAILED] state. A job in this state may 1083 // not be executed. If this happens, retry the UpdateJob request 1084 // until a successful response is received. 1085 UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) 1086 // Deletes a job. 1087 DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error) 1088 // Pauses a job. 1089 // 1090 // If a job is paused then the system will stop executing the job 1091 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1.CloudScheduler.ResumeJob]. The 1092 // state of the job is stored in [state][google.cloud.scheduler.v1.Job.state]; if paused it 1093 // 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] 1094 // to be paused. 1095 PauseJob(context.Context, *PauseJobRequest) (*Job, error) 1096 // Resume a job. 1097 // 1098 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED]. The 1099 // state of a job is stored in [Job.state][google.cloud.scheduler.v1.Job.state]; after calling this method it 1100 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1.Job.State.ENABLED]. A job must be in 1101 // [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED] to be resumed. 1102 ResumeJob(context.Context, *ResumeJobRequest) (*Job, error) 1103 // Forces a job to run now. 1104 // 1105 // When this method is called, Cloud Scheduler will dispatch the job, even 1106 // if the job is already running. 1107 RunJob(context.Context, *RunJobRequest) (*Job, error) 1108} 1109 1110// UnimplementedCloudSchedulerServer can be embedded to have forward compatible implementations. 1111type UnimplementedCloudSchedulerServer struct { 1112} 1113 1114func (*UnimplementedCloudSchedulerServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) { 1115 return nil, status.Errorf(codes.Unimplemented, "method ListJobs not implemented") 1116} 1117func (*UnimplementedCloudSchedulerServer) GetJob(context.Context, *GetJobRequest) (*Job, error) { 1118 return nil, status.Errorf(codes.Unimplemented, "method GetJob not implemented") 1119} 1120func (*UnimplementedCloudSchedulerServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error) { 1121 return nil, status.Errorf(codes.Unimplemented, "method CreateJob not implemented") 1122} 1123func (*UnimplementedCloudSchedulerServer) UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) { 1124 return nil, status.Errorf(codes.Unimplemented, "method UpdateJob not implemented") 1125} 1126func (*UnimplementedCloudSchedulerServer) DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error) { 1127 return nil, status.Errorf(codes.Unimplemented, "method DeleteJob not implemented") 1128} 1129func (*UnimplementedCloudSchedulerServer) PauseJob(context.Context, *PauseJobRequest) (*Job, error) { 1130 return nil, status.Errorf(codes.Unimplemented, "method PauseJob not implemented") 1131} 1132func (*UnimplementedCloudSchedulerServer) ResumeJob(context.Context, *ResumeJobRequest) (*Job, error) { 1133 return nil, status.Errorf(codes.Unimplemented, "method ResumeJob not implemented") 1134} 1135func (*UnimplementedCloudSchedulerServer) RunJob(context.Context, *RunJobRequest) (*Job, error) { 1136 return nil, status.Errorf(codes.Unimplemented, "method RunJob not implemented") 1137} 1138 1139func RegisterCloudSchedulerServer(s *grpc.Server, srv CloudSchedulerServer) { 1140 s.RegisterService(&_CloudScheduler_serviceDesc, srv) 1141} 1142 1143func _CloudScheduler_ListJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1144 in := new(ListJobsRequest) 1145 if err := dec(in); err != nil { 1146 return nil, err 1147 } 1148 if interceptor == nil { 1149 return srv.(CloudSchedulerServer).ListJobs(ctx, in) 1150 } 1151 info := &grpc.UnaryServerInfo{ 1152 Server: srv, 1153 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/ListJobs", 1154 } 1155 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1156 return srv.(CloudSchedulerServer).ListJobs(ctx, req.(*ListJobsRequest)) 1157 } 1158 return interceptor(ctx, in, info, handler) 1159} 1160 1161func _CloudScheduler_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1162 in := new(GetJobRequest) 1163 if err := dec(in); err != nil { 1164 return nil, err 1165 } 1166 if interceptor == nil { 1167 return srv.(CloudSchedulerServer).GetJob(ctx, in) 1168 } 1169 info := &grpc.UnaryServerInfo{ 1170 Server: srv, 1171 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/GetJob", 1172 } 1173 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1174 return srv.(CloudSchedulerServer).GetJob(ctx, req.(*GetJobRequest)) 1175 } 1176 return interceptor(ctx, in, info, handler) 1177} 1178 1179func _CloudScheduler_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1180 in := new(CreateJobRequest) 1181 if err := dec(in); err != nil { 1182 return nil, err 1183 } 1184 if interceptor == nil { 1185 return srv.(CloudSchedulerServer).CreateJob(ctx, in) 1186 } 1187 info := &grpc.UnaryServerInfo{ 1188 Server: srv, 1189 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/CreateJob", 1190 } 1191 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1192 return srv.(CloudSchedulerServer).CreateJob(ctx, req.(*CreateJobRequest)) 1193 } 1194 return interceptor(ctx, in, info, handler) 1195} 1196 1197func _CloudScheduler_UpdateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1198 in := new(UpdateJobRequest) 1199 if err := dec(in); err != nil { 1200 return nil, err 1201 } 1202 if interceptor == nil { 1203 return srv.(CloudSchedulerServer).UpdateJob(ctx, in) 1204 } 1205 info := &grpc.UnaryServerInfo{ 1206 Server: srv, 1207 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/UpdateJob", 1208 } 1209 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1210 return srv.(CloudSchedulerServer).UpdateJob(ctx, req.(*UpdateJobRequest)) 1211 } 1212 return interceptor(ctx, in, info, handler) 1213} 1214 1215func _CloudScheduler_DeleteJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1216 in := new(DeleteJobRequest) 1217 if err := dec(in); err != nil { 1218 return nil, err 1219 } 1220 if interceptor == nil { 1221 return srv.(CloudSchedulerServer).DeleteJob(ctx, in) 1222 } 1223 info := &grpc.UnaryServerInfo{ 1224 Server: srv, 1225 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/DeleteJob", 1226 } 1227 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1228 return srv.(CloudSchedulerServer).DeleteJob(ctx, req.(*DeleteJobRequest)) 1229 } 1230 return interceptor(ctx, in, info, handler) 1231} 1232 1233func _CloudScheduler_PauseJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1234 in := new(PauseJobRequest) 1235 if err := dec(in); err != nil { 1236 return nil, err 1237 } 1238 if interceptor == nil { 1239 return srv.(CloudSchedulerServer).PauseJob(ctx, in) 1240 } 1241 info := &grpc.UnaryServerInfo{ 1242 Server: srv, 1243 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/PauseJob", 1244 } 1245 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1246 return srv.(CloudSchedulerServer).PauseJob(ctx, req.(*PauseJobRequest)) 1247 } 1248 return interceptor(ctx, in, info, handler) 1249} 1250 1251func _CloudScheduler_ResumeJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1252 in := new(ResumeJobRequest) 1253 if err := dec(in); err != nil { 1254 return nil, err 1255 } 1256 if interceptor == nil { 1257 return srv.(CloudSchedulerServer).ResumeJob(ctx, in) 1258 } 1259 info := &grpc.UnaryServerInfo{ 1260 Server: srv, 1261 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/ResumeJob", 1262 } 1263 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1264 return srv.(CloudSchedulerServer).ResumeJob(ctx, req.(*ResumeJobRequest)) 1265 } 1266 return interceptor(ctx, in, info, handler) 1267} 1268 1269func _CloudScheduler_RunJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1270 in := new(RunJobRequest) 1271 if err := dec(in); err != nil { 1272 return nil, err 1273 } 1274 if interceptor == nil { 1275 return srv.(CloudSchedulerServer).RunJob(ctx, in) 1276 } 1277 info := &grpc.UnaryServerInfo{ 1278 Server: srv, 1279 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/RunJob", 1280 } 1281 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1282 return srv.(CloudSchedulerServer).RunJob(ctx, req.(*RunJobRequest)) 1283 } 1284 return interceptor(ctx, in, info, handler) 1285} 1286 1287var _CloudScheduler_serviceDesc = grpc.ServiceDesc{ 1288 ServiceName: "google.cloud.scheduler.v1.CloudScheduler", 1289 HandlerType: (*CloudSchedulerServer)(nil), 1290 Methods: []grpc.MethodDesc{ 1291 { 1292 MethodName: "ListJobs", 1293 Handler: _CloudScheduler_ListJobs_Handler, 1294 }, 1295 { 1296 MethodName: "GetJob", 1297 Handler: _CloudScheduler_GetJob_Handler, 1298 }, 1299 { 1300 MethodName: "CreateJob", 1301 Handler: _CloudScheduler_CreateJob_Handler, 1302 }, 1303 { 1304 MethodName: "UpdateJob", 1305 Handler: _CloudScheduler_UpdateJob_Handler, 1306 }, 1307 { 1308 MethodName: "DeleteJob", 1309 Handler: _CloudScheduler_DeleteJob_Handler, 1310 }, 1311 { 1312 MethodName: "PauseJob", 1313 Handler: _CloudScheduler_PauseJob_Handler, 1314 }, 1315 { 1316 MethodName: "ResumeJob", 1317 Handler: _CloudScheduler_ResumeJob_Handler, 1318 }, 1319 { 1320 MethodName: "RunJob", 1321 Handler: _CloudScheduler_RunJob_Handler, 1322 }, 1323 }, 1324 Streams: []grpc.StreamDesc{}, 1325 Metadata: "google/cloud/scheduler/v1/cloudscheduler.proto", 1326} 1327