d1sync

type PullOptions struct {
	// BatchSize is the number of rows fetched per SELECT page (default 500).
	BatchSize int
	// ProgressFn is called after each table is pulled; may be nil.
	ProgressFn func(table string, rows int)
}

type PushOptions struct {
	// BatchSize is the number of INSERT rows sent per D1 API call (default 100).
	// D1's HTTP API has a 100 statement limit per request.
	BatchSize int
	// DropExisting drops tables in D1 that already exist before recreating them.
	DropExisting bool
	// ProgressFn is called after each table is pushed; may be nil.
	ProgressFn func(table string, rows int)
}

type TableData struct {
	Name string
	DDL  string
	Rows []map[string]interface{}
}