command

Documentation

Index

• Variables
• type ZeebeCommand
  • func NewZeebeCommand(logger logger.Logger) *ZeebeCommand
  • func (z *ZeebeCommand) Init(metadata bindings.Metadata) error
  • func (z *ZeebeCommand) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
  • func (z *ZeebeCommand) Operations() []bindings.OperationKind

Variables

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

var (
	ErrMissingJobKey        = errors.New("jobKey is a required attribute")
	ErrUnsupportedOperation = func(operation bindings.OperationKind) error {
		return fmt.Errorf("unsupported operation: %v", operation)
	}
)

var (
	ErrAmbiguousCreationVars = errors.New("either 'bpmnProcessId' or 'workflowKey' must be passed, not both at the same time")
	ErrMissingCreationVars   = errors.New("either 'bpmnProcessId' or 'workflowKey' must be passed")
)

var (
	ErrMissingFileName = errors.New("fileName is a required attribute")
	ErrMissingFileType = errors.New("cannot determine file type from file name. Please specify a fileType")
	ErrInvalidFileType = errors.New("fileType must be either 'bpmn' of 'file'")
)

var (
	ErrMissingElementInstanceKey = errors.New("elementInstanceKey is a required attribute")
	ErrMissingVariables          = errors.New("variables is a required attribute")
)

var (
	ErrMissingErrorCode = errors.New("errorCode is a required attribute")
)

var (
	ErrMissingIncidentKey = errors.New("incidentKey is a required attribute")
)

var (
	ErrMissingMessageName = errors.New("messageName is a required attribute")
)

var (
	ErrMissingRetries = errors.New("retries is a required attribute")
)

var (
	ErrMissingWorkflowInstanceKey = errors.New("workflowInstanceKey is a required attribute")
)

Types

type ZeebeCommand

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

ZeebeCommand executes Zeebe commands

func NewZeebeCommand

func NewZeebeCommand(logger logger.Logger) *ZeebeCommand

NewZeebeCommand returns a new ZeebeCommand instance

func (*ZeebeCommand) Init

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

Init does metadata parsing and connection creation

func (*ZeebeCommand) Invoke

func (z *ZeebeCommand) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (*ZeebeCommand) Operations

func (z *ZeebeCommand) Operations() []bindings.OperationKind