proto

package
v0.0.15 Latest Latest
Warning

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

 Go to latest Published: Mar 27, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DistributionLogic_name = map[int32]string{
		0: "Unspecified",
		1: "RoundRobin",
		2: "ResourceAware",
	}
	DistributionLogic_value = map[string]int32{
		"Unspecified":   0,
		"RoundRobin":    1,
		"ResourceAware": 2,
	}
)

Enum value maps for DistributionLogic.

View Source 
var ControlPlane_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "controlplane.ControlPlane",
	HandlerType: (*ControlPlaneServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WorkerRegistration",
			Handler:    _ControlPlane_WorkerRegistration_Handler,
		},
		{
			MethodName: "CreateJob",
			Handler:    _ControlPlane_CreateJob_Handler,
		},
		{
			MethodName: "WorkerCheckIn",
			Handler:    _ControlPlane_WorkerCheckIn_Handler,
		},
		{
			MethodName: "ReportFailureTask",
			Handler:    _ControlPlane_ReportFailureTask_Handler,
		},
		{
			MethodName: "ReportSuccessTask",
			Handler:    _ControlPlane_ReportSuccessTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/controlplane.proto",
}

ControlPlane_ServiceDesc is the grpc.ServiceDesc for ControlPlane 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_proto_controlplane_proto protoreflect.FileDescriptor
View Source 
var File_proto_workernode_proto protoreflect.FileDescriptor
View Source 
var File_proto_workernodereceiver_proto protoreflect.FileDescriptor
View Source 
var WorkerNodeContainerReceiver_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "WorkerNode.WorkerNodeContainerReceiver",
	HandlerType: (*WorkerNodeContainerReceiverServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitSuccessTask",
			Handler:    _WorkerNodeContainerReceiver_SubmitSuccessTask_Handler,
		},
		{
			MethodName: "ReportTaskFailure",
			Handler:    _WorkerNodeContainerReceiver_ReportTaskFailure_Handler,
		},
		{
			MethodName: "GetTaskFromQueue",
			Handler:    _WorkerNodeContainerReceiver_GetTaskFromQueue_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/workernodereceiver.proto",
}

WorkerNodeContainerReceiver_ServiceDesc is the grpc.ServiceDesc for WorkerNodeContainerReceiver 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 WorkerNode_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "WorkerNode.WorkerNode",
	HandlerType: (*WorkerNodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendTask",
			Handler:    _WorkerNode_SendTask_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _WorkerNode_HealthCheck_Handler,
		},
		{
			MethodName: "GetAllTasks",
			Handler:    _WorkerNode_GetAllTasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/workernode.proto",
}

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

Functions

func RegisterControlPlaneServer 

func RegisterControlPlaneServer(s grpc.ServiceRegistrar, srv ControlPlaneServer)

func RegisterWorkerNodeContainerReceiverServer 

func RegisterWorkerNodeContainerReceiverServer(s grpc.ServiceRegistrar, srv WorkerNodeContainerReceiverServer)

func RegisterWorkerNodeServer 

func RegisterWorkerNodeServer(s grpc.ServiceRegistrar, srv WorkerNodeServer)

Types

type ComputeNodeRegistrationRequest 

type ComputeNodeRegistrationRequest struct {
	Port          int32  `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	NodePublicKey []byte `protobuf:"bytes,2,opt,name=nodePublicKey,proto3" json:"nodePublicKey,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeNodeRegistrationRequest) Descriptor deprecated 

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

Deprecated: Use ComputeNodeRegistrationRequest.ProtoReflect.Descriptor instead.

func (*ComputeNodeRegistrationRequest) GetNodePublicKey 

func (x *ComputeNodeRegistrationRequest) GetNodePublicKey() []byte

func (*ComputeNodeRegistrationRequest) GetPort 

func (x *ComputeNodeRegistrationRequest) GetPort() int32

func (*ComputeNodeRegistrationRequest) ProtoMessage 

func (*ComputeNodeRegistrationRequest) ProtoMessage()

func (*ComputeNodeRegistrationRequest) ProtoReflect 

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

func (*ComputeNodeRegistrationRequest) Reset 

func (x *ComputeNodeRegistrationRequest) Reset()

func (*ComputeNodeRegistrationRequest) String 

func (x *ComputeNodeRegistrationRequest) String() string

type ComputeNodeRegistrationResponse 

type ComputeNodeRegistrationResponse struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Certificate []byte `protobuf:"bytes,2,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeNodeRegistrationResponse) Descriptor deprecated 

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

Deprecated: Use ComputeNodeRegistrationResponse.ProtoReflect.Descriptor instead.

func (*ComputeNodeRegistrationResponse) GetCertificate 

func (x *ComputeNodeRegistrationResponse) GetCertificate() []byte

func (*ComputeNodeRegistrationResponse) GetId 

func (x *ComputeNodeRegistrationResponse) GetId() string

func (*ComputeNodeRegistrationResponse) ProtoMessage 

func (*ComputeNodeRegistrationResponse) ProtoMessage()

func (*ComputeNodeRegistrationResponse) ProtoReflect 

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

func (*ComputeNodeRegistrationResponse) Reset 

func (x *ComputeNodeRegistrationResponse) Reset()

func (*ComputeNodeRegistrationResponse) String 

func (x *ComputeNodeRegistrationResponse) String() string

type ControlPlaneClient 

type ControlPlaneClient interface {
	WorkerRegistration(ctx context.Context, in *ComputeNodeRegistrationRequest, opts ...grpc.CallOption) (*ComputeNodeRegistrationResponse, error)
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*CreateJobResponse, error)
	WorkerCheckIn(ctx context.Context, in *WorkerCheckInRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportFailureTask(ctx context.Context, in *ReportFailureTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportSuccessTask(ctx context.Context, in *ReportSuccessTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ControlPlaneClient is the client API for ControlPlane 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 NewControlPlaneClient 

func NewControlPlaneClient(cc grpc.ClientConnInterface) ControlPlaneClient

type ControlPlaneServer 

type ControlPlaneServer interface {
	WorkerRegistration(context.Context, *ComputeNodeRegistrationRequest) (*ComputeNodeRegistrationResponse, error)
	CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error)
	WorkerCheckIn(context.Context, *WorkerCheckInRequest) (*emptypb.Empty, error)
	ReportFailureTask(context.Context, *ReportFailureTaskRequest) (*emptypb.Empty, error)
	ReportSuccessTask(context.Context, *ReportSuccessTaskRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ControlPlaneServer is the server API for ControlPlane service. All implementations must embed UnimplementedControlPlaneServer for forward compatibility

type ControlPlaneTask 

type ControlPlaneTask struct {
	ID             string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Status         string `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"`
	TaskAttributes []byte `protobuf:"bytes,3,opt,name=TaskAttributes,proto3" json:"TaskAttributes,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlPlaneTask) Descriptor deprecated 

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

Deprecated: Use ControlPlaneTask.ProtoReflect.Descriptor instead.

func (*ControlPlaneTask) GetID 

func (x *ControlPlaneTask) GetID() string

func (*ControlPlaneTask) GetStatus 

func (x *ControlPlaneTask) GetStatus() string

func (*ControlPlaneTask) GetTaskAttributes 

func (x *ControlPlaneTask) GetTaskAttributes() []byte

func (*ControlPlaneTask) ProtoMessage 

func (*ControlPlaneTask) ProtoMessage()

func (*ControlPlaneTask) ProtoReflect 

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

func (*ControlPlaneTask) Reset 

func (x *ControlPlaneTask) Reset()

func (*ControlPlaneTask) String 

func (x *ControlPlaneTask) String() string

type CreateJobRequest 

type CreateJobRequest struct {
	Name              string            `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	ImageURL          string            `protobuf:"bytes,2,opt,name=ImageURL,proto3" json:"ImageURL,omitempty"`
	TaskAttributes    [][]byte          `protobuf:"bytes,3,rep,name=TaskAttributes,proto3" json:"TaskAttributes,omitempty"`
	IsExperiment      bool              `protobuf:"varint,4,opt,name=IsExperiment,proto3" json:"IsExperiment,omitempty"`
	DistributionLogic DistributionLogic `protobuf:"varint,5,opt,name=DistributionLogic,proto3,enum=controlplane.DistributionLogic" json:"DistributionLogic,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobRequest) Descriptor deprecated 

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetDistributionLogic added in v0.0.15 

func (x *CreateJobRequest) GetDistributionLogic() DistributionLogic

func (*CreateJobRequest) GetImageURL 

func (x *CreateJobRequest) GetImageURL() string

func (*CreateJobRequest) GetIsExperiment added in v0.0.5 

func (x *CreateJobRequest) GetIsExperiment() bool

func (*CreateJobRequest) GetName 

func (x *CreateJobRequest) GetName() string

func (*CreateJobRequest) GetTaskAttributes 

func (x *CreateJobRequest) GetTaskAttributes() [][]byte

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect 

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

func (*CreateJobRequest) Reset 

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (x *CreateJobRequest) String() string

type CreateJobResponse 

type CreateJobResponse struct {
	ID       string              `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Tasks    []*ControlPlaneTask `protobuf:"bytes,2,rep,name=Tasks,proto3" json:"Tasks,omitempty"`
	Status   string              `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	ImageURL string              `protobuf:"bytes,4,opt,name=ImageURL,proto3" json:"ImageURL,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobResponse) Descriptor deprecated 

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

Deprecated: Use CreateJobResponse.ProtoReflect.Descriptor instead.

func (*CreateJobResponse) GetID 

func (x *CreateJobResponse) GetID() string

func (*CreateJobResponse) GetImageURL 

func (x *CreateJobResponse) GetImageURL() string

func (*CreateJobResponse) GetStatus 

func (x *CreateJobResponse) GetStatus() string

func (*CreateJobResponse) GetTasks 

func (x *CreateJobResponse) GetTasks() []*ControlPlaneTask

func (*CreateJobResponse) ProtoMessage 

func (*CreateJobResponse) ProtoMessage()

func (*CreateJobResponse) ProtoReflect 

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

func (*CreateJobResponse) Reset 

func (x *CreateJobResponse) Reset()

func (*CreateJobResponse) String 

func (x *CreateJobResponse) String() string

type DistributionLogic added in v0.0.15 

type DistributionLogic int32
const (
	DistributionLogic_Unspecified   DistributionLogic = 0
	DistributionLogic_RoundRobin    DistributionLogic = 1
	DistributionLogic_ResourceAware DistributionLogic = 2
)

func (DistributionLogic) Descriptor added in v0.0.15 

func (DistributionLogic) Descriptor() protoreflect.EnumDescriptor

func (DistributionLogic) Enum added in v0.0.15 

func (x DistributionLogic) Enum() *DistributionLogic

func (DistributionLogic) EnumDescriptor deprecated added in v0.0.15 

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

Deprecated: Use DistributionLogic.Descriptor instead.

func (DistributionLogic) Number added in v0.0.15 

func (x DistributionLogic) Number() protoreflect.EnumNumber

func (DistributionLogic) String added in v0.0.15 

func (x DistributionLogic) String() string

func (DistributionLogic) Type added in v0.0.15 

func (DistributionLogic) Type() protoreflect.EnumType

type GetTaskPayload 

type GetTaskPayload struct {
	ImageUrl    string `protobuf:"bytes,1,opt,name=ImageUrl,proto3" json:"ImageUrl,omitempty"`
	ContainerId string `protobuf:"bytes,2,opt,name=ContainerId,proto3" json:"ContainerId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskPayload) Descriptor deprecated 

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

Deprecated: Use GetTaskPayload.ProtoReflect.Descriptor instead.

func (*GetTaskPayload) GetContainerId added in v0.0.14 

func (x *GetTaskPayload) GetContainerId() string

func (*GetTaskPayload) GetImageUrl 

func (x *GetTaskPayload) GetImageUrl() string

func (*GetTaskPayload) ProtoMessage 

func (*GetTaskPayload) ProtoMessage()

func (*GetTaskPayload) ProtoReflect 

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

func (*GetTaskPayload) Reset 

func (x *GetTaskPayload) Reset()

func (*GetTaskPayload) String 

func (x *GetTaskPayload) String() string

type RecievedTask 

type RecievedTask struct {
	ID             string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	TaskAttributes []byte `protobuf:"bytes,2,opt,name=TaskAttributes,proto3" json:"TaskAttributes,omitempty"`
	DockerImage    string `protobuf:"bytes,3,opt,name=DockerImage,proto3" json:"DockerImage,omitempty"`
	// contains filtered or unexported fields
}

func (*RecievedTask) Descriptor deprecated 

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

Deprecated: Use RecievedTask.ProtoReflect.Descriptor instead.

func (*RecievedTask) GetDockerImage 

func (x *RecievedTask) GetDockerImage() string

func (*RecievedTask) GetID 

func (x *RecievedTask) GetID() string

func (*RecievedTask) GetTaskAttributes 

func (x *RecievedTask) GetTaskAttributes() []byte

func (*RecievedTask) ProtoMessage 

func (*RecievedTask) ProtoMessage()

func (*RecievedTask) ProtoReflect 

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

func (*RecievedTask) Reset 

func (x *RecievedTask) Reset()

func (*RecievedTask) String 

func (x *RecievedTask) String() string

type ReportFailureTaskRequest 

type ReportFailureTaskRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeID  string `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportFailureTaskRequest) Descriptor deprecated 

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

Deprecated: Use ReportFailureTaskRequest.ProtoReflect.Descriptor instead.

func (*ReportFailureTaskRequest) GetId 

func (x *ReportFailureTaskRequest) GetId() string

func (*ReportFailureTaskRequest) GetMessage 

func (x *ReportFailureTaskRequest) GetMessage() string

func (*ReportFailureTaskRequest) GetNodeID 

func (x *ReportFailureTaskRequest) GetNodeID() string

func (*ReportFailureTaskRequest) ProtoMessage 

func (*ReportFailureTaskRequest) ProtoMessage()

func (*ReportFailureTaskRequest) ProtoReflect 

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

func (*ReportFailureTaskRequest) Reset 

func (x *ReportFailureTaskRequest) Reset()

func (*ReportFailureTaskRequest) String 

func (x *ReportFailureTaskRequest) String() string

type ReportSuccessTaskRequest 

type ReportSuccessTaskRequest struct {
	Id                string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeID            string             `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Result            []byte             `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	TaskResourceUsage *TaskResourceUsage `protobuf:"bytes,4,opt,name=taskResourceUsage,proto3" json:"taskResourceUsage,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportSuccessTaskRequest) Descriptor deprecated 

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

Deprecated: Use ReportSuccessTaskRequest.ProtoReflect.Descriptor instead.

func (*ReportSuccessTaskRequest) GetId 

func (x *ReportSuccessTaskRequest) GetId() string

func (*ReportSuccessTaskRequest) GetNodeID 

func (x *ReportSuccessTaskRequest) GetNodeID() string

func (*ReportSuccessTaskRequest) GetResult 

func (x *ReportSuccessTaskRequest) GetResult() []byte

func (*ReportSuccessTaskRequest) GetTaskResourceUsage added in v0.0.8 

func (x *ReportSuccessTaskRequest) GetTaskResourceUsage() *TaskResourceUsage

func (*ReportSuccessTaskRequest) ProtoMessage 

func (*ReportSuccessTaskRequest) ProtoMessage()

func (*ReportSuccessTaskRequest) ProtoReflect 

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

func (*ReportSuccessTaskRequest) Reset 

func (x *ReportSuccessTaskRequest) Reset()

func (*ReportSuccessTaskRequest) String 

func (x *ReportSuccessTaskRequest) String() string

type ReportTaskFailureRequest 

type ReportTaskFailureRequest struct {
	ID          string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ErrorDetail string `protobuf:"bytes,2,opt,name=ErrorDetail,proto3" json:"ErrorDetail,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportTaskFailureRequest) Descriptor deprecated 

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

Deprecated: Use ReportTaskFailureRequest.ProtoReflect.Descriptor instead.

func (*ReportTaskFailureRequest) GetErrorDetail 

func (x *ReportTaskFailureRequest) GetErrorDetail() string

func (*ReportTaskFailureRequest) GetID 

func (x *ReportTaskFailureRequest) GetID() string

func (*ReportTaskFailureRequest) ProtoMessage 

func (*ReportTaskFailureRequest) ProtoMessage()

func (*ReportTaskFailureRequest) ProtoReflect 

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

func (*ReportTaskFailureRequest) Reset 

func (x *ReportTaskFailureRequest) Reset()

func (*ReportTaskFailureRequest) String 

func (x *ReportTaskFailureRequest) String() string

type Resource added in v0.0.5 

type Resource struct {
	CpuCores               int64   `protobuf:"varint,1,opt,name=CpuCores,proto3" json:"CpuCores,omitempty"`
	AvailableCpuPercentage float32 `protobuf:"fixed32,2,opt,name=AvailableCpuPercentage,proto3" json:"AvailableCpuPercentage,omitempty"`
	AvailableMemory        string  `protobuf:"bytes,3,opt,name=AvailableMemory,proto3" json:"AvailableMemory,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated added in v0.0.5 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetAvailableCpuPercentage added in v0.0.5 

func (x *Resource) GetAvailableCpuPercentage() float32

func (*Resource) GetAvailableMemory added in v0.0.5 

func (x *Resource) GetAvailableMemory() string

func (*Resource) GetCpuCores added in v0.0.5 

func (x *Resource) GetCpuCores() int64

func (*Resource) ProtoMessage added in v0.0.5 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect added in v0.0.5 

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

func (*Resource) Reset added in v0.0.5 

func (x *Resource) Reset()

func (*Resource) String added in v0.0.5 

func (x *Resource) String() string

type SubmitSuccessTaskRequest 

type SubmitSuccessTaskRequest struct {
	ID      string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Results []byte `protobuf:"bytes,2,opt,name=Results,proto3" json:"Results,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitSuccessTaskRequest) Descriptor deprecated 

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

Deprecated: Use SubmitSuccessTaskRequest.ProtoReflect.Descriptor instead.

func (*SubmitSuccessTaskRequest) GetID 

func (x *SubmitSuccessTaskRequest) GetID() string

func (*SubmitSuccessTaskRequest) GetResults 

func (x *SubmitSuccessTaskRequest) GetResults() []byte

func (*SubmitSuccessTaskRequest) ProtoMessage 

func (*SubmitSuccessTaskRequest) ProtoMessage()

func (*SubmitSuccessTaskRequest) ProtoReflect 

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

func (*SubmitSuccessTaskRequest) Reset 

func (x *SubmitSuccessTaskRequest) Reset()

func (*SubmitSuccessTaskRequest) String 

func (x *SubmitSuccessTaskRequest) String() string

type Task 

type Task struct {
	ID             string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	JobID          string `protobuf:"bytes,2,opt,name=JobID,proto3" json:"JobID,omitempty"`
	TaskAttributes []byte `protobuf:"bytes,3,opt,name=TaskAttributes,proto3" json:"TaskAttributes,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetID 

func (x *Task) GetID() string

func (*Task) GetJobID 

func (x *Task) GetJobID() string

func (*Task) GetTaskAttributes 

func (x *Task) GetTaskAttributes() []byte

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskResourceUsage added in v0.0.8 

type TaskResourceUsage struct {
	AverageCpuUsage    float32 `protobuf:"fixed32,2,opt,name=AverageCpuUsage,proto3" json:"AverageCpuUsage,omitempty"`
	AverageMemoryUsage string  `protobuf:"bytes,3,opt,name=AverageMemoryUsage,proto3" json:"AverageMemoryUsage,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResourceUsage) Descriptor deprecated added in v0.0.8 

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

Deprecated: Use TaskResourceUsage.ProtoReflect.Descriptor instead.

func (*TaskResourceUsage) GetAverageCpuUsage added in v0.0.8 

func (x *TaskResourceUsage) GetAverageCpuUsage() float32

func (*TaskResourceUsage) GetAverageMemoryUsage added in v0.0.8 

func (x *TaskResourceUsage) GetAverageMemoryUsage() string

func (*TaskResourceUsage) ProtoMessage added in v0.0.8 

func (*TaskResourceUsage) ProtoMessage()

func (*TaskResourceUsage) ProtoReflect added in v0.0.8 

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

func (*TaskResourceUsage) Reset added in v0.0.8 

func (x *TaskResourceUsage) Reset()

func (*TaskResourceUsage) String added in v0.0.8 

func (x *TaskResourceUsage) String() string

type TaskResponse added in v0.0.15 

type TaskResponse struct {
	TaskIDs []string `protobuf:"bytes,1,rep,name=TaskIDs,proto3" json:"TaskIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResponse) Descriptor deprecated added in v0.0.15 

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

Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.

func (*TaskResponse) GetTaskIDs added in v0.0.15 

func (x *TaskResponse) GetTaskIDs() []string

func (*TaskResponse) ProtoMessage added in v0.0.15 

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) ProtoReflect added in v0.0.15 

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

func (*TaskResponse) Reset added in v0.0.15 

func (x *TaskResponse) Reset()

func (*TaskResponse) String added in v0.0.15 

func (x *TaskResponse) String() string

type UnimplementedControlPlaneServer 

type UnimplementedControlPlaneServer struct {
}

UnimplementedControlPlaneServer must be embedded to have forward compatible implementations.

func (UnimplementedControlPlaneServer) CreateJob 

func (UnimplementedControlPlaneServer) CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error)

func (UnimplementedControlPlaneServer) ReportFailureTask 

func (UnimplementedControlPlaneServer) ReportFailureTask(context.Context, *ReportFailureTaskRequest) (*emptypb.Empty, error)

func (UnimplementedControlPlaneServer) ReportSuccessTask 

func (UnimplementedControlPlaneServer) ReportSuccessTask(context.Context, *ReportSuccessTaskRequest) (*emptypb.Empty, error)

func (UnimplementedControlPlaneServer) WorkerCheckIn 

func (UnimplementedControlPlaneServer) WorkerCheckIn(context.Context, *WorkerCheckInRequest) (*emptypb.Empty, error)

func (UnimplementedControlPlaneServer) WorkerRegistration 

func (UnimplementedControlPlaneServer) WorkerRegistration(context.Context, *ComputeNodeRegistrationRequest) (*ComputeNodeRegistrationResponse, error)

type UnimplementedWorkerNodeContainerReceiverServer 

type UnimplementedWorkerNodeContainerReceiverServer struct {
}

UnimplementedWorkerNodeContainerReceiverServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerNodeContainerReceiverServer) GetTaskFromQueue 

func (UnimplementedWorkerNodeContainerReceiverServer) GetTaskFromQueue(context.Context, *GetTaskPayload) (*Task, error)

func (UnimplementedWorkerNodeContainerReceiverServer) ReportTaskFailure 

func (UnimplementedWorkerNodeContainerReceiverServer) ReportTaskFailure(context.Context, *ReportTaskFailureRequest) (*emptypb.Empty, error)

func (UnimplementedWorkerNodeContainerReceiverServer) SubmitSuccessTask 

func (UnimplementedWorkerNodeContainerReceiverServer) SubmitSuccessTask(context.Context, *SubmitSuccessTaskRequest) (*emptypb.Empty, error)

type UnimplementedWorkerNodeServer 

type UnimplementedWorkerNodeServer struct {
}

UnimplementedWorkerNodeServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerNodeServer) GetAllTasks added in v0.0.15 

func (UnimplementedWorkerNodeServer) GetAllTasks(context.Context, *emptypb.Empty) (*TaskResponse, error)

func (UnimplementedWorkerNodeServer) HealthCheck 

func (UnimplementedWorkerNodeServer) HealthCheck(context.Context, *emptypb.Empty) (*Resource, error)

func (UnimplementedWorkerNodeServer) SendTask 

func (UnimplementedWorkerNodeServer) SendTask(context.Context, *RecievedTask) (*emptypb.Empty, error)

type UnsafeControlPlaneServer 

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

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

type UnsafeWorkerNodeContainerReceiverServer 

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

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

type UnsafeWorkerNodeServer 

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

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

type WorkerCheckInRequest 

type WorkerCheckInRequest struct {
	Port        int32  `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Certificate []byte `protobuf:"bytes,2,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerCheckInRequest) Descriptor deprecated 

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

Deprecated: Use WorkerCheckInRequest.ProtoReflect.Descriptor instead.

func (*WorkerCheckInRequest) GetCertificate 

func (x *WorkerCheckInRequest) GetCertificate() []byte

func (*WorkerCheckInRequest) GetPort 

func (x *WorkerCheckInRequest) GetPort() int32

func (*WorkerCheckInRequest) ProtoMessage 

func (*WorkerCheckInRequest) ProtoMessage()

func (*WorkerCheckInRequest) ProtoReflect 

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

func (*WorkerCheckInRequest) Reset 

func (x *WorkerCheckInRequest) Reset()

func (*WorkerCheckInRequest) String 

func (x *WorkerCheckInRequest) String() string

type WorkerNodeClient 

type WorkerNodeClient interface {
	SendTask(ctx context.Context, in *RecievedTask, opts ...grpc.CallOption) (*emptypb.Empty, error)
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Resource, error)
	GetAllTasks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TaskResponse, error)
}

WorkerNodeClient is the client API for WorkerNode 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 NewWorkerNodeClient 

func NewWorkerNodeClient(cc grpc.ClientConnInterface) WorkerNodeClient

type WorkerNodeContainerReceiverClient 

type WorkerNodeContainerReceiverClient interface {
	SubmitSuccessTask(ctx context.Context, in *SubmitSuccessTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportTaskFailure(ctx context.Context, in *ReportTaskFailureRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetTaskFromQueue(ctx context.Context, in *GetTaskPayload, opts ...grpc.CallOption) (*Task, error)
}

WorkerNodeContainerReceiverClient is the client API for WorkerNodeContainerReceiver 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 NewWorkerNodeContainerReceiverClient 

func NewWorkerNodeContainerReceiverClient(cc grpc.ClientConnInterface) WorkerNodeContainerReceiverClient

type WorkerNodeContainerReceiverServer 

type WorkerNodeContainerReceiverServer interface {
	SubmitSuccessTask(context.Context, *SubmitSuccessTaskRequest) (*emptypb.Empty, error)
	ReportTaskFailure(context.Context, *ReportTaskFailureRequest) (*emptypb.Empty, error)
	GetTaskFromQueue(context.Context, *GetTaskPayload) (*Task, error)
	// contains filtered or unexported methods
}

WorkerNodeContainerReceiverServer is the server API for WorkerNodeContainerReceiver service. All implementations must embed UnimplementedWorkerNodeContainerReceiverServer for forward compatibility

type WorkerNodeServer 

type WorkerNodeServer interface {
	SendTask(context.Context, *RecievedTask) (*emptypb.Empty, error)
	HealthCheck(context.Context, *emptypb.Empty) (*Resource, error)
	GetAllTasks(context.Context, *emptypb.Empty) (*TaskResponse, error)
	// contains filtered or unexported methods
}

WorkerNodeServer is the server API for WorkerNode service. All implementations must embed UnimplementedWorkerNodeServer for forward compatibility

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.