worker

package
v0.19.1237 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 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 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) BulkCancelWorkflows added in v0.19.1191 

func (w *Workflows) BulkCancelWorkflows(ctx workflow.Context, req bulkcancel.Request) error

BulkCancelWorkflows cancels workflows one at a time, counting failures rather than aborting so one bad row does not strand the rest of the backlog.

func (*Workflows) CleanupQueueSignals added in v0.19.990 

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

func (*Workflows) CleanupTriggerEvents added in v0.19.1096 

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

func (*Workflows) ComponentHealthSweep added in v0.19.1098 

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

ComponentHealthSweep marks components unknown once their runner goes quiet.

One workflow for the whole fleet, not one per install: live installs get their verdicts when a report arrives, so the only thing left to schedule is noticing silence.

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.