plugins

package
v0.0.0-...-cfc85e1 Latest Latest
Warning

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

Go to latest
Published: Oct 4, 2024 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDestination

func RegisterDestination(name string, factory DestinationFactory)

func RegisterSource

func RegisterSource(name string, factory SourceFactory)

Types

type Destination

type Destination interface {
	Init(config map[string]interface{}, model *models.Model) error
	StoreData(data []map[string]interface{}) (int, int, error)
	RunSchema() error
	Close() error
}

Destination interface

func GetDestination

func GetDestination(name string) (Destination, error)

type DestinationFactory

type DestinationFactory func() Destination

type Source

type Source interface {
	Init(config map[string]interface{}, model *models.Model) error
	FetchData(opts map[string]interface{}) ([]map[string]interface{}, error)
	Close() error
}

Source interface

func GetSource

func GetSource(name string) (Source, error)

type SourceFactory

type SourceFactory func() Source

Directories

Path Synopsis
destination_plugins
source_plugins

Jump to

Keyboard shortcuts

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