standalone

Documentation

Index

• type Dispenser
  • func NewDispenser(logger zerolog.Logger, path string, opts ...client.Option) (*Dispenser, error)
  • func (d *Dispenser) DispenseDestination() (connector.DestinationPlugin, error)
  • func (d *Dispenser) DispenseSource() (connector.SourcePlugin, error)
  • func (d *Dispenser) DispenseSpecifier() (connector.SpecifierPlugin, error)
• type Registry
  • func NewRegistry(logger log.CtxLogger, pluginDir string) *Registry
  • func (r *Registry) List() map[plugin.FullName]pconnector.Specification
  • func (r *Registry) NewDispenser(logger log.CtxLogger, fullName plugin.FullName) (connector.Dispenser, error)

Types

type Dispenser

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

func NewDispenser

func NewDispenser(logger zerolog.Logger, path string, opts ...client.Option) (*Dispenser, error)

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 Registry

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

func NewRegistry

func NewRegistry(logger log.CtxLogger, pluginDir string) *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)