builtin

Documentation

Index

• Variables
• type Dispenser
  • func NewDispenser(name plugin.FullName, logger log.CtxLogger, ...) *Dispenser
  • func (d *Dispenser) DispenseDestination() (connector.DestinationPlugin, error)
  • func (d *Dispenser) DispenseSource() (connector.SourcePlugin, error)
  • func (d *Dispenser) DispenseSpecifier() (connector.SpecifierPlugin, error)
• type DispenserFactory
  • func NewDispenserFactory(conn sdk.Connector) DispenserFactory
• type InMemoryDestinationRunStream
  • func (s *InMemoryDestinationRunStream) Client() pconnector.DestinationRunStreamClient
  • func (s *InMemoryDestinationRunStream) Close(reason error) bool
  • func (s *InMemoryDestinationRunStream) Init(ctx context.Context)
  • func (s *InMemoryDestinationRunStream) Server() pconnector.DestinationRunStreamServer
• type InMemorySourceRunStream
  • func (s *InMemorySourceRunStream) Client() pconnector.SourceRunStreamClient
  • func (s *InMemorySourceRunStream) Close(reason error) bool
  • func (s *InMemorySourceRunStream) Init(ctx context.Context)
  • func (s *InMemorySourceRunStream) Server() pconnector.SourceRunStreamServer
• type Registry
  • func NewRegistry(logger log.CtxLogger, factories map[string]DispenserFactory) *Registry
  • func (r *Registry) List() map[plugin.FullName]pconnector.Specification
  • func (r *Registry) NewDispenser(logger log.CtxLogger, fullName plugin.FullName) (connector.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-generator": NewDispenserFactory(generator.Connector),
		"github.com/conduitio/conduit-connector-kafka":     NewDispenserFactory(kafka.Connector),
		"github.com/conduitio/conduit-connector-log":       NewDispenserFactory(connLog.Connector),
		"github.com/conduitio/conduit-connector-postgres":  NewDispenserFactory(postgres.Connector),
		"github.com/conduitio/conduit-connector-s3":        NewDispenserFactory(s3.Connector),
	}
)

Types

type Dispenser

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

func NewDispenser

func NewDispenser(
	name plugin.FullName,
	logger log.CtxLogger,
	specifierPlugin func() pconnector.SpecifierPlugin,
	sourcePlugin func() pconnector.SourcePlugin,
	destinationPlugin func() pconnector.DestinationPlugin,
) *Dispenser

func (*Dispenser) DispenseDestination

func (d *Dispenser) DispenseDestination() (connector.DestinationPlugin, error)

func (*Dispenser) DispenseSource

func (d *Dispenser) DispenseSource() (connector.SourcePlugin, error)

func (*Dispenser) DispenseSpecifier

func (d *Dispenser) DispenseSpecifier() (connector.SpecifierPlugin, error)

type DispenserFactory

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

func NewDispenserFactory

func NewDispenserFactory(conn sdk.Connector) DispenserFactory

type InMemoryDestinationRunStream

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

func (*InMemoryDestinationRunStream) Client

func (s *InMemoryDestinationRunStream) Client() pconnector.DestinationRunStreamClient

func (*InMemoryDestinationRunStream) Close

func (s *InMemoryDestinationRunStream) Close(reason error) bool

func (*InMemoryDestinationRunStream) Init

func (s *InMemoryDestinationRunStream) Init(ctx context.Context)

func (*InMemoryDestinationRunStream) Server

func (s *InMemoryDestinationRunStream) Server() pconnector.DestinationRunStreamServer

type InMemorySourceRunStream

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

func (*InMemorySourceRunStream) Client

func (s *InMemorySourceRunStream) Client() pconnector.SourceRunStreamClient

func (*InMemorySourceRunStream) Close

func (s *InMemorySourceRunStream) Close(reason error) bool

func (*InMemorySourceRunStream) Init

func (s *InMemorySourceRunStream) Init(ctx context.Context)

func (*InMemorySourceRunStream) Server

func (s *InMemorySourceRunStream) Server() pconnector.SourceRunStreamServer

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]pconnector.Specification

func (*Registry) NewDispenser

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