sources

Documentation

Index

• type Source
  • func Init(ctx context.Context, kind string, connection config.Metadata, ...) (Source, error)

Types

type Source

type Source interface {
	Init(ctx context.Context, connection config.Metadata, properties config.Metadata, bindingName string, log *logger.Logger) error
	Start(ctx context.Context, target []middleware.Middleware) error
	Stop() error
}

func Init

func Init(ctx context.Context, kind string, connection config.Metadata, properties config.Metadata, bindingName string, log *logger.Logger) (Source, error)