Documentation
¶
Index ¶
- func NewFilteredWriter(dst io.Writer, expr string) (io.Writer, error)
- func StartLineReader(input io.Reader, readerFunc func(string), logger *zap.Logger) error
- type FilteredWriter
- type NodeRunner
- func (runner *NodeRunner) Done() <-chan struct{}
- func (runner *NodeRunner) SetDir(dir string)
- func (runner *NodeRunner) SetEnv(env map[string]string)
- func (runner *NodeRunner) SetLineReader(fn func(string))
- func (runner *NodeRunner) SetLogFiltering(expr string)
- func (runner *NodeRunner) SetLogger(logger *zap.Logger)
- func (runner *NodeRunner) Start(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type FilteredWriter ¶
type FilteredWriter struct {
// contains filtered or unexported fields
}
type NodeRunner ¶
type NodeRunner struct {
// contains filtered or unexported fields
}
func (*NodeRunner) Done ¶
func (runner *NodeRunner) Done() <-chan struct{}
func (*NodeRunner) SetDir ¶
func (runner *NodeRunner) SetDir(dir string)
func (*NodeRunner) SetEnv ¶
func (runner *NodeRunner) SetEnv(env map[string]string)
func (*NodeRunner) SetLineReader ¶
func (runner *NodeRunner) SetLineReader(fn func(string))
func (*NodeRunner) SetLogFiltering ¶
func (runner *NodeRunner) SetLogFiltering(expr string)
func (*NodeRunner) SetLogger ¶
func (runner *NodeRunner) SetLogger(logger *zap.Logger)
Source Files
Click to show internal directories.
Click to hide internal directories.