schedulerv1alpha1

package
v1.36.11-2025092821081... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: BSD-3-Clause Imports: 8 Imported by: 1

Documentation

Index

Constants

View Source 
const Job_ContinuousOptions_case case_Job_Options = 3
View Source 
const Job_OneShotOptions_case case_Job_Options = 4
View Source 
const Job_Options_not_set_case case_Job_Options = 0
View Source 
const Job_QueuedOptions_case case_Job_Options = 5
View Source 
const Job_RecurringOptions_case case_Job_Options = 6

Variables

View Source 
var File_dendra_job_scheduler_v1alpha1_request_response_proto protoreflect.FileDescriptor
View Source 
var File_dendra_job_scheduler_v1alpha1_service_proto protoreflect.FileDescriptor
View Source 
var File_dendra_job_scheduler_v1alpha1_types_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CancelJobRequest 

type CancelJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelJobRequest) GetJobId 

func (x *CancelJobRequest) GetJobId() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

func (x *CancelJobRequest) ProtoReflect() protoreflect.Message

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) SetJobId 

func (x *CancelJobRequest) SetJobId(v string)

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CancelJobRequest_builder 

type CancelJobRequest_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (CancelJobRequest_builder) Build 

func (b0 CancelJobRequest_builder) Build() *CancelJobRequest

type CancelJobResponse 

type CancelJobResponse struct {
	// contains filtered or unexported fields
}

func (*CancelJobResponse) ProtoMessage 

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) ProtoReflect 

func (x *CancelJobResponse) ProtoReflect() protoreflect.Message

func (*CancelJobResponse) Reset 

func (x *CancelJobResponse) Reset()

func (*CancelJobResponse) String 

func (x *CancelJobResponse) String() string

type CancelJobResponse_builder 

type CancelJobResponse_builder struct {
	// contains filtered or unexported fields
}

func (CancelJobResponse_builder) Build 

func (b0 CancelJobResponse_builder) Build() *CancelJobResponse

type ContinuousJobOptions 

type ContinuousJobOptions struct {
	Timeout *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinuousJobOptions) ClearTimeout 

func (x *ContinuousJobOptions) ClearTimeout()

func (*ContinuousJobOptions) GetTimeout 

func (x *ContinuousJobOptions) GetTimeout() *durationpb.Duration

func (*ContinuousJobOptions) HasTimeout 

func (x *ContinuousJobOptions) HasTimeout() bool

func (*ContinuousJobOptions) ProtoMessage 

func (*ContinuousJobOptions) ProtoMessage()

func (*ContinuousJobOptions) ProtoReflect 

func (x *ContinuousJobOptions) ProtoReflect() protoreflect.Message

func (*ContinuousJobOptions) Reset 

func (x *ContinuousJobOptions) Reset()

func (*ContinuousJobOptions) SetTimeout 

func (x *ContinuousJobOptions) SetTimeout(v *durationpb.Duration)

func (*ContinuousJobOptions) String 

func (x *ContinuousJobOptions) String() string

type ContinuousJobOptions_builder 

type ContinuousJobOptions_builder struct {
	Timeout *durationpb.Duration
	// contains filtered or unexported fields
}

func (ContinuousJobOptions_builder) Build 

func (b0 ContinuousJobOptions_builder) Build() *ContinuousJobOptions

type CreateContinuousJobRequest 

type CreateContinuousJobRequest struct {
	JobId   string                      `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobType string                      `protobuf:"bytes,2,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	Timeout *durationpb.Duration        `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Spec    *v1alpha1.ContinuousJobSpec `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateContinuousJobRequest) ClearSpec 

func (x *CreateContinuousJobRequest) ClearSpec()

func (*CreateContinuousJobRequest) ClearTimeout 

func (x *CreateContinuousJobRequest) ClearTimeout()

func (*CreateContinuousJobRequest) GetJobId 

func (x *CreateContinuousJobRequest) GetJobId() string

func (*CreateContinuousJobRequest) GetJobType 

func (x *CreateContinuousJobRequest) GetJobType() string

func (*CreateContinuousJobRequest) GetSpec 

func (x *CreateContinuousJobRequest) GetSpec() *v1alpha1.ContinuousJobSpec

func (*CreateContinuousJobRequest) GetTimeout 

func (x *CreateContinuousJobRequest) GetTimeout() *durationpb.Duration

func (*CreateContinuousJobRequest) HasSpec 

func (x *CreateContinuousJobRequest) HasSpec() bool

func (*CreateContinuousJobRequest) HasTimeout 

func (x *CreateContinuousJobRequest) HasTimeout() bool

func (*CreateContinuousJobRequest) ProtoMessage 

func (*CreateContinuousJobRequest) ProtoMessage()

func (*CreateContinuousJobRequest) ProtoReflect 

func (x *CreateContinuousJobRequest) ProtoReflect() protoreflect.Message

func (*CreateContinuousJobRequest) Reset 

func (x *CreateContinuousJobRequest) Reset()

func (*CreateContinuousJobRequest) SetJobId 

func (x *CreateContinuousJobRequest) SetJobId(v string)

func (*CreateContinuousJobRequest) SetJobType 

func (x *CreateContinuousJobRequest) SetJobType(v string)

func (*CreateContinuousJobRequest) SetSpec 

func (x *CreateContinuousJobRequest) SetSpec(v *v1alpha1.ContinuousJobSpec)

func (*CreateContinuousJobRequest) SetTimeout 

func (x *CreateContinuousJobRequest) SetTimeout(v *durationpb.Duration)

func (*CreateContinuousJobRequest) String 

func (x *CreateContinuousJobRequest) String() string

type CreateContinuousJobRequest_builder 

type CreateContinuousJobRequest_builder struct {
	JobId   string
	JobType string
	Timeout *durationpb.Duration
	Spec    *v1alpha1.ContinuousJobSpec
	// contains filtered or unexported fields
}

func (CreateContinuousJobRequest_builder) Build 

func (b0 CreateContinuousJobRequest_builder) Build() *CreateContinuousJobRequest

type CreateContinuousJobResponse 

type CreateContinuousJobResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateContinuousJobResponse) GetJobId 

func (x *CreateContinuousJobResponse) GetJobId() string

func (*CreateContinuousJobResponse) ProtoMessage 

func (*CreateContinuousJobResponse) ProtoMessage()

func (*CreateContinuousJobResponse) ProtoReflect 

func (x *CreateContinuousJobResponse) ProtoReflect() protoreflect.Message

func (*CreateContinuousJobResponse) Reset 

func (x *CreateContinuousJobResponse) Reset()

func (*CreateContinuousJobResponse) SetJobId 

func (x *CreateContinuousJobResponse) SetJobId(v string)

func (*CreateContinuousJobResponse) String 

func (x *CreateContinuousJobResponse) String() string

type CreateContinuousJobResponse_builder 

type CreateContinuousJobResponse_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (CreateContinuousJobResponse_builder) Build 

func (b0 CreateContinuousJobResponse_builder) Build() *CreateContinuousJobResponse

type CreateOneShotJobRequest 

type CreateOneShotJobRequest struct {
	JobId   string                   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobType string                   `protobuf:"bytes,2,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	Timeout *durationpb.Duration     `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Spec    *v1alpha1.OneShotJobSpec `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateOneShotJobRequest) ClearSpec 

func (x *CreateOneShotJobRequest) ClearSpec()

func (*CreateOneShotJobRequest) ClearTimeout 

func (x *CreateOneShotJobRequest) ClearTimeout()

func (*CreateOneShotJobRequest) GetJobId 

func (x *CreateOneShotJobRequest) GetJobId() string

func (*CreateOneShotJobRequest) GetJobType 

func (x *CreateOneShotJobRequest) GetJobType() string

func (*CreateOneShotJobRequest) GetSpec 

func (x *CreateOneShotJobRequest) GetSpec() *v1alpha1.OneShotJobSpec

func (*CreateOneShotJobRequest) GetTimeout 

func (x *CreateOneShotJobRequest) GetTimeout() *durationpb.Duration

func (*CreateOneShotJobRequest) HasSpec 

func (x *CreateOneShotJobRequest) HasSpec() bool

func (*CreateOneShotJobRequest) HasTimeout 

func (x *CreateOneShotJobRequest) HasTimeout() bool

func (*CreateOneShotJobRequest) ProtoMessage 

func (*CreateOneShotJobRequest) ProtoMessage()

func (*CreateOneShotJobRequest) ProtoReflect 

func (x *CreateOneShotJobRequest) ProtoReflect() protoreflect.Message

func (*CreateOneShotJobRequest) Reset 

func (x *CreateOneShotJobRequest) Reset()

func (*CreateOneShotJobRequest) SetJobId 

func (x *CreateOneShotJobRequest) SetJobId(v string)

func (*CreateOneShotJobRequest) SetJobType 

func (x *CreateOneShotJobRequest) SetJobType(v string)

func (*CreateOneShotJobRequest) SetSpec 

func (x *CreateOneShotJobRequest) SetSpec(v *v1alpha1.OneShotJobSpec)

func (*CreateOneShotJobRequest) SetTimeout 

func (x *CreateOneShotJobRequest) SetTimeout(v *durationpb.Duration)

func (*CreateOneShotJobRequest) String 

func (x *CreateOneShotJobRequest) String() string

type CreateOneShotJobRequest_builder 

type CreateOneShotJobRequest_builder struct {
	JobId   string
	JobType string
	Timeout *durationpb.Duration
	Spec    *v1alpha1.OneShotJobSpec
	// contains filtered or unexported fields
}

func (CreateOneShotJobRequest_builder) Build 

func (b0 CreateOneShotJobRequest_builder) Build() *CreateOneShotJobRequest

type CreateOneShotJobResponse 

type CreateOneShotJobResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateOneShotJobResponse) GetJobId 

func (x *CreateOneShotJobResponse) GetJobId() string

func (*CreateOneShotJobResponse) ProtoMessage 

func (*CreateOneShotJobResponse) ProtoMessage()

func (*CreateOneShotJobResponse) ProtoReflect 

func (x *CreateOneShotJobResponse) ProtoReflect() protoreflect.Message

func (*CreateOneShotJobResponse) Reset 

func (x *CreateOneShotJobResponse) Reset()

func (*CreateOneShotJobResponse) SetJobId 

func (x *CreateOneShotJobResponse) SetJobId(v string)

func (*CreateOneShotJobResponse) String 

func (x *CreateOneShotJobResponse) String() string

type CreateOneShotJobResponse_builder 

type CreateOneShotJobResponse_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (CreateOneShotJobResponse_builder) Build 

func (b0 CreateOneShotJobResponse_builder) Build() *CreateOneShotJobResponse

type CreateQueuedJobRequest 

type CreateQueuedJobRequest struct {
	JobId   string                  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobType string                  `protobuf:"bytes,2,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	Timeout *durationpb.Duration    `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Queue   string                  `protobuf:"bytes,4,opt,name=queue,proto3" json:"queue,omitempty"`
	Spec    *v1alpha1.QueuedJobSpec `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateQueuedJobRequest) ClearSpec 

func (x *CreateQueuedJobRequest) ClearSpec()

func (*CreateQueuedJobRequest) ClearTimeout 

func (x *CreateQueuedJobRequest) ClearTimeout()

func (*CreateQueuedJobRequest) GetJobId 

func (x *CreateQueuedJobRequest) GetJobId() string

func (*CreateQueuedJobRequest) GetJobType 

func (x *CreateQueuedJobRequest) GetJobType() string

func (*CreateQueuedJobRequest) GetQueue 

func (x *CreateQueuedJobRequest) GetQueue() string

func (*CreateQueuedJobRequest) GetSpec 

func (x *CreateQueuedJobRequest) GetSpec() *v1alpha1.QueuedJobSpec

func (*CreateQueuedJobRequest) GetTimeout 

func (x *CreateQueuedJobRequest) GetTimeout() *durationpb.Duration

func (*CreateQueuedJobRequest) HasSpec 

func (x *CreateQueuedJobRequest) HasSpec() bool

func (*CreateQueuedJobRequest) HasTimeout 

func (x *CreateQueuedJobRequest) HasTimeout() bool

func (*CreateQueuedJobRequest) ProtoMessage 

func (*CreateQueuedJobRequest) ProtoMessage()

func (*CreateQueuedJobRequest) ProtoReflect 

func (x *CreateQueuedJobRequest) ProtoReflect() protoreflect.Message

func (*CreateQueuedJobRequest) Reset 

func (x *CreateQueuedJobRequest) Reset()

func (*CreateQueuedJobRequest) SetJobId 

func (x *CreateQueuedJobRequest) SetJobId(v string)

func (*CreateQueuedJobRequest) SetJobType 

func (x *CreateQueuedJobRequest) SetJobType(v string)

func (*CreateQueuedJobRequest) SetQueue 

func (x *CreateQueuedJobRequest) SetQueue(v string)

func (*CreateQueuedJobRequest) SetSpec 

func (x *CreateQueuedJobRequest) SetSpec(v *v1alpha1.QueuedJobSpec)

func (*CreateQueuedJobRequest) SetTimeout 

func (x *CreateQueuedJobRequest) SetTimeout(v *durationpb.Duration)

func (*CreateQueuedJobRequest) String 

func (x *CreateQueuedJobRequest) String() string

type CreateQueuedJobRequest_builder 

type CreateQueuedJobRequest_builder struct {
	JobId   string
	JobType string
	Timeout *durationpb.Duration
	Queue   string
	Spec    *v1alpha1.QueuedJobSpec
	// contains filtered or unexported fields
}

func (CreateQueuedJobRequest_builder) Build 

func (b0 CreateQueuedJobRequest_builder) Build() *CreateQueuedJobRequest

type CreateQueuedJobResponse 

type CreateQueuedJobResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateQueuedJobResponse) GetJobId 

func (x *CreateQueuedJobResponse) GetJobId() string

func (*CreateQueuedJobResponse) ProtoMessage 

func (*CreateQueuedJobResponse) ProtoMessage()

func (*CreateQueuedJobResponse) ProtoReflect 

func (x *CreateQueuedJobResponse) ProtoReflect() protoreflect.Message

func (*CreateQueuedJobResponse) Reset 

func (x *CreateQueuedJobResponse) Reset()

func (*CreateQueuedJobResponse) SetJobId 

func (x *CreateQueuedJobResponse) SetJobId(v string)

func (*CreateQueuedJobResponse) String 

func (x *CreateQueuedJobResponse) String() string

type CreateQueuedJobResponse_builder 

type CreateQueuedJobResponse_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (CreateQueuedJobResponse_builder) Build 

func (b0 CreateQueuedJobResponse_builder) Build() *CreateQueuedJobResponse

type CreateRecurringJobRequest 

type CreateRecurringJobRequest struct {
	JobId      string                     `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobType    string                     `protobuf:"bytes,2,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	Timeout    *durationpb.Duration       `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	RecurEvery *durationpb.Duration       `protobuf:"bytes,4,opt,name=recur_every,json=recurEvery,proto3" json:"recur_every,omitempty"`
	Spec       *v1alpha1.RecurringJobSpec `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRecurringJobRequest) ClearRecurEvery 

func (x *CreateRecurringJobRequest) ClearRecurEvery()

func (*CreateRecurringJobRequest) ClearSpec 

func (x *CreateRecurringJobRequest) ClearSpec()

func (*CreateRecurringJobRequest) ClearTimeout 

func (x *CreateRecurringJobRequest) ClearTimeout()

func (*CreateRecurringJobRequest) GetJobId 

func (x *CreateRecurringJobRequest) GetJobId() string

func (*CreateRecurringJobRequest) GetJobType 

func (x *CreateRecurringJobRequest) GetJobType() string

func (*CreateRecurringJobRequest) GetRecurEvery 

func (x *CreateRecurringJobRequest) GetRecurEvery() *durationpb.Duration

func (*CreateRecurringJobRequest) GetSpec 

func (x *CreateRecurringJobRequest) GetSpec() *v1alpha1.RecurringJobSpec

func (*CreateRecurringJobRequest) GetTimeout 

func (x *CreateRecurringJobRequest) GetTimeout() *durationpb.Duration

func (*CreateRecurringJobRequest) HasRecurEvery 

func (x *CreateRecurringJobRequest) HasRecurEvery() bool

func (*CreateRecurringJobRequest) HasSpec 

func (x *CreateRecurringJobRequest) HasSpec() bool

func (*CreateRecurringJobRequest) HasTimeout 

func (x *CreateRecurringJobRequest) HasTimeout() bool

func (*CreateRecurringJobRequest) ProtoMessage 

func (*CreateRecurringJobRequest) ProtoMessage()

func (*CreateRecurringJobRequest) ProtoReflect 

func (x *CreateRecurringJobRequest) ProtoReflect() protoreflect.Message

func (*CreateRecurringJobRequest) Reset 

func (x *CreateRecurringJobRequest) Reset()

func (*CreateRecurringJobRequest) SetJobId 

func (x *CreateRecurringJobRequest) SetJobId(v string)

func (*CreateRecurringJobRequest) SetJobType 

func (x *CreateRecurringJobRequest) SetJobType(v string)

func (*CreateRecurringJobRequest) SetRecurEvery 

func (x *CreateRecurringJobRequest) SetRecurEvery(v *durationpb.Duration)

func (*CreateRecurringJobRequest) SetSpec 

func (x *CreateRecurringJobRequest) SetSpec(v *v1alpha1.RecurringJobSpec)

func (*CreateRecurringJobRequest) SetTimeout 

func (x *CreateRecurringJobRequest) SetTimeout(v *durationpb.Duration)

func (*CreateRecurringJobRequest) String 

func (x *CreateRecurringJobRequest) String() string

type CreateRecurringJobRequest_builder 

type CreateRecurringJobRequest_builder struct {
	JobId      string
	JobType    string
	Timeout    *durationpb.Duration
	RecurEvery *durationpb.Duration
	Spec       *v1alpha1.RecurringJobSpec
	// contains filtered or unexported fields
}

func (CreateRecurringJobRequest_builder) Build 

func (b0 CreateRecurringJobRequest_builder) Build() *CreateRecurringJobRequest

type CreateRecurringJobResponse 

type CreateRecurringJobResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRecurringJobResponse) GetJobId 

func (x *CreateRecurringJobResponse) GetJobId() string

func (*CreateRecurringJobResponse) ProtoMessage 

func (*CreateRecurringJobResponse) ProtoMessage()

func (*CreateRecurringJobResponse) ProtoReflect 

func (x *CreateRecurringJobResponse) ProtoReflect() protoreflect.Message

func (*CreateRecurringJobResponse) Reset 

func (x *CreateRecurringJobResponse) Reset()

func (*CreateRecurringJobResponse) SetJobId 

func (x *CreateRecurringJobResponse) SetJobId(v string)

func (*CreateRecurringJobResponse) String 

func (x *CreateRecurringJobResponse) String() string

type CreateRecurringJobResponse_builder 

type CreateRecurringJobResponse_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (CreateRecurringJobResponse_builder) Build 

func (b0 CreateRecurringJobResponse_builder) Build() *CreateRecurringJobResponse

type DeleteJobRequest 

type DeleteJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteJobRequest) GetJobId 

func (x *DeleteJobRequest) GetJobId() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) ProtoReflect 

func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message

func (*DeleteJobRequest) Reset 

func (x *DeleteJobRequest) Reset()

func (*DeleteJobRequest) SetJobId 

func (x *DeleteJobRequest) SetJobId(v string)

func (*DeleteJobRequest) String 

func (x *DeleteJobRequest) String() string

type DeleteJobRequest_builder 

type DeleteJobRequest_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (DeleteJobRequest_builder) Build 

func (b0 DeleteJobRequest_builder) Build() *DeleteJobRequest

type DeleteJobResponse 

type DeleteJobResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteJobResponse) ProtoMessage 

func (*DeleteJobResponse) ProtoMessage()

func (*DeleteJobResponse) ProtoReflect 

func (x *DeleteJobResponse) ProtoReflect() protoreflect.Message

func (*DeleteJobResponse) Reset 

func (x *DeleteJobResponse) Reset()

func (*DeleteJobResponse) String 

func (x *DeleteJobResponse) String() string

type DeleteJobResponse_builder 

type DeleteJobResponse_builder struct {
	// contains filtered or unexported fields
}

func (DeleteJobResponse_builder) Build 

func (b0 DeleteJobResponse_builder) Build() *DeleteJobResponse

type GetJobRequest 

type GetJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) GetJobId 

func (x *GetJobRequest) GetJobId() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

func (x *GetJobRequest) ProtoReflect() protoreflect.Message

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) SetJobId 

func (x *GetJobRequest) SetJobId(v string)

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobRequest_builder 

type GetJobRequest_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (GetJobRequest_builder) Build 

func (b0 GetJobRequest_builder) Build() *GetJobRequest

type GetJobResponse 

type GetJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) ClearJob 

func (x *GetJobResponse) ClearJob()

func (*GetJobResponse) GetJob 

func (x *GetJobResponse) GetJob() *Job

func (*GetJobResponse) HasJob 

func (x *GetJobResponse) HasJob() bool

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

func (x *GetJobResponse) ProtoReflect() protoreflect.Message

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) SetJob 

func (x *GetJobResponse) SetJob(v *Job)

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

type GetJobResponse_builder 

type GetJobResponse_builder struct {
	Job *Job
	// contains filtered or unexported fields
}

func (GetJobResponse_builder) Build 

func (b0 GetJobResponse_builder) Build() *GetJobResponse

type Job 

type Job struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Types that are valid to be assigned to Options:
	//
	//	*Job_ContinuousOptions
	//	*Job_OneShotOptions
	//	*Job_QueuedOptions
	//	*Job_RecurringOptions
	Options    isJob_Options          `protobuf_oneof:"options"`
	Spec       *v1alpha11.JobSpec     `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	SpecTs     *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=spec_ts,json=specTs,proto3" json:"spec_ts,omitempty"`
	RunDetails *JobRunDetails         `protobuf:"bytes,10,opt,name=run_details,json=runDetails,proto3" json:"run_details,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) ClearContinuousOptions 

func (x *Job) ClearContinuousOptions()

func (*Job) ClearOneShotOptions 

func (x *Job) ClearOneShotOptions()

func (*Job) ClearOptions 

func (x *Job) ClearOptions()

func (*Job) ClearQueuedOptions 

func (x *Job) ClearQueuedOptions()

func (*Job) ClearRecurringOptions 

func (x *Job) ClearRecurringOptions()

func (*Job) ClearRunDetails 

func (x *Job) ClearRunDetails()

func (*Job) ClearSpec 

func (x *Job) ClearSpec()

func (*Job) ClearSpecTs 

func (x *Job) ClearSpecTs()

func (*Job) GetContinuousOptions 

func (x *Job) GetContinuousOptions() *ContinuousJobOptions

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetOneShotOptions 

func (x *Job) GetOneShotOptions() *OneShotJobOptions

func (*Job) GetOptions 

func (x *Job) GetOptions() isJob_Options

func (*Job) GetQueuedOptions 

func (x *Job) GetQueuedOptions() *QueuedJobOptions

func (*Job) GetRecurringOptions 

func (x *Job) GetRecurringOptions() *RecurringJobOptions

func (*Job) GetRunDetails 

func (x *Job) GetRunDetails() *JobRunDetails

func (*Job) GetSpec 

func (x *Job) GetSpec() *v1alpha11.JobSpec

func (*Job) GetSpecTs 

func (x *Job) GetSpecTs() *timestamppb.Timestamp

func (*Job) GetType 

func (x *Job) GetType() string

func (*Job) HasContinuousOptions 

func (x *Job) HasContinuousOptions() bool

func (*Job) HasOneShotOptions 

func (x *Job) HasOneShotOptions() bool

func (*Job) HasOptions 

func (x *Job) HasOptions() bool

func (*Job) HasQueuedOptions 

func (x *Job) HasQueuedOptions() bool

func (*Job) HasRecurringOptions 

func (x *Job) HasRecurringOptions() bool

func (*Job) HasRunDetails 

func (x *Job) HasRunDetails() bool

func (*Job) HasSpec 

func (x *Job) HasSpec() bool

func (*Job) HasSpecTs 

func (x *Job) HasSpecTs() bool

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) SetContinuousOptions 

func (x *Job) SetContinuousOptions(v *ContinuousJobOptions)

func (*Job) SetId 

func (x *Job) SetId(v string)

func (*Job) SetOneShotOptions 

func (x *Job) SetOneShotOptions(v *OneShotJobOptions)

func (*Job) SetQueuedOptions 

func (x *Job) SetQueuedOptions(v *QueuedJobOptions)

func (*Job) SetRecurringOptions 

func (x *Job) SetRecurringOptions(v *RecurringJobOptions)

func (*Job) SetRunDetails 

func (x *Job) SetRunDetails(v *JobRunDetails)

func (*Job) SetSpec 

func (x *Job) SetSpec(v *v1alpha11.JobSpec)

func (*Job) SetSpecTs 

func (x *Job) SetSpecTs(v *timestamppb.Timestamp)

func (*Job) SetType 

func (x *Job) SetType(v string)

func (*Job) String 

func (x *Job) String() string

func (*Job) WhichOptions 

func (x *Job) WhichOptions() case_Job_Options

type JobHistoryRecord 

type JobHistoryRecord struct {
	Ts       *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	JobState v1alpha1.JobState      `` /* 127-byte string literal not displayed */
	RunId    string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Worker   *v1alpha1.WorkerMeta   `protobuf:"bytes,4,opt,name=worker,proto3" json:"worker,omitempty"`
	Message  string                 `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*JobHistoryRecord) ClearTs 

func (x *JobHistoryRecord) ClearTs()

func (*JobHistoryRecord) ClearWorker 

func (x *JobHistoryRecord) ClearWorker()

func (*JobHistoryRecord) GetJobState 

func (x *JobHistoryRecord) GetJobState() v1alpha1.JobState

func (*JobHistoryRecord) GetMessage 

func (x *JobHistoryRecord) GetMessage() string

func (*JobHistoryRecord) GetRunId 

func (x *JobHistoryRecord) GetRunId() string

func (*JobHistoryRecord) GetTs 

func (x *JobHistoryRecord) GetTs() *timestamppb.Timestamp

func (*JobHistoryRecord) GetWorker 

func (x *JobHistoryRecord) GetWorker() *v1alpha1.WorkerMeta

func (*JobHistoryRecord) HasTs 

func (x *JobHistoryRecord) HasTs() bool

func (*JobHistoryRecord) HasWorker 

func (x *JobHistoryRecord) HasWorker() bool

func (*JobHistoryRecord) ProtoMessage 

func (*JobHistoryRecord) ProtoMessage()

func (*JobHistoryRecord) ProtoReflect 

func (x *JobHistoryRecord) ProtoReflect() protoreflect.Message

func (*JobHistoryRecord) Reset 

func (x *JobHistoryRecord) Reset()

func (*JobHistoryRecord) SetJobState 

func (x *JobHistoryRecord) SetJobState(v v1alpha1.JobState)

func (*JobHistoryRecord) SetMessage 

func (x *JobHistoryRecord) SetMessage(v string)

func (*JobHistoryRecord) SetRunId 

func (x *JobHistoryRecord) SetRunId(v string)

func (*JobHistoryRecord) SetTs 

func (x *JobHistoryRecord) SetTs(v *timestamppb.Timestamp)

func (*JobHistoryRecord) SetWorker 

func (x *JobHistoryRecord) SetWorker(v *v1alpha1.WorkerMeta)

func (*JobHistoryRecord) String 

func (x *JobHistoryRecord) String() string

type JobHistoryRecord_builder 

type JobHistoryRecord_builder struct {
	Ts       *timestamppb.Timestamp
	JobState v1alpha1.JobState
	RunId    string
	Worker   *v1alpha1.WorkerMeta
	Message  string
	// contains filtered or unexported fields
}

func (JobHistoryRecord_builder) Build 

func (b0 JobHistoryRecord_builder) Build() *JobHistoryRecord

type JobRunDetails 

type JobRunDetails struct {
	RunId  string               `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Worker *v1alpha1.WorkerMeta `protobuf:"bytes,5,opt,name=worker,proto3" json:"worker,omitempty"`
	Status *v1alpha1.JobStatus  `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRunDetails) ClearStatus 

func (x *JobRunDetails) ClearStatus()

func (*JobRunDetails) ClearWorker 

func (x *JobRunDetails) ClearWorker()

func (*JobRunDetails) GetRunId 

func (x *JobRunDetails) GetRunId() string

func (*JobRunDetails) GetStatus 

func (x *JobRunDetails) GetStatus() *v1alpha1.JobStatus

func (*JobRunDetails) GetWorker 

func (x *JobRunDetails) GetWorker() *v1alpha1.WorkerMeta

func (*JobRunDetails) HasStatus 

func (x *JobRunDetails) HasStatus() bool

func (*JobRunDetails) HasWorker 

func (x *JobRunDetails) HasWorker() bool

func (*JobRunDetails) ProtoMessage 

func (*JobRunDetails) ProtoMessage()

func (*JobRunDetails) ProtoReflect 

func (x *JobRunDetails) ProtoReflect() protoreflect.Message

func (*JobRunDetails) Reset 

func (x *JobRunDetails) Reset()

func (*JobRunDetails) SetRunId 

func (x *JobRunDetails) SetRunId(v string)

func (*JobRunDetails) SetStatus 

func (x *JobRunDetails) SetStatus(v *v1alpha1.JobStatus)

func (*JobRunDetails) SetWorker 

func (x *JobRunDetails) SetWorker(v *v1alpha1.WorkerMeta)

func (*JobRunDetails) String 

func (x *JobRunDetails) String() string

type JobRunDetails_builder 

type JobRunDetails_builder struct {
	RunId  string
	Worker *v1alpha1.WorkerMeta
	Status *v1alpha1.JobStatus
	// contains filtered or unexported fields
}

func (JobRunDetails_builder) Build 

func (b0 JobRunDetails_builder) Build() *JobRunDetails

type Job_ContinuousOptions 

type Job_ContinuousOptions struct {
	ContinuousOptions *ContinuousJobOptions `protobuf:"bytes,3,opt,name=continuous_options,json=continuousOptions,proto3,oneof"`
}

type Job_OneShotOptions 

type Job_OneShotOptions struct {
	OneShotOptions *OneShotJobOptions `protobuf:"bytes,4,opt,name=one_shot_options,json=oneShotOptions,proto3,oneof"`
}

type Job_QueuedOptions 

type Job_QueuedOptions struct {
	QueuedOptions *QueuedJobOptions `protobuf:"bytes,5,opt,name=queued_options,json=queuedOptions,proto3,oneof"`
}

type Job_RecurringOptions 

type Job_RecurringOptions struct {
	RecurringOptions *RecurringJobOptions `protobuf:"bytes,6,opt,name=recurring_options,json=recurringOptions,proto3,oneof"`
}

type Job_builder 

type Job_builder struct {
	Id   string
	Type string
	// Fields of oneof Options:
	ContinuousOptions *ContinuousJobOptions
	OneShotOptions    *OneShotJobOptions
	QueuedOptions     *QueuedJobOptions
	RecurringOptions  *RecurringJobOptions
	// -- end of Options
	Spec       *v1alpha11.JobSpec
	SpecTs     *timestamppb.Timestamp
	RunDetails *JobRunDetails
	// contains filtered or unexported fields
}

func (Job_builder) Build 

func (b0 Job_builder) Build() *Job

type ListJobHistoryRequest 

type ListJobHistoryRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobHistoryRequest) GetJobId 

func (x *ListJobHistoryRequest) GetJobId() string

func (*ListJobHistoryRequest) ProtoMessage 

func (*ListJobHistoryRequest) ProtoMessage()

func (*ListJobHistoryRequest) ProtoReflect 

func (x *ListJobHistoryRequest) ProtoReflect() protoreflect.Message

func (*ListJobHistoryRequest) Reset 

func (x *ListJobHistoryRequest) Reset()

func (*ListJobHistoryRequest) SetJobId 

func (x *ListJobHistoryRequest) SetJobId(v string)

func (*ListJobHistoryRequest) String 

func (x *ListJobHistoryRequest) String() string

type ListJobHistoryRequest_builder 

type ListJobHistoryRequest_builder struct {
	JobId string
	// contains filtered or unexported fields
}

func (ListJobHistoryRequest_builder) Build 

func (b0 ListJobHistoryRequest_builder) Build() *ListJobHistoryRequest

type ListJobHistoryResponse 

type ListJobHistoryResponse struct {
	Records []*JobHistoryRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobHistoryResponse) GetRecords 

func (x *ListJobHistoryResponse) GetRecords() []*JobHistoryRecord

func (*ListJobHistoryResponse) ProtoMessage 

func (*ListJobHistoryResponse) ProtoMessage()

func (*ListJobHistoryResponse) ProtoReflect 

func (x *ListJobHistoryResponse) ProtoReflect() protoreflect.Message

func (*ListJobHistoryResponse) Reset 

func (x *ListJobHistoryResponse) Reset()

func (*ListJobHistoryResponse) SetRecords 

func (x *ListJobHistoryResponse) SetRecords(v []*JobHistoryRecord)

func (*ListJobHistoryResponse) String 

func (x *ListJobHistoryResponse) String() string

type ListJobHistoryResponse_builder 

type ListJobHistoryResponse_builder struct {
	Records []*JobHistoryRecord
	// contains filtered or unexported fields
}

func (ListJobHistoryResponse_builder) Build 

func (b0 ListJobHistoryResponse_builder) Build() *ListJobHistoryResponse

type ListJobsRequest 

type ListJobsRequest struct {
	Filter *ListJobsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) ClearFilter 

func (x *ListJobsRequest) ClearFilter()

func (*ListJobsRequest) GetFilter 

func (x *ListJobsRequest) GetFilter() *ListJobsRequest_Filter

func (*ListJobsRequest) HasFilter 

func (x *ListJobsRequest) HasFilter() bool

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) SetFilter 

func (x *ListJobsRequest) SetFilter(v *ListJobsRequest_Filter)

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsRequest_Filter 

type ListJobsRequest_Filter struct {
	JobType string `protobuf:"bytes,1,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest_Filter) GetJobType 

func (x *ListJobsRequest_Filter) GetJobType() string

func (*ListJobsRequest_Filter) ProtoMessage 

func (*ListJobsRequest_Filter) ProtoMessage()

func (*ListJobsRequest_Filter) ProtoReflect 

func (x *ListJobsRequest_Filter) ProtoReflect() protoreflect.Message

func (*ListJobsRequest_Filter) Reset 

func (x *ListJobsRequest_Filter) Reset()

func (*ListJobsRequest_Filter) SetJobType 

func (x *ListJobsRequest_Filter) SetJobType(v string)

func (*ListJobsRequest_Filter) String 

func (x *ListJobsRequest_Filter) String() string

type ListJobsRequest_Filter_builder 

type ListJobsRequest_Filter_builder struct {
	JobType string
	// contains filtered or unexported fields
}

func (ListJobsRequest_Filter_builder) Build 

func (b0 ListJobsRequest_Filter_builder) Build() *ListJobsRequest_Filter

type ListJobsRequest_builder 

type ListJobsRequest_builder struct {
	Filter *ListJobsRequest_Filter
	// contains filtered or unexported fields
}

func (ListJobsRequest_builder) Build 

func (b0 ListJobsRequest_builder) Build() *ListJobsRequest

type ListJobsResponse 

type ListJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsResponse) GetJobs 

func (x *ListJobsResponse) GetJobs() []*Job

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

func (x *ListJobsResponse) ProtoReflect() protoreflect.Message

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) SetJobs 

func (x *ListJobsResponse) SetJobs(v []*Job)

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListJobsResponse_builder 

type ListJobsResponse_builder struct {
	Jobs []*Job
	// contains filtered or unexported fields
}

func (ListJobsResponse_builder) Build 

func (b0 ListJobsResponse_builder) Build() *ListJobsResponse

type ListWorkersRequest 

type ListWorkersRequest struct {
	// contains filtered or unexported fields
}

func (*ListWorkersRequest) ProtoMessage 

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) ProtoReflect 

func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message

func (*ListWorkersRequest) Reset 

func (x *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String 

func (x *ListWorkersRequest) String() string

type ListWorkersRequest_builder 

type ListWorkersRequest_builder struct {
	// contains filtered or unexported fields
}

func (ListWorkersRequest_builder) Build 

func (b0 ListWorkersRequest_builder) Build() *ListWorkersRequest

type ListWorkersResponse 

type ListWorkersResponse struct {
	Workers []*v1alpha11.WorkerMeta `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersResponse) GetWorkers 

func (x *ListWorkersResponse) GetWorkers() []*v1alpha11.WorkerMeta

func (*ListWorkersResponse) ProtoMessage 

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) ProtoReflect 

func (x *ListWorkersResponse) ProtoReflect() protoreflect.Message

func (*ListWorkersResponse) Reset 

func (x *ListWorkersResponse) Reset()

func (*ListWorkersResponse) SetWorkers 

func (x *ListWorkersResponse) SetWorkers(v []*v1alpha11.WorkerMeta)

func (*ListWorkersResponse) String 

func (x *ListWorkersResponse) String() string

type ListWorkersResponse_builder 

type ListWorkersResponse_builder struct {
	Workers []*v1alpha11.WorkerMeta
	// contains filtered or unexported fields
}

func (ListWorkersResponse_builder) Build 

func (b0 ListWorkersResponse_builder) Build() *ListWorkersResponse

type OneShotJobOptions 

type OneShotJobOptions struct {
	Timeout *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*OneShotJobOptions) ClearTimeout 

func (x *OneShotJobOptions) ClearTimeout()

func (*OneShotJobOptions) GetTimeout 

func (x *OneShotJobOptions) GetTimeout() *durationpb.Duration

func (*OneShotJobOptions) HasTimeout 

func (x *OneShotJobOptions) HasTimeout() bool

func (*OneShotJobOptions) ProtoMessage 

func (*OneShotJobOptions) ProtoMessage()

func (*OneShotJobOptions) ProtoReflect 

func (x *OneShotJobOptions) ProtoReflect() protoreflect.Message

func (*OneShotJobOptions) Reset 

func (x *OneShotJobOptions) Reset()

func (*OneShotJobOptions) SetTimeout 

func (x *OneShotJobOptions) SetTimeout(v *durationpb.Duration)

func (*OneShotJobOptions) String 

func (x *OneShotJobOptions) String() string

type OneShotJobOptions_builder 

type OneShotJobOptions_builder struct {
	Timeout *durationpb.Duration
	// contains filtered or unexported fields
}

func (OneShotJobOptions_builder) Build 

func (b0 OneShotJobOptions_builder) Build() *OneShotJobOptions

type QueuedJobOptions 

type QueuedJobOptions struct {
	Timeout *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Queue   string               `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*QueuedJobOptions) ClearTimeout 

func (x *QueuedJobOptions) ClearTimeout()

func (*QueuedJobOptions) GetQueue 

func (x *QueuedJobOptions) GetQueue() string

func (*QueuedJobOptions) GetTimeout 

func (x *QueuedJobOptions) GetTimeout() *durationpb.Duration

func (*QueuedJobOptions) HasTimeout 

func (x *QueuedJobOptions) HasTimeout() bool

func (*QueuedJobOptions) ProtoMessage 

func (*QueuedJobOptions) ProtoMessage()

func (*QueuedJobOptions) ProtoReflect 

func (x *QueuedJobOptions) ProtoReflect() protoreflect.Message

func (*QueuedJobOptions) Reset 

func (x *QueuedJobOptions) Reset()

func (*QueuedJobOptions) SetQueue 

func (x *QueuedJobOptions) SetQueue(v string)

func (*QueuedJobOptions) SetTimeout 

func (x *QueuedJobOptions) SetTimeout(v *durationpb.Duration)

func (*QueuedJobOptions) String 

func (x *QueuedJobOptions) String() string

type QueuedJobOptions_builder 

type QueuedJobOptions_builder struct {
	Timeout *durationpb.Duration
	Queue   string
	// contains filtered or unexported fields
}

func (QueuedJobOptions_builder) Build 

func (b0 QueuedJobOptions_builder) Build() *QueuedJobOptions

type RecurringJobOptions 

type RecurringJobOptions struct {
	Timeout    *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	RecurEvery *durationpb.Duration `protobuf:"bytes,2,opt,name=recur_every,json=recurEvery,proto3" json:"recur_every,omitempty"`
	// contains filtered or unexported fields
}

func (*RecurringJobOptions) ClearRecurEvery 

func (x *RecurringJobOptions) ClearRecurEvery()

func (*RecurringJobOptions) ClearTimeout 

func (x *RecurringJobOptions) ClearTimeout()

func (*RecurringJobOptions) GetRecurEvery 

func (x *RecurringJobOptions) GetRecurEvery() *durationpb.Duration

func (*RecurringJobOptions) GetTimeout 

func (x *RecurringJobOptions) GetTimeout() *durationpb.Duration

func (*RecurringJobOptions) HasRecurEvery 

func (x *RecurringJobOptions) HasRecurEvery() bool

func (*RecurringJobOptions) HasTimeout 

func (x *RecurringJobOptions) HasTimeout() bool

func (*RecurringJobOptions) ProtoMessage 

func (*RecurringJobOptions) ProtoMessage()

func (*RecurringJobOptions) ProtoReflect 

func (x *RecurringJobOptions) ProtoReflect() protoreflect.Message

func (*RecurringJobOptions) Reset 

func (x *RecurringJobOptions) Reset()

func (*RecurringJobOptions) SetRecurEvery 

func (x *RecurringJobOptions) SetRecurEvery(v *durationpb.Duration)

func (*RecurringJobOptions) SetTimeout 

func (x *RecurringJobOptions) SetTimeout(v *durationpb.Duration)

func (*RecurringJobOptions) String 

func (x *RecurringJobOptions) String() string

type RecurringJobOptions_builder 

type RecurringJobOptions_builder struct {
	Timeout    *durationpb.Duration
	RecurEvery *durationpb.Duration
	// contains filtered or unexported fields
}

func (RecurringJobOptions_builder) Build 

func (b0 RecurringJobOptions_builder) Build() *RecurringJobOptions

Source Files

  • request_response.pb.go
  • service.pb.go
  • types.pb.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.