worker

package
v0.19.1069 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2026 License: AGPL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CleanupQueueSignalsRequest added in v0.19.1031 

type CleanupQueueSignalsRequest struct {
	TotalDeleted int64 `json:"total_deleted"`
}

type Worker 

type Worker struct {
	worker.Worker
}

func New 

func New(params WorkerParams) (*Worker, error)

type WorkerParams 

type WorkerParams struct {
	fx.In

	Cfg             *internal.Config
	Tclient         temporalclient.Client
	Wkflows         *Workflows
	Acts            *activities.Activities
	L               *zap.Logger
	LC              fx.Lifecycle
	Interceptors    []interceptor.WorkerInterceptor `group:"interceptors"`
	SharedActs      *workflows.Activities
	SharedWorkflows *workflows.Workflows
}

type Workflows 

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

func NewWorkflows 

func NewWorkflows(params WorkflowsParams) (*Workflows, error)

func (Workflows) All 

func (w Workflows) All() []any

func (*Workflows) BackfillBlobs added in v0.19.1024 

func (w *Workflows) BackfillBlobs(ctx workflow.Context, req blobbackfill.RangeRequest) error

BackfillBlobs enumerates the day-buckets with un-mirrored rows and drains them one (table, day) child at a time, continue-as-newing to keep history bounded. Running sequentially keeps the per-activity S3 rate limiter acting globally.

func (*Workflows) BackfillBlobsDay added in v0.19.1024 

func (w *Workflows) BackfillBlobsDay(ctx workflow.Context, req blobbackfill.DayRequest) (blobbackfill.DayResult, error)

BackfillBlobsDay drains every un-mirrored row created within its day.

func (*Workflows) BackfillRunnerHealthcheckEmitters added in v0.19.1062 

func (w *Workflows) BackfillRunnerHealthcheckEmitters(ctx workflow.Context, req runnerhealthcheckbackfill.Request) error

BackfillRunnerHealthcheckEmitters drains the runner fleet in keyset-paginated batches, ensuring each runner has a runner-healthcheck emitter (creating and starting the emitter workflow for the ones that don't). It continue-as-news every backfillEmitterBatchesPerRun batches so history stays bounded, and exposes a progress query. Idempotent and safe to re-run.

func (*Workflows) CleanupQueueSignals added in v0.19.990 

func (w *Workflows) CleanupQueueSignals(ctx workflow.Context, req CleanupQueueSignalsRequest) error

func (*Workflows) ListWorkflowFns added in v0.19.850 

func (w *Workflows) ListWorkflowFns() []any

ListWorkflowFns returns the list of workflow functions for registration

func (*Workflows) Metrics 

func (w *Workflows) Metrics(ctx workflow.Context) error

func (*Workflows) VerifyBlobs added in v0.19.1024 

func (w *Workflows) VerifyBlobs(ctx workflow.Context, req blobverify.RangeRequest) error

VerifyBlobs enumerates the day-buckets with rows and walks them one (table, day) child at a time, continue-as-newing to keep history bounded. Running sequentially keeps the per-activity S3 rate limiter acting globally.

func (*Workflows) VerifyBlobsDay added in v0.19.1024 

func (w *Workflows) VerifyBlobsDay(ctx workflow.Context, req blobverify.DayRequest) (blobverify.DayResult, error)

VerifyBlobsDay verifies every row created within its day, walking by id cursor.

type WorkflowsParams 

type WorkflowsParams struct {
	fx.In

	V             *validator.Validate
	Cfg           *internal.Config
	MetricsWriter metrics.Writer
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.