output

Documentation

Index

• func GetAvailableAuditWriters() []string
• type AuditWriter
  • func CreateAuditWriter(auditWriterName string, config *viper.Viper) (*AuditWriter, error)
  • func NewAuditWriter(w io.Writer, attempts int) *AuditWriter
  • func (a *AuditWriter) Write(msg *parser.AuditMessageGroup) (err error)
• type AuditWriterFactory
• type HTTPWriter
  • func (w *HTTPWriter) Process(ctx context.Context)
  • func (w *HTTPWriter) Write(p []byte) (n int, err error)

Functions

func GetAvailableAuditWriters

func GetAvailableAuditWriters() []string

GetAvailableAuditWriters returns an array of audit writer names as strings

Types

type AuditWriter

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

AuditWriter is the class that encapsulates the io.Writer for output

func CreateAuditWriter

func CreateAuditWriter(auditWriterName string, config *viper.Viper) (*AuditWriter, error)

CreateAuditWriter creates an audit writer with the type specified by the name, the viper config is passed down to the audit writer factory method. It returns an audit writer or an error

func NewAuditWriter

func NewAuditWriter(w io.Writer, attempts int) *AuditWriter

NewAuditWriter creates a generic auditwriter which encapsulates a io.Writer

func (*AuditWriter) Write

func (a *AuditWriter) Write(msg *parser.AuditMessageGroup) (err error)

type AuditWriterFactory

type AuditWriterFactory func(conf *viper.Viper) (*AuditWriter, error)

AuditWriterFactory is the that represents a function that is a audit writer factory

type HTTPWriter

type HTTPWriter struct {
	ResponseBodyTransformer httptransformer.ResponseBodyTransformer
	// contains filtered or unexported fields
}

HTTPWriter is the class that encapsulates the http output plugin

func (*HTTPWriter) Process

func (w *HTTPWriter) Process(ctx context.Context)

Process blocks and listens for messages in the channel

func (*HTTPWriter) Write

func (w *HTTPWriter) Write(p []byte) (n int, err error)