worker

package

v0.0.0-...-06cc741 Latest Latest Go to latest Published: Nov 30, 2025 License: AGPL-3.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/spacechunks/explorer

Links

Open Source Insights

Documentation ¶

Index ¶

type CreateCheckpointClient
type CreateCheckpointWorker
- func NewCheckpointWorker(logger *slog.Logger, createCheckpointClient CreateCheckpointClient, ...) *CreateCheckpointWorker
- func (w *CreateCheckpointWorker) Timeout(*river.Job[job.CreateCheckpoint]) time.Duration
- func (w *CreateCheckpointWorker) Work(ctx context.Context, riverJob *river.Job[job.CreateCheckpoint]) (ret error)
type CreateImageWorker
- func NewCreateImageWorker(logger *slog.Logger, repo chunk.Repository, imgSvc image.Service, ...) *CreateImageWorker
- func (w *CreateImageWorker) Work(ctx context.Context, riverJob *river.Job[job.CreateImage]) (ret error)

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,
	timeout time.Duration,
	statusCheckInterval time.Duration,
	nodeRepo node.Repository,
	chunkRepo chunk.Repository,
) *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,
	imagePlatform string,
) *CreateImageWorker

func (*CreateImageWorker) Work ¶

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

Source Files ¶

View all Source files

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