archive

type ArchiveCandidate struct {
	TaskID              string
	JobID               string
	StorageBucket       string
	StoragePath         string
	SHA256              string
	CompressedSizeBytes int64
	ContentType         string
	ContentEncoding     string
}

type ArchiveSource interface {
	// Name returns a human-readable label, e.g. "task_html".
	Name() string
	// FindCandidates returns up to batchSize items eligible for archival.
	FindCandidates(ctx context.Context, batchSize int) ([]ArchiveCandidate, error)
	// OnArchived is called after the candidate has been safely persisted
	// in cold storage and verified.
	OnArchived(ctx context.Context, candidate ArchiveCandidate, provider, bucket, key string) error
}

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

type ColdStorageProvider interface {
	// Ping verifies that the provider can reach the given bucket.
	// Call once at startup to catch bad credentials/endpoints early.
	Ping(ctx context.Context, bucket string) error
	// Upload writes data to the given bucket/key.
	Upload(ctx context.Context, bucket, key string, data io.Reader, opts UploadOptions) error
	// Download retrieves an object by bucket/key.
	Download(ctx context.Context, bucket, key string) (io.ReadCloser, error)
	// Exists returns true if the object exists and is readable.
	Exists(ctx context.Context, bucket, key string) (bool, error)
	// Provider returns the short name of the backend ("r2", "s3", "b2").
	Provider() string
}

type Config struct {
	Provider      string        // "r2", "s3", "b2"
	Bucket        string        // cold-storage bucket name
	RetentionJobs int           // keep this many recent jobs hot per domain/org
	Interval      time.Duration // time between archive sweeps
	BatchSize     int           // candidates per sweep
	Concurrency   int           // parallel upload workers
}

type JobMarkerFunc func(ctx context.Context) (int64, error)

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

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

type UploadOptions struct {
	ContentType     string
	ContentEncoding string
	Metadata        map[string]string
}