jobworker

Documentation

Index

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

Variables

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

Functions

func NewZeebeJobWorker

func NewZeebeJobWorker(logger logger.Logger) bindings.InputBinding

NewZeebeJobWorker returns a new ZeebeJobWorker instance.

Types

type ZeebeJobWorker

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

ZeebeJobWorker allows handling jobs from the Zeebe command engine.

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(ctx context.Context, handler bindings.Handler) error