worker

package
v1.0.0-cli.0...-4491760 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 10, 2026 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ArchiveWorker

type ArchiveWorker struct {
	river.WorkerDefaults[job.Archive]
	// contains filtered or unexported fields
}

func NewArchiveWorker

func NewArchiveWorker(
	logger *slog.Logger,
	chunkRepo chunk.Repository,
	insRepo instance.Repository,
	archiveRepo chunk.ArchiveRepository,
) *ArchiveWorker

func (*ArchiveWorker) Work

func (w *ArchiveWorker) Work(ctx context.Context, _ *river.Job[job.Archive]) error

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 (*CreateCheckpointWorker) Work

func (w *CreateCheckpointWorker) Work(ctx context.Context, riverJob *river.Job[job.CreateCheckpoint]) (ret error)

type CreateCheckpointWorkerConfig

type CreateCheckpointWorkerConfig struct {
	Timeout             time.Duration
	StatusCheckInterval time.Duration
}

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

type CreateResourcePackWorkerConfig

type CreateResourcePackWorkerConfig struct {
	WorkingDir        string
	PackTemplateKey   string
	ItemTemplatePath  string
	ModelTemplatePath string
	ModelDir          string
	ItemDir           string
	TextureDir        string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL