firehose

Documentation

Overview

Package firehose containers the OutputPlugin which sends log records to Firehose

Index

• type OutputPlugin
  • func NewOutputPlugin(...) (*OutputPlugin, error)
  • func (output *OutputPlugin) AddRecord(record map[interface{}]interface{}, timeStamp *time.Time) int
  • func (output *OutputPlugin) Flush() int
• type PutRecordBatcher

Types

type OutputPlugin

type OutputPlugin struct {
	PluginID int
	// contains filtered or unexported fields
}

OutputPlugin sends log records to firehose

func NewOutputPlugin

func NewOutputPlugin(region, deliveryStream, dataKeys, roleARN, firehoseEndpoint, stsEndpoint, timeKey, timeFmt, logKey, replaceDots string, pluginID int, simpleAggregation bool) (*OutputPlugin, error)

NewOutputPlugin creates an OutputPlugin object

func (*OutputPlugin) AddRecord

func (output *OutputPlugin) AddRecord(record map[interface{}]interface{}, timeStamp *time.Time) int

AddRecord accepts a record and adds it to the buffer, flushing the buffer if it is full the return value is one of: FLB_OK FLB_RETRY API Errors lead to an FLB_RETRY, and all other errors are logged, the record is discarded and FLB_OK is returned

func (*OutputPlugin) Flush

func (output *OutputPlugin) Flush() int

Flush sends the current buffer of records Returns FLB_OK, FLB_RETRY, FLB_ERROR

type PutRecordBatcher

type PutRecordBatcher interface {
	PutRecordBatch(input *firehose.PutRecordBatchInput) (*firehose.PutRecordBatchOutput, error)
}

PutRecordBatcher contains the firehose PutRecordBatch method call