A container registry that uses the AT Protocol for manifest storage and S3 for blob storage.
remove unused function
-5
-5
pkg/appview/jetstream/backfill.go
-5
pkg/appview/jetstream/backfill.go
···
353
353
return nil
354
354
}
355
355
356
-
// processRecord processes a single record using the default processor.
357
-
func (b *BackfillWorker) processRecord(ctx context.Context, did, collection string, record *atproto.Record) error {
358
-
return b.processRecordWith(ctx, b.processor, did, collection, record)
359
-
}
360
-
361
356
// processRecordWith processes a single record using the given processor.
362
357
// This allows backfillRepo to use a transactional processor while other callers use the default.
363
358
func (b *BackfillWorker) processRecordWith(ctx context.Context, proc *Processor, did, collection string, record *atproto.Record) error {