worker

package

v1.21.0 Latest Latest Go to latest Published: Feb 3, 2026 License: MIT Imports: 4 Imported by: 1

Details

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

Repository

github.com/ncarlier/webhookd

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func StartDispatcher(nworkers int)
type ChanWriter
- func (c *ChanWriter) Write(p []byte) (int, error)
type Work
type Worker
- func NewWorker(id int, workerQueue chan chan Work) Worker
- func (w Worker) Start()
- func (w Worker) Stop()

Constants ¶

This section is empty.

Variables ¶

View Source

var WorkQueue = make(chan Work, 100)

WorkQueue is the global queue of work to dispatch

View Source

var WorkerQueue chan chan Work

WorkerQueue is the global queue of Workers

Functions ¶

func StartDispatcher ¶

func StartDispatcher(nworkers int)

StartDispatcher is charged to start n workers.

Types ¶

type ChanWriter ¶

type ChanWriter struct {
	ByteChan chan []byte
}

ChanWriter is a simple writer to a channel of byte.

func (*ChanWriter) Write ¶

func (c *ChanWriter) Write(p []byte) (int, error)

type Work ¶ added in v1.15.0

type Work interface {
	ID() uint64
	Name() string
	Run() error
	Close()
	SendMessage(message string)
	Logs(filter string) string
	StatusLabel() string
	Err() error
}

Work is a dispatched work given to a worker

type Worker ¶

type Worker struct {
	ID          int
	Work        chan Work
	WorkerQueue chan chan Work
	QuitChan    chan bool
}

Worker is a go routine in charge of executing a work.

func NewWorker ¶

func NewWorker(id int, workerQueue chan chan Work) Worker

NewWorker creates, and returns a new Worker object.

func (Worker) Start ¶

func (w Worker) Start()

Start is the function to starts the worker by starting a goroutine. That is an infinite "for-select" loop.

func (Worker) Stop ¶

func (w Worker) Stop()

Stop tells the worker to stop listening for work requests. Note that the worker will only stop *after* it has finished its work.

Source Files ¶

View all Source files

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