process

Jan 26, 2026

Changes in this version

+ func ValidStateStrings() []string

type API

+ DryRunCancelOrDeleteGetPIKeys func(ctx context.Context, keys types.Keys, opts ...options.FacadeOption) (types.Keys, types.Keys, error)

+ GetProcessInstances func(ctx context.Context, keys types.Keys, wantedWorkers int, ...) (ProcessInstances, error)

+ WaitForProcessInstancesState func(ctx context.Context, keys types.Keys, desired States, wantedWorkers int, ...) (StateReports, error)

type State

+ const StateUnknown

+ type StateReport struct

+ Key string

+ State State

+ Status string

+ func MapStateResponseToReport(in d.StateResponse) StateReport

+ type StateReports struct

+ Items []StateReport

+ func MapStateResponsesToReports(in d.StateResponses) StateReports

Nov 30, 2025

Changes in this version

type State

+ const StateAbsent

Nov 16, 2025

Changes in this version

type ProcessDefinition

+ Statistics *ProcessDefinitionStatistics

+ type ProcessDefinitionStatistics struct

+ Active int64

+ Canceled int64

+ Completed int64

+ Incidents int64

Nov 9, 2025

Changes in this version

type ProcessInstances

+ func (r ProcessInstances) FilterRootsOnly() ProcessInstances

Nov 8, 2025

Changes in this version

+ func TotalsOf[T OKer](items []T) (total, oks, noks int)

type API

+ CancelProcessInstances func(ctx context.Context, keys []string, parallel int, failFast bool, ...) (CancelReports, error)

+ DeleteProcessInstances func(ctx context.Context, keys []string, parallel int, failFast bool, ...) (DeleteReports, error)

+ GetProcessDefinition func(ctx context.Context, key string, opts ...foptions.FacadeOption) (ProcessDefinition, error)

+ GetProcessInstance func(ctx context.Context, key string, opts ...foptions.FacadeOption) (ProcessInstance, error)

+ SearchProcessDefinitionsLatest func(ctx context.Context, filter ProcessDefinitionFilter, ...) (ProcessDefinitions, error)

+ type CancelReport = Reporter

+ type CancelReports struct

+ Items []CancelReport

+ func (c CancelReports) Totals() (total int, oks int, noks int)

+ type DeleteReport = Reporter

+ type DeleteReports struct

+ Items []DeleteReport

+ func (c DeleteReports) Totals() (total int, oks int, noks int)

+ type OKer interface

+ OK func() bool

type ProcessDefinition

+ ProcessVersion int32

+ ProcessVersionTag string

+ type ProcessDefinitionFilter struct

+ BpmnProcessId string

+ Key string

+ ProcessVersion int32

+ ProcessVersionTag string

+ type ProcessInstanceFilter struct

+ BpmnProcessId string

+ Key string

+ ParentKey string

+ ProcessDefinitionKey string

+ ProcessVersion int32

+ ProcessVersionTag string

+ State State

+ type Reporter struct

+ Key string

+ Ok bool

+ Status string

+ StatusCode int

+ func (r Reporter) OK() bool

Nov 7, 2025

Changes in this version

type API

+ CreateNProcessInstances func(ctx context.Context, data ProcessInstanceData, n int, parallel int, ...) ([]ProcessInstance, error)

Nov 7, 2025

Changes in this version

type API

+ CreateProcessInstances func(ctx context.Context, datas []ProcessInstanceData, opts ...options.FacadeOption) ([]ProcessInstance, error)

Nov 3, 2025

Changes in this version

type API

+ CreateProcessInstance func(ctx context.Context, data ProcessInstanceData, opts ...options.FacadeOption) (ProcessInstance, error)

type ProcessInstance

+ Variables map[string]interface{}

+ type ProcessInstanceData struct

+ BpmnProcessId string

+ ProcessDefinitionSpecificId string

+ ProcessDefinitionVersion int32

+ TenantId string

+ Variables map[string]interface{}

Nov 1, 2025

Changes in this version

+ type API interface

+ CancelProcessInstance func(ctx context.Context, key string, opts ...options.FacadeOption) (CancelResponse, error)

+ DeleteProcessInstance func(ctx context.Context, key string, opts ...options.FacadeOption) (ChangeStatus, error)

+ FilterProcessInstanceWithOrphanParent func(ctx context.Context, items []ProcessInstance, opts ...options.FacadeOption) ([]ProcessInstance, error)

+ GetDirectChildrenOfProcessInstance func(ctx context.Context, key string, opts ...options.FacadeOption) (ProcessInstances, error)

+ GetProcessDefinitionByBpmnProcessIdAndVersion func(ctx context.Context, bpmnProcessId string, version int32, ...) (ProcessDefinition, error)

+ GetProcessDefinitionByBpmnProcessIdLatest func(ctx context.Context, bpmnProcessId string, opts ...options.FacadeOption) (ProcessDefinition, error)

+ GetProcessDefinitionByKey func(ctx context.Context, key string, opts ...options.FacadeOption) (ProcessDefinition, error)

+ GetProcessDefinitionsByBpmnProcessId func(ctx context.Context, bpmnProcessId string, opts ...options.FacadeOption) (ProcessDefinitions, error)

+ GetProcessDefinitionsLatest func(ctx context.Context) (ProcessDefinitions, error)

+ GetProcessInstanceByKey func(ctx context.Context, key string, opts ...options.FacadeOption) (ProcessInstance, error)

+ SearchProcessDefinitions func(ctx context.Context, filter ProcessDefinitionSearchFilterOpts, size int32, ...) (ProcessDefinitions, error)

+ SearchProcessInstances func(ctx context.Context, filter ProcessInstanceSearchFilterOpts, size int32, ...) (ProcessInstances, error)

+ WaitForProcessInstanceState func(ctx context.Context, key string, desired States, opts ...options.FacadeOption) (State, error)

+ func New(pdApi pdsvc.API, piApi pisvc.API) API

+ type CancelResponse struct

+ Status string

+ StatusCode int

+ type ChangeStatus struct

+ Deleted int64

+ Message string

+ func (c ChangeStatus) String() string

+ type ProcessDefinition struct

+ BpmnProcessId string

+ Key string

+ Name string

+ TenantId string

+ Version int32

+ VersionTag string

+ type ProcessDefinitionSearchFilterOpts struct

+ BpmnProcessId string

+ Key string

+ Version int32

+ VersionTag string

+ type ProcessDefinitions struct

+ Items []ProcessDefinition

+ Total int32

+ type ProcessInstance struct

+ BpmnProcessId string

+ EndDate string

+ Incident bool

+ Key string

+ ParentFlowNodeInstanceKey string

+ ParentKey string

+ ParentProcessInstanceKey string

+ ProcessDefinitionKey string

+ ProcessVersion int32

+ ProcessVersionTag string

+ StartDate string

+ State State

+ TenantId string

+ type ProcessInstanceSearchFilterOpts struct

+ BpmnProcessId string

+ Key string

+ ParentKey string

+ ProcessVersion int32

+ ProcessVersionTag string

+ State State

+ type ProcessInstances struct

+ Items []ProcessInstance

+ Total int32

+ func (r ProcessInstances) FilterByHavingIncidents(has bool) ProcessInstances

+ func (r ProcessInstances) FilterChildrenOnly() ProcessInstances

+ func (r ProcessInstances) FilterParentsOnly() ProcessInstances

+ type State string

+ const StateActive

+ const StateAll

+ const StateCanceled

+ const StateCompleted

+ const StateTerminated

+ func ParseState(in string) (State, bool)

+ func (s State) EqualsIgnoreCase(other State) bool

+ func (s State) In(states ...State) bool

+ func (s State) IsTerminal() bool

+ func (s State) String() string

+ type States []State

+ func ParseStates(in []string) (States, error)

+ func (sx States) Contains(state State) bool

+ func (sx States) String() string

+ func (sx States) Strings() []string

+ type Walker interface

+ Ancestry func(ctx context.Context, startKey string, opts ...options.FacadeOption) (rootKey string, path []string, chain map[string]ProcessInstance, err error)

+ Descendants func(ctx context.Context, rootKey string, opts ...options.FacadeOption) (desc []string, edges map[string][]string, chain map[string]ProcessInstance, ...)

+ Family func(ctx context.Context, startKey string, opts ...options.FacadeOption) (fam []string, edges map[string][]string, chain map[string]ProcessInstance, ...)

+ func AsWalker(client API) (Walker, bool)