drivers

Documentation

Index

• Constants
• Variables
• func Create(ctx context.Context, sourceID string, sourceConfig *base.SourceConfig, ...) (map[string]base.Driver, error)
• func ParseCollections(sourceConfig *base.SourceConfig) ([]*base.Collection, error)

Constants

const (
	DefaultCollection = "all"
)

Variables

var (
	ErrUnknownSource = errors.New("Unknown source type")
)

Functions

func Create

func Create(ctx context.Context, sourceID string, sourceConfig *base.SourceConfig, cronScheduler *scheduling.CronScheduler) (map[string]base.Driver, error)

Create source drivers per collection Enrich incoming configs with default values if needed

func ParseCollections

func ParseCollections(sourceConfig *base.SourceConfig) ([]*base.Collection, error)

ParseCollections return serialized Collection objects slice or return one default collection with 'schedule' if singer type