client

package

v0.5.3 Latest Latest Go to latest Published: Jan 12, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func LoadRoutine(grpcDriver *GRPCDriver, number int, channel chan bool)

LoadRoutine is not a test on its own.

type GRPCDriver struct {
	Connection *grpc.ClientConn
	// contains filtered or unexported fields
}

GRPCDriver is the main instance

func NewGRPCDriver() *GRPCDriver

NewGRPCDriver creates and initializes a new GRPC client and connection

func (g GRPCDriver) Complete(queueID, taskID string) *pb.StatusMessage

Complete moves the task from the running set to the completed set

func (g GRPCDriver) Fail(queueID, taskID string) *pb.StatusMessage

Fail marks the task as failed by pushing it to the failed set

func (g GRPCDriver) GetHealth() (status pb.StatusMessage, err error)

GetHealth just checks if everything, including Redis is healthy

func (g GRPCDriver) HeartBeat(queueID, taskID string, expirationSec int32) *pb.StatusMessage

HeartBeat updates the expiry of an item on the running set ToDo: add a timeout, for testing

func (g GRPCDriver) ListQueues() (queues map[string]*pb.QueueProgress, err error)

ListQueues returns a list of Progress structs

func (g GRPCDriver) LoadTask(ctx context.Context, queueID string) (task *pb.Task, err error)

LoadTask loads a task from the queue

func (g GRPCDriver) Peek(queueID, phase string, limit int32) (taskList *pb.TaskList, err error)

Peek get the n (limit) 'next' messages for a given queue/phase

func (g GRPCDriver) Progress(queueID string) (progress *pb.QueueProgress, err error)

Progress gets the status for a queue

func (g GRPCDriver) PushTask(task *pb.Task) (*pb.StatusMessage, error)

PushTask pushes a task onto the queue