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 func(*bindings.ReadResponse) ([]byte, error)) 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 func(*bindings.ReadResponse) ([]byte, error)) error