loader

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 17, 2025 License: Apache-2.0 Imports: 7 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadJobPlugin

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

LoadJobPlugin is currently not implemented properly and is only a placeholder. todo: Implement handle?

func LoadReaderJob

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

LoadReaderJob retrieves the job of a reader by its name. If name does not exist, it returns false.

func LoadReaderTask

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

LoadReaderTask retrieves the task of a reader by its name. If name does not exist, it returns false.

func LoadWriterJob

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

LoadWriterJob retrieves the job of a writer by its name. If name does not exist, it returns false.

func LoadWriterTask

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

LoadWriterTask retrieves the task of a writer by its name. If name does not exist, it returns false.

func RegisterReader

func RegisterReader(name string, reader spi.Reader)

RegisterReader registers a reader named name with the given reader. It will panic if name is duplicated, reader is nil, or reader's task and job are nil.

func RegisterWriter

func RegisterWriter(name string, writer spi.Writer)

RegisterWriter registers a writer named name with the given writer. It will panic if name is duplicated, writer is nil, or writer's task and job are nil.

func UnregisterReaders

func UnregisterReaders()

UnregisterReaders unregisters all readers.

func UnregisterWriters

func UnregisterWriters()

UnregisterWriters unregisters all writers.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL