flush

Documentation

Index

• func Ingest(data unsafe.Pointer, size int, tag string, ctx *outctx.S3Context) (int, error)

Functions

func Ingest

func Ingest(data unsafe.Pointer, size int, tag string, ctx *outctx.S3Context) (int, error)

Ingests Fluent Bit chunk, then sends to s3 in IR format. Data may be buffered on disk or in memory depending on plugin configuration.

Parameters:

• data: Msgpack data
• size: Byte length
• tag: Fluent Bit tag
• ctx: Plugin context

Returns:

• code: Fluent Bit success code (OK, RETRY, ERROR)
• err: Error if flush fails