1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/scheduler/v1/cloudscheduler.proto 3 4package scheduler 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 empty "github.com/golang/protobuf/ptypes/empty" 13 _ "google.golang.org/genproto/googleapis/api/annotations" 14 field_mask "google.golang.org/genproto/protobuf/field_mask" 15 grpc "google.golang.org/grpc" 16) 17 18// Reference imports to suppress errors if they are not otherwise used. 19var _ = proto.Marshal 20var _ = fmt.Errorf 21var _ = math.Inf 22 23// This is a compile-time assertion to ensure that this generated file 24// is compatible with the proto package it is being compiled against. 25// A compilation error at this line likely means your copy of the 26// proto package needs to be updated. 27const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 28 29// Request message for listing jobs using [ListJobs][google.cloud.scheduler.v1.CloudScheduler.ListJobs]. 30type ListJobsRequest struct { 31 // Required. 32 // 33 // The location name. For example: 34 // `projects/PROJECT_ID/locations/LOCATION_ID`. 35 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 36 // Requested page size. 37 // 38 // The maximum page size is 500. If unspecified, the page size will 39 // be the maximum. Fewer jobs than requested might be returned, 40 // even if more jobs exist; use next_page_token to determine if more 41 // jobs exist. 42 PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 43 // A token identifying a page of results the server will return. To 44 // request the first page results, page_token must be empty. To 45 // request the next page of results, page_token must be the value of 46 // [next_page_token][google.cloud.scheduler.v1.ListJobsResponse.next_page_token] returned from 47 // the previous call to [ListJobs][google.cloud.scheduler.v1.CloudScheduler.ListJobs]. It is an error to 48 // switch the value of [filter][google.cloud.scheduler.v1.ListJobsRequest.filter] or 49 // [order_by][google.cloud.scheduler.v1.ListJobsRequest.order_by] while iterating through pages. 50 PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 51 XXX_NoUnkeyedLiteral struct{} `json:"-"` 52 XXX_unrecognized []byte `json:"-"` 53 XXX_sizecache int32 `json:"-"` 54} 55 56func (m *ListJobsRequest) Reset() { *m = ListJobsRequest{} } 57func (m *ListJobsRequest) String() string { return proto.CompactTextString(m) } 58func (*ListJobsRequest) ProtoMessage() {} 59func (*ListJobsRequest) Descriptor() ([]byte, []int) { 60 return fileDescriptor_329fd147d63dc799, []int{0} 61} 62 63func (m *ListJobsRequest) XXX_Unmarshal(b []byte) error { 64 return xxx_messageInfo_ListJobsRequest.Unmarshal(m, b) 65} 66func (m *ListJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 67 return xxx_messageInfo_ListJobsRequest.Marshal(b, m, deterministic) 68} 69func (m *ListJobsRequest) XXX_Merge(src proto.Message) { 70 xxx_messageInfo_ListJobsRequest.Merge(m, src) 71} 72func (m *ListJobsRequest) XXX_Size() int { 73 return xxx_messageInfo_ListJobsRequest.Size(m) 74} 75func (m *ListJobsRequest) XXX_DiscardUnknown() { 76 xxx_messageInfo_ListJobsRequest.DiscardUnknown(m) 77} 78 79var xxx_messageInfo_ListJobsRequest proto.InternalMessageInfo 80 81func (m *ListJobsRequest) GetParent() string { 82 if m != nil { 83 return m.Parent 84 } 85 return "" 86} 87 88func (m *ListJobsRequest) GetPageSize() int32 { 89 if m != nil { 90 return m.PageSize 91 } 92 return 0 93} 94 95func (m *ListJobsRequest) GetPageToken() string { 96 if m != nil { 97 return m.PageToken 98 } 99 return "" 100} 101 102// Response message for listing jobs using [ListJobs][google.cloud.scheduler.v1.CloudScheduler.ListJobs]. 103type ListJobsResponse struct { 104 // The list of jobs. 105 Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` 106 // A token to retrieve next page of results. Pass this value in the 107 // [page_token][google.cloud.scheduler.v1.ListJobsRequest.page_token] field in the subsequent call to 108 // [ListJobs][google.cloud.scheduler.v1.CloudScheduler.ListJobs] to retrieve the next page of results. 109 // If this is empty it indicates that there are no more results 110 // through which to paginate. 111 // 112 // The page token is valid for only 2 hours. 113 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 114 XXX_NoUnkeyedLiteral struct{} `json:"-"` 115 XXX_unrecognized []byte `json:"-"` 116 XXX_sizecache int32 `json:"-"` 117} 118 119func (m *ListJobsResponse) Reset() { *m = ListJobsResponse{} } 120func (m *ListJobsResponse) String() string { return proto.CompactTextString(m) } 121func (*ListJobsResponse) ProtoMessage() {} 122func (*ListJobsResponse) Descriptor() ([]byte, []int) { 123 return fileDescriptor_329fd147d63dc799, []int{1} 124} 125 126func (m *ListJobsResponse) XXX_Unmarshal(b []byte) error { 127 return xxx_messageInfo_ListJobsResponse.Unmarshal(m, b) 128} 129func (m *ListJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 130 return xxx_messageInfo_ListJobsResponse.Marshal(b, m, deterministic) 131} 132func (m *ListJobsResponse) XXX_Merge(src proto.Message) { 133 xxx_messageInfo_ListJobsResponse.Merge(m, src) 134} 135func (m *ListJobsResponse) XXX_Size() int { 136 return xxx_messageInfo_ListJobsResponse.Size(m) 137} 138func (m *ListJobsResponse) XXX_DiscardUnknown() { 139 xxx_messageInfo_ListJobsResponse.DiscardUnknown(m) 140} 141 142var xxx_messageInfo_ListJobsResponse proto.InternalMessageInfo 143 144func (m *ListJobsResponse) GetJobs() []*Job { 145 if m != nil { 146 return m.Jobs 147 } 148 return nil 149} 150 151func (m *ListJobsResponse) GetNextPageToken() string { 152 if m != nil { 153 return m.NextPageToken 154 } 155 return "" 156} 157 158// Request message for [GetJob][google.cloud.scheduler.v1.CloudScheduler.GetJob]. 159type GetJobRequest struct { 160 // Required. 161 // 162 // The job name. For example: 163 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 164 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 165 XXX_NoUnkeyedLiteral struct{} `json:"-"` 166 XXX_unrecognized []byte `json:"-"` 167 XXX_sizecache int32 `json:"-"` 168} 169 170func (m *GetJobRequest) Reset() { *m = GetJobRequest{} } 171func (m *GetJobRequest) String() string { return proto.CompactTextString(m) } 172func (*GetJobRequest) ProtoMessage() {} 173func (*GetJobRequest) Descriptor() ([]byte, []int) { 174 return fileDescriptor_329fd147d63dc799, []int{2} 175} 176 177func (m *GetJobRequest) XXX_Unmarshal(b []byte) error { 178 return xxx_messageInfo_GetJobRequest.Unmarshal(m, b) 179} 180func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 181 return xxx_messageInfo_GetJobRequest.Marshal(b, m, deterministic) 182} 183func (m *GetJobRequest) XXX_Merge(src proto.Message) { 184 xxx_messageInfo_GetJobRequest.Merge(m, src) 185} 186func (m *GetJobRequest) XXX_Size() int { 187 return xxx_messageInfo_GetJobRequest.Size(m) 188} 189func (m *GetJobRequest) XXX_DiscardUnknown() { 190 xxx_messageInfo_GetJobRequest.DiscardUnknown(m) 191} 192 193var xxx_messageInfo_GetJobRequest proto.InternalMessageInfo 194 195func (m *GetJobRequest) GetName() string { 196 if m != nil { 197 return m.Name 198 } 199 return "" 200} 201 202// Request message for [CreateJob][google.cloud.scheduler.v1.CloudScheduler.CreateJob]. 203type CreateJobRequest struct { 204 // Required. 205 // 206 // The location name. For example: 207 // `projects/PROJECT_ID/locations/LOCATION_ID`. 208 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 209 // Required. 210 // 211 // The job to add. The user can optionally specify a name for the 212 // job in [name][google.cloud.scheduler.v1.Job.name]. [name][google.cloud.scheduler.v1.Job.name] cannot be the same as an 213 // existing job. If a name is not specified then the system will 214 // generate a random unique name that will be returned 215 // ([name][google.cloud.scheduler.v1.Job.name]) in the response. 216 Job *Job `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"` 217 XXX_NoUnkeyedLiteral struct{} `json:"-"` 218 XXX_unrecognized []byte `json:"-"` 219 XXX_sizecache int32 `json:"-"` 220} 221 222func (m *CreateJobRequest) Reset() { *m = CreateJobRequest{} } 223func (m *CreateJobRequest) String() string { return proto.CompactTextString(m) } 224func (*CreateJobRequest) ProtoMessage() {} 225func (*CreateJobRequest) Descriptor() ([]byte, []int) { 226 return fileDescriptor_329fd147d63dc799, []int{3} 227} 228 229func (m *CreateJobRequest) XXX_Unmarshal(b []byte) error { 230 return xxx_messageInfo_CreateJobRequest.Unmarshal(m, b) 231} 232func (m *CreateJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 233 return xxx_messageInfo_CreateJobRequest.Marshal(b, m, deterministic) 234} 235func (m *CreateJobRequest) XXX_Merge(src proto.Message) { 236 xxx_messageInfo_CreateJobRequest.Merge(m, src) 237} 238func (m *CreateJobRequest) XXX_Size() int { 239 return xxx_messageInfo_CreateJobRequest.Size(m) 240} 241func (m *CreateJobRequest) XXX_DiscardUnknown() { 242 xxx_messageInfo_CreateJobRequest.DiscardUnknown(m) 243} 244 245var xxx_messageInfo_CreateJobRequest proto.InternalMessageInfo 246 247func (m *CreateJobRequest) GetParent() string { 248 if m != nil { 249 return m.Parent 250 } 251 return "" 252} 253 254func (m *CreateJobRequest) GetJob() *Job { 255 if m != nil { 256 return m.Job 257 } 258 return nil 259} 260 261// Request message for [UpdateJob][google.cloud.scheduler.v1.CloudScheduler.UpdateJob]. 262type UpdateJobRequest struct { 263 // Required. 264 // 265 // The new job properties. [name][google.cloud.scheduler.v1.Job.name] must be specified. 266 // 267 // Output only fields cannot be modified using UpdateJob. 268 // Any value specified for an output only field will be ignored. 269 Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` 270 // A mask used to specify which fields of the job are being updated. 271 UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 272 XXX_NoUnkeyedLiteral struct{} `json:"-"` 273 XXX_unrecognized []byte `json:"-"` 274 XXX_sizecache int32 `json:"-"` 275} 276 277func (m *UpdateJobRequest) Reset() { *m = UpdateJobRequest{} } 278func (m *UpdateJobRequest) String() string { return proto.CompactTextString(m) } 279func (*UpdateJobRequest) ProtoMessage() {} 280func (*UpdateJobRequest) Descriptor() ([]byte, []int) { 281 return fileDescriptor_329fd147d63dc799, []int{4} 282} 283 284func (m *UpdateJobRequest) XXX_Unmarshal(b []byte) error { 285 return xxx_messageInfo_UpdateJobRequest.Unmarshal(m, b) 286} 287func (m *UpdateJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 288 return xxx_messageInfo_UpdateJobRequest.Marshal(b, m, deterministic) 289} 290func (m *UpdateJobRequest) XXX_Merge(src proto.Message) { 291 xxx_messageInfo_UpdateJobRequest.Merge(m, src) 292} 293func (m *UpdateJobRequest) XXX_Size() int { 294 return xxx_messageInfo_UpdateJobRequest.Size(m) 295} 296func (m *UpdateJobRequest) XXX_DiscardUnknown() { 297 xxx_messageInfo_UpdateJobRequest.DiscardUnknown(m) 298} 299 300var xxx_messageInfo_UpdateJobRequest proto.InternalMessageInfo 301 302func (m *UpdateJobRequest) GetJob() *Job { 303 if m != nil { 304 return m.Job 305 } 306 return nil 307} 308 309func (m *UpdateJobRequest) GetUpdateMask() *field_mask.FieldMask { 310 if m != nil { 311 return m.UpdateMask 312 } 313 return nil 314} 315 316// Request message for deleting a job using 317// [DeleteJob][google.cloud.scheduler.v1.CloudScheduler.DeleteJob]. 318type DeleteJobRequest struct { 319 // Required. 320 // 321 // The job name. For example: 322 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 323 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 324 XXX_NoUnkeyedLiteral struct{} `json:"-"` 325 XXX_unrecognized []byte `json:"-"` 326 XXX_sizecache int32 `json:"-"` 327} 328 329func (m *DeleteJobRequest) Reset() { *m = DeleteJobRequest{} } 330func (m *DeleteJobRequest) String() string { return proto.CompactTextString(m) } 331func (*DeleteJobRequest) ProtoMessage() {} 332func (*DeleteJobRequest) Descriptor() ([]byte, []int) { 333 return fileDescriptor_329fd147d63dc799, []int{5} 334} 335 336func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error { 337 return xxx_messageInfo_DeleteJobRequest.Unmarshal(m, b) 338} 339func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 340 return xxx_messageInfo_DeleteJobRequest.Marshal(b, m, deterministic) 341} 342func (m *DeleteJobRequest) XXX_Merge(src proto.Message) { 343 xxx_messageInfo_DeleteJobRequest.Merge(m, src) 344} 345func (m *DeleteJobRequest) XXX_Size() int { 346 return xxx_messageInfo_DeleteJobRequest.Size(m) 347} 348func (m *DeleteJobRequest) XXX_DiscardUnknown() { 349 xxx_messageInfo_DeleteJobRequest.DiscardUnknown(m) 350} 351 352var xxx_messageInfo_DeleteJobRequest proto.InternalMessageInfo 353 354func (m *DeleteJobRequest) GetName() string { 355 if m != nil { 356 return m.Name 357 } 358 return "" 359} 360 361// Request message for [PauseJob][google.cloud.scheduler.v1.CloudScheduler.PauseJob]. 362type PauseJobRequest struct { 363 // Required. 364 // 365 // The job name. For example: 366 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 367 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 368 XXX_NoUnkeyedLiteral struct{} `json:"-"` 369 XXX_unrecognized []byte `json:"-"` 370 XXX_sizecache int32 `json:"-"` 371} 372 373func (m *PauseJobRequest) Reset() { *m = PauseJobRequest{} } 374func (m *PauseJobRequest) String() string { return proto.CompactTextString(m) } 375func (*PauseJobRequest) ProtoMessage() {} 376func (*PauseJobRequest) Descriptor() ([]byte, []int) { 377 return fileDescriptor_329fd147d63dc799, []int{6} 378} 379 380func (m *PauseJobRequest) XXX_Unmarshal(b []byte) error { 381 return xxx_messageInfo_PauseJobRequest.Unmarshal(m, b) 382} 383func (m *PauseJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 384 return xxx_messageInfo_PauseJobRequest.Marshal(b, m, deterministic) 385} 386func (m *PauseJobRequest) XXX_Merge(src proto.Message) { 387 xxx_messageInfo_PauseJobRequest.Merge(m, src) 388} 389func (m *PauseJobRequest) XXX_Size() int { 390 return xxx_messageInfo_PauseJobRequest.Size(m) 391} 392func (m *PauseJobRequest) XXX_DiscardUnknown() { 393 xxx_messageInfo_PauseJobRequest.DiscardUnknown(m) 394} 395 396var xxx_messageInfo_PauseJobRequest proto.InternalMessageInfo 397 398func (m *PauseJobRequest) GetName() string { 399 if m != nil { 400 return m.Name 401 } 402 return "" 403} 404 405// Request message for [ResumeJob][google.cloud.scheduler.v1.CloudScheduler.ResumeJob]. 406type ResumeJobRequest struct { 407 // Required. 408 // 409 // The job name. For example: 410 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 411 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 412 XXX_NoUnkeyedLiteral struct{} `json:"-"` 413 XXX_unrecognized []byte `json:"-"` 414 XXX_sizecache int32 `json:"-"` 415} 416 417func (m *ResumeJobRequest) Reset() { *m = ResumeJobRequest{} } 418func (m *ResumeJobRequest) String() string { return proto.CompactTextString(m) } 419func (*ResumeJobRequest) ProtoMessage() {} 420func (*ResumeJobRequest) Descriptor() ([]byte, []int) { 421 return fileDescriptor_329fd147d63dc799, []int{7} 422} 423 424func (m *ResumeJobRequest) XXX_Unmarshal(b []byte) error { 425 return xxx_messageInfo_ResumeJobRequest.Unmarshal(m, b) 426} 427func (m *ResumeJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 428 return xxx_messageInfo_ResumeJobRequest.Marshal(b, m, deterministic) 429} 430func (m *ResumeJobRequest) XXX_Merge(src proto.Message) { 431 xxx_messageInfo_ResumeJobRequest.Merge(m, src) 432} 433func (m *ResumeJobRequest) XXX_Size() int { 434 return xxx_messageInfo_ResumeJobRequest.Size(m) 435} 436func (m *ResumeJobRequest) XXX_DiscardUnknown() { 437 xxx_messageInfo_ResumeJobRequest.DiscardUnknown(m) 438} 439 440var xxx_messageInfo_ResumeJobRequest proto.InternalMessageInfo 441 442func (m *ResumeJobRequest) GetName() string { 443 if m != nil { 444 return m.Name 445 } 446 return "" 447} 448 449// Request message for forcing a job to run now using 450// [RunJob][google.cloud.scheduler.v1.CloudScheduler.RunJob]. 451type RunJobRequest struct { 452 // Required. 453 // 454 // The job name. For example: 455 // `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. 456 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 457 XXX_NoUnkeyedLiteral struct{} `json:"-"` 458 XXX_unrecognized []byte `json:"-"` 459 XXX_sizecache int32 `json:"-"` 460} 461 462func (m *RunJobRequest) Reset() { *m = RunJobRequest{} } 463func (m *RunJobRequest) String() string { return proto.CompactTextString(m) } 464func (*RunJobRequest) ProtoMessage() {} 465func (*RunJobRequest) Descriptor() ([]byte, []int) { 466 return fileDescriptor_329fd147d63dc799, []int{8} 467} 468 469func (m *RunJobRequest) XXX_Unmarshal(b []byte) error { 470 return xxx_messageInfo_RunJobRequest.Unmarshal(m, b) 471} 472func (m *RunJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 473 return xxx_messageInfo_RunJobRequest.Marshal(b, m, deterministic) 474} 475func (m *RunJobRequest) XXX_Merge(src proto.Message) { 476 xxx_messageInfo_RunJobRequest.Merge(m, src) 477} 478func (m *RunJobRequest) XXX_Size() int { 479 return xxx_messageInfo_RunJobRequest.Size(m) 480} 481func (m *RunJobRequest) XXX_DiscardUnknown() { 482 xxx_messageInfo_RunJobRequest.DiscardUnknown(m) 483} 484 485var xxx_messageInfo_RunJobRequest proto.InternalMessageInfo 486 487func (m *RunJobRequest) GetName() string { 488 if m != nil { 489 return m.Name 490 } 491 return "" 492} 493 494func init() { 495 proto.RegisterType((*ListJobsRequest)(nil), "google.cloud.scheduler.v1.ListJobsRequest") 496 proto.RegisterType((*ListJobsResponse)(nil), "google.cloud.scheduler.v1.ListJobsResponse") 497 proto.RegisterType((*GetJobRequest)(nil), "google.cloud.scheduler.v1.GetJobRequest") 498 proto.RegisterType((*CreateJobRequest)(nil), "google.cloud.scheduler.v1.CreateJobRequest") 499 proto.RegisterType((*UpdateJobRequest)(nil), "google.cloud.scheduler.v1.UpdateJobRequest") 500 proto.RegisterType((*DeleteJobRequest)(nil), "google.cloud.scheduler.v1.DeleteJobRequest") 501 proto.RegisterType((*PauseJobRequest)(nil), "google.cloud.scheduler.v1.PauseJobRequest") 502 proto.RegisterType((*ResumeJobRequest)(nil), "google.cloud.scheduler.v1.ResumeJobRequest") 503 proto.RegisterType((*RunJobRequest)(nil), "google.cloud.scheduler.v1.RunJobRequest") 504} 505 506func init() { 507 proto.RegisterFile("google/cloud/scheduler/v1/cloudscheduler.proto", fileDescriptor_329fd147d63dc799) 508} 509 510var fileDescriptor_329fd147d63dc799 = []byte{ 511 // 719 bytes of a gzipped FileDescriptorProto 512 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x95, 0xcb, 0x4e, 0xdb, 0x4c, 513 0x14, 0xc7, 0x35, 0x5c, 0x22, 0x7c, 0x10, 0x10, 0xcd, 0x02, 0x85, 0xf0, 0xf1, 0x29, 0x32, 0x2a, 514 0x8a, 0x5c, 0xe4, 0x81, 0xd0, 0xaa, 0x6a, 0x50, 0x37, 0x5c, 0xda, 0x0a, 0x51, 0x29, 0x32, 0x65, 515 0x53, 0x55, 0x42, 0x4e, 0x32, 0xb8, 0x0e, 0x8e, 0xc7, 0xf5, 0xd8, 0xa8, 0xa5, 0x62, 0x01, 0xea, 516 0xae, 0x8b, 0xaa, 0xa2, 0xbc, 0x40, 0x5f, 0xa9, 0xaf, 0xd0, 0x07, 0xa9, 0x66, 0x7c, 0x81, 0xb8, 517 0xc4, 0xf6, 0x2e, 0x9e, 0xf3, 0x9f, 0x39, 0xbf, 0x39, 0xe7, 0x7f, 0x26, 0xa0, 0x5b, 0x8c, 0x59, 518 0x0e, 0x25, 0x3d, 0x87, 0x85, 0x7d, 0xc2, 0x7b, 0x1f, 0x68, 0x3f, 0x74, 0xa8, 0x4f, 0xce, 0x37, 519 0xa3, 0xa5, 0x74, 0x45, 0xf7, 0x7c, 0x16, 0x30, 0xbc, 0x14, 0xe9, 0x75, 0x19, 0xd4, 0xef, 0xa2, 520 0xe7, 0x9b, 0xf5, 0xff, 0xe2, 0xa3, 0x4c, 0xcf, 0x26, 0xa6, 0xeb, 0xb2, 0xc0, 0x0c, 0x6c, 0xe6, 521 0xf2, 0x68, 0x63, 0x7d, 0xe9, 0x5e, 0xd4, 0xa7, 0x9c, 0x85, 0x7e, 0x8f, 0xc6, 0xa1, 0xd5, 0xf1, 522 0x0c, 0x03, 0xd6, 0x8d, 0x45, 0xcb, 0xb1, 0x48, 0x7e, 0x75, 0xc3, 0x53, 0x42, 0x87, 0x5e, 0xf0, 523 0x39, 0x0e, 0x36, 0xb2, 0xc1, 0x53, 0x9b, 0x3a, 0xfd, 0x93, 0xa1, 0xc9, 0xcf, 0x22, 0x85, 0x4a, 524 0x61, 0xe1, 0xd0, 0xe6, 0xc1, 0x01, 0xeb, 0x72, 0x83, 0x7e, 0x0c, 0x29, 0x0f, 0xf0, 0x22, 0x54, 525 0x3c, 0xd3, 0xa7, 0x6e, 0x50, 0x43, 0x0d, 0xd4, 0x54, 0x8c, 0xf8, 0x0b, 0x2f, 0x83, 0xe2, 0x99, 526 0x16, 0x3d, 0xe1, 0xf6, 0x05, 0xad, 0x4d, 0x37, 0x50, 0x73, 0xda, 0x98, 0x11, 0x0b, 0x47, 0xf6, 527 0x05, 0xc5, 0x2b, 0x00, 0x32, 0x18, 0xb0, 0x33, 0xea, 0xd6, 0x2a, 0x72, 0xa3, 0x94, 0xbf, 0x15, 528 0x0b, 0xaa, 0x0b, 0xd5, 0xbb, 0x34, 0xdc, 0x63, 0x2e, 0xa7, 0xb8, 0x05, 0x53, 0x03, 0xd6, 0xe5, 529 0x35, 0xd4, 0x98, 0x6c, 0xce, 0xb6, 0xfe, 0xd7, 0xc7, 0x56, 0x50, 0x3f, 0x60, 0x5d, 0x43, 0x6a, 530 0xf1, 0x1a, 0x2c, 0xb8, 0xf4, 0x53, 0x70, 0x72, 0x2f, 0xd7, 0x84, 0xcc, 0x35, 0x27, 0x96, 0x3b, 531 0x69, 0xbe, 0x55, 0x98, 0x7b, 0x45, 0x45, 0xba, 0xe4, 0x52, 0x18, 0xa6, 0x5c, 0x73, 0x48, 0xe3, 532 0x2b, 0xc9, 0xdf, 0xea, 0x7b, 0xa8, 0xee, 0xfa, 0xd4, 0x0c, 0xe8, 0x3d, 0xdd, 0xb8, 0xcb, 0x6f, 533 0xc0, 0xe4, 0x80, 0x75, 0x65, 0xb2, 0x62, 0x56, 0x21, 0x55, 0xaf, 0x10, 0x54, 0x8f, 0xbd, 0xfe, 534 0xe8, 0xf1, 0xf1, 0x31, 0xa8, 0xf4, 0x31, 0x78, 0x1b, 0x66, 0x43, 0x79, 0x8a, 0xec, 0x5a, 0x0c, 535 0x50, 0x4f, 0x76, 0x26, 0x8d, 0xd5, 0x5f, 0x8a, 0xc6, 0xbe, 0x31, 0xf9, 0x99, 0x01, 0x91, 0x5c, 536 0xfc, 0x56, 0xd7, 0xa0, 0xba, 0x47, 0x1d, 0x3a, 0x82, 0xf0, 0x50, 0x25, 0x1e, 0xc1, 0x42, 0xc7, 537 0x0c, 0x79, 0x91, 0x6c, 0x0d, 0xaa, 0x06, 0xe5, 0xe1, 0xb0, 0x48, 0xb7, 0x0a, 0x73, 0x46, 0xe8, 538 0xe6, 0x8b, 0x5a, 0xb7, 0x0a, 0xcc, 0xef, 0x8a, 0x8b, 0x1f, 0x25, 0xf7, 0xc6, 0xb7, 0x08, 0x66, 539 0x12, 0x9b, 0x60, 0x2d, 0xa7, 0x3a, 0x19, 0xcb, 0xd6, 0x1f, 0x97, 0xd2, 0x46, 0xbe, 0x53, 0x37, 540 0xae, 0x7f, 0xff, 0xb9, 0x99, 0xd0, 0x70, 0x53, 0x0c, 0xd2, 0x97, 0xa8, 0xbf, 0x2f, 0x3c, 0x9f, 541 0x0d, 0x68, 0x2f, 0xe0, 0x44, 0x23, 0x0e, 0xeb, 0x45, 0x13, 0x4a, 0xb4, 0x4b, 0x22, 0x5d, 0xf7, 542 0x15, 0x41, 0x25, 0xb2, 0x13, 0x6e, 0xe6, 0x64, 0x1a, 0x71, 0x5c, 0xbd, 0xa0, 0xbb, 0x19, 0x0c, 543 0x51, 0x92, 0x31, 0x10, 0x92, 0x81, 0x68, 0x97, 0xf8, 0x3b, 0x02, 0x25, 0x35, 0x2c, 0xce, 0xbb, 544 0x73, 0xd6, 0xd6, 0x85, 0x30, 0x4f, 0x25, 0x0c, 0x51, 0x4b, 0xd7, 0xa4, 0x2d, 0xcd, 0x79, 0x83, 545 0x40, 0x49, 0x3d, 0x9e, 0x4b, 0x94, 0x9d, 0x84, 0x42, 0xa2, 0xe7, 0x92, 0x68, 0xab, 0xb5, 0x2e, 546 0x89, 0xc4, 0x7b, 0x57, 0xa2, 0x44, 0x11, 0xd5, 0x35, 0x02, 0x25, 0xb5, 0x7d, 0x2e, 0x55, 0x76, 547 0x38, 0xea, 0x8b, 0xff, 0x0c, 0xd6, 0xbe, 0x78, 0x4e, 0x93, 0x66, 0x69, 0xe5, 0x9b, 0xf5, 0x03, 548 0xc1, 0x4c, 0x32, 0x53, 0xb9, 0x5e, 0xce, 0x0c, 0x5e, 0xd9, 0xc2, 0xa8, 0x7a, 0x59, 0x94, 0xb6, 549 0x27, 0x32, 0xb4, 0x91, 0x86, 0x7f, 0x22, 0x50, 0xd2, 0x01, 0xce, 0x2d, 0x4c, 0x76, 0xcc, 0x0b, 550 0xa9, 0xda, 0x92, 0xea, 0x89, 0x4a, 0x4a, 0x53, 0xf9, 0x32, 0x85, 0xc0, 0xfa, 0x86, 0xa0, 0x12, 551 0xbd, 0x17, 0xb9, 0xe3, 0x35, 0xf2, 0xa4, 0x14, 0x02, 0x3d, 0x93, 0x40, 0x9b, 0xea, 0x7a, 0x79, 552 0xa0, 0xd0, 0x6d, 0x23, 0x6d, 0xe7, 0x0a, 0xc1, 0x4a, 0x8f, 0x0d, 0xc7, 0x1f, 0xbf, 0x33, 0x9f, 553 0xbe, 0x58, 0x1d, 0xe1, 0x92, 0x0e, 0x7a, 0xb7, 0x13, 0x8b, 0x2d, 0xe6, 0x98, 0xae, 0xa5, 0x33, 554 0xdf, 0x22, 0x16, 0x75, 0xa5, 0x87, 0x48, 0x14, 0x32, 0x3d, 0x9b, 0x3f, 0xf0, 0x47, 0xbe, 0x9d, 555 0x7e, 0xfc, 0x9a, 0x50, 0x8e, 0x76, 0x5f, 0xef, 0xef, 0x1d, 0x1f, 0xee, 0x1b, 0xdd, 0x8a, 0xdc, 556 0xba, 0xf5, 0x37, 0x00, 0x00, 0xff, 0xff, 0x1e, 0x36, 0xc7, 0x33, 0x86, 0x08, 0x00, 0x00, 557} 558 559// Reference imports to suppress errors if they are not otherwise used. 560var _ context.Context 561var _ grpc.ClientConn 562 563// This is a compile-time assertion to ensure that this generated file 564// is compatible with the grpc package it is being compiled against. 565const _ = grpc.SupportPackageIsVersion4 566 567// CloudSchedulerClient is the client API for CloudScheduler service. 568// 569// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 570type CloudSchedulerClient interface { 571 // Lists jobs. 572 ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) 573 // Gets a job. 574 GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) 575 // Creates a job. 576 CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) 577 // Updates a job. 578 // 579 // If successful, the updated [Job][google.cloud.scheduler.v1.Job] is returned. If the job does 580 // not exist, `NOT_FOUND` is returned. 581 // 582 // If UpdateJob does not successfully return, it is possible for the 583 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1.Job.State.UPDATE_FAILED] state. A job in this state may 584 // not be executed. If this happens, retry the UpdateJob request 585 // until a successful response is received. 586 UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) 587 // Deletes a job. 588 DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) 589 // Pauses a job. 590 // 591 // If a job is paused then the system will stop executing the job 592 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1.CloudScheduler.ResumeJob]. The 593 // state of the job is stored in [state][google.cloud.scheduler.v1.Job.state]; if paused it 594 // 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] 595 // to be paused. 596 PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) 597 // Resume a job. 598 // 599 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED]. The 600 // state of a job is stored in [Job.state][google.cloud.scheduler.v1.Job.state]; after calling this method it 601 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1.Job.State.ENABLED]. A job must be in 602 // [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED] to be resumed. 603 ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) 604 // Forces a job to run now. 605 // 606 // When this method is called, Cloud Scheduler will dispatch the job, even 607 // if the job is already running. 608 RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) 609} 610 611type cloudSchedulerClient struct { 612 cc *grpc.ClientConn 613} 614 615func NewCloudSchedulerClient(cc *grpc.ClientConn) CloudSchedulerClient { 616 return &cloudSchedulerClient{cc} 617} 618 619func (c *cloudSchedulerClient) ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) { 620 out := new(ListJobsResponse) 621 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/ListJobs", in, out, opts...) 622 if err != nil { 623 return nil, err 624 } 625 return out, nil 626} 627 628func (c *cloudSchedulerClient) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) { 629 out := new(Job) 630 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/GetJob", in, out, opts...) 631 if err != nil { 632 return nil, err 633 } 634 return out, nil 635} 636 637func (c *cloudSchedulerClient) CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) { 638 out := new(Job) 639 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/CreateJob", in, out, opts...) 640 if err != nil { 641 return nil, err 642 } 643 return out, nil 644} 645 646func (c *cloudSchedulerClient) UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) { 647 out := new(Job) 648 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/UpdateJob", in, out, opts...) 649 if err != nil { 650 return nil, err 651 } 652 return out, nil 653} 654 655func (c *cloudSchedulerClient) DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 656 out := new(empty.Empty) 657 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/DeleteJob", in, out, opts...) 658 if err != nil { 659 return nil, err 660 } 661 return out, nil 662} 663 664func (c *cloudSchedulerClient) PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) { 665 out := new(Job) 666 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/PauseJob", in, out, opts...) 667 if err != nil { 668 return nil, err 669 } 670 return out, nil 671} 672 673func (c *cloudSchedulerClient) ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) { 674 out := new(Job) 675 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/ResumeJob", in, out, opts...) 676 if err != nil { 677 return nil, err 678 } 679 return out, nil 680} 681 682func (c *cloudSchedulerClient) RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) { 683 out := new(Job) 684 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1.CloudScheduler/RunJob", in, out, opts...) 685 if err != nil { 686 return nil, err 687 } 688 return out, nil 689} 690 691// CloudSchedulerServer is the server API for CloudScheduler service. 692type CloudSchedulerServer interface { 693 // Lists jobs. 694 ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) 695 // Gets a job. 696 GetJob(context.Context, *GetJobRequest) (*Job, error) 697 // Creates a job. 698 CreateJob(context.Context, *CreateJobRequest) (*Job, error) 699 // Updates a job. 700 // 701 // If successful, the updated [Job][google.cloud.scheduler.v1.Job] is returned. If the job does 702 // not exist, `NOT_FOUND` is returned. 703 // 704 // If UpdateJob does not successfully return, it is possible for the 705 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1.Job.State.UPDATE_FAILED] state. A job in this state may 706 // not be executed. If this happens, retry the UpdateJob request 707 // until a successful response is received. 708 UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) 709 // Deletes a job. 710 DeleteJob(context.Context, *DeleteJobRequest) (*empty.Empty, error) 711 // Pauses a job. 712 // 713 // If a job is paused then the system will stop executing the job 714 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1.CloudScheduler.ResumeJob]. The 715 // state of the job is stored in [state][google.cloud.scheduler.v1.Job.state]; if paused it 716 // 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] 717 // to be paused. 718 PauseJob(context.Context, *PauseJobRequest) (*Job, error) 719 // Resume a job. 720 // 721 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED]. The 722 // state of a job is stored in [Job.state][google.cloud.scheduler.v1.Job.state]; after calling this method it 723 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1.Job.State.ENABLED]. A job must be in 724 // [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED] to be resumed. 725 ResumeJob(context.Context, *ResumeJobRequest) (*Job, error) 726 // Forces a job to run now. 727 // 728 // When this method is called, Cloud Scheduler will dispatch the job, even 729 // if the job is already running. 730 RunJob(context.Context, *RunJobRequest) (*Job, error) 731} 732 733func RegisterCloudSchedulerServer(s *grpc.Server, srv CloudSchedulerServer) { 734 s.RegisterService(&_CloudScheduler_serviceDesc, srv) 735} 736 737func _CloudScheduler_ListJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 738 in := new(ListJobsRequest) 739 if err := dec(in); err != nil { 740 return nil, err 741 } 742 if interceptor == nil { 743 return srv.(CloudSchedulerServer).ListJobs(ctx, in) 744 } 745 info := &grpc.UnaryServerInfo{ 746 Server: srv, 747 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/ListJobs", 748 } 749 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 750 return srv.(CloudSchedulerServer).ListJobs(ctx, req.(*ListJobsRequest)) 751 } 752 return interceptor(ctx, in, info, handler) 753} 754 755func _CloudScheduler_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 756 in := new(GetJobRequest) 757 if err := dec(in); err != nil { 758 return nil, err 759 } 760 if interceptor == nil { 761 return srv.(CloudSchedulerServer).GetJob(ctx, in) 762 } 763 info := &grpc.UnaryServerInfo{ 764 Server: srv, 765 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/GetJob", 766 } 767 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 768 return srv.(CloudSchedulerServer).GetJob(ctx, req.(*GetJobRequest)) 769 } 770 return interceptor(ctx, in, info, handler) 771} 772 773func _CloudScheduler_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 774 in := new(CreateJobRequest) 775 if err := dec(in); err != nil { 776 return nil, err 777 } 778 if interceptor == nil { 779 return srv.(CloudSchedulerServer).CreateJob(ctx, in) 780 } 781 info := &grpc.UnaryServerInfo{ 782 Server: srv, 783 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/CreateJob", 784 } 785 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 786 return srv.(CloudSchedulerServer).CreateJob(ctx, req.(*CreateJobRequest)) 787 } 788 return interceptor(ctx, in, info, handler) 789} 790 791func _CloudScheduler_UpdateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 792 in := new(UpdateJobRequest) 793 if err := dec(in); err != nil { 794 return nil, err 795 } 796 if interceptor == nil { 797 return srv.(CloudSchedulerServer).UpdateJob(ctx, in) 798 } 799 info := &grpc.UnaryServerInfo{ 800 Server: srv, 801 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/UpdateJob", 802 } 803 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 804 return srv.(CloudSchedulerServer).UpdateJob(ctx, req.(*UpdateJobRequest)) 805 } 806 return interceptor(ctx, in, info, handler) 807} 808 809func _CloudScheduler_DeleteJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 810 in := new(DeleteJobRequest) 811 if err := dec(in); err != nil { 812 return nil, err 813 } 814 if interceptor == nil { 815 return srv.(CloudSchedulerServer).DeleteJob(ctx, in) 816 } 817 info := &grpc.UnaryServerInfo{ 818 Server: srv, 819 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/DeleteJob", 820 } 821 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 822 return srv.(CloudSchedulerServer).DeleteJob(ctx, req.(*DeleteJobRequest)) 823 } 824 return interceptor(ctx, in, info, handler) 825} 826 827func _CloudScheduler_PauseJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 828 in := new(PauseJobRequest) 829 if err := dec(in); err != nil { 830 return nil, err 831 } 832 if interceptor == nil { 833 return srv.(CloudSchedulerServer).PauseJob(ctx, in) 834 } 835 info := &grpc.UnaryServerInfo{ 836 Server: srv, 837 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/PauseJob", 838 } 839 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 840 return srv.(CloudSchedulerServer).PauseJob(ctx, req.(*PauseJobRequest)) 841 } 842 return interceptor(ctx, in, info, handler) 843} 844 845func _CloudScheduler_ResumeJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 846 in := new(ResumeJobRequest) 847 if err := dec(in); err != nil { 848 return nil, err 849 } 850 if interceptor == nil { 851 return srv.(CloudSchedulerServer).ResumeJob(ctx, in) 852 } 853 info := &grpc.UnaryServerInfo{ 854 Server: srv, 855 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/ResumeJob", 856 } 857 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 858 return srv.(CloudSchedulerServer).ResumeJob(ctx, req.(*ResumeJobRequest)) 859 } 860 return interceptor(ctx, in, info, handler) 861} 862 863func _CloudScheduler_RunJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 864 in := new(RunJobRequest) 865 if err := dec(in); err != nil { 866 return nil, err 867 } 868 if interceptor == nil { 869 return srv.(CloudSchedulerServer).RunJob(ctx, in) 870 } 871 info := &grpc.UnaryServerInfo{ 872 Server: srv, 873 FullMethod: "/google.cloud.scheduler.v1.CloudScheduler/RunJob", 874 } 875 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 876 return srv.(CloudSchedulerServer).RunJob(ctx, req.(*RunJobRequest)) 877 } 878 return interceptor(ctx, in, info, handler) 879} 880 881var _CloudScheduler_serviceDesc = grpc.ServiceDesc{ 882 ServiceName: "google.cloud.scheduler.v1.CloudScheduler", 883 HandlerType: (*CloudSchedulerServer)(nil), 884 Methods: []grpc.MethodDesc{ 885 { 886 MethodName: "ListJobs", 887 Handler: _CloudScheduler_ListJobs_Handler, 888 }, 889 { 890 MethodName: "GetJob", 891 Handler: _CloudScheduler_GetJob_Handler, 892 }, 893 { 894 MethodName: "CreateJob", 895 Handler: _CloudScheduler_CreateJob_Handler, 896 }, 897 { 898 MethodName: "UpdateJob", 899 Handler: _CloudScheduler_UpdateJob_Handler, 900 }, 901 { 902 MethodName: "DeleteJob", 903 Handler: _CloudScheduler_DeleteJob_Handler, 904 }, 905 { 906 MethodName: "PauseJob", 907 Handler: _CloudScheduler_PauseJob_Handler, 908 }, 909 { 910 MethodName: "ResumeJob", 911 Handler: _CloudScheduler_ResumeJob_Handler, 912 }, 913 { 914 MethodName: "RunJob", 915 Handler: _CloudScheduler_RunJob_Handler, 916 }, 917 }, 918 Streams: []grpc.StreamDesc{}, 919 Metadata: "google/cloud/scheduler/v1/cloudscheduler.proto", 920} 921