flow

Oct 12, 2023

Changes in this version

+ const BpmnLeave

Sep 28, 2023

Changes in this version

type Client

+ func (c *Client) HandleServiceErr(ctx context.Context, req *api.ErrHandleRequest, opts ...vclient.CallOption) error

type RpcServer

+ func (rs *RpcServer) HandleServiceErr(ctx context.Context, req *api.HandleServiceErrRequest, ...) (err error)

type Scheduler

+ func (s *Scheduler) HandleServiceErr(ctx context.Context, req api.ErrHandleRequest) error

Sep 27, 2023

Changes in this version

+ const BpmnActiveEnd

+ const BpmnActiveStart

+ const BpmnCancel

+ const BpmnComplete

+ const BpmnError

+ const BpmnVisit

Sep 26, 2023

Changes in this version

type WorkflowBuilder

+ func (b *WorkflowBuilder) SetEntity(entity Entity) *WorkflowBuilder

Sep 25, 2023

Changes in this version

+ type IStepBuilder interface

+ Build func() (any, error)

+ Entity func() Entity

+ Id func() string

+ type SubWorkflowBuilder struct

+ func NewSubWorkflowBuilder(entity Entity, opts ...Option) *SubWorkflowBuilder

+ func (b *SubWorkflowBuilder) Build() (any, error)

+ func (b *SubWorkflowBuilder) Entity() Entity

+ func (b *SubWorkflowBuilder) Id() string

+ func (b *SubWorkflowBuilder) Item(key string, value any) *SubWorkflowBuilder

+ func (b *SubWorkflowBuilder) Items(items map[string]any) *SubWorkflowBuilder

+ func (b *SubWorkflowBuilder) Step(sb IStepBuilder) *SubWorkflowBuilder

+ func (b *SubWorkflowBuilder) Steps(sbs ...IStepBuilder) *SubWorkflowBuilder

type WorkflowStepBuilder

+ func (b *WorkflowStepBuilder) Entity() Entity

+ func (b *WorkflowStepBuilder) Id() string

+ func (b *WorkflowStepBuilder) SetId(id string) *WorkflowStepBuilder

Sep 21, 2023

Changes in this version

+ func OliveEscape(text string) string

+ func OliveUnEscape(text string) string

type Empty

+ func (e *Empty) GetEID() string

type Entity

+ GetEID func() string

type RpcServer

+ func (rs *RpcServer) ExecuteWorkflowInstance(ctx context.Context, req *api.ExecuteWorkflowInstanceRequest, ...) error

type TagKind

+ const TagKindEntity

type WorkflowBuilder

+ func NewWorkFlowBuilder(opts ...Option) *WorkflowBuilder

+ func (b *WorkflowBuilder) ToProcessDefinitions() (*schema.Definitions, map[string]any, error)

+ func (b *WorkflowBuilder) ToSubProcessDefinitions() (*schema.Definitions, map[string]any, error)

Jul 20, 2023

Changes in this version

+ type Logger struct

+ func NewLogger(opts ...LoggerOption) *Logger

+ func (lg *Logger) Debug(text string)

+ func (lg *Logger) Debugf(format string, args ...any)

+ func (lg *Logger) Error(text string)

+ func (lg *Logger) Errorf(format string, args ...any)

+ func (lg *Logger) Info(text string)

+ func (lg *Logger) Infof(format string, args ...any)

+ func (lg *Logger) Trace(text string)

+ func (lg *Logger) Tracef(format string, args ...any)

+ func (lg *Logger) Warn(text string)

+ func (lg *Logger) Warnf(format string, args ...any)

+ type LoggerOption func(options *LoggerOptions)

+ func WithLoggerContext(ctx *PipeSessionCtx) LoggerOption

+ type LoggerOptions struct

+ func NewLoggerOptions(opts ...LoggerOption) LoggerOptions

type PipeSessionCtx

+ func (c *PipeSessionCtx) Log(opts ...LoggerOption) *Logger

Jul 19, 2023

Changes in this version

type Workflow

+ func (w *Workflow) InstanceId() string

Jul 18, 2023

Changes in this version

type PipeSessionCtx

+ func (c *PipeSessionCtx) Debug(format string, args ...any)

+ func (c *PipeSessionCtx) Error(format string, args ...any)

+ func (c *PipeSessionCtx) Info(format string, args ...any)

+ func (c *PipeSessionCtx) Warn(ctx context.Context, format string, args ...any)

Jul 13, 2023

Changes in this version

type Client

+ func (c *Client) GetWorker(ctx context.Context, id string) (*api.Worker, error)

+ func (c *Client) WorkHook(ctx context.Context) (WorkHookWatcher, error)

type RpcServer

+ func (rs *RpcServer) GetWorker(ctx context.Context, req *api.GetWorkerRequest, rsp *api.GetWorkerResponse) error

+ func (rs *RpcServer) WorkHook(ctx context.Context, req *api.WorkHookRequest, ...) error

type Scheduler

+ func (s *Scheduler) GetWorker(ctx context.Context, id string) (*api.Worker, error)

+ type WorkHookWatcher interface

+ Next func() (*api.WorkHookResult, error)

+ type WorkerSub struct

+ func NewWorkSub() *WorkerSub

+ func (ws *WorkerSub) Add(id string, stream api.FlowRpc_WorkHookStream)

+ func (ws *WorkerSub) Del(id string)

+ func (ws *WorkerSub) Pub(result *api.WorkHookResult)

Jul 7, 2023

Changes in this version

+ func HashName(text string) string

Jun 19, 2023

Changes in this version

type Client

+ func (c *Client) GetWorkflow(ctx context.Context, id string) (*api.BpmnResource, error)

type RpcServer

+ func (rs *RpcServer) GetWorkflow(ctx context.Context, req *api.GetWorkflowRequest, rsp *api.GetWorkflowResponse) error

Jun 13, 2023

Changes in this version

type Scheduler

+ func (s *Scheduler) RemoveWorkflowInstance(wid string)

+ func (s *Scheduler) SetWorkflowInstance(wf *Workflow)

Jun 12, 2023

Changes in this version

type WorkflowBuilder

+ func FromSpec(spec *api.Workflow) *WorkflowBuilder

Jun 5, 2023

Changes in this version

+ func IsCancelErr(err error) bool

+ func IsShadowErr(err error) bool

type Client

+ func (c *Client) AbortWorkflowInstance(ctx context.Context, wid string) error

+ func (c *Client) CommitInteractive(ctx context.Context, pid, sid string, properties map[string]string, ...) error

+ func (c *Client) DeployWorkflow(ctx context.Context, resource *api.BpmnResource) (int64, error)

+ func (c *Client) ExecuteWorkflowInstance(ctx context.Context, id, name string, watch bool) (WorkflowWatcher, error)

+ func (c *Client) InspectWorkflowInstance(ctx context.Context, wid string) (*api.Workflow, error)

+ func (c *Client) ListInteractive(ctx context.Context, pid string, opts ...vclient.CallOption) ([]*api.Interactive, error)

+ func (c *Client) ListWorkFlowInstance(ctx context.Context) ([]*api.WorkflowSnapshot, error)

+ func (c *Client) ListWorkflow(ctx context.Context) ([]*api.BpmnResource, error)

+ func (c *Client) PauseWorkflowInstance(ctx context.Context, wid string) error

+ func (c *Client) ResumeWorkflowInstance(ctx context.Context, wid string) error

+ func (c *Client) WatchWorkflowInstance(ctx context.Context, wid string, opts ...vclient.CallOption) (WorkflowWatcher, error)

type RpcServer

+ func (rs *RpcServer) AbortWorkflowInstance(ctx context.Context, req *api.AbortWorkflowInstanceRequest, ...) error

+ func (rs *RpcServer) CommitInteractive(ctx context.Context, req *api.CommitInteractiveRequest, ...) (err error)

+ func (rs *RpcServer) DeployWorkflow(ctx context.Context, req *api.DeployWorkflowRequest, ...) error

+ func (rs *RpcServer) InspectWorkflowInstance(ctx context.Context, req *api.InspectWorkflowInstanceRequest, ...) error

+ func (rs *RpcServer) ListInteractive(ctx context.Context, req *api.ListInteractiveRequest, ...) (err error)

+ func (rs *RpcServer) ListWorkFlow(ctx context.Context, req *api.ListWorkflowRequest, ...) error

+ func (rs *RpcServer) ListWorkflowInstance(ctx context.Context, req *api.ListWorkflowInstanceRequest, ...) error

+ func (rs *RpcServer) PauseWorkflowInstance(ctx context.Context, req *api.PauseWorkflowInstanceRequest, ...) error

+ func (rs *RpcServer) ResumeWorkflowInstance(ctx context.Context, req *api.ResumeWorkflowInstanceRequest, ...) error

+ func (rs *RpcServer) RunWorkflowInstance(ctx context.Context, req *api.RunWorkflowInstanceRequest, ...) error

+ func (rs *RpcServer) WatchWorkflowInstance(ctx context.Context, req *api.WatchWorkflowInstanceRequest, ...) error

type Scheduler

+ func (s *Scheduler) CommitInteractive(ctx context.Context, pid, sid string, properties map[string]string) error

+ func (s *Scheduler) DeployWorkflow(ctx context.Context, resource *api.BpmnResource) (int64, error)

+ func (s *Scheduler) ExecuteWorkflowInstance(id, name string, ps *PipeSet) error

+ func (s *Scheduler) GetWorkflowDeployment(ctx context.Context, id string) (*bpmn.Definitions, error)

+ func (s *Scheduler) GetWorkflowInstance(wid string) (*Workflow, bool)

+ func (s *Scheduler) GetWorkflowInstances() []*api.WorkflowSnapshot

+ func (s *Scheduler) InspectWorkflowInstance(ctx context.Context, wid string) (*api.Workflow, error)

+ func (s *Scheduler) ListInteractive(ctx context.Context, pid string) ([]*api.Interactive, error)

+ func (s *Scheduler) ListWorkflow(ctx context.Context) ([]*api.BpmnResource, error)

+ func (s *Scheduler) WatchWorkflowInstance(ctx context.Context, wid string) (<-chan *api.WorkflowWatchResult, error)

type Workflow

+ func (w *Workflow) CommitInteractive(it *api.Interactive)

+ func (w *Workflow) Destroy()

+ func (w *Workflow) Handle(step *api.WorkflowStep, action api.StepAction, items map[string]string, ...) error

+ func (w *Workflow) InteractiveHandle(ctx context.Context, step *api.WorkflowStep, it *api.Interactive) error

type WorkflowBuilder

+ func (b *WorkflowBuilder) ToBpmn() (*bpmn.Definitions, error)

May 16, 2023

Changes in this version

type CallPack

+ func (p *CallPack) Apply(data []byte)

+ func (p *CallPack) ApplyErr(err error)

type StepPack

+ func (p *StepPack) Apply(data []byte)

+ func (p *StepPack) ApplyErr(err error)

May 12, 2023

Changes in this version

type WorkflowBuilder

+ func (b *WorkflowBuilder) Step(step *api.WorkflowStep) *WorkflowBuilder

May 11, 2023

Changes in this version

type WorkflowBuilder

+ func (b *WorkflowBuilder) Item(key string, value any) *WorkflowBuilder

May 6, 2023

Changes in this version

type Echo

+ Desc func() string

type Empty

+ func (e *Empty) Desc() string

type EmptyEcho

+ func (e *EmptyEcho) Desc() string

type EmptyStep

+ func (s *EmptyStep) Desc() string

type Entity

+ Desc func() string

type Step

+ Desc func() string

type TestStep

+ func (s *TestStep) Desc() string

May 4, 2023

Changes in this version

+ func ProvideWithName(name string, value any) error

+ func Provides(values ...any) error

type ClientStore

+ func (s *ClientStore) PopulateEcho(name string) (Echo, error)

+ func (s *ClientStore) PopulateStep(name string) (Step, error)

+ func (s *ClientStore) ProvideWithName(name string, value any) error

+ func (s *ClientStore) Provides(values ...any) error

Apr 28, 2023

Changes in this version

+ type CellStep struct

Apr 25, 2023

Changes in this version

type Tag

+ Kind TagKind

+ type TagKind int

+ const TagKindArgs

+ const TagKindCtx

type TestStep

+ ArgsA string

+ type WorkflowStepBuilder struct

+ func NewStepBuilder(step Step, worker string) *WorkflowStepBuilder

+ func (b *WorkflowStepBuilder) Arg(k, v string) *WorkflowStepBuilder

+ func (b *WorkflowStepBuilder) Args(args map[string]string) *WorkflowStepBuilder

+ func (b *WorkflowStepBuilder) Build() *api.WorkflowStep

+ func (b *WorkflowStepBuilder) ID(id string) *WorkflowStepBuilder

Apr 20, 2023

Changes in this version

type Echo

+ Owner func() reflect.Type

+ String func() string

type Empty

+ func (e *Empty) String() string

type EmptyEcho

+ func (e *EmptyEcho) Owner() reflect.Type

+ func (e *EmptyEcho) String() string

type EmptyStep

+ func (s *EmptyStep) Owner() reflect.Type

+ func (s *EmptyStep) String() string

type Entity

+ String func() string

type Step

+ Owner func() reflect.Type

+ String func() string

+ type TestStep struct

+ A string

+ B int32

+ C string

+ E *Empty

+ func (s *TestStep) Cancel(ctx *PipeSessionCtx) error

+ func (s *TestStep) Commit(ctx *PipeSessionCtx) error

+ func (s *TestStep) Owner() reflect.Type

+ func (s *TestStep) Prepare(ctx *PipeSessionCtx) error

+ func (s *TestStep) Rollback(ctx *PipeSessionCtx) error

+ func (s *TestStep) String() string

Apr 15, 2023

Changes in this version

type Client

+ func (c *Client) ExecuteWorkflow(ctx context.Context, spec *api.Workflow, watch bool) (WorkflowWatcher, error)

+ func (c *Client) NewWorkflow(opts ...Option) *WorkflowBuilder

Apr 14, 2023

Changes in this version

type ClientConfig

+ func (c *ClientConfig) WithStore(store *ClientStore) *ClientConfig

type ClientStore

+ func (s *ClientStore) Load(t any)

Mar 24, 2023

Changes in this version

type ClientConfig

+ func (c *ClientConfig) WithConn(conn vclient.Client) *ClientConfig

+ func (c *ClientConfig) WithHeartbeat(t time.Duration) *ClientConfig

+ func (c *ClientConfig) WithTimeout(t time.Duration) *ClientConfig

Mar 24, 2023

Changes in this version

+ const EntityUnique

+ var ErrAborted = errors.New("be aborted")

Mar 23, 2023

Changes in this version

type Client

+ func (c *Client) ListRegistry(ctx context.Context) ([]*api.Entity, []*api.Echo, []*api.Step, error)

+ func (c *Client) ListWorker(ctx context.Context) ([]*api.Worker, error)

type EchoSet

+ func (s *EchoSet) List() []*api.Echo

type EntitySet

+ func (s *EntitySet) List() []*api.Entity

type RpcServer

+ func (rs *RpcServer) ListRegistry(ctx context.Context, req *api.ListRegistryRequest, ...) error

+ func (rs *RpcServer) ListWorker(ctx context.Context, req *api.ListWorkerRequest, rsp *api.ListWorkerResponse) error

type Scheduler

+ func (s *Scheduler) GetRegistry() (entities []*api.Entity, echoes []*api.Echo, steps []*api.Step)

+ func (s *Scheduler) GetWorkers(ctx context.Context) ([]string, error)

type StepSet

+ func (s *StepSet) List() []*api.Step

Mar 23, 2023

Changes in this version

+ const EchoDesc

+ const EchoEndpoint

+ const EchoID

+ const EchoName

+ const EchoOwner

+ const EchoWorker

+ const EntityDesc

+ const EntityEndpoint

+ const EntityID

+ const EntityKind

+ const EntityWorker

+ const StepDesc

+ const StepEndpoint

+ const StepId

+ const StepName

+ const StepOwner

+ const StepWorker

+ var Root = "/vine.io/flow"

+ var WorkflowPath = path.Join(Root, "wf")

+ func EchoToAPI(echo Echo) *api.Echo

+ func EntityToAPI(entity Entity) *api.Entity

+ func ExtractFields(t any) []string

+ func ExtractTypeField(t any) ([]byte, error)

+ func GetTypePkgName(p reflect.Type) string

+ func InjectTypeFields(t any, items map[string][]byte, entityData []byte) error

+ func IsCancel(err error) bool

+ func IsRetriedErr(err error) bool

+ func Load(tps ...any)

+ func NewOptions(opts ...Option) *api.WorkflowOption

+ func SetTypeEntityField(t any, data []byte) error

+ func StepToAPI(step Step) *api.Step

+ func StepToWorkStep(step Step) *api.WorkflowStep

+ type CallPack struct

+ func NewCall(ctx context.Context, chunk *api.PipeCallRequest) *CallPack

+ func (p *CallPack) Destroy()

+ type Client struct

+ func NewClient(cfg ClientConfig) (*Client, error)

+ func (c *Client) AbortWorkflow(ctx context.Context, wid string) error

+ func (c *Client) Call(ctx context.Context, client, name string, data []byte) ([]byte, error)

+ func (c *Client) Id() string

+ func (c *Client) InspectWorkflow(ctx context.Context, wid string) (*api.Workflow, error)

+ func (c *Client) ListWorkFlow(ctx context.Context) ([]*api.WorkflowSnapshot, error)

+ func (c *Client) NewSession() (*PipeSession, error)

+ func (c *Client) PauseWorkflow(ctx context.Context, wid string) error

+ func (c *Client) ResumeWorkflow(ctx context.Context, wid string) error

+ func (c *Client) Step(ctx context.Context, name string, action api.StepAction, ...) ([]byte, error)

+ func (c *Client) WatchWorkflow(ctx context.Context, wid string) (WorkflowWatcher, error)

+ type ClientConfig struct

+ func NewConfig(name, id, address string) ClientConfig

+ type ClientPipe struct

+ Id string

+ func NewPipe(id string, pr *Peer, stream PipeStream) *ClientPipe

+ func (p *ClientPipe) Call(pack *CallPack) (<-chan []byte, <-chan error)

+ func (p *ClientPipe) Close()

+ func (p *ClientPipe) Start()

+ func (p *ClientPipe) Step(pack *StepPack) (<-chan []byte, <-chan error)

+ type ClientStore struct

+ func NewClientStore() *ClientStore

+ func (s *ClientStore) GetEcho(name string) (Echo, bool)

+ func (s *ClientStore) GetEntity(kind string) (Entity, bool)

+ func (s *ClientStore) GetStep(name string) (Step, bool)

+ type Echo interface

+ Call func(ctx context.Context, req []byte) ([]byte, error)

+ Metadata func() map[string]string

+ type EchoSet struct

+ func NewEchoSet() *EchoSet

+ func (s *EchoSet) Add(echo *api.Echo)

+ func (s *EchoSet) Contains(name string) bool

+ func (s *EchoSet) Del(echo *api.Echo)

+ func (s *EchoSet) Get(name string) (*api.Echo, bool)

+ type Empty struct

+ Name string

+ func (e *Empty) Marshal() ([]byte, error)

+ func (e *Empty) Metadata() map[string]string

+ func (e *Empty) OwnerReferences() []*api.OwnerReference

+ func (e *Empty) Unmarshal(data []byte) error

+ type EmptyEcho struct

+ func (e *EmptyEcho) Call(ctx context.Context, req []byte) ([]byte, error)

+ func (e *EmptyEcho) Metadata() map[string]string

+ type EmptyStep struct

+ A string

+ B int32

+ C string

+ Client string

+ E *Empty

+ func NewEmptyStep(e *Empty) *EmptyStep

+ func (s *EmptyStep) Cancel(ctx *PipeSessionCtx) error

+ func (s *EmptyStep) Commit(ctx *PipeSessionCtx) error

+ func (s *EmptyStep) Metadata() map[string]string

+ func (s *EmptyStep) Prepare(ctx *PipeSessionCtx) error

+ func (s *EmptyStep) Rollback(ctx *PipeSessionCtx) error

+ type Entity interface

+ Marshal func() ([]byte, error)

+ Metadata func() map[string]string

+ OwnerReferences func() []*api.OwnerReference

+ Unmarshal func(data []byte) error

+ type EntitySet struct

+ func NewEntitySet() *EntitySet

+ func (s *EntitySet) Add(entity *api.Entity)

+ func (s *EntitySet) Contains(name string) bool

+ func (s *EntitySet) Del(entity *api.Entity)

+ func (s *EntitySet) Get(kind string) (*api.Entity, bool)

+ type MemberPipeHandler func(*api.PipeResponse) (*api.PipeRequest, error)

+ type MemberPipeStream struct

+ func NewMemberPipeStream(ctx context.Context, id string, handler MemberPipeHandler) *MemberPipeStream

+ func (s *MemberPipeStream) Close() error

+ func (s *MemberPipeStream) Context() context.Context

+ func (s *MemberPipeStream) Recv() (*api.PipeRequest, error)

+ func (s *MemberPipeStream) Send(req *api.PipeResponse) error

+ type Option func(option *api.WorkflowOption)

+ func WithId(id string) Option

+ func WithMaxRetry(retry int32) Option

+ func WithMode(mode api.WorkflowMode) Option

+ func WithName(name string) Option

+ type Peer struct

+ Client string

+ Server string

+ type PipeSession struct

+ func NewPipeSession(c *Client) (*PipeSession, error)

+ func (s *PipeSession) Close()

+ func (s *PipeSession) ExecuteWorkflow(ctx context.Context, spec *api.Workflow, watch bool) (WorkflowWatcher, error)

+ func (s *PipeSession) IsConnected() bool

+ func (s *PipeSession) NewWorkflow(opts ...Option) *WorkflowBuilder

+ type PipeSessionCtx struct

+ func NewSessionCtx(ctx context.Context, wid, step string, revision api.Revision, c *Client) *PipeSessionCtx

+ func (c *PipeSessionCtx) Call(ctx context.Context, data []byte) ([]byte, error)

+ func (c *PipeSessionCtx) Get(ctx context.Context, key string) ([]byte, error)

+ func (c *PipeSessionCtx) Put(ctx context.Context, key string, data any) error

+ func (c *PipeSessionCtx) Revision() *api.Revision

+ func (c *PipeSessionCtx) Trace(ctx context.Context, text []byte) error

+ func (c *PipeSessionCtx) WorkflowID() string

+ type PipeSet struct

+ func NewPipeSet() *PipeSet

+ func (ps *PipeSet) Add(p *ClientPipe)

+ func (ps *PipeSet) Del(p *ClientPipe)

+ func (ps *PipeSet) Get(id string) (*ClientPipe, bool)

+ type PipeStream interface

+ Close func() error

+ Context func() context.Context

+ Recv func() (*api.PipeRequest, error)

+ Send func(*api.PipeResponse) error

+ type RpcServer struct

+ func NewRPCServer(s vserver.Server, scheduler *Scheduler) (*RpcServer, error)

+ func (rs *RpcServer) AbortWorkflow(ctx context.Context, req *api.AbortWorkflowRequest, ...) error

+ func (rs *RpcServer) Call(ctx context.Context, req *api.CallRequest, rsp *api.CallResponse) error

+ func (rs *RpcServer) Id() string

+ func (rs *RpcServer) InspectWorkflow(ctx context.Context, req *api.InspectWorkflowRequest, ...) error

+ func (rs *RpcServer) ListWorkflow(ctx context.Context, req *api.ListWorkflowRequest, ...) error

+ func (rs *RpcServer) PauseWorkflow(ctx context.Context, req *api.PauseWorkflowRequest, ...) error

+ func (rs *RpcServer) Pipe(ctx context.Context, stream api.FlowRpc_PipeStream) error

+ func (rs *RpcServer) Register(ctx context.Context, req *api.RegisterRequest, rsp *api.RegisterResponse) error

+ func (rs *RpcServer) ResumeWorkflow(ctx context.Context, req *api.ResumeWorkflowRequest, ...) error

+ func (rs *RpcServer) RunWorkflow(ctx context.Context, req *api.RunWorkflowRequest, ...) error

+ func (rs *RpcServer) Step(ctx context.Context, req *api.StepRequest, rsp *api.StepResponse) error

+ func (rs *RpcServer) StepGet(ctx context.Context, req *api.StepGetRequest, rsp *api.StepGetResponse) error

+ func (rs *RpcServer) StepPut(ctx context.Context, req *api.StepPutRequest, rsp *api.StepPutResponse) error

+ func (rs *RpcServer) StepTrace(ctx context.Context, req *api.StepTraceRequest, rsp *api.StepTraceResponse) error

+ func (rs *RpcServer) Stop() error

+ func (rs *RpcServer) WatchWorkflow(ctx context.Context, req *api.WatchWorkflowRequest, ...) error

+ type Scheduler struct

+ func NewScheduler(storage *clientv3.Client, size int) (*Scheduler, error)

+ func (s *Scheduler) ExecuteWorkflow(w *api.Workflow, ps *PipeSet) error

+ func (s *Scheduler) GetWorkflow(wid string) (*Workflow, bool)

+ func (s *Scheduler) InspectWorkflow(ctx context.Context, wid string) (*api.Workflow, error)

+ func (s *Scheduler) IsClosed() bool

+ func (s *Scheduler) Register(entities []*api.Entity, echoes []*api.Echo, steps []*api.Step)

+ func (s *Scheduler) StepGet(ctx context.Context, wid, key string) ([]byte, error)

+ func (s *Scheduler) StepPut(ctx context.Context, wid, key, value string) error

+ func (s *Scheduler) StepTrace(ctx context.Context, wid, step string, text []byte) error

+ func (s *Scheduler) Stop(wait bool)

+ func (s *Scheduler) WatchWorkflow(ctx context.Context, wid string) (<-chan *api.WorkflowWatchResult, error)

+ func (s *Scheduler) WorkflowSnapshots() []*api.WorkflowSnapshot

+ type Step interface

+ Cancel func(ctx *PipeSessionCtx) error

+ Commit func(ctx *PipeSessionCtx) error

+ Metadata func() map[string]string

+ Prepare func(ctx *PipeSessionCtx) error

+ Rollback func(ctx *PipeSessionCtx) error

+ type StepPack struct

+ func NewStep(ctx context.Context, chunk *api.PipeStepRequest) *StepPack

+ func (p *StepPack) Destroy()

+ type StepSet struct

+ func NewStepSet() *StepSet

+ func (s *StepSet) Add(step *api.Step)

+ func (s *StepSet) Contains(name string) bool

+ func (s *StepSet) Del(step *api.Step)

+ func (s *StepSet) Get(name string) (*api.Step, bool)

+ type Tag struct

+ IsEntity bool

+ Name string

+ type Workflow struct

+ func NewWorkflow(spec *api.Workflow) *Workflow

+ func (w *Workflow) Abort()

+ func (w *Workflow) Cancel()

+ func (w *Workflow) Context() context.Context

+ func (w *Workflow) Execute(ps *PipeSet, client *clientv3.Client)

+ func (w *Workflow) ID() string

+ func (w *Workflow) Init(client *clientv3.Client) (err error)

+ func (w *Workflow) Inspect(ctx context.Context, client *clientv3.Client) (*api.Workflow, error)

+ func (w *Workflow) IsAbort() bool

+ func (w *Workflow) IsStop() bool

+ func (w *Workflow) NewSnapshot() *api.WorkflowSnapshot

+ func (w *Workflow) NewWatcher(ctx context.Context, client *clientv3.Client) (<-chan *api.WorkflowWatchResult, error)

+ func (w *Workflow) Pause() bool

+ func (w *Workflow) Resume() bool

+ type WorkflowBuilder struct

+ func NewBuilder(opts ...Option) *WorkflowBuilder

+ func (b *WorkflowBuilder) Build() *api.Workflow

+ func (b *WorkflowBuilder) Entities(entities ...Entity) *WorkflowBuilder

+ func (b *WorkflowBuilder) Items(items map[string][]byte) *WorkflowBuilder

+ func (b *WorkflowBuilder) Steps(steps ...*api.WorkflowStep) *WorkflowBuilder

+ type WorkflowWatcher interface

+ Next func() (*api.WorkflowWatchResult, error)