queue

Feb 6, 2026

Changes in this version

+ func Push[E any](ctx context.Context, log *slog.Logger, client valkeygo.Client, ...) error

+ func Wait[E any](ctx context.Context, log *slog.Logger, client valkeygo.Client, ...) <-chan E

+ type Queue struct

+ func New(log *slog.Logger, client valkeygo.Client) *Queue

+ func (q *Queue) PushMachineAllocation(ctx context.Context, machineId string, ...) error

+ func (q *Queue) PushMachineCommand(ctx context.Context, partition string, command task.MachineBMCCommandPayload) error

+ func (q *Queue) PushMachineCommandDone(ctx context.Context, commandId string, command task.BMCCommandDonePayload) error

+ func (q *Queue) WaitMachineAllocation(ctx context.Context, machineId string) <-chan task.MachineAllocationPayload

+ func (q *Queue) WaitMachineCommand(ctx context.Context, partition string) <-chan task.MachineBMCCommandPayload

+ func (q *Queue) WaitMachineCommandDone(ctx context.Context, commandId string) <-chan task.BMCCommandDonePayload