Versions in this module Expand all Collapse all v1 v1.10.8 May 1, 2024 v1.10.7 Mar 14, 2024 v1.10.6 Jan 30, 2024 v1.10.5 Nov 9, 2023 v1.10.4 Nov 1, 2023 v1.10.3 Oct 26, 2023 v1.10.2 Oct 12, 2023 v1.10.1 Jun 20, 2023 v1.10.0 May 30, 2023 v1.9.1 May 8, 2023 v1.9.0 Mar 15, 2023 v1.8.0 Jan 5, 2023 v1.7.0 Nov 3, 2022 v1.6.0 Oct 25, 2022 Changes in this version + var File_google_cloud_scheduler_v1_cloudscheduler_proto protoreflect.FileDescriptor + var File_google_cloud_scheduler_v1_job_proto protoreflect.FileDescriptor + var File_google_cloud_scheduler_v1_target_proto protoreflect.FileDescriptor + var HttpMethod_name = map[int32]string + var HttpMethod_value = map[string]int32 + var Job_State_name = map[int32]string + var Job_State_value = map[string]int32 + func RegisterCloudSchedulerServer(s *grpc.Server, srv CloudSchedulerServer) + type AppEngineHttpTarget struct + AppEngineRouting *AppEngineRouting + Body []byte + Headers map[string]string + HttpMethod HttpMethod + RelativeUri string + func (*AppEngineHttpTarget) Descriptor() ([]byte, []int) + func (*AppEngineHttpTarget) ProtoMessage() + func (x *AppEngineHttpTarget) GetAppEngineRouting() *AppEngineRouting + func (x *AppEngineHttpTarget) GetBody() []byte + func (x *AppEngineHttpTarget) GetHeaders() map[string]string + func (x *AppEngineHttpTarget) GetHttpMethod() HttpMethod + func (x *AppEngineHttpTarget) GetRelativeUri() string + func (x *AppEngineHttpTarget) ProtoReflect() protoreflect.Message + func (x *AppEngineHttpTarget) Reset() + func (x *AppEngineHttpTarget) String() string + type AppEngineRouting struct + Host string + Instance string + Service string + Version string + func (*AppEngineRouting) Descriptor() ([]byte, []int) + func (*AppEngineRouting) ProtoMessage() + func (x *AppEngineRouting) GetHost() string + func (x *AppEngineRouting) GetInstance() string + func (x *AppEngineRouting) GetService() string + func (x *AppEngineRouting) GetVersion() string + func (x *AppEngineRouting) ProtoReflect() protoreflect.Message + func (x *AppEngineRouting) Reset() + func (x *AppEngineRouting) String() string + type CloudSchedulerClient interface + CreateJob func(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) + DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) + GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) + ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) + PauseJob func(ctx context.Context, in *PauseJobRequest, opts ...grpc.CallOption) (*Job, error) + ResumeJob func(ctx context.Context, in *ResumeJobRequest, opts ...grpc.CallOption) (*Job, error) + RunJob func(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*Job, error) + UpdateJob func(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) + func NewCloudSchedulerClient(cc grpc.ClientConnInterface) CloudSchedulerClient + type CloudSchedulerServer interface + CreateJob func(context.Context, *CreateJobRequest) (*Job, error) + DeleteJob func(context.Context, *DeleteJobRequest) (*empty.Empty, error) + GetJob func(context.Context, *GetJobRequest) (*Job, error) + ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + PauseJob func(context.Context, *PauseJobRequest) (*Job, error) + ResumeJob func(context.Context, *ResumeJobRequest) (*Job, error) + RunJob func(context.Context, *RunJobRequest) (*Job, error) + UpdateJob func(context.Context, *UpdateJobRequest) (*Job, error) + type CreateJobRequest struct + Job *Job + Parent string + func (*CreateJobRequest) Descriptor() ([]byte, []int) + func (*CreateJobRequest) ProtoMessage() + func (x *CreateJobRequest) GetJob() *Job + func (x *CreateJobRequest) GetParent() string + func (x *CreateJobRequest) ProtoReflect() protoreflect.Message + func (x *CreateJobRequest) Reset() + func (x *CreateJobRequest) String() string + type DeleteJobRequest struct + Name string + func (*DeleteJobRequest) Descriptor() ([]byte, []int) + func (*DeleteJobRequest) ProtoMessage() + func (x *DeleteJobRequest) GetName() string + func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message + func (x *DeleteJobRequest) Reset() + func (x *DeleteJobRequest) String() string + type GetJobRequest struct + Name string + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (x *GetJobRequest) GetName() string + func (x *GetJobRequest) ProtoReflect() protoreflect.Message + func (x *GetJobRequest) Reset() + func (x *GetJobRequest) String() string + type HttpMethod int32 + const HttpMethod_DELETE + const HttpMethod_GET + const HttpMethod_HEAD + const HttpMethod_HTTP_METHOD_UNSPECIFIED + const HttpMethod_OPTIONS + const HttpMethod_PATCH + const HttpMethod_POST + const HttpMethod_PUT + func (HttpMethod) Descriptor() protoreflect.EnumDescriptor + func (HttpMethod) EnumDescriptor() ([]byte, []int) + func (HttpMethod) Type() protoreflect.EnumType + func (x HttpMethod) Enum() *HttpMethod + func (x HttpMethod) Number() protoreflect.EnumNumber + func (x HttpMethod) String() string + type HttpTarget struct + AuthorizationHeader isHttpTarget_AuthorizationHeader + Body []byte + Headers map[string]string + HttpMethod HttpMethod + Uri string + func (*HttpTarget) Descriptor() ([]byte, []int) + func (*HttpTarget) ProtoMessage() + func (m *HttpTarget) GetAuthorizationHeader() isHttpTarget_AuthorizationHeader + func (x *HttpTarget) GetBody() []byte + func (x *HttpTarget) GetHeaders() map[string]string + func (x *HttpTarget) GetHttpMethod() HttpMethod + func (x *HttpTarget) GetOauthToken() *OAuthToken + func (x *HttpTarget) GetOidcToken() *OidcToken + func (x *HttpTarget) GetUri() string + func (x *HttpTarget) ProtoReflect() protoreflect.Message + func (x *HttpTarget) Reset() + func (x *HttpTarget) String() string + type HttpTarget_OauthToken struct + OauthToken *OAuthToken + type HttpTarget_OidcToken struct + OidcToken *OidcToken + type Job struct + AttemptDeadline *duration.Duration + Description string + LastAttemptTime *timestamp.Timestamp + Name string + RetryConfig *RetryConfig + Schedule string + ScheduleTime *timestamp.Timestamp + State Job_State + Status *status.Status + Target isJob_Target + TimeZone string + UserUpdateTime *timestamp.Timestamp + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (m *Job) GetTarget() isJob_Target + func (x *Job) GetAppEngineHttpTarget() *AppEngineHttpTarget + func (x *Job) GetAttemptDeadline() *duration.Duration + func (x *Job) GetDescription() string + func (x *Job) GetHttpTarget() *HttpTarget + func (x *Job) GetLastAttemptTime() *timestamp.Timestamp + func (x *Job) GetName() string + func (x *Job) GetPubsubTarget() *PubsubTarget + func (x *Job) GetRetryConfig() *RetryConfig + func (x *Job) GetSchedule() string + func (x *Job) GetScheduleTime() *timestamp.Timestamp + func (x *Job) GetState() Job_State + func (x *Job) GetStatus() *status.Status + func (x *Job) GetTimeZone() string + func (x *Job) GetUserUpdateTime() *timestamp.Timestamp + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type Job_AppEngineHttpTarget struct + AppEngineHttpTarget *AppEngineHttpTarget + type Job_HttpTarget struct + HttpTarget *HttpTarget + type Job_PubsubTarget struct + PubsubTarget *PubsubTarget + type Job_State int32 + const Job_DISABLED + const Job_ENABLED + const Job_PAUSED + const Job_STATE_UNSPECIFIED + const Job_UPDATE_FAILED + func (Job_State) Descriptor() protoreflect.EnumDescriptor + func (Job_State) EnumDescriptor() ([]byte, []int) + func (Job_State) Type() protoreflect.EnumType + func (x Job_State) Enum() *Job_State + func (x Job_State) Number() protoreflect.EnumNumber + func (x Job_State) String() string + type ListJobsRequest struct + PageSize int32 + PageToken string + Parent string + func (*ListJobsRequest) Descriptor() ([]byte, []int) + func (*ListJobsRequest) ProtoMessage() + func (x *ListJobsRequest) GetPageSize() int32 + func (x *ListJobsRequest) GetPageToken() string + func (x *ListJobsRequest) GetParent() string + func (x *ListJobsRequest) ProtoReflect() protoreflect.Message + func (x *ListJobsRequest) Reset() + func (x *ListJobsRequest) String() string + type ListJobsResponse struct + Jobs []*Job + NextPageToken string + func (*ListJobsResponse) Descriptor() ([]byte, []int) + func (*ListJobsResponse) ProtoMessage() + func (x *ListJobsResponse) GetJobs() []*Job + func (x *ListJobsResponse) GetNextPageToken() string + func (x *ListJobsResponse) ProtoReflect() protoreflect.Message + func (x *ListJobsResponse) Reset() + func (x *ListJobsResponse) String() string + type OAuthToken struct + Scope string + ServiceAccountEmail string + func (*OAuthToken) Descriptor() ([]byte, []int) + func (*OAuthToken) ProtoMessage() + func (x *OAuthToken) GetScope() string + func (x *OAuthToken) GetServiceAccountEmail() string + func (x *OAuthToken) ProtoReflect() protoreflect.Message + func (x *OAuthToken) Reset() + func (x *OAuthToken) String() string + type OidcToken struct + Audience string + ServiceAccountEmail string + func (*OidcToken) Descriptor() ([]byte, []int) + func (*OidcToken) ProtoMessage() + func (x *OidcToken) GetAudience() string + func (x *OidcToken) GetServiceAccountEmail() string + func (x *OidcToken) ProtoReflect() protoreflect.Message + func (x *OidcToken) Reset() + func (x *OidcToken) String() string + type PauseJobRequest struct + Name string + func (*PauseJobRequest) Descriptor() ([]byte, []int) + func (*PauseJobRequest) ProtoMessage() + func (x *PauseJobRequest) GetName() string + func (x *PauseJobRequest) ProtoReflect() protoreflect.Message + func (x *PauseJobRequest) Reset() + func (x *PauseJobRequest) String() string + type PubsubTarget struct + Attributes map[string]string + Data []byte + TopicName string + func (*PubsubTarget) Descriptor() ([]byte, []int) + func (*PubsubTarget) ProtoMessage() + func (x *PubsubTarget) GetAttributes() map[string]string + func (x *PubsubTarget) GetData() []byte + func (x *PubsubTarget) GetTopicName() string + func (x *PubsubTarget) ProtoReflect() protoreflect.Message + func (x *PubsubTarget) Reset() + func (x *PubsubTarget) String() string + type ResumeJobRequest struct + Name string + func (*ResumeJobRequest) Descriptor() ([]byte, []int) + func (*ResumeJobRequest) ProtoMessage() + func (x *ResumeJobRequest) GetName() string + func (x *ResumeJobRequest) ProtoReflect() protoreflect.Message + func (x *ResumeJobRequest) Reset() + func (x *ResumeJobRequest) String() string + type RetryConfig struct + MaxBackoffDuration *duration.Duration + MaxDoublings int32 + MaxRetryDuration *duration.Duration + MinBackoffDuration *duration.Duration + RetryCount int32 + func (*RetryConfig) Descriptor() ([]byte, []int) + func (*RetryConfig) ProtoMessage() + func (x *RetryConfig) GetMaxBackoffDuration() *duration.Duration + func (x *RetryConfig) GetMaxDoublings() int32 + func (x *RetryConfig) GetMaxRetryDuration() *duration.Duration + func (x *RetryConfig) GetMinBackoffDuration() *duration.Duration + func (x *RetryConfig) GetRetryCount() int32 + func (x *RetryConfig) ProtoReflect() protoreflect.Message + func (x *RetryConfig) Reset() + func (x *RetryConfig) String() string + type RunJobRequest struct + Name string + func (*RunJobRequest) Descriptor() ([]byte, []int) + func (*RunJobRequest) ProtoMessage() + func (x *RunJobRequest) GetName() string + func (x *RunJobRequest) ProtoReflect() protoreflect.Message + func (x *RunJobRequest) Reset() + func (x *RunJobRequest) String() string + type UnimplementedCloudSchedulerServer struct + func (*UnimplementedCloudSchedulerServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error) + func (*UnimplementedCloudSchedulerServer) DeleteJob(context.Context, *DeleteJobRequest) (*empty.Empty, error) + func (*UnimplementedCloudSchedulerServer) GetJob(context.Context, *GetJobRequest) (*Job, error) + func (*UnimplementedCloudSchedulerServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + func (*UnimplementedCloudSchedulerServer) PauseJob(context.Context, *PauseJobRequest) (*Job, error) + func (*UnimplementedCloudSchedulerServer) ResumeJob(context.Context, *ResumeJobRequest) (*Job, error) + func (*UnimplementedCloudSchedulerServer) RunJob(context.Context, *RunJobRequest) (*Job, error) + func (*UnimplementedCloudSchedulerServer) UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) + type UpdateJobRequest struct + Job *Job + UpdateMask *field_mask.FieldMask + func (*UpdateJobRequest) Descriptor() ([]byte, []int) + func (*UpdateJobRequest) ProtoMessage() + func (x *UpdateJobRequest) GetJob() *Job + func (x *UpdateJobRequest) GetUpdateMask() *field_mask.FieldMask + func (x *UpdateJobRequest) ProtoReflect() protoreflect.Message + func (x *UpdateJobRequest) Reset() + func (x *UpdateJobRequest) String() string