pool

Documentation

Index

• func CreateEnqueuer() *work.Enqueuer
• func CreateURL(base string, endPoint string, params interface{}) string
• func CreateWorkerPool() *work.WorkerPool
• type Context
  • func (c *Context) Export(job *work.Job) error
  • func (c *Context) Log(job *work.Job, next work.NextMiddlewareFunc) error
  • func (c *Context) ProcessBPMNActivity(job *work.Job) error

Functions

func CreateEnqueuer

func CreateEnqueuer() *work.Enqueuer

func CreateURL

func CreateURL(base string, endPoint string, params interface{}) string

func CreateWorkerPool

func CreateWorkerPool() *work.WorkerPool

Types

type Context

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

func (*Context) Export

func (c *Context) Export(job *work.Job) error

func (*Context) Log

func (c *Context) Log(job *work.Job, next work.NextMiddlewareFunc) error

func (*Context) ProcessBPMNActivity

func (c *Context) ProcessBPMNActivity(job *work.Job) error