plugin

Documentation

Index

• Constants
• func LoadPlugin(registry reg.ProcessorRegistry, path string) (string, error)
• func LoadPluginSymbol(registry reg.ProcessorRegistry, path string, symbol string) (string, error)
• func LogPluginDataSource(p BitflowPlugin, sourceName bitflow.EndpointType)
• func LogPluginProcessor(p BitflowPlugin, stepName string)
• type BitflowPlugin

Constants

const BitflowPluginSymbol = "Plugin"

Functions

func LoadPlugin

func LoadPlugin(registry reg.ProcessorRegistry, path string) (string, error)

func LoadPluginSymbol

func LoadPluginSymbol(registry reg.ProcessorRegistry, path string, symbol string) (string, error)

func LogPluginDataSource

func LogPluginDataSource(p BitflowPlugin, sourceName bitflow.EndpointType)

func LogPluginProcessor

func LogPluginProcessor(p BitflowPlugin, stepName string)

Types

type BitflowPlugin

type BitflowPlugin interface {
	Init(registry reg.ProcessorRegistry) error
	Name() string
}