output

Documentation

Index

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

FLBPluginGetContext reads the context associated with proxyCtx.

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

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)

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