worker

package
v0.1.156 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 17, 2026 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MIN_PORT = 8001
	MAX_PORT = 8100
)
View Source 
const DefaultMaxTaskResultSize = 64 << 10 // 64 KiB

DefaultMaxTaskResultSize is the default maximum task result size in bytes.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Name       string
	Address    string
	Broker     broker.Broker
	Runtime    runtime.Runtime
	Queues     map[string]int
	Limits     Limits
	Middleware []task.MiddlewareFunc
}

type Limits 

type Limits struct {
	DefaultCPUsLimit   string
	DefaultMemoryLimit string
	DefaultTimeout     string
	MaxResultSize      int
}

type Worker 

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

func NewWorker 

func NewWorker(cfg Config) (*Worker, error)

func (*Worker) Start 

func (w *Worker) Start() error

func (*Worker) Stop 

func (w *Worker) Stop() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.