memory

package

v0.0.0-...-bb1bb1d Latest Latest Go to latest Published: Nov 30, 2024 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func NewBackend(logger *slog.Logger) backend.Backend

type Backend struct {
	// contains filtered or unexported fields
}

func (b *Backend) Put(tube backend.Tube, pri uint64, delay uint64, ttr uint64, data []byte) (uint64, bool, error)

func (b *Backend) Reserve(tubes []backend.Tube, timeout int64) (uint64, []byte, error)

func (b *Backend) ResolveTube(name string) backend.Tube

type Job struct {
	ID          uint64
	Tube        *Tube
	Priority    uint64
	ReleaseTime time.Time
	TTR         uint64
	Data        []byte
}

type Tube struct {
	// contains filtered or unexported fields
}

func (t *Tube) Name() string

func (t *Tube) Release()

func (t *Tube) String() string