Documentation
¶
Overview ¶
Package firehose containers the OutputPlugin which sends log records to Firehose
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package mock_firehose is a generated GoMock package.
|
Package mock_firehose is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.