control

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2020 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Call 

type Call struct {
	// contains filtered or unexported fields
}

func (*Call) Close 

func (c *Call) Close()

Close the call gracefully, blocking until it is freed

func (*Call) Spawn 

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

type CallExitReason 

type CallExitReason uint8
const (
	SuccessDone CallExitReason = iota
	RuntimeError
	ParseError
)

func (CallExitReason) ExitErr 

func (code CallExitReason) ExitErr() error

type CallID 

type CallID string

type CallSummary 

type CallSummary struct {
	ActorName actor.ActorID `json:"actor"`
	Args      []string      `json:"args"`
}

type EnvGlobal 

type EnvGlobal interface {
	GetCall(id CallID) *Call
	MakeCall(actorID actor.ActorID, callID CallID, args []string) *Call
	IsClosing() bool
	KillActor(id actor.ActorID)
	GetCalls(id actor.ActorID) map[CallID]CallSummary
	GetLogData(key string) (value interface{}, ok bool)
	ClearLogData()
}

type LinesReader 

type LinesReader struct {
	Fn NextMultiLineFn
	// contains filtered or unexported fields
}

LinesReader is used to convert a stream of lines back into a reader

func (*LinesReader) Read 

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

type LogSplitFn 

type LogSplitFn func(entry *logrus.Entry) error

func (LogSplitFn) Format 

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

type NextMultiLineFn 

type NextMultiLineFn func() (string, error)

Reads one or more lines at a time. The multi-line string may not end with a linebreak character, but should never end in the middle of an actual line.

type NextSingleLineFn 

type NextSingleLineFn func() (string, error)

type ReadWithCallback 

type ReadWithCallback struct {
	io.Reader
	Callback func() error
}

func (*ReadWithCallback) Read 

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

type Session 

type Session struct {
	// contains filtered or unexported fields
}

func (*Session) Close 

func (sess *Session) Close() error

func (*Session) Done 

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

func (*Session) Each 

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

func (*Session) Exited 

func (sess *Session) Exited() bool

func (*Session) Get 

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

func (*Session) GetLastCall 

func (sess *Session) GetLastCall() *Call

func (*Session) HasInterest 

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

func (*Session) ListInterests 

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

func (*Session) NewCallID 

func (sess *Session) NewCallID() CallID

func (*Session) Run 

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

Run interprets a node inside a Rumor session, using the mvdan shell package.

From the shell docs: A node can be a *File, *Stmt, or Command. If a non-nil error is returned, it will typically contain commands exit status, which can be retrieved with IsExitStatus.

Run can be called multiple times synchronously to interpret programs incrementally. To reuse a Runner without keeping the internal shell state, call Reset.

func (*Session) RunCmd 

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

RunCmd implements interp.ExecHandlerFunc

func (*Session) RunInclude 

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

func (*Session) RunNonRumorCmd 

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

func (*Session) SetBlocking 

func (sess *Session) SetBlocking(blocking bool)

func (*Session) SetInterest 

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

func (*Session) UnsetInterest 

func (sess *Session) UnsetInterest(id CallID)

type SessionID 

type SessionID string

type SessionProcessor 

type SessionProcessor struct {
	// contains filtered or unexported fields
}

func NewSessionProcessor 

func NewSessionProcessor(adminLog logrus.FieldLogger) *SessionProcessor

func (*SessionProcessor) ClearLogData 

func (sp *SessionProcessor) ClearLogData()

func (*SessionProcessor) Close 

func (sp *SessionProcessor) Close()

func (*SessionProcessor) GetActor 

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

func (*SessionProcessor) GetCall 

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

func (*SessionProcessor) GetCalls 

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

func (*SessionProcessor) GetLogData 

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

func (*SessionProcessor) IsClosing 

func (sp *SessionProcessor) IsClosing() bool

func (*SessionProcessor) KillActor 

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

func (*SessionProcessor) MakeCall 

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

func (*SessionProcessor) NewSession 

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

func (*SessionProcessor) RemoveInterests 

func (sp *SessionProcessor) RemoveInterests(id CallID)

type VoidWriter 

type VoidWriter struct{}

func (VoidWriter) Write 

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

type WriteableFn 

type WriteableFn func(msg string)

func (WriteableFn) Write 

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

Source Files

View all Source files

Directories

Path Synopsis
attestations
base
blocks
chain
chain/on
chain/on/cold
chain/on/head
chain/on/hot
chain/on/serve
chain/on/sync
dv5
enr
flags
gossip
host
peer
peer/metadata
peer/status
peerstore
rpc
states

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.