s3

Documentation

Overview

Package s3 containers the OutputPlugin which sends log records to S3

Index

• type OutputPlugin
  • func NewOutputPlugin(region, bucket, prefix string, gzip bool, pluginID int) (*OutputPlugin, error)
  • func (output *OutputPlugin) AddRecord(record map[interface{}]interface{}, fluentTag string, timestamp time.Time) int
  • func (output *OutputPlugin) Flush(fluentTag string) error

Types

type OutputPlugin

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

OutputPlugin sends log records to s3

func NewOutputPlugin

func NewOutputPlugin(region, bucket, prefix string, gzip bool, pluginID int) (*OutputPlugin, error)

NewOutputPlugin creates a OutputPlugin object

func (*OutputPlugin) AddRecord

func (output *OutputPlugin) AddRecord(record map[interface{}]interface{}, fluentTag string, 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(fluentTag string) error

Flush sends the current buffer of records