Documentation
¶
Overview ¶
Package dash contains the c4t console dashboard.
Index ¶
- Variables
- func NewCorpusObserver() (*actionObserver, error)
- type Dash
- func (d *Dash) Close() error
- func (d *Dash) OnBuild(builder.Message)
- func (d *Dash) OnCompilerConfig(compiler.Message)
- func (d *Dash) OnCycle(m director.CycleMessage)
- func (d *Dash) OnCycleAnalysis(m director.CycleAnalysis)
- func (d *Dash) OnCycleBuild(c director.Cycle, m builder.Message)
- func (d *Dash) OnCycleCompiler(c director.Cycle, m compiler.Message)
- func (d *Dash) OnCycleCopy(c director.Cycle, m copier.Message)
- func (d *Dash) OnCycleInstance(c director.Cycle, m director.InstanceMessage)
- func (d *Dash) OnCycleSave(c director.Cycle, m saver.ArchiveMessage)
- func (d *Dash) OnMachines(machine.Message)
- func (d *Dash) OnPlan(planner.Message)
- func (d *Dash) OnPrepare(m director.PrepareMessage)
- func (d *Dash) Run(ctx context.Context, cancel func()) error
- type Instance
- func (o *Instance) AddToGrid(gb *grid.Builder, pc int)
- func (o *Instance) OnAnalysis(a analysis.Analysis)
- func (o *Instance) OnArchive(saver.ArchiveMessage)
- func (o *Instance) OnBuild(m builder.Message)
- func (o *Instance) OnCompilerConfig(m compiler.Message)
- func (o *Instance) OnCopy(m copy2.Message)
- func (o *Instance) OnCycle(r director.CycleMessage)
- func (o *Instance) OnInstance(m director.InstanceMessage)
- func (o *Instance) OnMachineNodeAction(observer.Message)
- func (o *Instance) OnPerturb(perturber.Message)
- type ResultLog
Constants ¶
This section is empty.
Variables ¶
var ErrNoSuchInstance = errors.New("received message for instance that doesn't exist")
ErrNoSuchInstance occurs when a message arrives from an instance that the dashboard hasn't allocated room for.
Functions ¶
func NewCorpusObserver ¶
func NewCorpusObserver() (*actionObserver, error)
Types ¶
type Dash ¶
type Dash struct {
// contains filtered or unexported fields
}
Dash is a director observer that displays all of the current director machines in a terminal dashboard.
func (*Dash) OnCompilerConfig ¶
OnCompilerConfig (currently) does nothing.
func (*Dash) OnCycle ¶
func (d *Dash) OnCycle(m director.CycleMessage)
OnCycle forwards the cycle message m to the relevant instance.
func (*Dash) OnCycleAnalysis ¶
func (d *Dash) OnCycleAnalysis(m director.CycleAnalysis)
OnCycleAnalysis forwards the analysis m to the relevant instance.
func (*Dash) OnCycleBuild ¶
OnCycleBuild forwards the cycle corpus build information m to the instance mentioned in c.
func (*Dash) OnCycleCompiler ¶
OnCycleCompiler forwards the compiler message m to the instance mentioned in c.
func (*Dash) OnCycleCopy ¶
OnCycleCopy forwards the copier message m to the instance mentioned in c.
func (*Dash) OnCycleInstance ¶
func (d *Dash) OnCycleInstance(c director.Cycle, m director.InstanceMessage)
OnCycleInstance forwards the instance message m to the instance mentioned in c.
func (*Dash) OnCycleSave ¶
func (d *Dash) OnCycleSave(c director.Cycle, m saver.ArchiveMessage)
OnCycleSave forwards the archive message m to the instance mentioned in c.
func (*Dash) OnMachines ¶
func (*Dash) OnPrepare ¶
func (d *Dash) OnPrepare(m director.PrepareMessage)
OnPrepare uses the instance calculation to prepare a machine grid.
type Instance ¶
type Instance struct {
// contains filtered or unexported fields
}
Instance represents a single machine instance inside a dash.
func NewInstance ¶
NewInstance constructs an Instance, initialising its various widgets. It accepts the id of the parent container (from which the IDs of various sub-containers can be derived), as well as the parent dash d (used to access the results log and parent container).
func (*Instance) AddToGrid ¶
AddToGrid adds this observer to a grid builder gb with the container ID id..
func (*Instance) OnAnalysis ¶
OnAnalysis observes an analysis by adding failure/timeout/flag rates to the sparklines.
func (*Instance) OnArchive ¶
func (o *Instance) OnArchive(saver.ArchiveMessage)
OnArchive currently ignores a save observation.
func (*Instance) OnCompilerConfig ¶
OnCompilerConfig forwards a build observation.
func (*Instance) OnCycle ¶
func (o *Instance) OnCycle(r director.CycleMessage)
OnCycle logs that a new iteration has begun.
func (*Instance) OnInstance ¶
func (o *Instance) OnInstance(m director.InstanceMessage)
OnInstance forwards the instance message to relevant bits of the dash.
func (*Instance) OnMachineNodeAction ¶
OnMachineNodeAction does nothing, at the moment.
type ResultLog ¶
type ResultLog struct {
// contains filtered or unexported fields
}
ResultLog provides a logging mechanism for collated subjects.
func (*ResultLog) Log ¶
func (r *ResultLog) Log(sc director.CycleAnalysis) error
Log logs a sourced collation sc.
func (*ResultLog) LogBucketEntry ¶
LogBucketEntry logs an entry for a subject with name sname.
func (*ResultLog) LogBucketHeader ¶
LogBucketHeader logs the header of a collation bucket with status st.
Source Files