worker

package

v0.4.0 Latest Latest Go to latest Published: Nov 8, 2026 License: MIT Imports: 8 Imported by: 0

Details

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

Repository

github.com/getcortexlabs/ranjit

Links

Open Source Insights

Documentation ¶

Index ¶

type Worker
- func New(db *store.Store, source provider.Source, interval time.Duration, ...) *Worker
- func (w *Worker) Run(ctx context.Context)
- func (w *Worker) Step(ctx context.Context) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Worker ¶

type Worker struct {
	Monitor       *monitor.Worker
	ConnectionIDs map[string]bool
	Store         *store.Store
	Source        provider.Source
	Interval      time.Duration
	Logger        *slog.Logger
	Now           func() time.Time
}

func New ¶

func New(db *store.Store, source provider.Source, interval time.Duration, logger *slog.Logger) *Worker

func (*Worker) Run ¶

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

func (*Worker) Step ¶

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

Step processes at most one job. A lease fences results from a worker that has lost ownership.

Source Files ¶

View all Source files

worker.go

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