async

Feb 27, 2022

Changes in this version

type SwitchCase

+ Default bool

Feb 27, 2022

Changes in this version

type State

+ func (s *State) UpdateWorkflowsStatus()

Feb 26, 2022

Changes in this version

+ const HandlerTypeReflect

+ type ReflectHandler struct

+ Handler interface{}

+ func (h *ReflectHandler) Handle(ctx context.Context, req CallbackRequest, input interface{}) (interface{}, error)

+ func (h *ReflectHandler) Type() string

+ func (h ReflectHandler) MarshalJSON() ([]byte, error)

+ func (h ReflectHandler) Schemas() (in *jsonschema.Schema, out *jsonschema.Schema, err error)

+ func (t *ReflectHandler) Setup(ctx context.Context, req CallbackRequest) (string, error)

+ func (t *ReflectHandler) Teardown(ctx context.Context, req CallbackRequest, handled bool) error

type WaitEvent

+ Type string

Aug 26, 2021

Changes in this version

+ type CheckpointType string

+ const CheckpointAfterCondition

+ const CheckpointAfterResume

+ const CheckpointAfterSetup

+ const CheckpointAfterStep

+ const CheckpointAfterTeardown

type Event

+ func OnEvent(name string, h interface{}, stmts ...Stmt) Event

+ type ReflectEvent struct

+ Handler interface{}

+ func (h *ReflectEvent) Handle(ctx context.Context, req CallbackRequest, input interface{}) (interface{}, error)

+ func (h ReflectEvent) MarshalJSON() ([]byte, error)

+ func (h ReflectEvent) Schemas() (in *jsonschema.Schema, out *jsonschema.Schema, err error)

+ func (t *ReflectEvent) Setup(ctx context.Context, req CallbackRequest) (string, error)

+ func (t *ReflectEvent) Teardown(ctx context.Context, req CallbackRequest, handled bool) error

Aug 13, 2021

Changes in this version

+ func ResumeWithSave(ctx context.Context, wf WorkflowState, s *State, save Checkpoint) (bool, error)

+ type ErrExec struct

+ Step string

+ func (e ErrExec) Error() string

+ func (e ErrExec) Unwrap() error

type WorkflowStatus

+ const WorkflowResuming

Jul 28, 2021

Changes in this version

+ type ContinueStmt struct

+ func Continue() ContinueStmt

+ func (s ContinueStmt) MarshalJSON() ([]byte, error)

+ func (s ContinueStmt) Resume(ctx *resumeContext) (*Stop, error)

type ForStmt

+ Section Section

type Thread

+ Continue bool

+ CurCallback string

Jul 20, 2021

Changes in this version

type BreakStmt

+ func (s BreakStmt) MarshalJSON() ([]byte, error)

+ type Event struct

+ Callback CallbackRequest

+ Handler Handler

+ Stmt Stmt

+ func (s Event) MarshalJSON() ([]byte, error)

type ForStmt

+ Name string

+ func (s ForStmt) MarshalJSON() ([]byte, error)

type GoStmt

+ func (s GoStmt) MarshalJSON() ([]byte, error)

type ReturnStmt

+ func (s ReturnStmt) MarshalJSON() ([]byte, error)

type Section

+ func (s Section) MarshalJSON() ([]byte, error)

type StmtStep

+ func (s StmtStep) MarshalJSON() ([]byte, error)

type Stop

+ WaitEvents *WaitEventsStmt

type SwitchCase

+ Name string

+ func (s SwitchCase) MarshalJSON() ([]byte, error)

type SwitchStmt

+ func (s SwitchStmt) MarshalJSON() ([]byte, error)

+ type WaitCondStmt struct

+ Cond bool

+ Handler func()

+ Name string

+ func (f WaitCondStmt) Resume(ctx *resumeContext) (*Stop, error)

+ func (s WaitCondStmt) MarshalJSON() ([]byte, error)

+ type WaitEventsStmt struct

+ Cases []Event

+ Name string

+ func (s WaitEventsStmt) MarshalJSON() ([]byte, error)

+ func (s WaitEventsStmt) Resume(ctx *resumeContext) (*Stop, error)

Jul 16, 2021

Changes in this version

type WaitEvent

+ Handled bool

Jul 15, 2021

Changes in this version

+ func Validate(s Section) error

type Stop

+ Cond string

type Thread

+ Break bool

type ThreadStatus

+ const ThreadWaitingCondition

+ const ThreadWaitingEvent

+ type WG struct

+ I int

+ func (wg *WG) Add(i int)

+ func (wg *WG) Done()

+ func (wg *WG) Wait(label string) Stmt

+ type WaitStmt struct

+ Cond bool

+ CondLabel string

+ Handler func()

+ func FindWaitingStep(name string, sec Stmt) (WaitStmt, error)

+ func (f WaitStmt) Resume(ctx *ResumeContext) (*Stop, error)

Jul 14, 2021

Changes in this version

type SwitchStmt

+ Cases []SwitchCase

+ func (s *SwitchStmt) Else(sec ...Stmt) *SwitchStmt

+ func (s *SwitchStmt) ElseIf(cond bool, sec ...Stmt) *SwitchStmt

type WaitEventStatus

+ const EventPendingSetup

+ const EventPendingTeardown

Jul 9, 2021

Changes in this version

+ const MainThread

+ func HandleCallback(ctx context.Context, req CallbackRequest, wf WorkflowState, s *State, ...) (interface{}, error)

+ func HandleEvent(ctx context.Context, name string, wf WorkflowState, s *State, ...) (interface{}, error)

+ func Resume(ctx context.Context, wf WorkflowState, s *State, save Checkpoint) error

type CallbackRequest

+ SetupData json.RawMessage

type GoStmt

+ func (s *GoStmt) WithID(id func() string)

Jul 8, 2021

Changes in this version

type Runner

+ func (r *Runner) OnEvent(ctx context.Context, name string, wf WorkflowState, s *State, ...) (interface{}, error)

Jul 8, 2021

Changes in this version

type Handler

+ func FindHandler(req CallbackRequest, sec Stmt) Handler

+ Setup func(ctx context.Context, req CallbackRequest) error

+ Teardown func(ctx context.Context, req CallbackRequest) error

Jul 7, 2021

Changes in this version

+ type Engine interface

+ OnCallback func(ctx context.Context, lkp EventLookupFunc, input interface{}) (interface{}, error)

+ OnResume func(ctx context.Context, id string) error

+ type EventLookupFunc func(s *State) (CallbackRequest, error)

+ type JsonEvent struct

+ Handler interface{}

+ Path string

+ func (h JsonEvent) Handle(req CallbackRequest, input interface{}) (interface{}, error)

+ func (h JsonEvent) Type() string

+ type Scheduler interface

+ Schedule func(ctx context.Context, id string) error

Jul 5, 2021

Changes in this version

type CallbackRequest

+ Handler interface{}

+ type Checkpoint func(scheduleResume bool) error

type ResumeContext

+ Return bool

type Runner

+ func (r *Runner) OnResume(ctx context.Context, wf WorkflowState, s *State, save Checkpoint) error

type State

+ func NewState(id, name string) State

Jul 1, 2021

Changes in this version

+ var ErrPCMismatch = fmt.Errorf("PC doesn't match (callback is late)")

+ type CallbackManager interface

+ Setup func(req CallbackRequest) error

+ Teardown func(req CallbackRequest) error

type CallbackRequest

+ Data json.RawMessage

+ Name string

+ Type string

+ type DB interface

+ Create func(ctx context.Context, id string, s *State) error

+ RunLocked func(ctx context.Context, id string, f UpdaterFunc) error

type Handler

+ Handle func(req CallbackRequest, input json.RawMessage) (json.RawMessage, error)

+ Marshal func() json.RawMessage

+ Type func() string

type ResumeContext

+ Callback CallbackRequest

+ type Resumer interface

+ ScheduleResume func(r *Runner, id string) error

type Runner

+ CallbackManagers map[string]CallbackManager

+ DB DB

+ Resumer Resumer

+ Workflows map[string]Workflow

+ func (r *Runner) OnCallback(ctx context.Context, req CallbackRequest) error

+ func (r *Runner) Resume(ctx context.Context, dur time.Duration, steps int, id string) error

type Thread

+ func (t *Thread) WaitingForCallback(cb CallbackRequest) bool

+ type UpdaterFunc func(ctx context.Context, s *State, save func() error) error

type WaitCond

+ Callback CallbackRequest

type WaitEvent

+ Error string

+ Req CallbackRequest

+ Status string

+ type WaitEventStatus string

+ const EventPending

+ const EventSetup

+ const EventSetupError

+ const EventTeardownError

type WorkflowStatus

+ const WorkflowWaiting

Jun 1, 2021

Changes in this version

+ const MaxWaittTill

+ var ErrDuplicate = fmt.Errorf("PC doesn't match (duplicate/out of time event)")

+ func DefaultCollectionName(s *State) string

+ func DefaultQueueNameFunc(s *State) string

+ func Walk(s Stmt, f func(s Stmt) bool) bool

+ type ActionFunc func() ActionResult

+ type ActionResult struct

+ Error string

+ Retries int

+ RetryInterval time.Duration

+ Success bool

+ type BreakStmt struct

+ func Break() BreakStmt

+ func (s BreakStmt) Resume(ctx *ResumeContext) (*Stop, error)

+ type CBHandler struct

+ Docs HandlerDocs

+ Handler http.HandlerFunc

+ type CallbackRequest struct

+ Callback string

+ PC int

+ ThreadID string

+ WorkflowID string

+ type DocWorkflow struct

+ Handlers map[string]HandlerDocs

+ Input *jsonschema.Schema

+ Output *jsonschema.Schema

+ func Docs(def WorkflowDefinition) DocWorkflow

+ type ExecuteRequest struct

+ PC int

+ Step string

+ ThreadID string

+ WorkflowID string

+ type ForStmt struct

+ Cond bool

+ CondLabel string

+ Stmt Stmt

+ func (f ForStmt) Resume(ctx *ResumeContext) (*Stop, error)

+ type GoStmt struct

+ ID func() string

+ Name string

+ Stmt Stmt

+ func Go(name string, body Stmt, id func() string) GoStmt

+ func (s GoStmt) Resume(ctx *ResumeContext) (*Stop, error)

+ type Handler interface

+ type HandlerDocs struct

+ Input *jsonschema.Schema

+ Output *jsonschema.Schema

+ func ReflectDoc(handler Handler, inline bool) HandlerDocs

+ type ResumeContext struct

+ Break bool

+ CallbackInput json.RawMessage

+ CallbackName string

+ CallbackOutput json.RawMessage

+ Running bool

+ type ResumeRequest struct

+ PC int

+ ThreadID string

+ WorkflowID string

+ type ReturnStmt struct

+ Value interface{}

+ func Return(v interface{}) ReturnStmt

+ func (s ReturnStmt) Resume(ctx *ResumeContext) (*Stop, error)

+ type Runner struct

+ func NewRunner(cfg RunnerConfig, db *firestore.Client, tasks *cloudtasks.Service) (*Runner, error)

+ func (r *Runner) CallbackStateHandler(s *State, req CallbackRequest) error

+ func (r *Runner) ExecStep(s *State, req ExecuteRequest) error

+ func (r *Runner) LockWorkflow(ctx context.Context, id string, thread string, pc int) (*State, error)

+ func (r *Runner) NewWorkflow(ctx context.Context, id, name string, state interface{}) error

+ func (r *Runner) ResumeState(ctx *ResumeContext) (WorkflowState, error)

+ func (r *Runner) ResumeStateHandler(s *State, req ResumeRequest) error

+ func (r *Runner) Router() *mux.Router

+ func (r *Runner) ScheduleTasks(s *State, tID string) error

+ func (r *Runner) UnlockWorkflow(ctx context.Context, id string, s *State) error

+ type RunnerConfig struct

+ BaseURL string

+ Collection string

+ LocationID string

+ ProjectID string

+ QueueName string

+ Workflows map[string]Workflow

+ func (cfg *RunnerConfig) SetDefaultsAndValidate() error

+ type Section []Stmt

+ func S(ss ...Stmt) Section

+ func (s Section) Resume(ctx *ResumeContext) (*Stop, error)

+ type SelectStmt struct

+ Cases []WaitCond

+ Name string

+ func WaitEvent(event string, handler Handler, sec ...Stmt) SelectStmt

+ func WaitFor(name string, d time.Duration, sec ...Stmt) SelectStmt

+ func (s SelectStmt) Resume(ctx *ResumeContext) (*Stop, error)

+ type State struct

+ ID string

+ Input []byte

+ LockTill time.Time

+ Output []byte

+ PC int

+ State []byte

+ Status WorkflowStatus

+ Threads Threads

+ Workflow string

+ func (s *State) DumpState(v interface{}) error

+ type Stmt interface

+ Resume func(ctx *ResumeContext) (*Stop, error)

+ func FindStep(name string, sec Stmt) Stmt

+ func For(cond bool, condLabel string, sec Stmt) Stmt

+ type StmtStep struct

+ Action ActionFunc

+ Name string

+ func Step(name string, action ActionFunc) StmtStep

+ func (s StmtStep) Resume(ctx *ResumeContext) (*Stop, error)

+ type Stop struct

+ Return interface{}

+ Select *SelectStmt

+ Step string

+ type SwitchCase struct

+ Cond bool

+ CondLabel string

+ Stmt Stmt

+ func Default(sec Stmt) SwitchCase

+ type SwitchStmt []SwitchCase

+ func If(cond bool, condLabel string, sec Stmt) SwitchStmt

+ func Switch(ss ...SwitchCase) SwitchStmt

+ func (s SwitchStmt) Resume(ctx *ResumeContext) (*Stop, error)

type Thread

+ CurStep string

+ ExecBackoff time.Time

+ ExecError string

+ ExecRetries int

+ Name string

+ PC int

+ WaitEvents []string

+ func (t Thread) EventIndex(name string) int

+ type ThreadStatus string

+ const ThreadExecuting

+ const ThreadPaused

+ const ThreadResuming

+ const ThreadWaiting

+ type Threads []*Thread

+ func (tt *Threads) Add(t *Thread)

+ func (tt *Threads) Find(id string) (*Thread, bool)

+ func (tt *Threads) Remove(id string)

+ type WaitCond struct

+ CallbackName string

+ CaseAfter time.Duration

+ CaseRecv string

+ CaseSend string

+ CaseWait bool

+ Handler Handler

+ SendData json.RawMessage

+ Stmt Stmt

+ func After(d time.Duration, sec Stmt) WaitCond

+ func On(event string, handler Handler, sec Stmt) WaitCond

+ func Wait(event string, cond bool, sec Stmt) WaitCond

type Workflow

+ InitState func() WorkflowState

type WorkflowDefinition

+ Body Section

+ New Handler

+ type WorkflowState interface

+ Definition func() WorkflowDefinition

+ type WorkflowStatus string

+ const WorkflowFinished

+ const WorkflowRunning

Dec 22, 2020

Changes in this version

type Call

+ API string

+ ID string

+ func (m *Call) GetAPI() string

+ func (m *Call) GetID() string

type Case

+ Callback string

+ func (m *Case) GetCallback() string

type Channel

+ ID string

+ func (m *Channel) GetID() string

type CloseChanReq

+ IDs []string

+ func (m *CloseChanReq) GetIDs() []string

type DeleteChanReq

+ IDs []string

+ func (m *DeleteChanReq) GetIDs() []string

type ExtendLockReq

+ ID string

+ LockID uint64

+ func (m *ExtendLockReq) GetID() string

+ func (m *ExtendLockReq) GetLockID() uint64

+ type GetChanReq struct

+ ID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetChanReq) Descriptor() ([]byte, []int)

+ func (*GetChanReq) ProtoMessage()

+ func (m *GetChanReq) GetID() string

+ func (m *GetChanReq) Reset()

+ func (m *GetChanReq) String() string

+ func (m *GetChanReq) XXX_DiscardUnknown()

+ func (m *GetChanReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetChanReq) XXX_Merge(src proto.Message)

+ func (m *GetChanReq) XXX_Size() int

+ func (m *GetChanReq) XXX_Unmarshal(b []byte) error

+ type GetTypeReq struct

+ ID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTypeReq) Descriptor() ([]byte, []int)

+ func (*GetTypeReq) ProtoMessage()

+ func (m *GetTypeReq) GetID() string

+ func (m *GetTypeReq) Reset()

+ func (m *GetTypeReq) String() string

+ func (m *GetTypeReq) XXX_DiscardUnknown()

+ func (m *GetTypeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTypeReq) XXX_Merge(src proto.Message)

+ func (m *GetTypeReq) XXX_Size() int

+ func (m *GetTypeReq) XXX_Unmarshal(b []byte) error

+ type GetWorkflowAPIReq struct

+ ID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowAPIReq) Descriptor() ([]byte, []int)

+ func (*GetWorkflowAPIReq) ProtoMessage()

+ func (m *GetWorkflowAPIReq) GetID() string

+ func (m *GetWorkflowAPIReq) Reset()

+ func (m *GetWorkflowAPIReq) String() string

+ func (m *GetWorkflowAPIReq) XXX_DiscardUnknown()

+ func (m *GetWorkflowAPIReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetWorkflowAPIReq) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowAPIReq) XXX_Size() int

+ func (m *GetWorkflowAPIReq) XXX_Unmarshal(b []byte) error

type GetWorkflowReq

+ ID string

+ func (m *GetWorkflowReq) GetID() string

type ListWorkflowAPIsResp

+ APIs []*WorkflowAPI

+ func (m *ListWorkflowAPIsResp) GetAPIs() []*WorkflowAPI

type LockWorkflowReq

+ ID string

+ func (m *LockWorkflowReq) GetID() string

type LockedWorkflow

+ LockID uint64

+ func (m *LockedWorkflow) GetLockID() uint64

type RuntimeClient

+ GetChan func(ctx context.Context, in *GetChanReq, opts ...grpc.CallOption) (*Channel, error)

+ GetType func(ctx context.Context, in *GetTypeReq, opts ...grpc.CallOption) (*Type, error)

+ GetWorkflowAPI func(ctx context.Context, in *GetWorkflowAPIReq, opts ...grpc.CallOption) (*WorkflowAPI, error)

type RuntimeServer

+ GetChan func(context.Context, *GetChanReq) (*Channel, error)

+ GetType func(context.Context, *GetTypeReq) (*Type, error)

+ GetWorkflowAPI func(context.Context, *GetWorkflowAPIReq) (*WorkflowAPI, error)

type Select

+ Closed bool

+ func (m *Select) GetClosed() bool

type Thread

+ Callback string

+ ID string

+ func (m *Thread) GetCallback() string

+ func (m *Thread) GetID() string

type Type

+ ID string

+ func (m *Type) GetID() string

type UpdateWorkflowReq

+ LockID uint64

+ func (m *UpdateWorkflowReq) GetLockID() uint64

type Workflow

+ API string

+ ID string

+ func (m *Workflow) GetAPI() string

+ func (m *Workflow) GetID() string

Dec 16, 2020

Changes in this version

+ const None

Dec 16, 2020

Changes in this version

+ type ExtendLockReq struct

+ Id string

+ Lockid uint64

+ Seconds uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExtendLockReq) Descriptor() ([]byte, []int)

+ func (*ExtendLockReq) ProtoMessage()

+ func (m *ExtendLockReq) GetId() string

+ func (m *ExtendLockReq) GetLockid() uint64

+ func (m *ExtendLockReq) GetSeconds() uint64

+ func (m *ExtendLockReq) Reset()

+ func (m *ExtendLockReq) String() string

+ func (m *ExtendLockReq) XXX_DiscardUnknown()

+ func (m *ExtendLockReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExtendLockReq) XXX_Merge(src proto.Message)

+ func (m *ExtendLockReq) XXX_Size() int

+ func (m *ExtendLockReq) XXX_Unmarshal(b []byte) error

type LockWorkflowReq

+ Seconds uint64

+ func (m *LockWorkflowReq) GetSeconds() uint64

type RuntimeClient

+ ExtendLock func(ctx context.Context, in *ExtendLockReq, opts ...grpc.CallOption) (*Empty, error)

type RuntimeServer

+ ExtendLock func(context.Context, *ExtendLockReq) (*Empty, error)

Dec 16, 2020

Changes in this version

+ func ManageWorkflows(ctx context.Context, client RuntimeClient, s Service) error

+ func Setup(ctx context.Context, client RuntimeClient, s Service) error

Dec 16, 2020

Changes in this version

+ type ListWorkflowAPIsReq struct

+ From string

+ Id string

+ Limit uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListWorkflowAPIsReq) Descriptor() ([]byte, []int)

+ func (*ListWorkflowAPIsReq) ProtoMessage()

+ func (m *ListWorkflowAPIsReq) GetFrom() string

+ func (m *ListWorkflowAPIsReq) GetId() string

+ func (m *ListWorkflowAPIsReq) GetLimit() uint64

+ func (m *ListWorkflowAPIsReq) Reset()

+ func (m *ListWorkflowAPIsReq) String() string

+ func (m *ListWorkflowAPIsReq) XXX_DiscardUnknown()

+ func (m *ListWorkflowAPIsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListWorkflowAPIsReq) XXX_Merge(src proto.Message)

+ func (m *ListWorkflowAPIsReq) XXX_Size() int

+ func (m *ListWorkflowAPIsReq) XXX_Unmarshal(b []byte) error

+ type ListWorkflowAPIsResp struct

+ Apis []*WorkflowAPI

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListWorkflowAPIsResp) Descriptor() ([]byte, []int)

+ func (*ListWorkflowAPIsResp) ProtoMessage()

+ func (m *ListWorkflowAPIsResp) GetApis() []*WorkflowAPI

+ func (m *ListWorkflowAPIsResp) Reset()

+ func (m *ListWorkflowAPIsResp) String() string

+ func (m *ListWorkflowAPIsResp) XXX_DiscardUnknown()

+ func (m *ListWorkflowAPIsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListWorkflowAPIsResp) XXX_Merge(src proto.Message)

+ func (m *ListWorkflowAPIsResp) XXX_Size() int

+ func (m *ListWorkflowAPIsResp) XXX_Unmarshal(b []byte) error

type RuntimeClient

+ DeleteWorkflowAPI func(ctx context.Context, in *WorkflowAPI, opts ...grpc.CallOption) (*Empty, error)

+ ListWorkflowAPIs func(ctx context.Context, in *ListWorkflowAPIsReq, opts ...grpc.CallOption) (*ListWorkflowAPIsResp, error)

+ PutWorkflowAPI func(ctx context.Context, in *WorkflowAPI, opts ...grpc.CallOption) (*Empty, error)

type RuntimeServer

+ DeleteWorkflowAPI func(context.Context, *WorkflowAPI) (*Empty, error)

+ ListWorkflowAPIs func(context.Context, *ListWorkflowAPIsReq) (*ListWorkflowAPIsResp, error)

+ PutWorkflowAPI func(context.Context, *WorkflowAPI) (*Empty, error)

type Service

+ Workflows []WorkflowDefinition

+ type WorkflowDefinition struct

+ API *WorkflowAPI

+ Setup func() (interface{}, error)

+ Teardown func(interface{}) error

Dec 15, 2020

Changes in this version

+ type W struct

+ func (p *W) After(after time.Duration) *W

+ func (p *W) At(at time.Time) *W

+ func (p *W) Call(name string, input interface{}) *W

+ func (p *W) Default() *W

+ func (p *W) Finish(result interface{}) *W

+ func (p *W) Go(id string, f func(p *W))

+ func (p *W) ID() string

+ func (p *W) MakeChan(t *Type, bufsize int) Channel

+ func (p *W) Name() string

+ func (p *W) NewID() string

+ func (p *W) Recv(channel Channel) *W

+ func (p *W) Select() *W

+ func (p *W) Send(channel Channel, data interface{}) *W

+ func (p *W) Service() string

+ func (p *W) To(cb interface{}) *W

Dec 3, 2020

Changes in this version

+ var Workflow_Status_name = map[int32]string

+ var Workflow_Status_value = map[string]int32

+ type DeleteChanReq struct

+ Ids []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteChanReq) Descriptor() ([]byte, []int)

+ func (*DeleteChanReq) ProtoMessage()

+ func (m *DeleteChanReq) GetIds() []string

+ func (m *DeleteChanReq) Reset()

+ func (m *DeleteChanReq) String() string

+ func (m *DeleteChanReq) XXX_DiscardUnknown()

+ func (m *DeleteChanReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteChanReq) XXX_Merge(src proto.Message)

+ func (m *DeleteChanReq) XXX_Size() int

+ func (m *DeleteChanReq) XXX_Unmarshal(b []byte) error

+ type FindWorkflowsReq struct

+ Filter string

+ From uint64

+ Limit uint64

+ Scanlimit uint64

+ To uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindWorkflowsReq) Descriptor() ([]byte, []int)

+ func (*FindWorkflowsReq) ProtoMessage()

+ func (m *FindWorkflowsReq) GetFilter() string

+ func (m *FindWorkflowsReq) GetFrom() uint64

+ func (m *FindWorkflowsReq) GetLimit() uint64

+ func (m *FindWorkflowsReq) GetScanlimit() uint64

+ func (m *FindWorkflowsReq) GetTo() uint64

+ func (m *FindWorkflowsReq) Reset()

+ func (m *FindWorkflowsReq) String() string

+ func (m *FindWorkflowsReq) XXX_DiscardUnknown()

+ func (m *FindWorkflowsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FindWorkflowsReq) XXX_Merge(src proto.Message)

+ func (m *FindWorkflowsReq) XXX_Size() int

+ func (m *FindWorkflowsReq) XXX_Unmarshal(b []byte) error

+ type FindWorkflowsResp struct

+ Workflows []*Workflow

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindWorkflowsResp) Descriptor() ([]byte, []int)

+ func (*FindWorkflowsResp) ProtoMessage()

+ func (m *FindWorkflowsResp) GetWorkflows() []*Workflow

+ func (m *FindWorkflowsResp) Reset()

+ func (m *FindWorkflowsResp) String() string

+ func (m *FindWorkflowsResp) XXX_DiscardUnknown()

+ func (m *FindWorkflowsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FindWorkflowsResp) XXX_Merge(src proto.Message)

+ func (m *FindWorkflowsResp) XXX_Size() int

+ func (m *FindWorkflowsResp) XXX_Unmarshal(b []byte) error

+ type GetWorkflowReq struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowReq) Descriptor() ([]byte, []int)

+ func (*GetWorkflowReq) ProtoMessage()

+ func (m *GetWorkflowReq) GetId() string

+ func (m *GetWorkflowReq) Reset()

+ func (m *GetWorkflowReq) String() string

+ func (m *GetWorkflowReq) XXX_DiscardUnknown()

+ func (m *GetWorkflowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetWorkflowReq) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowReq) XXX_Size() int

+ func (m *GetWorkflowReq) XXX_Unmarshal(b []byte) error

+ type ListenWorkflowsUpdatesReq struct

+ Filter string

+ From uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListenWorkflowsUpdatesReq) Descriptor() ([]byte, []int)

+ func (*ListenWorkflowsUpdatesReq) ProtoMessage()

+ func (m *ListenWorkflowsUpdatesReq) GetFilter() string

+ func (m *ListenWorkflowsUpdatesReq) GetFrom() uint64

+ func (m *ListenWorkflowsUpdatesReq) Reset()

+ func (m *ListenWorkflowsUpdatesReq) String() string

+ func (m *ListenWorkflowsUpdatesReq) XXX_DiscardUnknown()

+ func (m *ListenWorkflowsUpdatesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListenWorkflowsUpdatesReq) XXX_Merge(src proto.Message)

+ func (m *ListenWorkflowsUpdatesReq) XXX_Size() int

+ func (m *ListenWorkflowsUpdatesReq) XXX_Unmarshal(b []byte) error

+ type LockWorkflowReq struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LockWorkflowReq) Descriptor() ([]byte, []int)

+ func (*LockWorkflowReq) ProtoMessage()

+ func (m *LockWorkflowReq) GetId() string

+ func (m *LockWorkflowReq) Reset()

+ func (m *LockWorkflowReq) String() string

+ func (m *LockWorkflowReq) XXX_DiscardUnknown()

+ func (m *LockWorkflowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LockWorkflowReq) XXX_Merge(src proto.Message)

+ func (m *LockWorkflowReq) XXX_Size() int

+ func (m *LockWorkflowReq) XXX_Unmarshal(b []byte) error

+ type LockedWorkflow struct

+ LockId uint64

+ Thread *Thread

+ Workflow *Workflow

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LockedWorkflow) Descriptor() ([]byte, []int)

+ func (*LockedWorkflow) ProtoMessage()

+ func (m *LockedWorkflow) GetLockId() uint64

+ func (m *LockedWorkflow) GetThread() *Thread

+ func (m *LockedWorkflow) GetWorkflow() *Workflow

+ func (m *LockedWorkflow) Reset()

+ func (m *LockedWorkflow) String() string

+ func (m *LockedWorkflow) XXX_DiscardUnknown()

+ func (m *LockedWorkflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LockedWorkflow) XXX_Merge(src proto.Message)

+ func (m *LockedWorkflow) XXX_Size() int

+ func (m *LockedWorkflow) XXX_Unmarshal(b []byte) error

+ type NewWorkflowReq struct

+ Call *Call

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NewWorkflowReq) Descriptor() ([]byte, []int)

+ func (*NewWorkflowReq) ProtoMessage()

+ func (m *NewWorkflowReq) GetCall() *Call

+ func (m *NewWorkflowReq) Reset()

+ func (m *NewWorkflowReq) String() string

+ func (m *NewWorkflowReq) XXX_DiscardUnknown()

+ func (m *NewWorkflowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NewWorkflowReq) XXX_Merge(src proto.Message)

+ func (m *NewWorkflowReq) XXX_Size() int

+ func (m *NewWorkflowReq) XXX_Unmarshal(b []byte) error

+ type RegisterWorkflowHandlerReq struct

+ PollIntervalMs int64

+ Pool int64

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterWorkflowHandlerReq) Descriptor() ([]byte, []int)

+ func (*RegisterWorkflowHandlerReq) ProtoMessage()

+ func (m *RegisterWorkflowHandlerReq) GetPollIntervalMs() int64

+ func (m *RegisterWorkflowHandlerReq) GetPool() int64

+ func (m *RegisterWorkflowHandlerReq) GetService() string

+ func (m *RegisterWorkflowHandlerReq) Reset()

+ func (m *RegisterWorkflowHandlerReq) String() string

+ func (m *RegisterWorkflowHandlerReq) XXX_DiscardUnknown()

+ func (m *RegisterWorkflowHandlerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RegisterWorkflowHandlerReq) XXX_Merge(src proto.Message)

+ func (m *RegisterWorkflowHandlerReq) XXX_Size() int

+ func (m *RegisterWorkflowHandlerReq) XXX_Unmarshal(b []byte) error

type RuntimeClient

+ DeleteAPI func(ctx context.Context, in *WorkflowAPI, opts ...grpc.CallOption) (*Empty, error)

+ DeleteChan func(ctx context.Context, in *DeleteChanReq, opts ...grpc.CallOption) (*Empty, error)

+ DeleteType func(ctx context.Context, in *Type, opts ...grpc.CallOption) (*Empty, error)

+ FindWorkflows func(ctx context.Context, in *FindWorkflowsReq, opts ...grpc.CallOption) (*FindWorkflowsResp, error)

+ GetWorkflow func(ctx context.Context, in *GetWorkflowReq, opts ...grpc.CallOption) (*Workflow, error)

+ ListenWorkflowsUpdates func(ctx context.Context, in *ListenWorkflowsUpdatesReq, opts ...grpc.CallOption) (Runtime_ListenWorkflowsUpdatesClient, error)

+ LockWorkflow func(ctx context.Context, in *LockWorkflowReq, opts ...grpc.CallOption) (*LockedWorkflow, error)

+ NewWorkflow func(ctx context.Context, in *NewWorkflowReq, opts ...grpc.CallOption) (*Empty, error)

+ RegisterWorkflowHandler func(ctx context.Context, in *RegisterWorkflowHandlerReq, opts ...grpc.CallOption) (Runtime_RegisterWorkflowHandlerClient, error)

+ UpdateWorkflow func(ctx context.Context, in *UpdateWorkflowReq, opts ...grpc.CallOption) (*Empty, error)

type RuntimeServer

+ DeleteAPI func(context.Context, *WorkflowAPI) (*Empty, error)

+ DeleteChan func(context.Context, *DeleteChanReq) (*Empty, error)

+ DeleteType func(context.Context, *Type) (*Empty, error)

+ FindWorkflows func(context.Context, *FindWorkflowsReq) (*FindWorkflowsResp, error)

+ GetWorkflow func(context.Context, *GetWorkflowReq) (*Workflow, error)

+ ListenWorkflowsUpdates func(*ListenWorkflowsUpdatesReq, Runtime_ListenWorkflowsUpdatesServer) error

+ LockWorkflow func(context.Context, *LockWorkflowReq) (*LockedWorkflow, error)

+ NewWorkflow func(context.Context, *NewWorkflowReq) (*Empty, error)

+ RegisterWorkflowHandler func(*RegisterWorkflowHandlerReq, Runtime_RegisterWorkflowHandlerServer) error

+ UpdateWorkflow func(context.Context, *UpdateWorkflowReq) (*Empty, error)

+ type Runtime_ListenWorkflowsUpdatesClient interface

+ Recv func() (*WorkflowEvent, error)

+ type Runtime_ListenWorkflowsUpdatesServer interface

+ Send func(*WorkflowEvent) error

+ type Runtime_RegisterWorkflowHandlerClient interface

+ Recv func() (*LockedWorkflow, error)

+ type Runtime_RegisterWorkflowHandlerServer interface

+ Send func(*LockedWorkflow) error

type Thread

+ Workflow string

+ func (m *Thread) GetWorkflow() string

+ type UpdateWorkflowReq struct

+ LockId uint64

+ UnblockedAt uint64

+ Workflow *Workflow

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateWorkflowReq) Descriptor() ([]byte, []int)

+ func (*UpdateWorkflowReq) ProtoMessage()

+ func (m *UpdateWorkflowReq) GetLockId() uint64

+ func (m *UpdateWorkflowReq) GetUnblockedAt() uint64

+ func (m *UpdateWorkflowReq) GetWorkflow() *Workflow

+ func (m *UpdateWorkflowReq) Reset()

+ func (m *UpdateWorkflowReq) String() string

+ func (m *UpdateWorkflowReq) XXX_DiscardUnknown()

+ func (m *UpdateWorkflowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateWorkflowReq) XXX_Merge(src proto.Message)

+ func (m *UpdateWorkflowReq) XXX_Size() int

+ func (m *UpdateWorkflowReq) XXX_Unmarshal(b []byte) error

type WaitCallIndex

+ WorkflowsId string

+ func (m *WaitCallIndex) GetWorkflowsId() string

+ type Workflow struct

+ Id string

+ Input []byte

+ Name string

+ Output []byte

+ Service string

+ State []byte

+ Status Workflow_Status

+ Threads []*Thread

+ UpdatedAt uint64

+ Version uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Workflow) Descriptor() ([]byte, []int)

+ func (*Workflow) ProtoMessage()

+ func (m *Workflow) GetId() string

+ func (m *Workflow) GetInput() []byte

+ func (m *Workflow) GetName() string

+ func (m *Workflow) GetOutput() []byte

+ func (m *Workflow) GetService() string

+ func (m *Workflow) GetState() []byte

+ func (m *Workflow) GetStatus() Workflow_Status

+ func (m *Workflow) GetThreads() []*Thread

+ func (m *Workflow) GetUpdatedAt() uint64

+ func (m *Workflow) GetVersion() uint64

+ func (m *Workflow) Reset()

+ func (m *Workflow) String() string

+ func (m *Workflow) XXX_DiscardUnknown()

+ func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Workflow) XXX_Merge(src proto.Message)

+ func (m *Workflow) XXX_Size() int

+ func (m *Workflow) XXX_Unmarshal(b []byte) error

+ func (s *Workflow) HasThread(id string) bool

+ func (s *Workflow) SetThread(new *Thread) (created bool)

+ type WorkflowAPI struct

+ Description string

+ Input string

+ Name string

+ Output string

+ Service string

+ State string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowAPI) Descriptor() ([]byte, []int)

+ func (*WorkflowAPI) ProtoMessage()

+ func (m *WorkflowAPI) GetDescription() string

+ func (m *WorkflowAPI) GetInput() string

+ func (m *WorkflowAPI) GetName() string

+ func (m *WorkflowAPI) GetOutput() string

+ func (m *WorkflowAPI) GetService() string

+ func (m *WorkflowAPI) GetState() string

+ func (m *WorkflowAPI) Reset()

+ func (m *WorkflowAPI) String() string

+ func (m *WorkflowAPI) XXX_DiscardUnknown()

+ func (m *WorkflowAPI) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowAPI) XXX_Merge(src proto.Message)

+ func (m *WorkflowAPI) XXX_Size() int

+ func (m *WorkflowAPI) XXX_Unmarshal(b []byte) error

+ type WorkflowEvent struct

+ Thread *Thread

+ Workflow *Workflow

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowEvent) Descriptor() ([]byte, []int)

+ func (*WorkflowEvent) ProtoMessage()

+ func (m *WorkflowEvent) GetThread() *Thread

+ func (m *WorkflowEvent) GetWorkflow() *Workflow

+ func (m *WorkflowEvent) Reset()

+ func (m *WorkflowEvent) String() string

+ func (m *WorkflowEvent) XXX_DiscardUnknown()

+ func (m *WorkflowEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowEvent) XXX_Merge(src proto.Message)

+ func (m *WorkflowEvent) XXX_Size() int

+ func (m *WorkflowEvent) XXX_Unmarshal(b []byte) error

+ type Workflow_Status int32

+ const Workflow_Finished

+ const Workflow_Invalid

+ const Workflow_Running

+ const Workflow_Started

+ func (Workflow_Status) EnumDescriptor() ([]byte, []int)

+ func (x Workflow_Status) String() string

Dec 1, 2020

Changes in this version

type P

+ func (p *P) Select() *P

Nov 3, 2020

Changes in this version

+ var Case_Op_name = map[int32]string

+ var Case_Op_value = map[string]int32

+ var Process_Status_name = map[int32]string

+ var Process_Status_value = map[string]int32

+ var Select_Result_name = map[int32]string

+ var Select_Result_value = map[string]int32

+ var Thread_Status_name = map[int32]string

+ var Thread_Status_value = map[string]int32

+ func GetFunctionName(i interface{}) string

+ func Manage(ctx context.Context, client RuntimeClient, ss ...Service) error

+ func RegisterRuntimeServer(s *grpc.Server, srv RuntimeServer)

+ type API struct

+ API *ProcessAPI

+ NewProcState func() interface{}

+ type AsyncType interface

+ Type func() *Type

+ type BufData struct

+ Chan string

+ Clock uint64

+ Data []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BufData) Descriptor() ([]byte, []int)

+ func (*BufData) ProtoMessage()

+ func (m *BufData) GetChan() string

+ func (m *BufData) GetClock() uint64

+ func (m *BufData) GetData() []byte

+ func (m *BufData) Reset()

+ func (m *BufData) String() string

+ func (m *BufData) XXX_DiscardUnknown()

+ func (m *BufData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BufData) XXX_Merge(src proto.Message)

+ func (m *BufData) XXX_Size() int

+ func (m *BufData) XXX_Unmarshal(b []byte) error

+ type Call struct

+ Id string

+ Input []byte

+ InputType string

+ Name string

+ Output []byte

+ OutputType string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Call) Descriptor() ([]byte, []int)

+ func (*Call) ProtoMessage()

+ func (m *Call) GetId() string

+ func (m *Call) GetInput() []byte

+ func (m *Call) GetInputType() string

+ func (m *Call) GetName() string

+ func (m *Call) GetOutput() []byte

+ func (m *Call) GetOutputType() string

+ func (m *Call) Reset()

+ func (m *Call) String() string

+ func (m *Call) XXX_DiscardUnknown()

+ func (m *Call) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Call) XXX_Merge(src proto.Message)

+ func (m *Call) XXX_Size() int

+ func (m *Call) XXX_Unmarshal(b []byte) error

+ type Case struct

+ Chan string

+ Data []byte

+ DataType string

+ Op Case_Op

+ Time uint64

+ ToStatus string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Case) Descriptor() ([]byte, []int)

+ func (*Case) ProtoMessage()

+ func (m *Case) GetChan() string

+ func (m *Case) GetData() []byte

+ func (m *Case) GetDataType() string

+ func (m *Case) GetOp() Case_Op

+ func (m *Case) GetTime() uint64

+ func (m *Case) GetToStatus() string

+ func (m *Case) Reset()

+ func (m *Case) String() string

+ func (m *Case) XXX_DiscardUnknown()

+ func (m *Case) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Case) XXX_Merge(src proto.Message)

+ func (m *Case) XXX_Size() int

+ func (m *Case) XXX_Unmarshal(b []byte) error

+ type Case_Op int32

+ const Case_Default

+ const Case_Invalid

+ const Case_Recv

+ const Case_Send

+ const Case_Time

+ func (Case_Op) EnumDescriptor() ([]byte, []int)

+ func (x Case_Op) String() string

+ type ChanSelect struct

+ BlockedAt uint64

+ Case uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChanSelect) Descriptor() ([]byte, []int)

+ func (*ChanSelect) ProtoMessage()

+ func (m *ChanSelect) GetBlockedAt() uint64

+ func (m *ChanSelect) GetCase() uint64

+ func (m *ChanSelect) Reset()

+ func (m *ChanSelect) String() string

+ func (m *ChanSelect) XXX_DiscardUnknown()

+ func (m *ChanSelect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ChanSelect) XXX_Merge(src proto.Message)

+ func (m *ChanSelect) XXX_Size() int

+ func (m *ChanSelect) XXX_Unmarshal(b []byte) error

+ type Channel struct

+ BufMaxSize uint64

+ BufSize uint64

+ Closed bool

+ DataType string

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Channel) Descriptor() ([]byte, []int)

+ func (*Channel) ProtoMessage()

+ func (m *Channel) GetBufMaxSize() uint64

+ func (m *Channel) GetBufSize() uint64

+ func (m *Channel) GetClosed() bool

+ func (m *Channel) GetDataType() string

+ func (m *Channel) GetId() string

+ func (m *Channel) Reset()

+ func (m *Channel) String() string

+ func (m *Channel) XXX_DiscardUnknown()

+ func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Channel) XXX_Merge(src proto.Message)

+ func (m *Channel) XXX_Size() int

+ func (m *Channel) XXX_Unmarshal(b []byte) error

+ type CloseChanReq struct

+ Ids []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CloseChanReq) Descriptor() ([]byte, []int)

+ func (*CloseChanReq) ProtoMessage()

+ func (m *CloseChanReq) GetIds() []string

+ func (m *CloseChanReq) Reset()

+ func (m *CloseChanReq) String() string

+ func (m *CloseChanReq) XXX_DiscardUnknown()

+ func (m *CloseChanReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CloseChanReq) XXX_Merge(src proto.Message)

+ func (m *CloseChanReq) XXX_Size() int

+ func (m *CloseChanReq) XXX_Unmarshal(b []byte) error

+ type Empty struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

+ func (m *Empty) XXX_DiscardUnknown()

+ func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Empty) XXX_Merge(src proto.Message)

+ func (m *Empty) XXX_Size() int

+ func (m *Empty) XXX_Unmarshal(b []byte) error

+ type GetProcessReq struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetProcessReq) Descriptor() ([]byte, []int)

+ func (*GetProcessReq) ProtoMessage()

+ func (m *GetProcessReq) GetId() string

+ func (m *GetProcessReq) Reset()

+ func (m *GetProcessReq) String() string

+ func (m *GetProcessReq) XXX_DiscardUnknown()

+ func (m *GetProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetProcessReq) XXX_Merge(src proto.Message)

+ func (m *GetProcessReq) XXX_Size() int

+ func (m *GetProcessReq) XXX_Unmarshal(b []byte) error

+ type ListAPIsReq struct

+ From string

+ Id string

+ Limit uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListAPIsReq) Descriptor() ([]byte, []int)

+ func (*ListAPIsReq) ProtoMessage()

+ func (m *ListAPIsReq) GetFrom() string

+ func (m *ListAPIsReq) GetId() string

+ func (m *ListAPIsReq) GetLimit() uint64

+ func (m *ListAPIsReq) Reset()

+ func (m *ListAPIsReq) String() string

+ func (m *ListAPIsReq) XXX_DiscardUnknown()

+ func (m *ListAPIsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListAPIsReq) XXX_Merge(src proto.Message)

+ func (m *ListAPIsReq) XXX_Size() int

+ func (m *ListAPIsReq) XXX_Unmarshal(b []byte) error

+ type ListAPIsResp struct

+ Apis []*ProcessAPI

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListAPIsResp) Descriptor() ([]byte, []int)

+ func (*ListAPIsResp) ProtoMessage()

+ func (m *ListAPIsResp) GetApis() []*ProcessAPI

+ func (m *ListAPIsResp) Reset()

+ func (m *ListAPIsResp) String() string

+ func (m *ListAPIsResp) XXX_DiscardUnknown()

+ func (m *ListAPIsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListAPIsResp) XXX_Merge(src proto.Message)

+ func (m *ListAPIsResp) XXX_Size() int

+ func (m *ListAPIsResp) XXX_Unmarshal(b []byte) error

+ type ListChansReq struct

+ From string

+ Id string

+ Limit uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListChansReq) Descriptor() ([]byte, []int)

+ func (*ListChansReq) ProtoMessage()

+ func (m *ListChansReq) GetFrom() string

+ func (m *ListChansReq) GetId() string

+ func (m *ListChansReq) GetLimit() uint64

+ func (m *ListChansReq) Reset()

+ func (m *ListChansReq) String() string

+ func (m *ListChansReq) XXX_DiscardUnknown()

+ func (m *ListChansReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListChansReq) XXX_Merge(src proto.Message)

+ func (m *ListChansReq) XXX_Size() int

+ func (m *ListChansReq) XXX_Unmarshal(b []byte) error

+ type ListChansResp struct

+ Chans []*Channel

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListChansResp) Descriptor() ([]byte, []int)

+ func (*ListChansResp) ProtoMessage()

+ func (m *ListChansResp) GetChans() []*Channel

+ func (m *ListChansResp) Reset()

+ func (m *ListChansResp) String() string

+ func (m *ListChansResp) XXX_DiscardUnknown()

+ func (m *ListChansResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListChansResp) XXX_Merge(src proto.Message)

+ func (m *ListChansResp) XXX_Size() int

+ func (m *ListChansResp) XXX_Unmarshal(b []byte) error

+ type ListTypesReq struct

+ From string

+ Id string

+ Limit uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListTypesReq) Descriptor() ([]byte, []int)

+ func (*ListTypesReq) ProtoMessage()

+ func (m *ListTypesReq) GetFrom() string

+ func (m *ListTypesReq) GetId() string

+ func (m *ListTypesReq) GetLimit() uint64

+ func (m *ListTypesReq) Reset()

+ func (m *ListTypesReq) String() string

+ func (m *ListTypesReq) XXX_DiscardUnknown()

+ func (m *ListTypesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListTypesReq) XXX_Merge(src proto.Message)

+ func (m *ListTypesReq) XXX_Size() int

+ func (m *ListTypesReq) XXX_Unmarshal(b []byte) error

+ type ListTypesResp struct

+ Types []*Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListTypesResp) Descriptor() ([]byte, []int)

+ func (*ListTypesResp) ProtoMessage()

+ func (m *ListTypesResp) GetTypes() []*Type

+ func (m *ListTypesResp) Reset()

+ func (m *ListTypesResp) String() string

+ func (m *ListTypesResp) XXX_DiscardUnknown()

+ func (m *ListTypesResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListTypesResp) XXX_Merge(src proto.Message)

+ func (m *ListTypesResp) XXX_Size() int

+ func (m *ListTypesResp) XXX_Unmarshal(b []byte) error

+ type ListenProcessesUpdatesReq struct

+ From uint64

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListenProcessesUpdatesReq) Descriptor() ([]byte, []int)

+ func (*ListenProcessesUpdatesReq) ProtoMessage()

+ func (m *ListenProcessesUpdatesReq) GetFrom() uint64

+ func (m *ListenProcessesUpdatesReq) GetService() string

+ func (m *ListenProcessesUpdatesReq) Reset()

+ func (m *ListenProcessesUpdatesReq) String() string

+ func (m *ListenProcessesUpdatesReq) XXX_DiscardUnknown()

+ func (m *ListenProcessesUpdatesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListenProcessesUpdatesReq) XXX_Merge(src proto.Message)

+ func (m *ListenProcessesUpdatesReq) XXX_Size() int

+ func (m *ListenProcessesUpdatesReq) XXX_Unmarshal(b []byte) error

+ type LockProcessReq struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LockProcessReq) Descriptor() ([]byte, []int)

+ func (*LockProcessReq) ProtoMessage()

+ func (m *LockProcessReq) GetId() string

+ func (m *LockProcessReq) Reset()

+ func (m *LockProcessReq) String() string

+ func (m *LockProcessReq) XXX_DiscardUnknown()

+ func (m *LockProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LockProcessReq) XXX_Merge(src proto.Message)

+ func (m *LockProcessReq) XXX_Size() int

+ func (m *LockProcessReq) XXX_Unmarshal(b []byte) error

+ type LockedProcess struct

+ LockId uint64

+ Process *Process

+ Thread *Thread

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LockedProcess) Descriptor() ([]byte, []int)

+ func (*LockedProcess) ProtoMessage()

+ func (m *LockedProcess) GetLockId() uint64

+ func (m *LockedProcess) GetProcess() *Process

+ func (m *LockedProcess) GetThread() *Thread

+ func (m *LockedProcess) Reset()

+ func (m *LockedProcess) String() string

+ func (m *LockedProcess) XXX_DiscardUnknown()

+ func (m *LockedProcess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LockedProcess) XXX_Merge(src proto.Message)

+ func (m *LockedProcess) XXX_Size() int

+ func (m *LockedProcess) XXX_Unmarshal(b []byte) error

+ type MakeChanReq struct

+ Chan *Channel

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MakeChanReq) Descriptor() ([]byte, []int)

+ func (*MakeChanReq) ProtoMessage()

+ func (m *MakeChanReq) GetChan() *Channel

+ func (m *MakeChanReq) Reset()

+ func (m *MakeChanReq) String() string

+ func (m *MakeChanReq) XXX_DiscardUnknown()

+ func (m *MakeChanReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MakeChanReq) XXX_Merge(src proto.Message)

+ func (m *MakeChanReq) XXX_Size() int

+ func (m *MakeChanReq) XXX_Unmarshal(b []byte) error

+ type NewProcessReq struct

+ Call *Call

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NewProcessReq) Descriptor() ([]byte, []int)

+ func (*NewProcessReq) ProtoMessage()

+ func (m *NewProcessReq) GetCall() *Call

+ func (m *NewProcessReq) Reset()

+ func (m *NewProcessReq) String() string

+ func (m *NewProcessReq) XXX_DiscardUnknown()

+ func (m *NewProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NewProcessReq) XXX_Merge(src proto.Message)

+ func (m *NewProcessReq) XXX_Size() int

+ func (m *NewProcessReq) XXX_Unmarshal(b []byte) error

+ type P struct

+ func (p *P) After(after time.Duration) *P

+ func (p *P) At(at time.Time) *P

+ func (p *P) Call(name string, input interface{}) *P

+ func (p *P) Default() *P

+ func (p *P) Finish(result interface{}) *P

+ func (p *P) Go(id string, f func(p *P))

+ func (p *P) ID() string

+ func (p *P) MakeChan(t *Type, bufsize int) Channel

+ func (p *P) Name() string

+ func (p *P) NewID() string

+ func (p *P) Recv(channel Channel) *P

+ func (p *P) Send(channel Channel, data interface{}) *P

+ func (p *P) Service() string

+ func (p *P) To(cb interface{}) *P

+ type Process struct

+ Id string

+ Input []byte

+ Name string

+ Output []byte

+ Service string

+ State []byte

+ Status Process_Status

+ Threads []*Thread

+ UpdatedAt uint64

+ Version uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Process) Descriptor() ([]byte, []int)

+ func (*Process) ProtoMessage()

+ func (m *Process) GetId() string

+ func (m *Process) GetInput() []byte

+ func (m *Process) GetName() string

+ func (m *Process) GetOutput() []byte

+ func (m *Process) GetService() string

+ func (m *Process) GetState() []byte

+ func (m *Process) GetStatus() Process_Status

+ func (m *Process) GetThreads() []*Thread

+ func (m *Process) GetUpdatedAt() uint64

+ func (m *Process) GetVersion() uint64

+ func (m *Process) Reset()

+ func (m *Process) String() string

+ func (m *Process) XXX_DiscardUnknown()

+ func (m *Process) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Process) XXX_Merge(src proto.Message)

+ func (m *Process) XXX_Size() int

+ func (m *Process) XXX_Unmarshal(b []byte) error

+ func (s *Process) HasThread(id string) bool

+ func (s *Process) SetThread(new *Thread) (created bool)

+ type ProcessAPI struct

+ Description string

+ Input string

+ Name string

+ Output string

+ Service string

+ State string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ProcessAPI) Descriptor() ([]byte, []int)

+ func (*ProcessAPI) ProtoMessage()

+ func (m *ProcessAPI) GetDescription() string

+ func (m *ProcessAPI) GetInput() string

+ func (m *ProcessAPI) GetName() string

+ func (m *ProcessAPI) GetOutput() string

+ func (m *ProcessAPI) GetService() string

+ func (m *ProcessAPI) GetState() string

+ func (m *ProcessAPI) Reset()

+ func (m *ProcessAPI) String() string

+ func (m *ProcessAPI) XXX_DiscardUnknown()

+ func (m *ProcessAPI) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProcessAPI) XXX_Merge(src proto.Message)

+ func (m *ProcessAPI) XXX_Size() int

+ func (m *ProcessAPI) XXX_Unmarshal(b []byte) error

+ type ProcessEvent struct

+ Process *Process

+ Thread *Thread

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ProcessEvent) Descriptor() ([]byte, []int)

+ func (*ProcessEvent) ProtoMessage()

+ func (m *ProcessEvent) GetProcess() *Process

+ func (m *ProcessEvent) GetThread() *Thread

+ func (m *ProcessEvent) Reset()

+ func (m *ProcessEvent) String() string

+ func (m *ProcessEvent) XXX_DiscardUnknown()

+ func (m *ProcessEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProcessEvent) XXX_Merge(src proto.Message)

+ func (m *ProcessEvent) XXX_Size() int

+ func (m *ProcessEvent) XXX_Unmarshal(b []byte) error

+ type Process_Status int32

+ const Process_Finished

+ const Process_Invalid

+ const Process_Running

+ const Process_Started

+ func (Process_Status) EnumDescriptor() ([]byte, []int)

+ func (x Process_Status) String() string

+ type PutProcessReq struct

+ Process *Process

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PutProcessReq) Descriptor() ([]byte, []int)

+ func (*PutProcessReq) ProtoMessage()

+ func (m *PutProcessReq) GetProcess() *Process

+ func (m *PutProcessReq) Reset()

+ func (m *PutProcessReq) String() string

+ func (m *PutProcessReq) XXX_DiscardUnknown()

+ func (m *PutProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PutProcessReq) XXX_Merge(src proto.Message)

+ func (m *PutProcessReq) XXX_Size() int

+ func (m *PutProcessReq) XXX_Unmarshal(b []byte) error

+ type RegisterProcessHandlerReq struct

+ PollIntervalMs int64

+ Pool int64

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterProcessHandlerReq) Descriptor() ([]byte, []int)

+ func (*RegisterProcessHandlerReq) ProtoMessage()

+ func (m *RegisterProcessHandlerReq) GetPollIntervalMs() int64

+ func (m *RegisterProcessHandlerReq) GetPool() int64

+ func (m *RegisterProcessHandlerReq) GetService() string

+ func (m *RegisterProcessHandlerReq) Reset()

+ func (m *RegisterProcessHandlerReq) String() string

+ func (m *RegisterProcessHandlerReq) XXX_DiscardUnknown()

+ func (m *RegisterProcessHandlerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RegisterProcessHandlerReq) XXX_Merge(src proto.Message)

+ func (m *RegisterProcessHandlerReq) XXX_Size() int

+ func (m *RegisterProcessHandlerReq) XXX_Unmarshal(b []byte) error

+ type RuntimeClient interface

+ CloseChan func(ctx context.Context, in *CloseChanReq, opts ...grpc.CallOption) (*Empty, error)

+ GetProcess func(ctx context.Context, in *GetProcessReq, opts ...grpc.CallOption) (*Process, error)

+ ListAPIs func(ctx context.Context, in *ListAPIsReq, opts ...grpc.CallOption) (*ListAPIsResp, error)

+ ListChans func(ctx context.Context, in *ListChansReq, opts ...grpc.CallOption) (*ListChansResp, error)

+ ListTypes func(ctx context.Context, in *ListTypesReq, opts ...grpc.CallOption) (*ListTypesResp, error)

+ ListenProcessesUpdates func(ctx context.Context, in *ListenProcessesUpdatesReq, opts ...grpc.CallOption) (Runtime_ListenProcessesUpdatesClient, error)

+ LockProcess func(ctx context.Context, in *LockProcessReq, opts ...grpc.CallOption) (*LockedProcess, error)

+ MakeChan func(ctx context.Context, in *MakeChanReq, opts ...grpc.CallOption) (*Empty, error)

+ NewProcess func(ctx context.Context, in *NewProcessReq, opts ...grpc.CallOption) (*Empty, error)

+ PutAPI func(ctx context.Context, in *ProcessAPI, opts ...grpc.CallOption) (*Empty, error)

+ PutProcess func(ctx context.Context, in *PutProcessReq, opts ...grpc.CallOption) (*Empty, error)

+ PutType func(ctx context.Context, in *Type, opts ...grpc.CallOption) (*Empty, error)

+ RegisterProcessHandler func(ctx context.Context, in *RegisterProcessHandlerReq, opts ...grpc.CallOption) (Runtime_RegisterProcessHandlerClient, error)

+ UpdateProcess func(ctx context.Context, in *UpdateProcessReq, opts ...grpc.CallOption) (*Empty, error)

+ func NewRuntimeClient(cc *grpc.ClientConn) RuntimeClient

+ type RuntimeServer interface

+ CloseChan func(context.Context, *CloseChanReq) (*Empty, error)

+ GetProcess func(context.Context, *GetProcessReq) (*Process, error)

+ ListAPIs func(context.Context, *ListAPIsReq) (*ListAPIsResp, error)

+ ListChans func(context.Context, *ListChansReq) (*ListChansResp, error)

+ ListTypes func(context.Context, *ListTypesReq) (*ListTypesResp, error)

+ ListenProcessesUpdates func(*ListenProcessesUpdatesReq, Runtime_ListenProcessesUpdatesServer) error

+ LockProcess func(context.Context, *LockProcessReq) (*LockedProcess, error)

+ MakeChan func(context.Context, *MakeChanReq) (*Empty, error)

+ NewProcess func(context.Context, *NewProcessReq) (*Empty, error)

+ PutAPI func(context.Context, *ProcessAPI) (*Empty, error)

+ PutProcess func(context.Context, *PutProcessReq) (*Empty, error)

+ PutType func(context.Context, *Type) (*Empty, error)

+ RegisterProcessHandler func(*RegisterProcessHandlerReq, Runtime_RegisterProcessHandlerServer) error

+ UpdateProcess func(context.Context, *UpdateProcessReq) (*Empty, error)

+ type Runtime_ListenProcessesUpdatesClient interface

+ Recv func() (*ProcessEvent, error)

+ type Runtime_ListenProcessesUpdatesServer interface

+ Send func(*ProcessEvent) error

+ type Runtime_RegisterProcessHandlerClient interface

+ Recv func() (*LockedProcess, error)

+ type Runtime_RegisterProcessHandlerServer interface

+ Send func(*LockedProcess) error

+ type Select struct

+ Cases []*Case

+ RecvData []byte

+ Result Select_Result

+ UnblockedCase uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Select) Descriptor() ([]byte, []int)

+ func (*Select) ProtoMessage()

+ func (m *Select) GetCases() []*Case

+ func (m *Select) GetRecvData() []byte

+ func (m *Select) GetResult() Select_Result

+ func (m *Select) GetUnblockedCase() uint64

+ func (m *Select) Reset()

+ func (m *Select) String() string

+ func (m *Select) XXX_DiscardUnknown()

+ func (m *Select) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Select) XXX_Merge(src proto.Message)

+ func (m *Select) XXX_Size() int

+ func (m *Select) XXX_Unmarshal(b []byte) error

+ type Select_Result int32

+ const Select_Closed

+ const Select_Invalid

+ const Select_OK

+ func (Select_Result) EnumDescriptor() ([]byte, []int)

+ func (x Select_Result) String() string

+ type Service struct

+ APIs []API

+ Init func(ctx context.Context) error

+ Name string

+ SingletonRun func(ctx context.Context, c RuntimeClient) error

+ Types []*Type

+ type Thread struct

+ BlockedAt uint64

+ Call *Call

+ Id string

+ Process string

+ Select *Select

+ Service string

+ Status Thread_Status

+ ToStatus string

+ UnblockedAt uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Thread) Descriptor() ([]byte, []int)

+ func (*Thread) ProtoMessage()

+ func (m *Thread) GetBlockedAt() uint64

+ func (m *Thread) GetCall() *Call

+ func (m *Thread) GetId() string

+ func (m *Thread) GetProcess() string

+ func (m *Thread) GetSelect() *Select

+ func (m *Thread) GetService() string

+ func (m *Thread) GetStatus() Thread_Status

+ func (m *Thread) GetToStatus() string

+ func (m *Thread) GetUnblockedAt() uint64

+ func (m *Thread) Reset()

+ func (m *Thread) String() string

+ func (m *Thread) XXX_DiscardUnknown()

+ func (m *Thread) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Thread) XXX_Merge(src proto.Message)

+ func (m *Thread) XXX_Size() int

+ func (m *Thread) XXX_Unmarshal(b []byte) error

+ type Thread_Status int32

+ const Thread_Aborted

+ const Thread_Blocked

+ const Thread_Invalid

+ const Thread_Unblocked

+ func (Thread_Status) EnumDescriptor() ([]byte, []int)

+ func (x Thread_Status) String() string

+ type Time struct

+ func (t *Time) UnmarshalJSON(data []byte) error

+ func (t Time) MarshalJSON() ([]byte, error)

+ type Type struct

+ Description string

+ Id string

+ JsonSchema []byte

+ Version uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func ReflectType(name string, t interface{}) *Type

+ func (*Type) Descriptor() ([]byte, []int)

+ func (*Type) ProtoMessage()

+ func (m *Type) GetDescription() string

+ func (m *Type) GetId() string

+ func (m *Type) GetJsonSchema() []byte

+ func (m *Type) GetVersion() uint64

+ func (m *Type) Reset()

+ func (m *Type) String() string

+ func (m *Type) XXX_DiscardUnknown()

+ func (m *Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Type) XXX_Merge(src proto.Message)

+ func (m *Type) XXX_Size() int

+ func (m *Type) XXX_Unmarshal(b []byte) error

+ type UpdateProcessReq struct

+ LockId uint64

+ Process *Process

+ UnblockedAt uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateProcessReq) Descriptor() ([]byte, []int)

+ func (*UpdateProcessReq) ProtoMessage()

+ func (m *UpdateProcessReq) GetLockId() uint64

+ func (m *UpdateProcessReq) GetProcess() *Process

+ func (m *UpdateProcessReq) GetUnblockedAt() uint64

+ func (m *UpdateProcessReq) Reset()

+ func (m *UpdateProcessReq) String() string

+ func (m *UpdateProcessReq) XXX_DiscardUnknown()

+ func (m *UpdateProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateProcessReq) XXX_Merge(src proto.Message)

+ func (m *UpdateProcessReq) XXX_Size() int

+ func (m *UpdateProcessReq) XXX_Unmarshal(b []byte) error

+ type WaitCallIndex struct

+ BlockedAt uint64

+ ProcessesId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WaitCallIndex) Descriptor() ([]byte, []int)

+ func (*WaitCallIndex) ProtoMessage()

+ func (m *WaitCallIndex) GetBlockedAt() uint64

+ func (m *WaitCallIndex) GetProcessesId() string

+ func (m *WaitCallIndex) Reset()

+ func (m *WaitCallIndex) String() string

+ func (m *WaitCallIndex) XXX_DiscardUnknown()

+ func (m *WaitCallIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WaitCallIndex) XXX_Merge(src proto.Message)

+ func (m *WaitCallIndex) XXX_Size() int

+ func (m *WaitCallIndex) XXX_Unmarshal(b []byte) error