json

Documentation

Index

• Constants
• type JsonFormat
  • func NewFormat(log logger.Underlying, compression kt.Compression, doFlatten bool) (*JsonFormat, error)
  • func (f *JsonFormat) From(raw *kt.Output) ([]map[string]interface{}, error)
  • func (f *JsonFormat) Rollup(rolls []rollup.Rollup) (*kt.Output, error)
  • func (f *JsonFormat) To(msgs []*kt.JCHF, serBuf []byte) (*kt.Output, error)

Constants

const (
	InstNameNetflowEvent = "netflow-events"
	InstNameVPCEvent     = "vpc-flow-events"
	InstNameAWSVPCEvent  = "aws-vpc-flow-events"
	InstNameHttpEvent    = "http-events"
)

Types

type JsonFormat

type JsonFormat struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func NewFormat

func NewFormat(log logger.Underlying, compression kt.Compression, doFlatten bool) (*JsonFormat, error)

func (*JsonFormat) From

func (f *JsonFormat) From(raw *kt.Output) ([]map[string]interface{}, error)

func (*JsonFormat) Rollup

func (f *JsonFormat) Rollup(rolls []rollup.Rollup) (*kt.Output, error)

func (*JsonFormat) To

func (f *JsonFormat) To(msgs []*kt.JCHF, serBuf []byte) (*kt.Output, error)