handlers

func DrainTasks ¶ added in v1.0.84

func DrainTasks(ctx context.Context) error

DrainTasks releases the running task back to the queue so another agent run picks it up rather than waiting out its lease.

func EnsureConnected ¶

func EnsureConnected(conn *grpc.ClientConn)

func InitgRPC ¶

func InitgRPC() error

func NewGRPCConnection ¶

func NewGRPCConnection(addr string) (*grpc.ClientConn, error)

func ShutdownGRPCClient ¶

func ShutdownGRPCClient() error

func StopAcceptingTasks ¶ added in v1.0.84

func StopAcceptingTasks(ctx context.Context) error

StopAcceptingTasks closes the task subscription so no new work arrives. The in-flight task keeps running; DrainTasks deals with it.