queue

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

type AdvertisementPublishingQueue Queue[schema.Advertisement]

type AdvertisementPublishingQueuePoller = QueuePoller[schema.Advertisement]

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

type Handler[Job any] interface {
	// contains filtered or unexported methods
}

type Option func(*config)

type PublishingJob struct {
	ProviderInfo peer.AddrInfo
	ContextID    string
	Digests      iter.Seq[mh.Multihash]
	Meta         metadata.Metadata
}

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

type PublishingQueue Queue[PublishingJob]

type PublishingQueuePoller = QueuePoller[PublishingJob]

type Queue[Job any] interface {
	QueueQueuer[Job]
	QueueReader[Job]
	QueueReleaser
	QueueDeleter
}

type QueueDeleter interface {
	Delete(ctx context.Context, jobID string) error
}

type QueuePoller[Job any] struct {
	// contains filtered or unexported fields
}

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

type QueueQueuer[Job any] interface {
	Queue(ctx context.Context, job Job) error
}

type QueueReader[Job any] interface {
	Read(ctx context.Context, maxJobs int) ([]WithID[Job], error)
}

type QueueReleaser interface {
	Release(ctx context.Context, jobID string) error
}

type WithID[Job any] struct {
	ID  string
	Job Job
}