memory

package

v0.5.0 Latest Latest Go to latest Published: Mar 10, 2026 License: GPL-3.0 Imports: 6 Imported by: 0

Details

View Source

const (
	MaxMaxDepth      = 16
	MaxMaxHandlesPer = 16
	MaxMaxBytesPer   = 1 << 20
)

This section is empty.

This section is empty.

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

func (q *Queue) Config() blobcache.QueueConfig

func (q *Queue) Dequeue(ctx context.Context, buf []blobcache.Message, opts blobcache.DequeueOpts) (int, error)

func (q *Queue) Enqueue(ctx context.Context, msgs []blobcache.Message) (int, error)

func (q *Queue) QueueDown(ctx context.Context) error

type System struct {
}

func (sys *System) CreateQueue(ctx context.Context, spec blobcache.QueueBackend_Memory) (*Queue, error)

func (sys *System) QueueDown(ctx context.Context, q *Queue) error