worker

package
v0.0.0-...-1bc3d80 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2025 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WorkerService_CreateJob_FullMethodName   = "/eolymp.worker.WorkerService/CreateJob"
	WorkerService_DescribeJob_FullMethodName = "/eolymp.worker.WorkerService/DescribeJob"
	WorkerService_ListJobs_FullMethodName    = "/eolymp.worker.WorkerService/ListJobs"
)
View Source 
const (
	ExecutorService_ExecuteJob_FullMethodName = "/eolymp.worker.ExecutorService/ExecuteJob"
)

Variables

View Source 
var (
	Job_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "CREATED",
		2: "STARTED",
		3: "COMPLETE",
		4: "ERROR",
	}
	Job_Status_value = map[string]int32{
		"UNKNOWN":  0,
		"CREATED":  1,
		"STARTED":  2,
		"COMPLETE": 3,
		"ERROR":    4,
	}
)

Enum value maps for Job_Status.

View Source 
var (
	Job_Patch_name = map[int32]string{
		0: "UNKNOWN_PATCH",
		1: "PATCH_ALL",
		2: "PATCH_PROGRESS",
		3: "PATCH_OUTPUTS",
		4: "PATCH_LOGS_URL",
		5: "PATCH_STATUS",
	}
	Job_Patch_value = map[string]int32{
		"UNKNOWN_PATCH":  0,
		"PATCH_ALL":      1,
		"PATCH_PROGRESS": 2,
		"PATCH_OUTPUTS":  3,
		"PATCH_LOGS_URL": 4,
		"PATCH_STATUS":   5,
	}
)

Enum value maps for Job_Patch.

View Source 
var ExecutorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eolymp.worker.ExecutorService",
	HandlerType: (*ExecutorServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteJob",
			Handler:       _ExecutorService_ExecuteJob_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "eolymp/worker/executor_service.proto",
}

ExecutorService_ServiceDesc is the grpc.ServiceDesc for ExecutorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_eolymp_worker_executor_service_proto protoreflect.FileDescriptor
View Source 
var File_eolymp_worker_worker_job_proto protoreflect.FileDescriptor
View Source 
var File_eolymp_worker_worker_service_proto protoreflect.FileDescriptor
View Source 
var WorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eolymp.worker.WorkerService",
	HandlerType: (*WorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateJob",
			Handler:    _WorkerService_CreateJob_Handler,
		},
		{
			MethodName: "DescribeJob",
			Handler:    _WorkerService_DescribeJob_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _WorkerService_ListJobs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "eolymp/worker/worker_service.proto",
}

WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterExecutorServiceServer 

func RegisterExecutorServiceServer(s grpc.ServiceRegistrar, srv ExecutorServiceServer)

func RegisterWorkerServiceHttpHandlers 

func RegisterWorkerServiceHttpHandlers(router *mux.Router, prefix string, cli WorkerServiceClient)

RegisterWorkerServiceHttpHandlers adds handlers for for WorkerServiceClient

func RegisterWorkerServiceHttpProxy 

func RegisterWorkerServiceHttpProxy(router *mux.Router, prefix string, conn grpc.ClientConnInterface)

RegisterWorkerServiceHttpProxy adds proxy handlers for for WorkerServiceClient

func RegisterWorkerServiceServer 

func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)

Types

type CreateJobInput 

type CreateJobInput struct {
	Type   string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Inputs map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateJobInput) Descriptor deprecated 

func (*CreateJobInput) Descriptor() ([]byte, []int)

Deprecated: Use CreateJobInput.ProtoReflect.Descriptor instead.

func (*CreateJobInput) GetInputs 

func (x *CreateJobInput) GetInputs() map[string]string

func (*CreateJobInput) GetType 

func (x *CreateJobInput) GetType() string

func (*CreateJobInput) ProtoMessage 

func (*CreateJobInput) ProtoMessage()

func (*CreateJobInput) ProtoReflect 

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

func (*CreateJobInput) Reset 

func (x *CreateJobInput) Reset()

func (*CreateJobInput) String 

func (x *CreateJobInput) String() string

type CreateJobOutput 

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

func (*CreateJobOutput) Descriptor deprecated 

func (*CreateJobOutput) Descriptor() ([]byte, []int)

Deprecated: Use CreateJobOutput.ProtoReflect.Descriptor instead.

func (*CreateJobOutput) GetJobId 

func (x *CreateJobOutput) GetJobId() string

func (*CreateJobOutput) ProtoMessage 

func (*CreateJobOutput) ProtoMessage()

func (*CreateJobOutput) ProtoReflect 

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

func (*CreateJobOutput) Reset 

func (x *CreateJobOutput) Reset()

func (*CreateJobOutput) String 

func (x *CreateJobOutput) String() string

type DescribeJobInput 

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

func (*DescribeJobInput) Descriptor deprecated 

func (*DescribeJobInput) Descriptor() ([]byte, []int)

Deprecated: Use DescribeJobInput.ProtoReflect.Descriptor instead.

func (*DescribeJobInput) GetJobId 

func (x *DescribeJobInput) GetJobId() string

func (*DescribeJobInput) ProtoMessage 

func (*DescribeJobInput) ProtoMessage()

func (*DescribeJobInput) ProtoReflect 

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

func (*DescribeJobInput) Reset 

func (x *DescribeJobInput) Reset()

func (*DescribeJobInput) String 

func (x *DescribeJobInput) String() string

type DescribeJobOutput 

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

func (*DescribeJobOutput) Descriptor deprecated 

func (*DescribeJobOutput) Descriptor() ([]byte, []int)

Deprecated: Use DescribeJobOutput.ProtoReflect.Descriptor instead.

func (*DescribeJobOutput) GetJob 

func (x *DescribeJobOutput) GetJob() *Job

func (*DescribeJobOutput) ProtoMessage 

func (*DescribeJobOutput) ProtoMessage()

func (*DescribeJobOutput) ProtoReflect 

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

func (*DescribeJobOutput) Reset 

func (x *DescribeJobOutput) Reset()

func (*DescribeJobOutput) String 

func (x *DescribeJobOutput) String() string

type ExecuteJobInput 

type ExecuteJobInput struct {
	JobId     string            `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Namespace string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string            `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"`
	Inputs    map[string]string `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteJobInput) Descriptor deprecated 

func (*ExecuteJobInput) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteJobInput.ProtoReflect.Descriptor instead.

func (*ExecuteJobInput) GetInputs 

func (x *ExecuteJobInput) GetInputs() map[string]string

func (*ExecuteJobInput) GetJobId 

func (x *ExecuteJobInput) GetJobId() string

func (*ExecuteJobInput) GetNamespace 

func (x *ExecuteJobInput) GetNamespace() string

func (*ExecuteJobInput) GetType 

func (x *ExecuteJobInput) GetType() string

func (*ExecuteJobInput) ProtoMessage 

func (*ExecuteJobInput) ProtoMessage()

func (*ExecuteJobInput) ProtoReflect 

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

func (*ExecuteJobInput) Reset 

func (x *ExecuteJobInput) Reset()

func (*ExecuteJobInput) String 

func (x *ExecuteJobInput) String() string

type ExecuteJobUpdate 

type ExecuteJobUpdate struct {

	// Types that are valid to be assigned to Update:
	//
	//	*ExecuteJobUpdate_Progress
	//	*ExecuteJobUpdate_Outputs
	//	*ExecuteJobUpdate_Logs
	Update isExecuteJobUpdate_Update `protobuf_oneof:"update"`
	// contains filtered or unexported fields
}

func (*ExecuteJobUpdate) Descriptor deprecated 

func (*ExecuteJobUpdate) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteJobUpdate.ProtoReflect.Descriptor instead.

func (*ExecuteJobUpdate) GetLogs 

func (x *ExecuteJobUpdate) GetLogs() *ExecuteJobUpdate_LoggingUpdate

func (*ExecuteJobUpdate) GetOutputs 

func (x *ExecuteJobUpdate) GetOutputs() *ExecuteJobUpdate_OutputUpdate

func (*ExecuteJobUpdate) GetProgress 

func (x *ExecuteJobUpdate) GetProgress() *ExecuteJobUpdate_ProgressUpdate

func (*ExecuteJobUpdate) GetUpdate 

func (x *ExecuteJobUpdate) GetUpdate() isExecuteJobUpdate_Update

func (*ExecuteJobUpdate) ProtoMessage 

func (*ExecuteJobUpdate) ProtoMessage()

func (*ExecuteJobUpdate) ProtoReflect 

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

func (*ExecuteJobUpdate) Reset 

func (x *ExecuteJobUpdate) Reset()

func (*ExecuteJobUpdate) String 

func (x *ExecuteJobUpdate) String() string

type ExecuteJobUpdate_LoggingUpdate 

type ExecuteJobUpdate_LoggingUpdate struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteJobUpdate_LoggingUpdate) Descriptor deprecated 

func (*ExecuteJobUpdate_LoggingUpdate) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteJobUpdate_LoggingUpdate.ProtoReflect.Descriptor instead.

func (*ExecuteJobUpdate_LoggingUpdate) GetChunk 

func (x *ExecuteJobUpdate_LoggingUpdate) GetChunk() []byte

func (*ExecuteJobUpdate_LoggingUpdate) ProtoMessage 

func (*ExecuteJobUpdate_LoggingUpdate) ProtoMessage()

func (*ExecuteJobUpdate_LoggingUpdate) ProtoReflect 

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

func (*ExecuteJobUpdate_LoggingUpdate) Reset 

func (x *ExecuteJobUpdate_LoggingUpdate) Reset()

func (*ExecuteJobUpdate_LoggingUpdate) String 

func (x *ExecuteJobUpdate_LoggingUpdate) String() string

type ExecuteJobUpdate_Logs 

type ExecuteJobUpdate_Logs struct {
	Logs *ExecuteJobUpdate_LoggingUpdate `protobuf:"bytes,3,opt,name=logs,proto3,oneof"`
}

type ExecuteJobUpdate_OutputUpdate 

type ExecuteJobUpdate_OutputUpdate struct {
	Outputs map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteJobUpdate_OutputUpdate) Descriptor deprecated 

func (*ExecuteJobUpdate_OutputUpdate) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteJobUpdate_OutputUpdate.ProtoReflect.Descriptor instead.

func (*ExecuteJobUpdate_OutputUpdate) GetOutputs 

func (x *ExecuteJobUpdate_OutputUpdate) GetOutputs() map[string]string

func (*ExecuteJobUpdate_OutputUpdate) ProtoMessage 

func (*ExecuteJobUpdate_OutputUpdate) ProtoMessage()

func (*ExecuteJobUpdate_OutputUpdate) ProtoReflect 

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

func (*ExecuteJobUpdate_OutputUpdate) Reset 

func (x *ExecuteJobUpdate_OutputUpdate) Reset()

func (*ExecuteJobUpdate_OutputUpdate) String 

func (x *ExecuteJobUpdate_OutputUpdate) String() string

type ExecuteJobUpdate_Outputs 

type ExecuteJobUpdate_Outputs struct {
	Outputs *ExecuteJobUpdate_OutputUpdate `protobuf:"bytes,2,opt,name=outputs,proto3,oneof"`
}

type ExecuteJobUpdate_Progress 

type ExecuteJobUpdate_Progress struct {
	Progress *ExecuteJobUpdate_ProgressUpdate `protobuf:"bytes,1,opt,name=progress,proto3,oneof"`
}

type ExecuteJobUpdate_ProgressUpdate 

type ExecuteJobUpdate_ProgressUpdate struct {
	Progress uint32 `protobuf:"varint,1,opt,name=progress,proto3" json:"progress,omitempty"`
	Total    uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteJobUpdate_ProgressUpdate) Descriptor deprecated 

func (*ExecuteJobUpdate_ProgressUpdate) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteJobUpdate_ProgressUpdate.ProtoReflect.Descriptor instead.

func (*ExecuteJobUpdate_ProgressUpdate) GetProgress 

func (x *ExecuteJobUpdate_ProgressUpdate) GetProgress() uint32

func (*ExecuteJobUpdate_ProgressUpdate) GetTotal 

func (x *ExecuteJobUpdate_ProgressUpdate) GetTotal() uint32

func (*ExecuteJobUpdate_ProgressUpdate) ProtoMessage 

func (*ExecuteJobUpdate_ProgressUpdate) ProtoMessage()

func (*ExecuteJobUpdate_ProgressUpdate) ProtoReflect 

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

func (*ExecuteJobUpdate_ProgressUpdate) Reset 

func (x *ExecuteJobUpdate_ProgressUpdate) Reset()

func (*ExecuteJobUpdate_ProgressUpdate) String 

func (x *ExecuteJobUpdate_ProgressUpdate) String() string

type ExecutorServiceClient 

type ExecutorServiceClient interface {
	ExecuteJob(ctx context.Context, in *ExecuteJobInput, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecuteJobUpdate], error)
}

ExecutorServiceClient is the client API for ExecutorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutorServiceClient 

func NewExecutorServiceClient(cc grpc.ClientConnInterface) ExecutorServiceClient

type ExecutorServiceServer 

type ExecutorServiceServer interface {
	ExecuteJob(*ExecuteJobInput, grpc.ServerStreamingServer[ExecuteJobUpdate]) error
}

ExecutorServiceServer is the server API for ExecutorService service. All implementations should embed UnimplementedExecutorServiceServer for forward compatibility.

type ExecutorServiceService 

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

func NewExecutorServiceHttpClient 

func NewExecutorServiceHttpClient(url string, cli _ExecutorServiceHttpClient) *ExecutorServiceService

NewExecutorServiceHttpClient constructs client for ExecutorService

type ExecutorService_ExecuteJobClient 

type ExecutorService_ExecuteJobClient = grpc.ServerStreamingClient[ExecuteJobUpdate]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ExecutorService_ExecuteJobServer 

type ExecutorService_ExecuteJobServer = grpc.ServerStreamingServer[ExecuteJobUpdate]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

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"`
	Namespace  string                 `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Status     Job_Status             `protobuf:"varint,30,opt,name=status,proto3,enum=eolymp.worker.Job_Status" json:"status,omitempty"`
	Progress   uint32                 `protobuf:"varint,20,opt,name=progress,proto3" json:"progress,omitempty"`
	Total      uint32                 `protobuf:"varint,21,opt,name=total,proto3" json:"total,omitempty"`
	Inputs     map[string]string      `` /* 139-byte string literal not displayed */
	Outputs    map[string]string      `` /* 142-byte string literal not displayed */
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt  *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ProgressAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=progress_at,json=progressAt,proto3" json:"progress_at,omitempty"`
	CompleteAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=complete_at,json=completeAt,proto3" json:"complete_at,omitempty"`
	LogsUrl    string                 `protobuf:"bytes,100,opt,name=logs_url,json=logsUrl,proto3" json:"logs_url,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

func (*Job) Descriptor() ([]byte, []int)

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetCompleteAt 

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

func (*Job) GetCreatedAt 

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

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetInputs 

func (x *Job) GetInputs() map[string]string

func (*Job) GetLogsUrl 

func (x *Job) GetLogsUrl() string

func (*Job) GetNamespace 

func (x *Job) GetNamespace() string

func (*Job) GetOutputs 

func (x *Job) GetOutputs() map[string]string

func (*Job) GetProgress 

func (x *Job) GetProgress() uint32

func (*Job) GetProgressAt 

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

func (*Job) GetStartedAt 

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

func (*Job) GetStatus 

func (x *Job) GetStatus() Job_Status

func (*Job) GetTotal 

func (x *Job) GetTotal() uint32

func (*Job) GetType 

func (x *Job) GetType() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobTriggerEvent 

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

func (*JobTriggerEvent) Descriptor deprecated 

func (*JobTriggerEvent) Descriptor() ([]byte, []int)

Deprecated: Use JobTriggerEvent.ProtoReflect.Descriptor instead.

func (*JobTriggerEvent) GetJob 

func (x *JobTriggerEvent) GetJob() *Job

func (*JobTriggerEvent) ProtoMessage 

func (*JobTriggerEvent) ProtoMessage()

func (*JobTriggerEvent) ProtoReflect 

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

func (*JobTriggerEvent) Reset 

func (x *JobTriggerEvent) Reset()

func (*JobTriggerEvent) String 

func (x *JobTriggerEvent) String() string

type Job_Patch 

type Job_Patch int32
const (
	Job_UNKNOWN_PATCH  Job_Patch = 0
	Job_PATCH_ALL      Job_Patch = 1
	Job_PATCH_PROGRESS Job_Patch = 2
	Job_PATCH_OUTPUTS  Job_Patch = 3
	Job_PATCH_LOGS_URL Job_Patch = 4
	Job_PATCH_STATUS   Job_Patch = 5
)

func (Job_Patch) Descriptor 

func (Job_Patch) Descriptor() protoreflect.EnumDescriptor

func (Job_Patch) Enum 

func (x Job_Patch) Enum() *Job_Patch

func (Job_Patch) EnumDescriptor deprecated 

func (Job_Patch) EnumDescriptor() ([]byte, []int)

Deprecated: Use Job_Patch.Descriptor instead.

func (Job_Patch) Number 

func (x Job_Patch) Number() protoreflect.EnumNumber

func (Job_Patch) String 

func (x Job_Patch) String() string

func (Job_Patch) Type 

func (Job_Patch) Type() protoreflect.EnumType

type Job_Status 

type Job_Status int32
const (
	Job_UNKNOWN  Job_Status = 0
	Job_CREATED  Job_Status = 1
	Job_STARTED  Job_Status = 2
	Job_COMPLETE Job_Status = 3
	Job_ERROR    Job_Status = 4
)

func (Job_Status) Descriptor 

func (Job_Status) Descriptor() protoreflect.EnumDescriptor

func (Job_Status) Enum 

func (x Job_Status) Enum() *Job_Status

func (Job_Status) EnumDescriptor deprecated 

func (Job_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Job_Status.Descriptor instead.

func (Job_Status) Number 

func (x Job_Status) Number() protoreflect.EnumNumber

func (Job_Status) String 

func (x Job_Status) String() string

func (Job_Status) Type 

func (Job_Status) Type() protoreflect.EnumType

type ListJobsInput 

type ListJobsInput struct {

	// pagination
	Offset int32 `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
	Size   int32 `protobuf:"varint,11,opt,name=size,proto3" json:"size,omitempty"`
	// data filters
	Filters *ListJobsInput_Filter `protobuf:"bytes,40,opt,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsInput) Descriptor deprecated 

func (*ListJobsInput) Descriptor() ([]byte, []int)

Deprecated: Use ListJobsInput.ProtoReflect.Descriptor instead.

func (*ListJobsInput) GetFilters 

func (x *ListJobsInput) GetFilters() *ListJobsInput_Filter

func (*ListJobsInput) GetOffset 

func (x *ListJobsInput) GetOffset() int32

func (*ListJobsInput) GetSize 

func (x *ListJobsInput) GetSize() int32

func (*ListJobsInput) ProtoMessage 

func (*ListJobsInput) ProtoMessage()

func (*ListJobsInput) ProtoReflect 

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

func (*ListJobsInput) Reset 

func (x *ListJobsInput) Reset()

func (*ListJobsInput) String 

func (x *ListJobsInput) String() string

type ListJobsInput_Filter 

type ListJobsInput_Filter struct {
	Id     []*wellknown.ExpressionID   `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	Type   []*wellknown.ExpressionEnum `protobuf:"bytes,2,rep,name=type,proto3" json:"type,omitempty"`
	Status []*wellknown.ExpressionEnum `protobuf:"bytes,3,rep,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsInput_Filter) Descriptor deprecated 

func (*ListJobsInput_Filter) Descriptor() ([]byte, []int)

Deprecated: Use ListJobsInput_Filter.ProtoReflect.Descriptor instead.

func (*ListJobsInput_Filter) GetId 

func (x *ListJobsInput_Filter) GetId() []*wellknown.ExpressionID

func (*ListJobsInput_Filter) GetStatus 

func (x *ListJobsInput_Filter) GetStatus() []*wellknown.ExpressionEnum

func (*ListJobsInput_Filter) GetType 

func (x *ListJobsInput_Filter) GetType() []*wellknown.ExpressionEnum

func (*ListJobsInput_Filter) ProtoMessage 

func (*ListJobsInput_Filter) ProtoMessage()

func (*ListJobsInput_Filter) ProtoReflect 

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

func (*ListJobsInput_Filter) Reset 

func (x *ListJobsInput_Filter) Reset()

func (*ListJobsInput_Filter) String 

func (x *ListJobsInput_Filter) String() string

type ListJobsOutput 

type ListJobsOutput struct {
	Total int32  `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Items []*Job `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsOutput) Descriptor deprecated 

func (*ListJobsOutput) Descriptor() ([]byte, []int)

Deprecated: Use ListJobsOutput.ProtoReflect.Descriptor instead.

func (*ListJobsOutput) GetItems 

func (x *ListJobsOutput) GetItems() []*Job

func (*ListJobsOutput) GetTotal 

func (x *ListJobsOutput) GetTotal() int32

func (*ListJobsOutput) ProtoMessage 

func (*ListJobsOutput) ProtoMessage()

func (*ListJobsOutput) ProtoReflect 

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

func (*ListJobsOutput) Reset 

func (x *ListJobsOutput) Reset()

func (*ListJobsOutput) String 

func (x *ListJobsOutput) String() string

type UnimplementedExecutorServiceServer 

type UnimplementedExecutorServiceServer struct{}

UnimplementedExecutorServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedExecutorServiceServer) ExecuteJob 

func (UnimplementedExecutorServiceServer) ExecuteJob(*ExecuteJobInput, grpc.ServerStreamingServer[ExecuteJobUpdate]) error

type UnimplementedWorkerServiceServer 

type UnimplementedWorkerServiceServer struct{}

UnimplementedWorkerServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedWorkerServiceServer) CreateJob 

func (UnimplementedWorkerServiceServer) CreateJob(context.Context, *CreateJobInput) (*CreateJobOutput, error)

func (UnimplementedWorkerServiceServer) DescribeJob 

func (UnimplementedWorkerServiceServer) DescribeJob(context.Context, *DescribeJobInput) (*DescribeJobOutput, error)

func (UnimplementedWorkerServiceServer) ListJobs 

func (UnimplementedWorkerServiceServer) ListJobs(context.Context, *ListJobsInput) (*ListJobsOutput, error)

type UnsafeExecutorServiceServer 

type UnsafeExecutorServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServiceServer will result in compilation errors.

type UnsafeWorkerServiceServer 

type UnsafeWorkerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors.

type WorkerServiceClient 

type WorkerServiceClient interface {
	CreateJob(ctx context.Context, in *CreateJobInput, opts ...grpc.CallOption) (*CreateJobOutput, error)
	DescribeJob(ctx context.Context, in *DescribeJobInput, opts ...grpc.CallOption) (*DescribeJobOutput, error)
	ListJobs(ctx context.Context, in *ListJobsInput, opts ...grpc.CallOption) (*ListJobsOutput, error)
}

WorkerServiceClient is the client API for WorkerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWorkerServiceClient 

func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

type WorkerServiceServer 

type WorkerServiceServer interface {
	CreateJob(context.Context, *CreateJobInput) (*CreateJobOutput, error)
	DescribeJob(context.Context, *DescribeJobInput) (*DescribeJobOutput, error)
	ListJobs(context.Context, *ListJobsInput) (*ListJobsOutput, error)
}

WorkerServiceServer is the server API for WorkerService service. All implementations should embed UnimplementedWorkerServiceServer for forward compatibility.

type WorkerServiceService 

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

func NewWorkerServiceHttpClient 

func NewWorkerServiceHttpClient(url string, cli _WorkerServiceHttpClient) *WorkerServiceService

NewWorkerServiceHttpClient constructs client for WorkerService

func (*WorkerServiceService) DescribeJob 

func (s *WorkerServiceService) DescribeJob(ctx context.Context, in *DescribeJobInput) (*DescribeJobOutput, error)

func (*WorkerServiceService) ListJobs 

func (s *WorkerServiceService) ListJobs(ctx context.Context, in *ListJobsInput) (*ListJobsOutput, error)

Source Files

View all Source files

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.