loader

Documentation

Index

• func LoadJobPlugin(typ plugin.Type, name string) (plugin.Job, error)
• func LoadReaderJob(name string) (reader.Job, bool)
• func LoadReaderTask(name string) (reader.Task, bool)
• func LoadWriterJob(name string) (writer.Job, bool)
• func LoadWriterTask(name string) (writer.Task, bool)
• func RegisterReader(name string, reader spi.Reader)
• func RegisterWriter(name string, writer spi.Writer)
• func UnregisterReaders()
• func UnregisterWriters()

Functions

func LoadJobPlugin

func LoadJobPlugin(typ plugin.Type, name string) (plugin.Job, error)

LoadJobPlugin 目前未正常实现该函数，仅仅是个架子 todo: 实现handle ?

func LoadReaderJob

func LoadReaderJob(name string) (reader.Job, bool)

LoadReaderJob ,根据名字name获取读取器的工作 如果name不存在，返回的布尔值为false

func LoadReaderTask

func LoadReaderTask(name string) (reader.Task, bool)

LoadReaderTask ,根据名字name获取读取器的任务 如果name不存在，返回的布尔值为false

func LoadWriterJob

func LoadWriterJob(name string) (writer.Job, bool)

LoadWriterJob ,根据名字name获取写入器的工作 如果name不存在，返回的布尔值为false

func LoadWriterTask

func LoadWriterTask(name string) (writer.Task, bool)

LoadWriterTask ,根据名字name获取写入器的任务 如果name不存在，返回的布尔值为false

func RegisterReader

func RegisterReader(name string, reader spi.Reader)

RegisterReader 注册名字为name的读取器reader 当name重复，reader为空或者reader的task和job为空会panic

func RegisterWriter

func RegisterWriter(name string, writer spi.Writer)

RegisterWriter 注册名字为name的写入器writer 当name重复，writer为空或者writer的task和job为空会panic

func UnregisterReaders

func UnregisterReaders()

UnregisterReaders 注销所有读取器

func UnregisterWriters

func UnregisterWriters()

UnregisterWriters 注销所有写入器