jobworker

Documentation

Index

• Variables
• type ZeebeJobWorker
  • func NewZeebeJobWorker(logger logger.Logger) *ZeebeJobWorker
  • func (z *ZeebeJobWorker) Init(metadata bindings.Metadata) error
  • func (z *ZeebeJobWorker) Read(handler bindings.Handler) error

Variables

var ErrMissingJobType = errors.New("jobType is a required attribute")

Types

type ZeebeJobWorker

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

ZeebeJobWorker allows handling jobs from the Zeebe command engine.

func NewZeebeJobWorker

func NewZeebeJobWorker(logger logger.Logger) *ZeebeJobWorker

NewZeebeJobWorker returns a new ZeebeJobWorker instance.

func (*ZeebeJobWorker) Init

func (z *ZeebeJobWorker) Init(metadata bindings.Metadata) error

Init does metadata parsing and connection creation.

func (*ZeebeJobWorker) Read

func (z *ZeebeJobWorker) Read(handler bindings.Handler) error