worker

package

v0.0.0-...-511e509 Latest Latest Go to latest Published: Apr 11, 2026 License: Apache-2.0 Imports: 28 Imported by: 0

Details

This section is empty.

This section is empty.

func ParseNodeLabels(raw string) map[string]string

func SubscribeWakeups(ctx context.Context, bus event.Bus) <-chan struct{}

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

func NewClaimer(nodeID string, store *run.Store, leaseTTL time.Duration, nodeLabels ...map[string]string) *Claimer

func (c *Claimer) ClaimNext(ctx context.Context) (*models.TaskRun, error)

ClaimNext claims one ready task, or returns nil when no tasks are available.

func (c *Claimer) ReclaimExpired(ctx context.Context) error

type ExpiredReclaimer interface {
	ReclaimExpired(ctx context.Context) error
}

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

Pool bounds concurrent goroutines using a semaphore.

func NewPool(size int) *Pool

func (p *Pool) Submit(ctx context.Context, fn func()) error

func (p *Pool) Wait()

type TaskClaimer interface {
	ClaimNext(ctx context.Context) (*models.TaskRun, error)
}

type TaskExecutor func(ctx context.Context, task *models.TaskRun)

func NewRuntimeExecutor(store *run.Store, taskTimeout, workerLeaseTTL time.Duration, failurePolicy string) TaskExecutor

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

func NewWorker(claimer TaskClaimer, pool *Pool, pollInterval time.Duration, executor TaskExecutor) *Worker

func (w *Worker) Run(ctx context.Context) error

func (w *Worker) WithWakeups(ch <-chan struct{}) *Worker