builtin

package
v0.10.0 Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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),
	}
)

Functions

This section is empty.

Types

type DispenserFactory

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

func NewDispenserFactory

func NewDispenserFactory(conn 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 (*Registry) NewDispenser

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

Directories

Path Synopsis
v1

Jump to

Keyboard shortcuts

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