workflow

Feb 12, 2023

Changes in this version

+ func ExecuteCtx(ctx context.Context, name string, gid string, data []byte) ([]byte, error)

Aug 11, 2022

Changes in this version

+ func Execute2(name string, gid string, data []byte) ([]byte, error)

+ func Register2(name string, handler WfFunc2, custom ...func(wf *Workflow)) error

+ type WfFunc2 func(wf *Workflow, data []byte) ([]byte, error)

Jul 12, 2022

Changes in this version

+ func Execute(name string, gid string, data []byte) error

+ func ExecuteByQS(qs url.Values, body []byte) error

+ func GrpcError2DtmError(err error) error

+ func HTTPResp2DtmError(resp *http.Response) ([]byte, error)

+ func InitGrpc(grpcDtm string, clientHost string, grpcServer *grpc.Server)

+ func InitHTTP(httpDtm string, callback string)

+ func Interceptor(ctx context.Context, method string, req, reply interface{}, ...) error

+ func NewRespBodyFromBytes(body []byte) io.ReadCloser

+ func Register(name string, handler WfFunc, custom ...func(wf *Workflow)) error

+ func SetProtocolForTest(protocol string)

+ type Options struct

+ CompensateErrorBranch bool

+ GRPCError2DtmError func(error) error

+ HTTPResp2DtmError func(*http.Response) ([]byte, error)

+ type WfFunc func(wf *Workflow, data []byte) error

+ type WfPhase2Func func(bb *dtmcli.BranchBarrier) error

+ type Workflow struct

+ Name string

+ Options Options

+ func (wf *Workflow) Do(fn func(bb *dtmcli.BranchBarrier) ([]byte, error)) ([]byte, error)

+ func (wf *Workflow) DoXa(dbConf dtmcli.DBConf, fn func(db *sql.DB) ([]byte, error)) ([]byte, error)

+ func (wf *Workflow) NewBranch() *Workflow

+ func (wf *Workflow) NewBranchCtx() context.Context

+ func (wf *Workflow) NewRequest() *resty.Request

+ func (wf *Workflow) OnCommit(fn WfPhase2Func) *Workflow

+ func (wf *Workflow) OnFinish(fn func(bb *dtmcli.BranchBarrier, isRollback bool) error) *Workflow

+ func (wf *Workflow) OnRollback(compensate WfPhase2Func) *Workflow