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)
• func ParseTypedQueryParameters(queryStr string, params reg.RegisteredParameters) (map[string]interface{}, 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)

func ParseTypedQueryParameters

func ParseTypedQueryParameters(queryStr string, params reg.RegisteredParameters) (map[string]interface{}, error)

Types

type BitflowPlugin

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