output

Documentation

Index

• Constants
• func FLBPluginConfigKey(plugin unsafe.Pointer, key string) string
• func FLBPluginGetCMetricsContext(plugin unsafe.Pointer) (*cmetrics.Context, error)
• func FLBPluginGetContext(proxyCtx unsafe.Pointer) interface{}
• func FLBPluginLogPrint(plugin unsafe.Pointer, log_level C.int, message string)
• func FLBPluginRegister(def unsafe.Pointer, name, desc string) int
• func FLBPluginSetContext(plugin unsafe.Pointer, ctx interface{})
• func FLBPluginUnregister(def unsafe.Pointer)
• func GetRecord(dec *FLBDecoder) (ret int, ts interface{}, rec map[interface{}]interface{})
• type FLBDecoder
  • func NewByteDecoder(b []byte) *FLBDecoder
  • func NewDecoder(data unsafe.Pointer, length int) *FLBDecoder
• type FLBOutPlugin
• type FLBPluginProxyDef
• type FLBTime
  • func (f FLBTime) ConvertExt(v interface{}) interface{}
  • func (f FLBTime) ReadExt(i interface{}, b []byte)
  • func (f FLBTime) UpdateExt(dest interface{}, v interface{})
  • func (f FLBTime) WriteExt(interface{}) []byte

Constants

const (
	FLB_ERROR = C.FLB_ERROR
	FLB_OK    = C.FLB_OK
	FLB_RETRY = C.FLB_RETRY

	FLB_PROXY_OUTPUT_PLUGIN = C.FLB_PROXY_OUTPUT_PLUGIN
	FLB_PROXY_GOLANG        = C.FLB_PROXY_GOLANG

	FLB_LOG_ERROR = C.FLB_LOG_ERROR
	FLB_LOG_WARN  = C.FLB_LOG_WARN
	FLB_LOG_INFO  = C.FLB_LOG_INFO
	FLB_LOG_DEBUG = C.FLB_LOG_DEBUG
)

Define constants matching Fluent Bit core

Functions

func FLBPluginConfigKey

func FLBPluginConfigKey(plugin unsafe.Pointer, key string) string

func FLBPluginGetCMetricsContext

func FLBPluginGetCMetricsContext(plugin unsafe.Pointer) (*cmetrics.Context, error)

func FLBPluginGetContext

func FLBPluginGetContext(proxyCtx unsafe.Pointer) interface{}

FLBPluginGetContext reads the context associated with proxyCtx.

func FLBPluginLogPrint

func FLBPluginLogPrint(plugin unsafe.Pointer, log_level C.int, message string)

func FLBPluginRegister

func FLBPluginRegister(def unsafe.Pointer, name, desc string) int

FLBPluginRegister when the FLBPluginInit is triggered by Fluent Bit, a plugin context is passed and the next step is to invoke this FLBPluginRegister() function to fill the required information: type, proxy type, flags name and description.

func FLBPluginSetContext

func FLBPluginSetContext(plugin unsafe.Pointer, ctx interface{})

FLBPluginSetContext sets the context for plugin to ctx.

Limit FLBPluginSetContext calls to once per plugin instance for best performance.

func FLBPluginUnregister

func FLBPluginUnregister(def unsafe.Pointer)

FLBPluginUnregister release resources allocated by the plugin initialization

func GetRecord

func GetRecord(dec *FLBDecoder) (ret int, ts interface{}, rec map[interface{}]interface{})

Types

type FLBDecoder

type FLBDecoder struct {
	// contains filtered or unexported fields
}

func NewByteDecoder

func NewByteDecoder(b []byte) *FLBDecoder

func NewDecoder

func NewDecoder(data unsafe.Pointer, length int) *FLBDecoder

type FLBOutPlugin

type FLBOutPlugin C.struct_flbgo_output_plugin

type FLBPluginProxyDef

type FLBPluginProxyDef C.struct_flb_plugin_proxy_def

FLBPluginProxyDef local type.

type FLBTime

type FLBTime struct {
	time.Time
}

func (FLBTime) ConvertExt

func (f FLBTime) ConvertExt(v interface{}) interface{}

func (FLBTime) ReadExt

func (f FLBTime) ReadExt(i interface{}, b []byte)

func (FLBTime) UpdateExt

func (f FLBTime) UpdateExt(dest interface{}, v interface{})

func (FLBTime) WriteExt

func (f FLBTime) WriteExt(interface{}) []byte