deletion

package
v1.13.0 Latest Latest
Warning

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

Go to latest
Published: Sep 8, 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