worker

package
v0.0.0-...-1a6d63d Latest Latest
Warning

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

Go to latest
Published: Mar 22, 2026 License: AGPL-3.0 Imports: 23 Imported by: 0

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 (*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