input

package
v1.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

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

	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

Variables

This section is empty.

Functions

func FLBPluginConfigKey

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

func FLBPluginGetCMetricsContext added in v0.1.3

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

func FLBPluginLogPrint added in v0.1.4

func FLBPluginLogPrint(plugin unsafe.Pointer, log_level C.int, message 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

Local type to define a plugin definition

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL