flow

Documentation

Index

• type Flow
  • func (w *Flow) Execute(ctx context.Context, APIName string, options *structs.ExecuteOptions) (invokeResult *structs.FlowExecuteResult, err error)
  • func (w *Flow) GetApprovalInstance(ctx context.Context, options *structs.GetApprovalInstanceOptions) (*structs.ApprovalInstance, error)
  • func (w *Flow) GetApprovalInstanceList(ctx context.Context, options *structs.ApprovalInstanceListOptions) (*structs.ApprovalInstanceList, error)
  • func (w *Flow) GetExecutionInfo(ctx context.Context, executionID int64) (*structs.ExecutionInfo, error)
  • func (w *Flow) GetExecutionUserTaskInfo(ctx context.Context, executionID int64) ([]*structs.TaskInfo, error)
  • func (w *Flow) RevokeExecution(ctx context.Context, executionID int64, options *structs.RevokeOptions) error
• type IFlow
  • func NewFlow(appCtx *structs.AppCtx) IFlow

Types

type Flow

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

func (*Flow) Execute

func (w *Flow) Execute(ctx context.Context, APIName string, options *structs.ExecuteOptions) (invokeResult *structs.FlowExecuteResult, err error)

func (*Flow) GetApprovalInstance

func (w *Flow) GetApprovalInstance(ctx context.Context, options *structs.GetApprovalInstanceOptions) (*structs.ApprovalInstance, error)

func (*Flow) GetApprovalInstanceList

func (w *Flow) GetApprovalInstanceList(ctx context.Context, options *structs.ApprovalInstanceListOptions) (*structs.ApprovalInstanceList, error)

func (*Flow) GetExecutionInfo

func (w *Flow) GetExecutionInfo(ctx context.Context, executionID int64) (*structs.ExecutionInfo, error)

func (*Flow) GetExecutionUserTaskInfo

func (w *Flow) GetExecutionUserTaskInfo(ctx context.Context, executionID int64) ([]*structs.TaskInfo, error)

func (*Flow) RevokeExecution

func (w *Flow) RevokeExecution(ctx context.Context, executionID int64, options *structs.RevokeOptions) error

type IFlow

type IFlow interface {
	// GetExecutionUserTaskInfo 获取流程实例人工任务详情列表
	GetExecutionUserTaskInfo(ctx context.Context, executionID int64) (taskInfo []*structs.TaskInfo, err error)

	// Execute 触发流程 (需要关注目前能够触发的流程类型，见使用指南)
	Execute(ctx context.Context, APIName string, options *structs.ExecuteOptions) (invokeResult *structs.FlowExecuteResult, err error)
	// RevokeExecution 撤销流程 (仅支持撤销包含人工任务的流程)
	RevokeExecution(ctx context.Context, executionID int64, options *structs.RevokeOptions) (err error)
	// GetExecutionInfo 获取流程实例信息
	GetExecutionInfo(ctx context.Context, executionID int64) (info *structs.ExecutionInfo, err error)
	GetApprovalInstanceList(ctx context.Context, options *structs.ApprovalInstanceListOptions) (*structs.ApprovalInstanceList, error)
	GetApprovalInstance(ctx context.Context, options *structs.GetApprovalInstanceOptions) (*structs.ApprovalInstance, error)
}

func NewFlow

func NewFlow(appCtx *structs.AppCtx) IFlow