splunk

Documentation

Index

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

Types

type SplunkFormat

type SplunkFormat struct {
	logger.ContextL

	EventChan chan []byte
	// contains filtered or unexported fields
}

func NewFormat

func NewFormat(log logger.Underlying, compression kt.Compression) (*SplunkFormat, error)

func (*SplunkFormat) From

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

func (*SplunkFormat) Rollup

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

func (*SplunkFormat) To

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

type SplunkMetric

type SplunkMetric struct {
	Host       string                 `json:"host"`
	SourceType string                 `json:"sourcetype"`
	Timestamp  int64                  `json:"time"`
	Event      map[string]interface{} `json:"event"`
}