blero

package

v0.2.1 Latest Latest Go to latest Published: Nov 25, 2022 License: MIT Imports: 9 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

This section is empty.

This section is empty.

This section is empty.

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

Blero struct

func New(dbPath string) *Blero

New creates new Blero Backend

func (bl *Blero) EnqueueJob(name string, data []byte) (uint64, error)

EnqueueJob enqueues a new Job and returns the job id

func (bl *Blero) RegisterProcessor(p Processor) int

RegisterProcessor registers a new processor and returns the processor id

func (bl *Blero) RegisterProcessorFunc(f func(j *Job) error) int

RegisterProcessorFunc registers a new ProcessorFunc and returns the processor id

func (bl *Blero) Start() error

Start Blero

func (bl *Blero) Stop() error

Stop Blero and Release resources

func (bl *Blero) UnregisterProcessor(pID int)

UnregisterProcessor unregisters a processor No more jobs will be assigned but if will not cancel a job that already started processing

type Job struct {
	ID   uint64
	Name string
	Data []byte
}

Job represents a Goblero job definition

type Processor interface {
	Run(j *Job) error
}

Processor interface

type ProcessorFunc func(j *Job) error

ProcessorFunc is a processor function

func (pf ProcessorFunc) Run(j *Job) error

Run allows using ProcessorFunc as a Processor