elements

Documentation

Index

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

Functions

func NewCreateElementAggregator

func NewCreateElementAggregator() (core.Aggregator, error)

NewCreateElementAggregator constructs a CreateElementAggregator

Types

type CreateElementAggregator

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

CreateElementAggregator tracks document.createElement calls and first-arguments (i.e., element type tags)

func (*CreateElementAggregator) DumpToPostgresql

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

DumpToMongresql dumps create-element tuple records to Postgres

func (*CreateElementAggregator) DumpToStream

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

DumpToStream implementation for create-elements

func (*CreateElementAggregator) IngestRecord

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

IngestRecord parses a trace record, looking for document.createElement calls to track