Help us shape the future of Go! Take the 2026 Go Developer Survey

deletion

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 12, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	BatchSize       int           // Number of deletions per batch
	ProcessInterval time.Duration // Interval between batch processing
	PruneAge        time.Duration // Age after which entries are pruned
	RetryDelay      time.Duration // Backoff before a failed deletion is retried (0 = retry next cycle)
}

Config holds configuration for the deletion queue

type Queue

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

Queue manages centralized file deletion

func NewQueue

func NewQueue(meta *metadata.MetaDB, config Config) *Queue

NewQueue creates a new deletion queue

func (*Queue) Add

func (q *Queue) Add(filepath string) error

Add adds a file to the deletion queue

func (*Queue) GetQueueDepth

func (q *Queue) GetQueueDepth() int64

GetQueueDepth returns the current number of entries in the deletion queue.

func (*Queue) ProcessBatch

func (q *Queue) ProcessBatch()

ProcessBatch processes a batch of deletion requests

func (*Queue) Start

func (q *Queue) Start()

Start begins background processing

func (*Queue) Stop

func (q *Queue) Stop()

Stop gracefully stops the queue

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL