builtin

Documentation

Index

• Variables
• type DispenserFactory
• type Registry
  • func NewRegistry(logger log.CtxLogger, factories ...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 = []DispenserFactory{
		sdkDispenserFactory(file.Connector),
		sdkDispenserFactory(kafka.Connector),
		sdkDispenserFactory(generator.Connector),
		sdkDispenserFactory(s3.Connector),
		sdkDispenserFactory(postgres.Connector),
		sdkDispenserFactory(connLog.Connector),
	}
)

Types

type DispenserFactory

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

type Registry

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

func NewRegistry

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