sqlsync

type SQLDataSynchronizer ¶

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

SQLDataSynchronizer is a struct that implements the Synchronizer interface for bundle files stored in SQL database. It is expected that the caller will handle concurrency and parallelism. The Synchronizer is not thread-safe. It dumps files stored in SQL database into a directory used by the builder package to construct a bundle.

func NewSQLSourceDataSynchronizer(path string, db *database.Database, sourceID int64, sourceName string, opts ...SQLSyncOption) *SQLDataSynchronizer

func (*SQLDataSynchronizer) Close(context.Context)

func (s *SQLDataSynchronizer) Execute(ctx context.Context) (map[string]any, error)

type SQLSyncOption ¶ added in v0.5.0

type SQLSyncOption func(*SQLDataSynchronizer)

func WithMetadataFields(fields []string) SQLSyncOption