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