builtin

Documentation

Index

• Variables
• type DispenserFactory
  • func NewDispenserFactory(connector sdk.Connector) DispenserFactory
• type Registry
  • func NewRegistry(logger log.CtxLogger, factories map[string]DispenserFactory) *Registry
  • func (r *Registry) List() map[plugin.FullName]plugin.Specification
  • func (r *Registry) NewDispenser(logger log.CtxLogger, fullName plugin.FullName) (plugin.Dispenser, error)

Variables

var (
	// DefaultDispenserFactories contains default dispenser factories for
	// built-in plugins. The key of the map is the import path of the module
	// containing the connector implementation.
	DefaultDispenserFactories = map[string]DispenserFactory{
		"github.com/conduitio/conduit-connector-file":      NewDispenserFactory(file.Connector),
		"github.com/conduitio/conduit-connector-kafka":     NewDispenserFactory(kafka.Connector),
		"github.com/conduitio/conduit-connector-generator": NewDispenserFactory(generator.Connector),
		"github.com/conduitio/conduit-connector-s3":        NewDispenserFactory(s3.Connector),
		"github.com/conduitio/conduit-connector-postgres":  NewDispenserFactory(postgres.Connector),
		"github.com/conduitio/conduit-connector-log":       NewDispenserFactory(connLog.Connector),
	}
)

Types

type DispenserFactory

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

func NewDispenserFactory

func NewDispenserFactory(connector sdk.Connector) DispenserFactory

type Registry

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

func NewRegistry

func NewRegistry(logger log.CtxLogger, factories map[string]DispenserFactory) *Registry

func (*Registry) List

func (r *Registry) List() map[plugin.FullName]plugin.Specification

func (*Registry) NewDispenser

func (r *Registry) NewDispenser(logger log.CtxLogger, fullName plugin.FullName) (plugin.Dispenser, error)