plugins

Documentation

Index

• func RegisterDestination(name string, factory DestinationFactory)
• func RegisterSource(name string, factory SourceFactory)
• type Destination
  • func GetDestination(name string) (Destination, error)
• type DestinationFactory
• type Source
  • func GetSource(name string) (Source, error)
• type SourceFactory

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