queuex

package

v0.0.5 Latest Latest Go to latest Published: Jan 23, 2026 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

View Source

var ErrorSkipRetry error = errors.New("skip retry")

func UnMarshalTaskPayload[S storagex.Serial](s storagex.Serial, payload []byte, v any) error

type ConsumerQueue interface {
	HandleFunc(key string, h Handler)

	Run() error
}

type Handler func(ctx context.Context, id string, task *Task) error

type ProducerQueue interface {
	Enqueue(task *Task, delay time.Duration) (id string, err error)
}

type Queue interface {
	ProducerQueue
	ConsumerQueue

	Stop()
}

type Task struct {
	Key     string
	Payload []byte
}

func MarshalTask[S storagex.Serial](key string, s storagex.Serial, d any) *Task