Versions in this module Expand all Collapse all v0 v0.1.3 Feb 10, 2026 v0.1.2 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
Go to main page