Documentation
¶
Index ¶
- func StateOrNil(s processinstance.State) *operatev87.ProcessInstanceState
- type Option
- type Service
- func (s *Service) Ancestry(ctx context.Context, startKey int64) (rootKey int64, path []int64, chain map[int64]processinstance.ProcessInstance, ...)
- func (s *Service) CancelProcessInstance(ctx context.Context, key int64) (processinstance.CancelResponse, error)
- func (s *Service) Capabilities(ctx context.Context) camunda.Capabilities
- func (s *Service) DeleteProcessInstance(ctx context.Context, key int64) (processinstance.ChangeStatus, error)
- func (s *Service) DeleteProcessInstanceWithCancel(ctx context.Context, key int64) (processinstance.ChangeStatus, error)
- func (s *Service) Descendants(ctx context.Context, rootKey int64) (desc []int64, edges map[int64][]int64, ...)
- func (s *Service) Family(ctx context.Context, startKey int64) (fam []int64, edges map[int64][]int64, ...)
- func (s *Service) FilterProcessInstanceWithOrphanParent(ctx context.Context, items []processinstance.ProcessInstance) ([]processinstance.ProcessInstance, error)
- func (s *Service) GetDirectChildrenOfProcessInstance(ctx context.Context, key int64) (processinstance.ProcessInstances, error)
- func (s *Service) GetProcessInstanceByKey(ctx context.Context, key int64) (processinstance.ProcessInstance, error)
- func (s *Service) SearchForProcessInstances(ctx context.Context, filter processinstance.SearchFilterOpts, size int32) (processinstance.ProcessInstances, error)
- func (s *Service) WaitForProcessInstanceState(ctx context.Context, key string, desiredState string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StateOrNil ¶
func StateOrNil(s processinstance.State) *operatev87.ProcessInstanceState
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) Ancestry ¶ added in v0.0.30
func (s *Service) Ancestry(ctx context.Context, startKey int64) (rootKey int64, path []int64, chain map[int64]processinstance.ProcessInstance, err error)
func (*Service) CancelProcessInstance ¶
func (s *Service) CancelProcessInstance(ctx context.Context, key int64) (processinstance.CancelResponse, error)
func (*Service) Capabilities ¶
func (s *Service) Capabilities(ctx context.Context) camunda.Capabilities
func (*Service) DeleteProcessInstance ¶
func (s *Service) DeleteProcessInstance(ctx context.Context, key int64) (processinstance.ChangeStatus, error)
func (*Service) DeleteProcessInstanceWithCancel ¶
func (s *Service) DeleteProcessInstanceWithCancel(ctx context.Context, key int64) (processinstance.ChangeStatus, error)
func (*Service) Descendants ¶ added in v0.0.30
func (*Service) FilterProcessInstanceWithOrphanParent ¶
func (s *Service) FilterProcessInstanceWithOrphanParent(ctx context.Context, items []processinstance.ProcessInstance) ([]processinstance.ProcessInstance, error)
func (*Service) GetDirectChildrenOfProcessInstance ¶
func (s *Service) GetDirectChildrenOfProcessInstance(ctx context.Context, key int64) (processinstance.ProcessInstances, error)
func (*Service) GetProcessInstanceByKey ¶
func (s *Service) GetProcessInstanceByKey(ctx context.Context, key int64) (processinstance.ProcessInstance, error)
func (*Service) SearchForProcessInstances ¶
func (s *Service) SearchForProcessInstances(ctx context.Context, filter processinstance.SearchFilterOpts, size int32) (processinstance.ProcessInstances, error)
func (*Service) WaitForProcessInstanceState ¶
func (s *Service) WaitForProcessInstanceState(ctx context.Context, key string, desiredState string) error
WaitForProcessInstanceState waits until the instance reaches the desired state. - Respects ctx cancellation/deadline; augments with cfg.Timeout if set - Returns nil on success or an error on failure/timeout.
Click to show internal directories.
Click to hide internal directories.