Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreateCheckpointClient ¶
type CreateCheckpointClient func(host string) (checkpointv1alpha1.CheckpointServiceClient, error)
type CreateCheckpointWorker ¶
type CreateCheckpointWorker struct {
river.WorkerDefaults[job.CreateCheckpoint]
// contains filtered or unexported fields
}
func NewCheckpointWorker ¶
func NewCheckpointWorker( logger *slog.Logger, createCheckpointClient CreateCheckpointClient, nodeRepo node.Repository, chunkRepo chunk.Repository, cfg CreateCheckpointWorkerConfig, ) *CreateCheckpointWorker
func (*CreateCheckpointWorker) Timeout ¶
func (w *CreateCheckpointWorker) Timeout(*river.Job[job.CreateCheckpoint]) time.Duration
func (*CreateCheckpointWorker) Work ¶
func (w *CreateCheckpointWorker) Work(ctx context.Context, riverJob *river.Job[job.CreateCheckpoint]) (ret error)
type CreateImageWorker ¶
type CreateImageWorker struct {
river.WorkerDefaults[job.CreateImage]
// contains filtered or unexported fields
}
func NewCreateImageWorker ¶
func NewCreateImageWorker( logger *slog.Logger, repo chunk.Repository, imgSvc image.Service, jobClient job.Client, store blob.S3Store, cfg CreateImageWorkerConfig, ) *CreateImageWorker
func (*CreateImageWorker) Work ¶
func (w *CreateImageWorker) Work(ctx context.Context, riverJob *river.Job[job.CreateImage]) (ret error)
type CreateImageWorkerConfig ¶
type CreateImageWorkerConfig struct {
ImagePlatform string
}
type CreateResourcePackWorker ¶
type CreateResourcePackWorker struct {
river.WorkerDefaults[job.CreateResourcePack]
// contains filtered or unexported fields
}
func NewCreateResourcePackWorker ¶
func NewCreateResourcePackWorker( logger *slog.Logger, s3store blob.S3Store, repo chunk.Repository, cfg CreateResourcePackWorkerConfig, ) *CreateResourcePackWorker
func (*CreateResourcePackWorker) Work ¶
func (w *CreateResourcePackWorker) Work(ctx context.Context, riverJob *river.Job[job.CreateResourcePack]) error
Click to show internal directories.
Click to hide internal directories.