jobworker

Documentation

Index

• Variables
• func NewZeebeJobWorker(logger logger.Logger) bindings.InputBinding
• type ZeebeJobWorker
  • func (z *ZeebeJobWorker) Close() error
  • func (z *ZeebeJobWorker) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
  • func (z *ZeebeJobWorker) Init(ctx context.Context, 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) Close

func (z *ZeebeJobWorker) Close() error

func (*ZeebeJobWorker) GetComponentMetadata

func (z *ZeebeJobWorker) GetComponentMetadata() (metadataInfo metadata.MetadataMap)

GetComponentMetadata returns the metadata of the component.

func (*ZeebeJobWorker) Init

func (z *ZeebeJobWorker) Init(ctx context.Context, 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