execution

type Copier interface {
	RawCopyTo(ctx context.Context, w io.Writer, sql string) error
	RawCopyFrom(ctx context.Context, r io.Reader, sql string) error
}

type ErrorClassifier func(meta schema.ClientMeta, resourceName string, err error) diag.Diagnostics

type QueryExecer interface {
	pgxscan.Querier
	Exec(ctx context.Context, query string, args ...interface{}) error
}

type Storage interface {
	QueryExecer
	Copier
	Insert(ctx context.Context, t *schema.Table, instance schema.Resources, shouldCascade bool, cascadeDeleteFilters map[string]interface{}) error
	Delete(ctx context.Context, t *schema.Table, kvFilters []interface{}) error
	RemoveStaleData(ctx context.Context, t *schema.Table, executionStart time.Time, kvFilters []interface{}) error
	CopyFrom(ctx context.Context, resources schema.Resources, shouldCascade bool, cascadeDeleteFilters map[string]interface{}) error
	Close()
	Dialect() schema.Dialect
}

type TableExecutor struct {
	// ResourceName name of top-level resource associated with table
	ResourceName string
	// Table this execution is associated with
	Table *schema.Table
	// Database connection to insert data into
	Db Storage
	// Logger associated with this execution
	Logger hclog.Logger
	// contains filtered or unexported fields
}