handlerservice

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

type IControlPlane interface {
	RegisterWorker(ctx context.Context, ip string, port int32, nodePublicKey cert.KeyData) (certificate cert.TLSCertificate, err error)
	GetAllWorkerNodeFromRegistry(ctx context.Context) ([]models.NodeEntry, error)
	CheckInWorkerNode(ctx context.Context, ip string, port int32, cert []byte) error
}

type IWorker interface {
	// ControlPlane related method
	CheckInWorkerNodeToControlPlane(ctx context.Context) error

	// Task related method
	StoreTaskInQueue(containerImage string, taskId string, input []byte) error
	GetTask(containerImage string, containerId string) (*proto.Task, error)
	SubmitSuccessTask(ctx context.Context, id string, results []byte) error
	ReportFailTask(ctx context.Context, id string, errorMessage string) error
	CalculateAverageContainerResourceUsage(usage []models.ContainerResourceUsage) error
	GetRunningTask() []string
	GetAvailableTaskSlot() int
	GetQueuedTask() []string

	// TaskDistributionDaemonLoop is a method allowing the daemon to call to accomplish its routine.
	TaskDistributionDaemonLoop(ctx context.Context)
}

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