poller package - codeberg.org/forgejo/runner/poller

Details

Learn more about best practices

Documentation ¶

Index ¶

Variables
type Metric
- func NewMetric() Metric
type Poller
- func New(cli client.Client, dispatch func(context.Context, *runnerv1.Task) error, ...) *Poller
- func (p *Poller) Poll(ctx context.Context) error
- func (p *Poller) Wait()

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrDataLock = errors.New("Data Lock Error")

Functions ¶

This section is empty.

Types ¶

type Metric ¶

type Metric interface {
	IncBusyWorker() int64
	DecBusyWorker() int64
	BusyWorkers() int64
}

Metric interface

func NewMetric ¶

func NewMetric() Metric

NewMetric for default metric structure

type Poller ¶

type Poller struct {
	Client   client.Client
	Dispatch func(context.Context, *runnerv1.Task) error

	sync.Mutex
	// contains filtered or unexported fields
}

func New ¶

func New(cli client.Client, dispatch func(context.Context, *runnerv1.Task) error, cfg *config.Config) *Poller

func (*Poller) Poll ¶

func (p *Poller) Poll(ctx context.Context) error

func (*Poller) Wait ¶

func (p *Poller) Wait()

Source Files ¶

View all Source files

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