local

Documentation

Index

• type Broker
  • func (b *Broker) Init() (bool, error)
  • func (b *Broker) Listen(pipelines []*jobs.Pipeline, pool chan jobs.Handler, err jobs.ErrorHandler) error
  • func (b *Broker) Push(p *jobs.Pipeline, j *jobs.Job) (string, error)
  • func (b *Broker) Serve() error
  • func (b *Broker) Stop()

Types

type Broker

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

Broker run queue using local goroutines.

func (*Broker) Init

func (b *Broker) Init() (bool, error)

Init configures local job broker.

func (*Broker) Listen

func (b *Broker) Listen(pipelines []*jobs.Pipeline, pool chan jobs.Handler, err jobs.ErrorHandler) error

Listen configures broker with list of pipelines to listen and handler function. Broker broker groups all pipelines together.

func (*Broker) Push

func (b *Broker) Push(p *jobs.Pipeline, j *jobs.Job) (string, error)

Push new job to queue

func (*Broker) Serve

func (b *Broker) Serve() error

Serve local broker.

func (*Broker) Stop

func (b *Broker) Stop()

Stop local broker.