jobs

Documentation

Index

• type BucketDeletion
  • func (BucketDeletion) Kind() string
• type BucketDeletionWorker
  • func NewBucketDeletionWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *BucketDeletionWorker
  • func (w *BucketDeletionWorker) Work(ctx context.Context, bucketDeletion *river.Job[BucketDeletion]) error
• type BucketEmptying
  • func (BucketEmptying) Kind() string
• type BucketEmptyingWorker
  • func NewBucketEmptyingWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *BucketEmptyingWorker
  • func (w *BucketEmptyingWorker) Work(ctx context.Context, bucketEmpty *river.Job[BucketEmptying]) error
• type ObjectDeletion
  • func (ObjectDeletion) Kind() string
• type ObjectDeletionWorker
  • func NewObjectDeletionWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *ObjectDeletionWorker
  • func (w *ObjectDeletionWorker) Work(ctx context.Context, objectDeletion *river.Job[ObjectDeletion]) error
• type PreSignedUploadSessionCompletion
  • func (PreSignedUploadSessionCompletion) Kind() string
• type PreSignedUploadSessionCompletionWorker
  • func NewPreSignedUploadSessionCompletionWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *PreSignedUploadSessionCompletionWorker
  • func (w *PreSignedUploadSessionCompletionWorker) Work(ctx context.Context, ...) error

Types

type BucketDeletion

type BucketDeletion struct {
	BucketId string `json:"bucket_id"`
}

func (BucketDeletion) Kind

func (BucketDeletion) Kind() string

type BucketDeletionWorker

type BucketDeletionWorker struct {
	river.WorkerDefaults[BucketDeletion]
	// contains filtered or unexported fields
}

func NewBucketDeletionWorker

func NewBucketDeletionWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *BucketDeletionWorker

func (*BucketDeletionWorker) Work

func (w *BucketDeletionWorker) Work(ctx context.Context, bucketDeletion *river.Job[BucketDeletion]) error

type BucketEmptying

type BucketEmptying struct {
	BucketId string `json:"bucket_id"`
}

func (BucketEmptying) Kind

func (BucketEmptying) Kind() string

type BucketEmptyingWorker

type BucketEmptyingWorker struct {
	river.WorkerDefaults[BucketEmptying]
	// contains filtered or unexported fields
}

func NewBucketEmptyingWorker

func NewBucketEmptyingWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *BucketEmptyingWorker

func (*BucketEmptyingWorker) Work

func (w *BucketEmptyingWorker) Work(ctx context.Context, bucketEmpty *river.Job[BucketEmptying]) error

type ObjectDeletion

type ObjectDeletion struct {
	ObjectId string `json:"object_id"`
}

func (ObjectDeletion) Kind

func (ObjectDeletion) Kind() string

type ObjectDeletionWorker

type ObjectDeletionWorker struct {
	river.WorkerDefaults[ObjectDeletion]
	// contains filtered or unexported fields
}

func NewObjectDeletionWorker

func NewObjectDeletionWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *ObjectDeletionWorker

func (*ObjectDeletionWorker) Work

func (w *ObjectDeletionWorker) Work(ctx context.Context, objectDeletion *river.Job[ObjectDeletion]) error

type PreSignedUploadSessionCompletion

type PreSignedUploadSessionCompletion struct {
	ObjectId string `json:"object_id"`
}

func (PreSignedUploadSessionCompletion) Kind

func (PreSignedUploadSessionCompletion) Kind() string

type PreSignedUploadSessionCompletionWorker

type PreSignedUploadSessionCompletionWorker struct {
	river.WorkerDefaults[PreSignedUploadSessionCompletion]
	// contains filtered or unexported fields
}

func NewPreSignedUploadSessionCompletionWorker

func NewPreSignedUploadSessionCompletionWorker(db *pgxpool.Pool, storage *storage.Storage, logger *zap.Logger) *PreSignedUploadSessionCompletionWorker

func (*PreSignedUploadSessionCompletionWorker) Work

func (w *PreSignedUploadSessionCompletionWorker) Work(ctx context.Context, preSignedUploadSessionCompletion *river.Job[PreSignedUploadSessionCompletion]) error