builtin

Documentation

Index

• Variables
• type DispenserFactory
• type Registry
  • func NewRegistry(logger log.CtxLogger, factories ...DispenserFactory) *Registry
  • func (r *Registry) List() (map[string]plugin.Specification, error)
  • func (r *Registry) NewDispenser(logger log.CtxLogger, name string) (plugin.Dispenser, error)

Variables

var (
	DefaultDispenserFactories = []DispenserFactory{
		sdkDispenserFactory(file.Specification, file.NewSource, file.NewDestination),
		sdkDispenserFactory(kafka.Specification, kafka.NewSource, kafka.NewDestination),
		sdkDispenserFactory(generator.Specification, generator.NewSource, nil),
		sdkDispenserFactory(s3.Specification, s3source.NewSource, s3destination.NewDestination),
		sdkDispenserFactory(postgres.Specification, pgsource.NewSource, pgdest.NewDestination),
	}
)

Types

type DispenserFactory

type DispenserFactory func(name string, logger log.CtxLogger) plugin.Dispenser

type Registry

type Registry struct {
	// contains filtered or unexported fields
}

func NewRegistry

func NewRegistry(logger log.CtxLogger, factories ...DispenserFactory) *Registry

func (*Registry) List

func (r *Registry) List() (map[string]plugin.Specification, error)

func (*Registry) NewDispenser

func (r *Registry) NewDispenser(logger log.CtxLogger, name string) (plugin.Dispenser, error)