task

package

v1.0.85 Latest Latest Go to latest Published: Jul 14, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func SetSink(s Sink)

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

func NewHandler(conn *grpc.ClientConn) *Handler

func (h *Handler) Client() pb.AgentTaskServiceClient

func (h *Handler) Context() context.Context

func (h *Handler) Run()

func (h *Handler) Stop()

func (h *Handler) StopAccepting(ctx context.Context) error

StopAccepting closes the subscription so no further assignments arrive. The executor drains separately, so an in-flight task keeps running.

type Sink interface {
	Submit(a *pb.TaskAssignment)
	RunningTask() (taskID string, leaseToken string)
}

Sink receives assignments from the stream. The executor implements it (Task 12).