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 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, connectors map[string]sdk.Connector, ...) *Registry
  • func (r *Registry) Init(ctx context.Context)
  • func (r *Registry) List() map[plugin.FullName]pconnector.Specification
  • func (r *Registry) NewDispenser(logger log.CtxLogger, fullName plugin.FullName, cfg pconnector.PluginConfig) (connector.Dispenser, error)

Variables

var DefaultBuiltinConnectors = map[string]sdk.Connector{
	"github.com/conduitio/conduit-connector-file":      file.Connector,
	"github.com/conduitio/conduit-connector-generator": generator.Connector,
	"github.com/conduitio/conduit-connector-kafka":     kafka.Connector,
	"github.com/conduitio/conduit-connector-log":       connLog.Connector,
	"github.com/conduitio/conduit-connector-postgres":  postgres.Connector,
	"github.com/conduitio/conduit-connector-s3":        s3.Connector,
}

DefaultBuiltinConnectors contains the default built-in connectors. The key of the map is the import path of the module containing the connector implementation.

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 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, connectors map[string]sdk.Connector, service *connutils.SchemaService) *Registry

func (*Registry) Init

func (r *Registry) Init(ctx context.Context)

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, cfg pconnector.PluginConfig) (connector.Dispenser, error)