sources

Documentation

Index

• func Connectors() common.Connectors
• type Source
  • func Init(ctx context.Context, cfg config.Spec, logger *logger.Logger) (Source, error)

Functions

func Connectors

func Connectors() common.Connectors

Types

type Source

type Source interface {
	Init(ctx context.Context, cfg config.Spec, log *logger.Logger) error
	Start(ctx context.Context, target middleware.Middleware) error
	Stop() error
	Connector() *common.Connector
}

func Init

func Init(ctx context.Context, cfg config.Spec, logger *logger.Logger) (Source, error)