Package: /pkg/telemetry/dbg

type DbgMsg (interface) DbgMsg is the interface for the messages to be sent to the am-dbg server. TODO refac Msg Methods (total 2) ( DbgMsg) Clock(statesIndex am.S, state string) uint64 Clock returns the state's clock, using the passed index ( DbgMsg) Is(statesIndex am.S, states am.S) bool Is returns true if the state is active, using the passed index Implemented By (at least 2) *DbgMsgStruct *DbgMsgTx

type DbgMsgStruct (struct) DbgMsgStruct contains the state and relations data. TODO refac: MsgSchema Fields (total 7) Groups map[string][]int list of group names and state indexes GroupsOrder []string order of groups ID string Machine ID Parent string parent am ID States am.Schema all the states with relations TODO refac: Schema StatesIndex am.S state names defining the indexes for diffs Tags []string am tags Methods (total 3) (*DbgMsgStruct) Clock(_ am.S, _ string) uint64 (*DbgMsgStruct) HasTag(tag string, val string) bool (*DbgMsgStruct) Is(_ am.S, _ am.S) bool Implements (at least one exported) *DbgMsgStruct : DbgMsg As Inputs Of (at least 2) func github.com/pancsta/asyncmachine-go/pkg/graph.(*Graph).AddClient(msg *DbgMsgStruct) error func github.com/pancsta/asyncmachine-go/tools/debugger/server.(*RPCServer).DbgMsgSchema(msgSchema *DbgMsgStruct, _ *string) error

type DbgMsgTx (struct) DbgMsgTx contains transition data. Fields (total 21) Accepted bool result of the transition TODO rename to IsAccepted Args map[string]string CalledStates []string called states TODO remove. Deprecated use [CalledStatesIdxs] CalledStatesIdxs []int TODO rename to CalledStates, re-gen all assets Clocks am.Time Clocks is represents the am time [am.Time] from after the current transition. TODO refac to TimeAfter, re-gen all the assets ID string Transition ID TODO refac: Id IsAuto bool transition was triggered by an auto state IsCheck bool is this a check (Can*) tx or mutation? IsQueued bool is this a queued mutation? LogEntries []*am.LogEntry log entries created during the transition MachineID string MutQueueTick uint64 MutQueueTick is the assigned queue tick when the tx will be executed. Only for IsQueued. MutQueueToken uint64 TODO QueueDebug with all string entries for comparison MutQueueToken is the token of a prepended mutation, can be scheduled or executed, depending on IsQueued. PreLogEntries []*am.LogEntry log entries before the transition, which happened after the prev one Queue int queue length at the start of the transition TODO rename to QueueLen TODO change to int32 QueueDump []string QueueTick uint64 QueueTick is the current queue tick in the am. transition. StackTrace string Steps []*am.Step all the transition steps Time *time.Time Time is human time. Don't send this over the wire. TODO remove or skip in msgpack TODO rename to HTime Type am.MutationType mutation type Methods (total 12) (*DbgMsgTx) ActiveStates(statesIndex am.S) am.S (*DbgMsgTx) CalledStateNames(statesIndex am.S) am.S (*DbgMsgTx) Clock(statesIndex am.S, state string) uint64 (*DbgMsgTx) Index(statesIndex am.S, state string) int (*DbgMsgTx) Is(statesIndex am.S, states am.S) bool (*DbgMsgTx) Is1(statesIndex am.S, state string) bool (*DbgMsgTx) IsIdx(idxs []int) bool (*DbgMsgTx) MutString(statesIndex am.S) string TODO unify with Mut String (*DbgMsgTx) String() string (*DbgMsgTx) TimeSum() uint64 TODO Sum() and TimeSum(idxs []int) (*DbgMsgTx) TxString(statesIndex am.S) string TODO unify with Tx String (*DbgMsgTx) Url() string Implements (at least 3) *DbgMsgTx : DbgMsg *DbgMsgTx : expvar.Var *DbgMsgTx : fmt.Stringer As Outputs Of (at least 5) func github.com/pancsta/asyncmachine-go/tools/debugger.(*Debugger).CurrentTx() *DbgMsgTx func github.com/pancsta/asyncmachine-go/tools/debugger.(*Debugger).NextTx() *DbgMsgTx func github.com/pancsta/asyncmachine-go/tools/debugger.(*Debugger).PrevTx() *DbgMsgTx func github.com/pancsta/asyncmachine-go/tools/debugger/server.(*Client).Tx(idx int) *DbgMsgTx func github.com/pancsta/asyncmachine-go/tools/debugger/server.(*Client).TxExecutedBy(idx int) *DbgMsgTx As Inputs Of (at least 2) func github.com/pancsta/asyncmachine-go/pkg/graph.(*Graph).ParseMsg(id string, msgTx *DbgMsgTx) func github.com/pancsta/asyncmachine-go/tools/debugger/server.(*RPCServer).DbgMsgTx(msgTx *DbgMsgTx, _ *string) error

type Opts (struct) Fields (only one) WebSocket bool As Inputs Of (at least one exported) func TransitionsToDbg(mach am.Api, addr string, opts ...*Opts) error

type Tracer (struct) Fields (total 5) Addr string Mach am.Api TracerNoOp *am.TracerNoOp TracerNoOp.Id string Ws bool connect to a websocket Methods (total 15) ( Tracer) HandlerEnd(transition *machine.Transition, emitter string, handler string) ( Tracer) HandlerStart(transition *machine.Transition, emitter string, handler string) ( Tracer) Inheritable() bool (*Tracer) MachineDispose(id string) (*Tracer) MachineInit(mach am.Api) context.Context (*Tracer) MutationQueued(mach am.Api, mut *am.Mutation) ( Tracer) NewSubmachine(parent, machine machine.Api) ( Tracer) QueueEnd(machine machine.Api) (*Tracer) SchemaChange(mach am.Api, _ am.Schema) (*Tracer) TracerId() string (*Tracer) TransitionEnd(tx *am.Transition) ( Tracer) TransitionFinals(transition *machine.Transition) ( Tracer) TransitionInit(transition *machine.Transition) ( Tracer) TransitionStart(transition *machine.Transition) ( Tracer) VerifyStates(machine machine.Api) Implements (at least one exported) *Tracer : github.com/pancsta/asyncmachine-go/pkg/machine.Tracer As Outputs Of (at least one exported) func NewTracer(mach am.Api, addr string) *Tracer