modules

Documentation

Index

• Variables
• func IsFormatSupported(format string) bool
• func RegisterConverter(name string, provider message.ConverterProvider)
• func RegisterFunc(name string, f NewFuncFunc)
• func RegisterLookupSource(name string, f NewLookupSourceFunc)
• func RegisterSink(name string, f NewSinkFunc)
• func RegisterSource(name string, f NewSourceFunc)
• type NewFuncFunc
• type NewLookupSourceFunc
• type NewSinkFunc
• type NewSourceFunc

Variables

var (
	Sources       = map[string]NewSourceFunc{}
	Sinks         = map[string]NewSinkFunc{}
	LookupSources = map[string]NewLookupSourceFunc{}
)

var Converters = map[string]message.ConverterProvider{}

var Functions = map[string]NewFuncFunc{}

Functions

func IsFormatSupported

func IsFormatSupported(format string) bool

func RegisterConverter

func RegisterConverter(name string, provider message.ConverterProvider)

RegisterConverter registers a converter with the given name.

func RegisterFunc

func RegisterFunc(name string, f NewFuncFunc)

func RegisterLookupSource

func RegisterLookupSource(name string, f NewLookupSourceFunc)

func RegisterSink

func RegisterSink(name string, f NewSinkFunc)

func RegisterSource

func RegisterSource(name string, f NewSourceFunc)

Types

type NewFuncFunc

type NewFuncFunc func() api.Function

type NewLookupSourceFunc

type NewLookupSourceFunc func() api.LookupSource

type NewSinkFunc

type NewSinkFunc func() api.Sink

type NewSourceFunc

type NewSourceFunc func() api.Source