executor

Dec 20, 2024

Changes in this version

type Iterator

+ Seq func(ctx context.Context) iter.Seq[R]

Feb 16, 2023

Changes in this version

+ func NewExecuteQueryError(err error) error

+ func NewValidateQueryError(err error) error

+ type ExecuteQueryError struct

+ func (e ExecuteQueryError) Error() string

+ func (e ExecuteQueryError) Is(err error) bool

+ func (e ExecuteQueryError) Unwrap() error

+ type Selector interface

+ PreselectForExecutor func(conditions where.Conditions) ([]record.Record, error)

+ type ValidateQueryError struct

+ func (e ValidateQueryError) Error() string

+ func (e ValidateQueryError) Is(err error) bool

+ func (e ValidateQueryError) Unwrap() error

Jan 11, 2023

Changes in this version

+ var ErrExecuteQuery = errors.New("execute query")

+ var ErrValidateQuery = errors.New("validate query")

+ type Iterator interface

+ Err func() error

+ Item func() record.Record

+ Next func(ctx context.Context) bool

+ Size func() int

+ type Namespace interface

+ Delete func(id int64) error

+ Get func(id int64) record.Record

+ Insert func(item record.Record) error

+ SelectForExecutor func(conditions where.Conditions) ([]record.Record, error)

+ Upsert func(item record.Record) error

+ type QueryExecutor interface

+ FetchAll func(ctx context.Context, q query.Query) (Iterator, error)

+ FetchAllAndTotal func(ctx context.Context, q query.Query) (Iterator, int, error)

+ FetchTotal func(ctx context.Context, q query.Query) (int, error)

+ func CreateQueryExecutor(storage Namespace) QueryExecutor