1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/scheduler/v1beta1/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.v1beta1.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.v1beta1.ListJobsResponse.next_page_token] returned from 47 // the previous call to [ListJobs][google.cloud.scheduler.v1beta1.CloudScheduler.ListJobs]. It is an error to 48 // switch the value of [filter][google.cloud.scheduler.v1beta1.ListJobsRequest.filter] or 49 // [order_by][google.cloud.scheduler.v1beta1.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_ab8778b9dae54836, []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.v1beta1.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.v1beta1.ListJobsRequest.page_token] field in the subsequent call to 108 // [ListJobs][google.cloud.scheduler.v1beta1.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_ab8778b9dae54836, []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.v1beta1.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_ab8778b9dae54836, []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.v1beta1.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.v1beta1.Job.name]. [name][google.cloud.scheduler.v1beta1.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.v1beta1.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_ab8778b9dae54836, []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.v1beta1.CloudScheduler.UpdateJob]. 262type UpdateJobRequest struct { 263 // Required. 264 // 265 // The new job properties. [name][google.cloud.scheduler.v1beta1.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_ab8778b9dae54836, []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.v1beta1.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_ab8778b9dae54836, []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.v1beta1.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_ab8778b9dae54836, []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.v1beta1.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_ab8778b9dae54836, []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.v1beta1.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_ab8778b9dae54836, []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.v1beta1.ListJobsRequest") 496 proto.RegisterType((*ListJobsResponse)(nil), "google.cloud.scheduler.v1beta1.ListJobsResponse") 497 proto.RegisterType((*GetJobRequest)(nil), "google.cloud.scheduler.v1beta1.GetJobRequest") 498 proto.RegisterType((*CreateJobRequest)(nil), "google.cloud.scheduler.v1beta1.CreateJobRequest") 499 proto.RegisterType((*UpdateJobRequest)(nil), "google.cloud.scheduler.v1beta1.UpdateJobRequest") 500 proto.RegisterType((*DeleteJobRequest)(nil), "google.cloud.scheduler.v1beta1.DeleteJobRequest") 501 proto.RegisterType((*PauseJobRequest)(nil), "google.cloud.scheduler.v1beta1.PauseJobRequest") 502 proto.RegisterType((*ResumeJobRequest)(nil), "google.cloud.scheduler.v1beta1.ResumeJobRequest") 503 proto.RegisterType((*RunJobRequest)(nil), "google.cloud.scheduler.v1beta1.RunJobRequest") 504} 505 506func init() { 507 proto.RegisterFile("google/cloud/scheduler/v1beta1/cloudscheduler.proto", fileDescriptor_ab8778b9dae54836) 508} 509 510var fileDescriptor_ab8778b9dae54836 = []byte{ 511 // 731 bytes of a gzipped FileDescriptorProto 512 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x96, 0x4b, 0x4f, 0xdb, 0x4a, 513 0x14, 0xc7, 0x35, 0x3c, 0x22, 0x72, 0x10, 0x10, 0xcd, 0x02, 0xe5, 0x86, 0x7b, 0xaf, 0x22, 0xa3, 514 0x8b, 0xa2, 0x48, 0x64, 0x6e, 0x78, 0xf4, 0x11, 0xfa, 0x90, 0x78, 0x94, 0x0a, 0x51, 0x29, 0x32, 515 0x65, 0xd3, 0x0d, 0x1a, 0x27, 0x83, 0xeb, 0xe0, 0x78, 0x5c, 0x8f, 0x5d, 0xb5, 0x54, 0x6c, 0xba, 516 0xa8, 0x2a, 0xb5, 0x3b, 0x76, 0x5d, 0x54, 0x15, 0xed, 0x37, 0xea, 0x57, 0xe8, 0x07, 0xa9, 0x66, 517 0xfc, 0x80, 0xb8, 0x80, 0xed, 0x5d, 0x3c, 0xe7, 0x9c, 0x39, 0xbf, 0x39, 0xe7, 0xfc, 0x8f, 0x02, 518 0xab, 0x26, 0xe7, 0xa6, 0xcd, 0x48, 0xcf, 0xe6, 0x41, 0x9f, 0x88, 0xde, 0x4b, 0xd6, 0x0f, 0x6c, 519 0xe6, 0x91, 0xd7, 0x6d, 0x83, 0xf9, 0xb4, 0x1d, 0x9e, 0x27, 0xc7, 0x2d, 0xd7, 0xe3, 0x3e, 0xc7, 520 0xff, 0x86, 0x41, 0x2d, 0x65, 0x6c, 0x5d, 0x5a, 0xa3, 0xa0, 0xda, 0xdf, 0xd1, 0xa5, 0xd4, 0xb5, 521 0x08, 0x75, 0x1c, 0xee, 0x53, 0xdf, 0xe2, 0x8e, 0x08, 0xa3, 0x6b, 0x7f, 0x5d, 0xb1, 0x7a, 0x4c, 522 0xf0, 0xc0, 0xeb, 0xb1, 0xc8, 0xd4, 0xc8, 0xa0, 0x19, 0x70, 0x23, 0xf2, 0x5c, 0x88, 0x3c, 0xd5, 523 0x97, 0x11, 0x1c, 0x13, 0x36, 0x74, 0xfd, 0xb7, 0x91, 0xb1, 0x9e, 0x36, 0x1e, 0x5b, 0xcc, 0xee, 524 0x1f, 0x0d, 0xa9, 0x38, 0x09, 0x3d, 0x34, 0x06, 0x73, 0xfb, 0x96, 0xf0, 0xf7, 0xb8, 0x21, 0x74, 525 0xf6, 0x2a, 0x60, 0xc2, 0xc7, 0xf3, 0x50, 0x72, 0xa9, 0xc7, 0x1c, 0xbf, 0x8a, 0xea, 0xa8, 0x51, 526 0xd6, 0xa3, 0x2f, 0xbc, 0x00, 0x65, 0x97, 0x9a, 0xec, 0x48, 0x58, 0xa7, 0xac, 0x3a, 0x59, 0x47, 527 0x8d, 0x49, 0x7d, 0x4a, 0x1e, 0x1c, 0x58, 0xa7, 0x0c, 0xff, 0x03, 0xa0, 0x8c, 0x3e, 0x3f, 0x61, 528 0x4e, 0xb5, 0xa4, 0x02, 0x95, 0xfb, 0x73, 0x79, 0xa0, 0x09, 0xa8, 0x5c, 0xa6, 0x11, 0x2e, 0x77, 529 0x04, 0xc3, 0x77, 0x61, 0x62, 0xc0, 0x0d, 0x51, 0x45, 0xf5, 0xf1, 0xc6, 0xf4, 0xca, 0x62, 0xeb, 530 0xf6, 0x5a, 0xb6, 0xf6, 0xb8, 0xa1, 0xab, 0x00, 0xbc, 0x04, 0x73, 0x0e, 0x7b, 0xe3, 0x1f, 0x5d, 531 0x49, 0x38, 0xa6, 0x12, 0xce, 0xc8, 0xe3, 0x6e, 0x92, 0x74, 0x11, 0x66, 0x76, 0x99, 0xcc, 0x19, 532 0xbf, 0x0c, 0xc3, 0x84, 0x43, 0x87, 0x2c, 0x7a, 0x97, 0xfa, 0xad, 0x51, 0xa8, 0x6c, 0x79, 0x8c, 533 0xfa, 0xec, 0x8a, 0xdf, 0x4d, 0x15, 0x58, 0x87, 0xf1, 0x01, 0x37, 0x54, 0xb2, 0x9c, 0xc0, 0xd2, 534 0x5f, 0xfb, 0x80, 0xa0, 0x72, 0xe8, 0xf6, 0x47, 0x73, 0x44, 0x77, 0xa1, 0x62, 0x77, 0xe1, 0x0d, 535 0x98, 0x0e, 0xd4, 0x55, 0xaa, 0x89, 0x11, 0x4a, 0x2d, 0x0e, 0x8f, 0xfb, 0xdc, 0x7a, 0x22, 0xfb, 536 0xfc, 0x8c, 0x8a, 0x13, 0x1d, 0x42, 0x77, 0xf9, 0x5b, 0x5b, 0x82, 0xca, 0x36, 0xb3, 0xd9, 0x08, 537 0xc7, 0x75, 0x35, 0xf9, 0x0f, 0xe6, 0xba, 0x34, 0x10, 0x59, 0x6e, 0x4b, 0x50, 0xd1, 0x99, 0x08, 538 0x86, 0x59, 0x7e, 0x8b, 0x30, 0xa3, 0x07, 0xce, 0xed, 0x4e, 0x2b, 0x1f, 0x01, 0x66, 0xb7, 0xe4, 539 0xeb, 0x0f, 0xe2, 0xc7, 0xe3, 0x1f, 0x08, 0xa6, 0xe2, 0xa9, 0xc1, 0x24, 0xab, 0x44, 0xa9, 0x31, 540 0xae, 0xfd, 0x9f, 0x3f, 0x20, 0x1c, 0x48, 0x6d, 0xfd, 0xfd, 0xcf, 0x5f, 0xe7, 0x63, 0x04, 0x2f, 541 0x27, 0x32, 0x7b, 0x17, 0x36, 0xfe, 0xa1, 0xeb, 0xf1, 0x01, 0xeb, 0xf9, 0x82, 0x34, 0x89, 0xcd, 542 0x7b, 0xa1, 0x88, 0x49, 0xf3, 0x8c, 0xa8, 0x71, 0x3c, 0x47, 0x50, 0x0a, 0xe7, 0x0c, 0x2f, 0x67, 543 0xe5, 0x1c, 0x99, 0xc7, 0x5a, 0x9e, 0xb6, 0x5f, 0x47, 0x25, 0x0b, 0x76, 0x03, 0x93, 0x42, 0x22, 544 0xcd, 0x33, 0xfc, 0x15, 0x41, 0x39, 0x19, 0x6c, 0x9c, 0x59, 0x8c, 0xb4, 0x06, 0xf2, 0xb1, 0x75, 545 0x14, 0xdb, 0x9a, 0x56, 0xac, 0x62, 0x1d, 0x35, 0xc9, 0x17, 0x08, 0xca, 0x89, 0x2a, 0xb2, 0x01, 546 0xd3, 0x02, 0xca, 0x07, 0xf8, 0x48, 0x01, 0xde, 0x5b, 0x69, 0x5f, 0x02, 0xca, 0xd5, 0x99, 0xa3, 547 0x80, 0x21, 0xe4, 0x67, 0x04, 0xe5, 0x44, 0x32, 0xd9, 0x90, 0x69, 0x75, 0xd5, 0xe6, 0xff, 0x50, 548 0xe6, 0x8e, 0x5c, 0xcf, 0x71, 0x53, 0x9b, 0x05, 0x9b, 0xfa, 0x0d, 0xc1, 0x54, 0xac, 0xcc, 0x6c, 549 0x45, 0xa4, 0x34, 0x5c, 0xa8, 0x62, 0xda, 0x6a, 0x21, 0xb2, 0x8e, 0x2b, 0x73, 0x75, 0x50, 0x13, 550 0x7f, 0x47, 0x50, 0x4e, 0xb6, 0x42, 0x76, 0xc5, 0xd2, 0x0b, 0x24, 0x1f, 0xe4, 0x63, 0x05, 0x79, 551 0x5f, 0x5b, 0x2b, 0x06, 0xe9, 0xa9, 0x64, 0x92, 0xf2, 0x0b, 0x82, 0x52, 0xb8, 0x93, 0xb2, 0x35, 552 0x3b, 0xb2, 0xbb, 0xf2, 0xf1, 0x3d, 0x50, 0x7c, 0x77, 0xb4, 0x76, 0x41, 0xbe, 0xc0, 0xe9, 0xa0, 553 0xe6, 0xe6, 0x27, 0x04, 0x5a, 0x8f, 0x0f, 0x33, 0x12, 0x6d, 0xce, 0x26, 0x9b, 0xb2, 0x2b, 0x87, 554 0xab, 0x8b, 0x5e, 0xec, 0x46, 0x11, 0x26, 0xb7, 0xa9, 0x63, 0xb6, 0xb8, 0x67, 0x12, 0x93, 0x39, 555 0x6a, 0xf4, 0x48, 0x68, 0xa2, 0xae, 0x25, 0x6e, 0xfa, 0x53, 0xb1, 0x91, 0x9c, 0x5c, 0x8c, 0x95, 556 0x0f, 0xb6, 0x9e, 0xee, 0x6c, 0x1f, 0xee, 0xef, 0xe8, 0x46, 0x49, 0xc5, 0xaf, 0xfe, 0x0e, 0x00, 557 0x00, 0xff, 0xff, 0x42, 0xed, 0xf2, 0xae, 0x21, 0x09, 0x00, 0x00, 558} 559 560// Reference imports to suppress errors if they are not otherwise used. 561var _ context.Context 562var _ grpc.ClientConn 563 564// This is a compile-time assertion to ensure that this generated file 565// is compatible with the grpc package it is being compiled against. 566const _ = grpc.SupportPackageIsVersion4 567 568// CloudSchedulerClient is the client API for CloudScheduler service. 569// 570// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 571type CloudSchedulerClient interface { 572 // Lists jobs. 573 ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) 574 // Gets a job. 575 GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) 576 // Creates a job. 577 CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) 578 // Updates a job. 579 // 580 // If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job does 581 // not exist, `NOT_FOUND` is returned. 582 // 583 // If UpdateJob does not successfully return, it is possible for the 584 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job in this state may 585 // not be executed. If this happens, retry the UpdateJob request 586 // until a successful response is received. 587 UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) 588 // Deletes a job. 589 DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) 590 // Pauses a job. 591 // 592 // If a job is paused then the system will stop executing the job 593 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The 594 // state of the job is stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it 595 // will be set to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] 596 // to be paused. 597 PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) 598 // Resume a job. 599 // 600 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The 601 // state of a job is stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it 602 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job must be in 603 // [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. 604 ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) 605 // Forces a job to run now. 606 // 607 // When this method is called, Cloud Scheduler will dispatch the job, even 608 // if the job is already running. 609 RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) 610} 611 612type cloudSchedulerClient struct { 613 cc *grpc.ClientConn 614} 615 616func NewCloudSchedulerClient(cc *grpc.ClientConn) CloudSchedulerClient { 617 return &cloudSchedulerClient{cc} 618} 619 620func (c *cloudSchedulerClient) ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) { 621 out := new(ListJobsResponse) 622 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/ListJobs", in, out, opts...) 623 if err != nil { 624 return nil, err 625 } 626 return out, nil 627} 628 629func (c *cloudSchedulerClient) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) { 630 out := new(Job) 631 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/GetJob", in, out, opts...) 632 if err != nil { 633 return nil, err 634 } 635 return out, nil 636} 637 638func (c *cloudSchedulerClient) CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) { 639 out := new(Job) 640 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/CreateJob", in, out, opts...) 641 if err != nil { 642 return nil, err 643 } 644 return out, nil 645} 646 647func (c *cloudSchedulerClient) UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) { 648 out := new(Job) 649 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/UpdateJob", in, out, opts...) 650 if err != nil { 651 return nil, err 652 } 653 return out, nil 654} 655 656func (c *cloudSchedulerClient) DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 657 out := new(empty.Empty) 658 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob", in, out, opts...) 659 if err != nil { 660 return nil, err 661 } 662 return out, nil 663} 664 665func (c *cloudSchedulerClient) PauseJob(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) { 666 out := new(Job) 667 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob", in, out, opts...) 668 if err != nil { 669 return nil, err 670 } 671 return out, nil 672} 673 674func (c *cloudSchedulerClient) ResumeJob(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) { 675 out := new(Job) 676 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob", in, out, opts...) 677 if err != nil { 678 return nil, err 679 } 680 return out, nil 681} 682 683func (c *cloudSchedulerClient) RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) { 684 out := new(Job) 685 err := c.cc.Invoke(ctx, "/google.cloud.scheduler.v1beta1.CloudScheduler/RunJob", in, out, opts...) 686 if err != nil { 687 return nil, err 688 } 689 return out, nil 690} 691 692// CloudSchedulerServer is the server API for CloudScheduler service. 693type CloudSchedulerServer interface { 694 // Lists jobs. 695 ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) 696 // Gets a job. 697 GetJob(context.Context, *GetJobRequest) (*Job, error) 698 // Creates a job. 699 CreateJob(context.Context, *CreateJobRequest) (*Job, error) 700 // Updates a job. 701 // 702 // If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job does 703 // not exist, `NOT_FOUND` is returned. 704 // 705 // If UpdateJob does not successfully return, it is possible for the 706 // job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job in this state may 707 // not be executed. If this happens, retry the UpdateJob request 708 // until a successful response is received. 709 UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) 710 // Deletes a job. 711 DeleteJob(context.Context, *DeleteJobRequest) (*empty.Empty, error) 712 // Pauses a job. 713 // 714 // If a job is paused then the system will stop executing the job 715 // until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The 716 // state of the job is stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it 717 // will be set to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] 718 // to be paused. 719 PauseJob(context.Context, *PauseJobRequest) (*Job, error) 720 // Resume a job. 721 // 722 // This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The 723 // state of a job is stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it 724 // will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job must be in 725 // [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. 726 ResumeJob(context.Context, *ResumeJobRequest) (*Job, error) 727 // Forces a job to run now. 728 // 729 // When this method is called, Cloud Scheduler will dispatch the job, even 730 // if the job is already running. 731 RunJob(context.Context, *RunJobRequest) (*Job, error) 732} 733 734func RegisterCloudSchedulerServer(s *grpc.Server, srv CloudSchedulerServer) { 735 s.RegisterService(&_CloudScheduler_serviceDesc, srv) 736} 737 738func _CloudScheduler_ListJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 739 in := new(ListJobsRequest) 740 if err := dec(in); err != nil { 741 return nil, err 742 } 743 if interceptor == nil { 744 return srv.(CloudSchedulerServer).ListJobs(ctx, in) 745 } 746 info := &grpc.UnaryServerInfo{ 747 Server: srv, 748 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/ListJobs", 749 } 750 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 751 return srv.(CloudSchedulerServer).ListJobs(ctx, req.(*ListJobsRequest)) 752 } 753 return interceptor(ctx, in, info, handler) 754} 755 756func _CloudScheduler_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 757 in := new(GetJobRequest) 758 if err := dec(in); err != nil { 759 return nil, err 760 } 761 if interceptor == nil { 762 return srv.(CloudSchedulerServer).GetJob(ctx, in) 763 } 764 info := &grpc.UnaryServerInfo{ 765 Server: srv, 766 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/GetJob", 767 } 768 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 769 return srv.(CloudSchedulerServer).GetJob(ctx, req.(*GetJobRequest)) 770 } 771 return interceptor(ctx, in, info, handler) 772} 773 774func _CloudScheduler_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 775 in := new(CreateJobRequest) 776 if err := dec(in); err != nil { 777 return nil, err 778 } 779 if interceptor == nil { 780 return srv.(CloudSchedulerServer).CreateJob(ctx, in) 781 } 782 info := &grpc.UnaryServerInfo{ 783 Server: srv, 784 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/CreateJob", 785 } 786 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 787 return srv.(CloudSchedulerServer).CreateJob(ctx, req.(*CreateJobRequest)) 788 } 789 return interceptor(ctx, in, info, handler) 790} 791 792func _CloudScheduler_UpdateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 793 in := new(UpdateJobRequest) 794 if err := dec(in); err != nil { 795 return nil, err 796 } 797 if interceptor == nil { 798 return srv.(CloudSchedulerServer).UpdateJob(ctx, in) 799 } 800 info := &grpc.UnaryServerInfo{ 801 Server: srv, 802 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/UpdateJob", 803 } 804 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 805 return srv.(CloudSchedulerServer).UpdateJob(ctx, req.(*UpdateJobRequest)) 806 } 807 return interceptor(ctx, in, info, handler) 808} 809 810func _CloudScheduler_DeleteJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 811 in := new(DeleteJobRequest) 812 if err := dec(in); err != nil { 813 return nil, err 814 } 815 if interceptor == nil { 816 return srv.(CloudSchedulerServer).DeleteJob(ctx, in) 817 } 818 info := &grpc.UnaryServerInfo{ 819 Server: srv, 820 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob", 821 } 822 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 823 return srv.(CloudSchedulerServer).DeleteJob(ctx, req.(*DeleteJobRequest)) 824 } 825 return interceptor(ctx, in, info, handler) 826} 827 828func _CloudScheduler_PauseJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 829 in := new(PauseJobRequest) 830 if err := dec(in); err != nil { 831 return nil, err 832 } 833 if interceptor == nil { 834 return srv.(CloudSchedulerServer).PauseJob(ctx, in) 835 } 836 info := &grpc.UnaryServerInfo{ 837 Server: srv, 838 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob", 839 } 840 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 841 return srv.(CloudSchedulerServer).PauseJob(ctx, req.(*PauseJobRequest)) 842 } 843 return interceptor(ctx, in, info, handler) 844} 845 846func _CloudScheduler_ResumeJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 847 in := new(ResumeJobRequest) 848 if err := dec(in); err != nil { 849 return nil, err 850 } 851 if interceptor == nil { 852 return srv.(CloudSchedulerServer).ResumeJob(ctx, in) 853 } 854 info := &grpc.UnaryServerInfo{ 855 Server: srv, 856 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob", 857 } 858 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 859 return srv.(CloudSchedulerServer).ResumeJob(ctx, req.(*ResumeJobRequest)) 860 } 861 return interceptor(ctx, in, info, handler) 862} 863 864func _CloudScheduler_RunJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 865 in := new(RunJobRequest) 866 if err := dec(in); err != nil { 867 return nil, err 868 } 869 if interceptor == nil { 870 return srv.(CloudSchedulerServer).RunJob(ctx, in) 871 } 872 info := &grpc.UnaryServerInfo{ 873 Server: srv, 874 FullMethod: "/google.cloud.scheduler.v1beta1.CloudScheduler/RunJob", 875 } 876 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 877 return srv.(CloudSchedulerServer).RunJob(ctx, req.(*RunJobRequest)) 878 } 879 return interceptor(ctx, in, info, handler) 880} 881 882var _CloudScheduler_serviceDesc = grpc.ServiceDesc{ 883 ServiceName: "google.cloud.scheduler.v1beta1.CloudScheduler", 884 HandlerType: (*CloudSchedulerServer)(nil), 885 Methods: []grpc.MethodDesc{ 886 { 887 MethodName: "ListJobs", 888 Handler: _CloudScheduler_ListJobs_Handler, 889 }, 890 { 891 MethodName: "GetJob", 892 Handler: _CloudScheduler_GetJob_Handler, 893 }, 894 { 895 MethodName: "CreateJob", 896 Handler: _CloudScheduler_CreateJob_Handler, 897 }, 898 { 899 MethodName: "UpdateJob", 900 Handler: _CloudScheduler_UpdateJob_Handler, 901 }, 902 { 903 MethodName: "DeleteJob", 904 Handler: _CloudScheduler_DeleteJob_Handler, 905 }, 906 { 907 MethodName: "PauseJob", 908 Handler: _CloudScheduler_PauseJob_Handler, 909 }, 910 { 911 MethodName: "ResumeJob", 912 Handler: _CloudScheduler_ResumeJob_Handler, 913 }, 914 { 915 MethodName: "RunJob", 916 Handler: _CloudScheduler_RunJob_Handler, 917 }, 918 }, 919 Streams: []grpc.StreamDesc{}, 920 Metadata: "google/cloud/scheduler/v1beta1/cloudscheduler.proto", 921} 922