executor

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

type Iterator[R record.Record] interface {
	Next(ctx context.Context) bool
	Item() R
	Size() int
	Err() error
	Seq(ctx context.Context) iter.Seq[R]
}

type QueryExecutor[R record.Record] interface {
	FetchTotal(ctx context.Context, q query.Query[R]) (int, error)
	FetchAll(ctx context.Context, q query.Query[R]) (Iterator[R], error)
	FetchAllAndTotal(ctx context.Context, q query.Query[R]) (Iterator[R], int, error)
}

type Selector[R record.Record] interface {
	PreselectForExecutor(conditions where.Conditions[R]) ([]R, error)
}

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