worker

package

v0.107.1 Latest Latest Go to latest Published: Nov 2, 2023 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrInitializationFailed = errors.New("worker initialization failed")
	ErrShutdown             = errors.New("worker is shutting down")
)

This section is empty.

type Option func(*Worker)

func WithLabels(labels map[string]string) Option

func WithLogger(logger logrus.FieldLogger) Option

func WithResources(resources map[string]float64) Option

func WithSecurity(security *security.Security) Option

func WithUpstream(upstream *upstream.Upstream) Option

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

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

func New(opts ...Option) (*Worker, error)

func (worker *Worker) Pause(ctx context.Context, wait bool) error

func (worker *Worker) Resume(ctx context.Context) (err error)

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

Path	Synopsis
security
upstream