causality

Documentation

Index

• func NewScriptCausalityAggregator() (core.Aggregator, error)
• type ScriptCausalityAggregator
  • func (agg *ScriptCausalityAggregator) DumpToPostgresql(ctx *core.AggregationContext, sqlDb *sql.DB) error
  • func (agg *ScriptCausalityAggregator) DumpToStream(ctx *core.AggregationContext, stream io.Writer) error
  • func (agg *ScriptCausalityAggregator) IngestRecord(ctx *core.ExecutionContext, lineNumber int, op byte, fields []string) error

Functions

func NewScriptCausalityAggregator

func NewScriptCausalityAggregator() (core.Aggregator, error)

NewScriptCausalityAggregator constructs a new ScriptCausalityAggregator

Types

type ScriptCausalityAggregator

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

A ScriptCausalityAggregator reconstructs a tree of script causality from evals, inclusions, insertions, and document.writes...

func (*ScriptCausalityAggregator) DumpToPostgresql

func (agg *ScriptCausalityAggregator) DumpToPostgresql(ctx *core.AggregationContext, sqlDb *sql.DB) error

DumpToMongresql can trigger both the new GraphML-blob-save-to-Mongo logic and the old-n-busted save-links-to-Postgres logic

func (*ScriptCausalityAggregator) DumpToStream

func (agg *ScriptCausalityAggregator) DumpToStream(ctx *core.AggregationContext, stream io.Writer) error

DumpToStream serializes a ScriptCausalityAggregator's results as a GraphML XML document written to the given stream

func (*ScriptCausalityAggregator) IngestRecord

func (agg *ScriptCausalityAggregator) IngestRecord(ctx *core.ExecutionContext, lineNumber int, op byte, fields []string) error

IngestRecord processes a single trace record (line), looking for dynamic script causality