engine

Documentation

Index

• func ExecProgram(in string) (string, error)
• type AuditTrailsV1ParserImpl
  • func NewAuditTrailsV1ParserImpl(useElasticSchema, removeNestingInDetails, sniff bool, logger log.Logger, ...) (*AuditTrailsV1ParserImpl, error)
  • func (p *AuditTrailsV1ParserImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *AuditTrailsV1ParserImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem

Functions

func ExecProgram

func ExecProgram(in string) (string, error)

Types

type AuditTrailsV1ParserImpl

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

func NewAuditTrailsV1ParserImpl

func NewAuditTrailsV1ParserImpl(
	useElasticSchema, removeNestingInDetails, sniff bool, logger log.Logger, registry *stats.SourceStats,
) (*AuditTrailsV1ParserImpl, error)

func (*AuditTrailsV1ParserImpl) Do

func (p *AuditTrailsV1ParserImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem

func (*AuditTrailsV1ParserImpl) DoBatch

func (p *AuditTrailsV1ParserImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem