starter

package

v1.15.14 Latest Latest Go to latest Published: Mar 14, 2024 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/whywaita/myshoes

Links

Open Source Insights

README ¶

starter

starter is a dispatcher for running job

Documentation ¶

Index ¶

Variables
type Starter
- func New(ds datastore.Datastore, s safety.Safety, runnerVersion string, ...) *Starter
- func (s *Starter) Loop(ctx context.Context) error
- func (s *Starter) ProcessJob(ctx context.Context, job datastore.Job) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// CountRunning is count of running semaphore
	CountRunning atomic.Int64
	// CountWaiting is count of waiting job
	CountWaiting atomic.Int64

	// CountRecovered is count of recovered job per target
	CountRecovered = sync.Map{}
)

Functions ¶

This section is empty.

Types ¶

type Starter ¶

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

Starter is dispatcher for running job

func New ¶

func New(ds datastore.Datastore, s safety.Safety, runnerVersion string, notifyEnqueueCh <-chan struct{}) *Starter

New create starter instance

func (*Starter) Loop ¶

func (s *Starter) Loop(ctx context.Context) error

Loop is main loop for starter

func (*Starter) ProcessJob ¶ added in v1.15.11

func (s *Starter) ProcessJob(ctx context.Context, job datastore.Job) error

ProcessJob is process job

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
safety
unlimited

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