process

package

v0.5.2 Latest Latest Go to latest Published: Jan 9, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func Exec(task *pb.Task) (result int, err error)

Exec executes a program

func LoadTimeOut(cancel func())

LoadTimeOut is a simple timeout to wait for a new item on the queue or exit

func RepeatHeartBeat(grpcDriver *client.GRPCDriver, queueID string, taskID string, isWorking *struct{ active bool })

RepeatHeartBeat calls the heartbeat function repeatedly, until the task completes

func Work(grpcDriver *client.GRPCDriver, queueID string, workType string) (result int, err error)

Work manages getting, heartbeating, and completing or failing items, in a loop

This section is empty.