data

Documentation

Index

• Variables
• func NewDataProvider(lgr log.Logger, registry metrics.Registry, transfer *model.Transfer, ...) (p base.DataProvider, err error)
• func NewSnapshotProvider(lgr log.Logger, registry metrics.Registry, transfer *model.Transfer, ...) (base.SnapshotProvider, error)

Variables

var (
	TryLegacySourceError = xerrors.New("Not found in new sources, try legacy source")
)

Functions

func NewDataProvider

func NewDataProvider(lgr log.Logger, registry metrics.Registry, transfer *model.Transfer, cp coordinator.Coordinator) (p base.DataProvider, err error)

func NewSnapshotProvider

func NewSnapshotProvider(lgr log.Logger, registry metrics.Registry, transfer *model.Transfer, cp coordinator.Coordinator) (base.SnapshotProvider, error)