blero

package

v0.2.1 Latest Latest Go to latest Published: Nov 25, 2022 License: MIT Imports: 9 Imported by: 0

Details

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