workerv1alpha1

package
v1.36.10-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: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobState_name = map[int32]string{
		0: "JOB_STATE_UNSPECIFIED",
		1: "JOB_STATE_STARTED",
		2: "JOB_STATE_STOPPED",
		9: "JOB_STATE_ERRORED",
	}
	JobState_value = map[string]int32{
		"JOB_STATE_UNSPECIFIED": 0,
		"JOB_STATE_STARTED":     1,
		"JOB_STATE_STOPPED":     2,
		"JOB_STATE_ERRORED":     9,
	}
)

Enum value maps for JobState.

View Source 
var File_dendra_job_worker_v1alpha1_event_proto protoreflect.FileDescriptor
View Source 
var File_dendra_job_worker_v1alpha1_request_response_proto protoreflect.FileDescriptor
View Source 
var File_dendra_job_worker_v1alpha1_types_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type JobState 

type JobState int32
const (
	JobState_JOB_STATE_UNSPECIFIED JobState = 0
	JobState_JOB_STATE_STARTED     JobState = 1
	JobState_JOB_STATE_STOPPED     JobState = 2
	JobState_JOB_STATE_ERRORED     JobState = 9
)

func (JobState) Descriptor 

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum 

func (x JobState) Enum() *JobState

func (JobState) Number 

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String 

func (x JobState) String() string

func (JobState) Type 

func (JobState) Type() protoreflect.EnumType

type JobStatus 

type JobStatus struct {
	JobId        string                 `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobState     JobState               `` /* 127-byte string literal not displayed */
	RunId        string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	StartedTs    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_ts,json=startedTs,proto3" json:"started_ts,omitempty"`
	StoppedTs    *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=stopped_ts,json=stoppedTs,proto3" json:"stopped_ts,omitempty"`
	ErrorMessage string                 `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatus) ClearStartedTs 

func (x *JobStatus) ClearStartedTs()

func (*JobStatus) ClearStoppedTs 

func (x *JobStatus) ClearStoppedTs()

func (*JobStatus) GetErrorMessage 

func (x *JobStatus) GetErrorMessage() string

func (*JobStatus) GetJobId 

func (x *JobStatus) GetJobId() string

func (*JobStatus) GetJobState 

func (x *JobStatus) GetJobState() JobState

func (*JobStatus) GetRunId 

func (x *JobStatus) GetRunId() string

func (*JobStatus) GetStartedTs 

func (x *JobStatus) GetStartedTs() *timestamppb.Timestamp

func (*JobStatus) GetStoppedTs 

func (x *JobStatus) GetStoppedTs() *timestamppb.Timestamp

func (*JobStatus) HasStartedTs 

func (x *JobStatus) HasStartedTs() bool

func (*JobStatus) HasStoppedTs 

func (x *JobStatus) HasStoppedTs() bool

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect 

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

func (*JobStatus) Reset 

func (x *JobStatus) Reset()

func (*JobStatus) SetErrorMessage 

func (x *JobStatus) SetErrorMessage(v string)

func (*JobStatus) SetJobId 

func (x *JobStatus) SetJobId(v string)

func (*JobStatus) SetJobState 

func (x *JobStatus) SetJobState(v JobState)

func (*JobStatus) SetRunId 

func (x *JobStatus) SetRunId(v string)

func (*JobStatus) SetStartedTs 

func (x *JobStatus) SetStartedTs(v *timestamppb.Timestamp)

func (*JobStatus) SetStoppedTs 

func (x *JobStatus) SetStoppedTs(v *timestamppb.Timestamp)

func (*JobStatus) String 

func (x *JobStatus) String() string

type JobStatusEvent 

type JobStatusEvent struct {
	JobType     string       `protobuf:"bytes,1,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	JobStatuses []*JobStatus `protobuf:"bytes,2,rep,name=job_statuses,json=jobStatuses,proto3" json:"job_statuses,omitempty"`
	Worker      *WorkerMeta  `protobuf:"bytes,8,opt,name=worker,proto3" json:"worker,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatusEvent) ClearWorker 

func (x *JobStatusEvent) ClearWorker()

func (*JobStatusEvent) GetJobStatuses 

func (x *JobStatusEvent) GetJobStatuses() []*JobStatus

func (*JobStatusEvent) GetJobType 

func (x *JobStatusEvent) GetJobType() string

func (*JobStatusEvent) GetWorker 

func (x *JobStatusEvent) GetWorker() *WorkerMeta

func (*JobStatusEvent) HasWorker 

func (x *JobStatusEvent) HasWorker() bool

func (*JobStatusEvent) ProtoMessage 

func (*JobStatusEvent) ProtoMessage()

func (*JobStatusEvent) ProtoReflect 

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

func (*JobStatusEvent) Reset 

func (x *JobStatusEvent) Reset()

func (*JobStatusEvent) SetJobStatuses 

func (x *JobStatusEvent) SetJobStatuses(v []*JobStatus)

func (*JobStatusEvent) SetJobType 

func (x *JobStatusEvent) SetJobType(v string)

func (*JobStatusEvent) SetWorker 

func (x *JobStatusEvent) SetWorker(v *WorkerMeta)

func (*JobStatusEvent) String 

func (x *JobStatusEvent) String() string

type JobStatusEvent_builder 

type JobStatusEvent_builder struct {
	JobType     string
	JobStatuses []*JobStatus
	Worker      *WorkerMeta
	// contains filtered or unexported fields
}

func (JobStatusEvent_builder) Build 

func (b0 JobStatusEvent_builder) Build() *JobStatusEvent

type JobStatus_builder 

type JobStatus_builder struct {
	JobId        string
	JobState     JobState
	RunId        string
	StartedTs    *timestamppb.Timestamp
	StoppedTs    *timestamppb.Timestamp
	ErrorMessage string
	// contains filtered or unexported fields
}

func (JobStatus_builder) Build 

func (b0 JobStatus_builder) Build() *JobStatus

type StartJobRequest 

type StartJobRequest struct {
	JobId   string               `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	RunId   string               `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Spec    *v1alpha1.JobSpec    `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

StartJob

func (*StartJobRequest) ClearSpec 

func (x *StartJobRequest) ClearSpec()

func (*StartJobRequest) ClearTimeout 

func (x *StartJobRequest) ClearTimeout()

func (*StartJobRequest) GetJobId 

func (x *StartJobRequest) GetJobId() string

func (*StartJobRequest) GetRunId 

func (x *StartJobRequest) GetRunId() string

func (*StartJobRequest) GetSpec 

func (x *StartJobRequest) GetSpec() *v1alpha1.JobSpec

func (*StartJobRequest) GetTimeout 

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

func (*StartJobRequest) HasSpec 

func (x *StartJobRequest) HasSpec() bool

func (*StartJobRequest) HasTimeout 

func (x *StartJobRequest) HasTimeout() bool

func (*StartJobRequest) ProtoMessage 

func (*StartJobRequest) ProtoMessage()

func (*StartJobRequest) ProtoReflect 

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

func (*StartJobRequest) Reset 

func (x *StartJobRequest) Reset()

func (*StartJobRequest) SetJobId 

func (x *StartJobRequest) SetJobId(v string)

func (*StartJobRequest) SetRunId 

func (x *StartJobRequest) SetRunId(v string)

func (*StartJobRequest) SetSpec 

func (x *StartJobRequest) SetSpec(v *v1alpha1.JobSpec)

func (*StartJobRequest) SetTimeout 

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

func (*StartJobRequest) String 

func (x *StartJobRequest) String() string

type StartJobRequest_builder 

type StartJobRequest_builder struct {
	JobId   string
	RunId   string
	Timeout *durationpb.Duration
	Spec    *v1alpha1.JobSpec
	// contains filtered or unexported fields
}

func (StartJobRequest_builder) Build 

func (b0 StartJobRequest_builder) Build() *StartJobRequest

type StartJobResponse 

type StartJobResponse struct {
	Worker *WorkerMeta `protobuf:"bytes,1,opt,name=worker,proto3" json:"worker,omitempty"`
	// contains filtered or unexported fields
}

func (*StartJobResponse) ClearWorker 

func (x *StartJobResponse) ClearWorker()

func (*StartJobResponse) GetWorker 

func (x *StartJobResponse) GetWorker() *WorkerMeta

func (*StartJobResponse) HasWorker 

func (x *StartJobResponse) HasWorker() bool

func (*StartJobResponse) ProtoMessage 

func (*StartJobResponse) ProtoMessage()

func (*StartJobResponse) ProtoReflect 

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

func (*StartJobResponse) Reset 

func (x *StartJobResponse) Reset()

func (*StartJobResponse) SetWorker 

func (x *StartJobResponse) SetWorker(v *WorkerMeta)

func (*StartJobResponse) String 

func (x *StartJobResponse) String() string

type StartJobResponse_builder 

type StartJobResponse_builder struct {
	Worker *WorkerMeta
	// contains filtered or unexported fields
}

func (StartJobResponse_builder) Build 

func (b0 StartJobResponse_builder) Build() *StartJobResponse

type StopJobRequest 

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

StopJob

func (*StopJobRequest) GetJobId 

func (x *StopJobRequest) GetJobId() string

func (*StopJobRequest) GetRunId 

func (x *StopJobRequest) GetRunId() string

func (*StopJobRequest) ProtoMessage 

func (*StopJobRequest) ProtoMessage()

func (*StopJobRequest) ProtoReflect 

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

func (*StopJobRequest) Reset 

func (x *StopJobRequest) Reset()

func (*StopJobRequest) SetJobId 

func (x *StopJobRequest) SetJobId(v string)

func (*StopJobRequest) SetRunId 

func (x *StopJobRequest) SetRunId(v string)

func (*StopJobRequest) String 

func (x *StopJobRequest) String() string

type StopJobRequest_builder 

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

func (StopJobRequest_builder) Build 

func (b0 StopJobRequest_builder) Build() *StopJobRequest

type StopJobResponse 

type StopJobResponse struct {
	Found bool `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	// contains filtered or unexported fields
}

func (*StopJobResponse) GetFound 

func (x *StopJobResponse) GetFound() bool

func (*StopJobResponse) ProtoMessage 

func (*StopJobResponse) ProtoMessage()

func (*StopJobResponse) ProtoReflect 

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

func (*StopJobResponse) Reset 

func (x *StopJobResponse) Reset()

func (*StopJobResponse) SetFound 

func (x *StopJobResponse) SetFound(v bool)

func (*StopJobResponse) String 

func (x *StopJobResponse) String() string

type StopJobResponse_builder 

type StopJobResponse_builder struct {
	Found bool
	// contains filtered or unexported fields
}

func (StopJobResponse_builder) Build 

func (b0 StopJobResponse_builder) Build() *StopJobResponse

type WorkerMeta 

type WorkerMeta struct {
	Namespace  string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkerId   string                 `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	WorkerType string                 `protobuf:"bytes,3,opt,name=worker_type,json=workerType,proto3" json:"worker_type,omitempty"`
	WorkerTs   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=worker_ts,json=workerTs,proto3" json:"worker_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerMeta) ClearWorkerTs 

func (x *WorkerMeta) ClearWorkerTs()

func (*WorkerMeta) GetNamespace 

func (x *WorkerMeta) GetNamespace() string

func (*WorkerMeta) GetWorkerId 

func (x *WorkerMeta) GetWorkerId() string

func (*WorkerMeta) GetWorkerTs 

func (x *WorkerMeta) GetWorkerTs() *timestamppb.Timestamp

func (*WorkerMeta) GetWorkerType 

func (x *WorkerMeta) GetWorkerType() string

func (*WorkerMeta) HasWorkerTs 

func (x *WorkerMeta) HasWorkerTs() bool

func (*WorkerMeta) ProtoMessage 

func (*WorkerMeta) ProtoMessage()

func (*WorkerMeta) ProtoReflect 

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

func (*WorkerMeta) Reset 

func (x *WorkerMeta) Reset()

func (*WorkerMeta) SetNamespace 

func (x *WorkerMeta) SetNamespace(v string)

func (*WorkerMeta) SetWorkerId 

func (x *WorkerMeta) SetWorkerId(v string)

func (*WorkerMeta) SetWorkerTs 

func (x *WorkerMeta) SetWorkerTs(v *timestamppb.Timestamp)

func (*WorkerMeta) SetWorkerType 

func (x *WorkerMeta) SetWorkerType(v string)

func (*WorkerMeta) String 

func (x *WorkerMeta) String() string

type WorkerMeta_builder 

type WorkerMeta_builder struct {
	Namespace  string
	WorkerId   string
	WorkerType string
	WorkerTs   *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (WorkerMeta_builder) Build 

func (b0 WorkerMeta_builder) Build() *WorkerMeta

type WorkerStatusEvent 

type WorkerStatusEvent struct {
	JobTypes []string    `protobuf:"bytes,1,rep,name=job_types,json=jobTypes,proto3" json:"job_types,omitempty"`
	Worker   *WorkerMeta `protobuf:"bytes,8,opt,name=worker,proto3" json:"worker,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerStatusEvent) ClearWorker 

func (x *WorkerStatusEvent) ClearWorker()

func (*WorkerStatusEvent) GetJobTypes 

func (x *WorkerStatusEvent) GetJobTypes() []string

func (*WorkerStatusEvent) GetWorker 

func (x *WorkerStatusEvent) GetWorker() *WorkerMeta

func (*WorkerStatusEvent) HasWorker 

func (x *WorkerStatusEvent) HasWorker() bool

func (*WorkerStatusEvent) ProtoMessage 

func (*WorkerStatusEvent) ProtoMessage()

func (*WorkerStatusEvent) ProtoReflect 

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

func (*WorkerStatusEvent) Reset 

func (x *WorkerStatusEvent) Reset()

func (*WorkerStatusEvent) SetJobTypes 

func (x *WorkerStatusEvent) SetJobTypes(v []string)

func (*WorkerStatusEvent) SetWorker 

func (x *WorkerStatusEvent) SetWorker(v *WorkerMeta)

func (*WorkerStatusEvent) String 

func (x *WorkerStatusEvent) String() string

type WorkerStatusEvent_builder 

type WorkerStatusEvent_builder struct {
	JobTypes []string
	Worker   *WorkerMeta
	// contains filtered or unexported fields
}

func (WorkerStatusEvent_builder) Build 

func (b0 WorkerStatusEvent_builder) Build() *WorkerStatusEvent

Source Files

  • event.pb.go
  • request_response.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.