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)
• func ParseEndpointUrl(urlStr string, includesSchema bool) (string, string, map[string]string, error)
• func ParseQueryParameters(queryStr string) (map[string]string, error)
• 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)

func ParseEndpointUrl

func ParseEndpointUrl(urlStr string, includesSchema bool) (string, string, map[string]string, error)

func ParseQueryParameters

func ParseQueryParameters(queryStr string) (map[string]string, error)

Types

type BitflowPlugin

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