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
- type FLBOutPlugin
- type FLBPluginProxyDef
- type FLBTime
Constants ¶
View Source
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
Variables ¶
This section is empty.
Functions ¶
func FLBPluginGetCMetricsContext ¶ added in v0.1.3
func FLBPluginGetContext ¶
FLBPluginGetContext reads the context associated with proxyCtx.
func FLBPluginLogPrint ¶ added in v0.1.4
func 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 ¶
FLBPluginSetContext sets the context for plugin to ctx.
Limit FLBPluginSetContext calls to once per plugin instance for best performance.
func 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 ¶ added in v1.1.1
func NewByteDecoder(b []byte) *FLBDecoder
func NewDecoder ¶
func NewDecoder(data unsafe.Pointer, length int) *FLBDecoder
type FLBOutPlugin ¶
type FLBOutPlugin C.struct_flbgo_output_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 ¶
func (FLBTime) ConvertExt ¶
func (f FLBTime) ConvertExt(v interface{}) interface{}
Source Files
Click to show internal directories.
Click to hide internal directories.