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