Help us shape the future of Go! Take the 2026 Go Developer Survey

command

package
v1.11.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 20, 2023 License: Apache-2.0 Imports: 12 Imported by: 2

Documentation

Index

Constants

View Source
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

View Source
var (
	ErrMissingJobType           = errors.New("jobType is a required attribute")
	ErrMissingMaxJobsToActivate = errors.New("maxJobsToActivate is a required attribute")
)
View Source
var (
	ErrMissingJobKey        = errors.New("jobKey is a required attribute")
	ErrUnsupportedOperation = func(operation bindings.OperationKind) error {
		return fmt.Errorf("unsupported operation: %v", operation)
	}
)
View Source
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")
)
View Source
var (
	ErrMissingElementInstanceKey = errors.New("elementInstanceKey is a required attribute")
	ErrMissingVariables          = errors.New("variables is a required attribute")
)
View Source
var ErrMissingErrorCode = errors.New("errorCode is a required attribute")
View Source
var ErrMissingFileName = errors.New("fileName is a required attribute")
View Source
var ErrMissingIncidentKey = errors.New("incidentKey is a required attribute")
View Source
var ErrMissingMessageName = errors.New("messageName is a required attribute")
View Source
var ErrMissingProcessInstanceKey = errors.New("processInstanceKey is a required attribute")
View Source
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) GetComponentMetadata added in v1.11.0

func (z *ZeebeCommand) GetComponentMetadata() map[string]string

GetComponentMetadata returns the metadata of the component.

func (*ZeebeCommand) Init

func (z *ZeebeCommand) Init(ctx context.Context, metadata bindings.Metadata) error

Init does metadata parsing and connection creation.

func (*ZeebeCommand) Invoke

func (*ZeebeCommand) Operations

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL