output

Documentation

Index

• Constants
• func FLBPluginConfigKey(plugin unsafe.Pointer, key string) string
• func FLBPluginGetContext(i unsafe.Pointer) interface{}
• 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 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
)

Define constants matching Fluent Bit core

Functions

func FLBPluginConfigKey

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

func FLBPluginGetContext

func FLBPluginGetContext(i unsafe.Pointer) interface{}

func FLBPluginRegister

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

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{})

func FLBPluginUnregister

func FLBPluginUnregister(def unsafe.Pointer)

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 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

Local type to define a plugin definition

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