Struct Queue

src/internal/backend/memory/queue.go:20–26

var _ backend.QueueSystem[blobcache.QueueBackend_Memory, *Queue] = &System{}

type Queue struct {
	mu          sync.Mutex
	cond        *sync.Cond
	msgs        []blobcache.Message
	maxDepth    uint32
	evictOldest bool
}

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