io

Documentation

Index

• func GetSinkPlugin(name string) (plugin.EXTENSION_TYPE, string, string)
• func GetSourcePlugin(name string) (plugin.EXTENSION_TYPE, string, string)
• func Initialize(factories []binder.FactoryEntry) error
• func LookupSource(name string) (api.Source, error)
• func Sink(name string) (api.Sink, error)
• func Source(name string) (api.Source, error)
• type Manager
  • func GetManager() *Manager
  • func (m *Manager) LookupSource(name string) (api.Source, error)
  • func (m *Manager) Sink(name string) (api.Sink, error)
  • func (m *Manager) SinkPluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)
  • func (m *Manager) Source(name string) (api.Source, error)
  • func (m *Manager) SourcePluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)

Functions

func GetSinkPlugin

func GetSinkPlugin(name string) (plugin.EXTENSION_TYPE, string, string)

func GetSourcePlugin

func GetSourcePlugin(name string) (plugin.EXTENSION_TYPE, string, string)

func Initialize

func Initialize(factories []binder.FactoryEntry) error

func LookupSource

func LookupSource(name string) (api.Source, error)

func Sink

func Sink(name string) (api.Sink, error)

func Source

func Source(name string) (api.Source, error)

Types

type Manager

type Manager struct{}

func GetManager

func GetManager() *Manager

func (*Manager) LookupSource

func (m *Manager) LookupSource(name string) (api.Source, error)

func (*Manager) Sink

func (m *Manager) Sink(name string) (api.Sink, error)

func (*Manager) SinkPluginInfo

func (m *Manager) SinkPluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)

func (*Manager) Source

func (m *Manager) Source(name string) (api.Source, error)

func (*Manager) SourcePluginInfo

func (m *Manager) SourcePluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)