input

Documentation

Index

• Constants
• func FLBPluginConfigKey(plugin unsafe.Pointer, key string) string
• func FLBPluginRegister(def unsafe.Pointer, name, desc string) int
• func FLBPluginUnregister(def unsafe.Pointer)
• type FLBEncoder
  • func NewEncoder() *FLBEncoder
  • func (enc *FLBEncoder) Encode(val interface{}) (packed []byte, err error)
• type FLBInPlugin
• type FLBPluginProxyDef
• type FLBTime
  • func (f FLBTime) ReadExt(i interface{}, b []byte)
  • func (f FLBTime) WriteExt(i interface{}) []byte

Constants

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

	FLB_PROXY_INPUT_PLUGIN = C.FLB_PROXY_INPUT_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 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 FLBPluginUnregister

func FLBPluginUnregister(def unsafe.Pointer)

Release resources allocated by the plugin initialization

Types

type FLBEncoder

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

func NewEncoder

func NewEncoder() *FLBEncoder

func (*FLBEncoder) Encode

func (enc *FLBEncoder) Encode(val interface{}) (packed []byte, err error)

type FLBInPlugin

type FLBInPlugin C.struct_flbgo_input_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) ReadExt

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

func (FLBTime) WriteExt

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