command

Documentation

Index

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

Constants

const (
	// operations.
	TopologyOperation         bindings.OperationKind = "topology"
	DeployProcessOperation    bindings.OperationKind = "deploy-process"
	CreateInstanceOperation   bindings.OperationKind = "create-instance"
	CancelInstanceOperation   bindings.OperationKind = "cancel-instance"
	SetVariablesOperation     bindings.OperationKind = "set-variables"
	ResolveIncidentOperation  bindings.OperationKind = "resolve-incident"
	PublishMessageOperation   bindings.OperationKind = "publish-message"
	ActivateJobsOperation     bindings.OperationKind = "activate-jobs"
	CompleteJobOperation      bindings.OperationKind = "complete-job"
	FailJobOperation          bindings.OperationKind = "fail-job"
	UpdateJobRetriesOperation bindings.OperationKind = "update-job-retries"
	ThrowErrorOperation       bindings.OperationKind = "throw-error"
)

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 'processDefinitionKey' must be passed, not both at the same time")
	ErrMissingCreationVars   = errors.New("either 'bpmnProcessId' or 'processDefinitionKey' must be passed")
)

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 ErrMissingFileName = errors.New("fileName is a required attribute")

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

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

var ErrMissingProcessInstanceKey = errors.New("processInstanceKey is a required attribute")

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

Functions

func NewZeebeCommand

func NewZeebeCommand(logger logger.Logger) bindings.OutputBinding

NewZeebeCommand returns a new ZeebeCommand instance.

Types

type ZeebeCommand

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

ZeebeCommand executes Zeebe commands.

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(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (*ZeebeCommand) Operations

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