Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TaskExecutor ¶
type TaskExecutor struct {
// contains filtered or unexported fields
}
TaskExecutor implements node.TaskHandler. It executes tasks dispatched from Hivemind via the heartbeat stream.
func NewTaskExecutor ¶
func NewTaskExecutor(nodeService *node.Service) *TaskExecutor
NewTaskExecutor creates a new TaskExecutor.
func (*TaskExecutor) CancelTask ¶
func (h *TaskExecutor) CancelTask(taskID string, reason string)
CancelTask cancels a running task.
func (*TaskExecutor) HandleTask ¶
func (h *TaskExecutor) HandleTask(ctx context.Context, task *pb.Task)
HandleTask executes a dispatched task asynchronously and reports the result.
Source Files
Click to show internal directories.
Click to hide internal directories.