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, id string) *SQLDataSynchronizer

func (*SQLDataSynchronizer) Close(context.Context)

func (s *SQLDataSynchronizer) Execute(ctx context.Context) error