control

Oct 18, 2020

Changes in this version

type EnvGlobal

+ NewSubSession func(log logrus.FieldLogger, ctx context.Context, parentEnv expand.Environ) *Session

type SessionProcessor

+ func (sp *SessionProcessor) NewSubSession(log logrus.FieldLogger, ctx context.Context, parentEnv expand.Environ) *Session

Aug 24, 2020

Changes in this version

+ type Report struct

+ Actors map[actor.ActorID]ReportActor

+ Calls map[CallID]ReportCall

+ type ReportActor struct

+ ENR string

+ ListenAddrs []string

+ PeerID string

+ Peers []string

+ type ReportCall struct

+ Actor actor.ActorID

+ Args []string

+ StartTimeMS int64

type SessionProcessor

+ func (sp *SessionProcessor) Report() *Report

Aug 11, 2020

Changes in this version

type CallErr

+ Err error

+ func (ce *CallErr) Error() string

+ func (ce *CallErr) String() string

Aug 7, 2020

Changes in this version

+ func MaybeRuntimeErr(err error) error

+ type CallErr struct

+ Exit CallExitReason

+ func (ce *CallErr) Unwrap() error

type CallExitReason

+ func (code CallExitReason) WithErr(err error) *CallErr

Jul 15, 2020

Changes in this version

+ const LogKeyActor

+ const LogKeyCallID

type Call

+ func (c *Call) RegisterStop(onStop base.OnStop)

+ func (c *Call) RequestStep(ctx context.Context) (noStep bool, finish bool, err error)

+ func (c *Call) RequestStop(ctx context.Context) error

+ func (c *Call) Step(step base.Step) error

+ type ShellLogFmt struct

+ FieldMap FieldMap

+ func (f *ShellLogFmt) Format(entry *Entry) ([]byte, error)

Jul 4, 2020

Changes in this version

+ type Call struct

+ func (c *Call) Close()

+ func (c *Call) Spawn() (ctx context.Context, done context.CancelFunc)

+ type CallExitReason uint8

+ const ParseError

+ const RuntimeError

+ const SuccessDone

+ func (code CallExitReason) ExitErr() error

+ type CallID string

+ type CallSummary struct

+ ActorName actor.ActorID

+ Args []string

+ type EnvGlobal interface

+ ClearLogData func()

+ GetCall func(id CallID) *Call

+ GetCalls func(id actor.ActorID) map[CallID]CallSummary

+ GetLogData func(key string) (value interface{}, ok bool)

+ IsClosing func() bool

+ KillActor func(id actor.ActorID)

+ MakeCall func(actorID actor.ActorID, callID CallID, args []string) *Call

+ type LinesReader struct

+ Fn NextMultiLineFn

+ func (lr *LinesReader) Read(p []byte) (n int, err error)

+ type LogSplitFn func(entry *logrus.Entry) error

+ func (fn LogSplitFn) Format(entry *logrus.Entry) ([]byte, error)

+ type NextMultiLineFn func() (string, error)

+ type NextSingleLineFn func() (string, error)

+ type ReadWithCallback struct

+ Callback func() error

+ func (rc *ReadWithCallback) Read(p []byte) (n int, err error)

+ type Session struct

+ func (sess *Session) Close() error

+ func (sess *Session) Done() <-chan struct{}

+ func (sess *Session) Each(fn func(name string, vr expand.Variable) bool)

+ func (sess *Session) Exited() bool

+ func (sess *Session) Get(name string) expand.Variable

+ func (sess *Session) GetLastCall() *Call

+ func (sess *Session) HasInterest(id CallID) (lvl logrus.Level, ok bool)

+ func (sess *Session) ListInterests() (out []CallID)

+ func (sess *Session) NewCallID() CallID

+ func (sess *Session) Run(ctx context.Context, node syntax.Node) error

+ func (sess *Session) RunCmd(ctx context.Context, args []string) error

+ func (sess *Session) RunInclude(ctx context.Context, includePath string) error

+ func (sess *Session) RunNonRumorCmd(ctx context.Context, args []string) error

+ func (sess *Session) SetBlocking(blocking bool)

+ func (sess *Session) SetInterest(id CallID, lvl logrus.Level)

+ func (sess *Session) UnsetInterest(id CallID)

+ type SessionID string

+ type SessionProcessor struct

+ func NewSessionProcessor(adminLog logrus.FieldLogger) *SessionProcessor

+ func (sp *SessionProcessor) ClearLogData()

+ func (sp *SessionProcessor) Close()

+ func (sp *SessionProcessor) GetActor(name actor.ActorID) *actor.Actor

+ func (sp *SessionProcessor) GetCall(id CallID) *Call

+ func (sp *SessionProcessor) GetCalls(id actor.ActorID) map[CallID]CallSummary

+ func (sp *SessionProcessor) GetLogData(key string) (value interface{}, ok bool)

+ func (sp *SessionProcessor) IsClosing() bool

+ func (sp *SessionProcessor) KillActor(id actor.ActorID)

+ func (sp *SessionProcessor) MakeCall(actorName actor.ActorID, callID CallID, cmdArgs []string) *Call

+ func (sp *SessionProcessor) NewSession(log logrus.FieldLogger) *Session

+ func (sp *SessionProcessor) RemoveInterests(id CallID)

+ type VoidWriter struct

+ func (v VoidWriter) Write(p []byte) (n int, err error)

+ type WriteableFn func(msg string)

+ func (fn WriteableFn) Write(p []byte) (n int, err error)