namespace

Feb 16, 2023

Changes in this version

+ func NewRecordAlreadyExists(id int64) error

+ type Logger interface

+ Println func(...interface{})

+ type RecordAlreadyExistsError struct

+ ID int64

+ func (e RecordAlreadyExistsError) Error() string

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

+ type WithIndexes struct

+ func CreateNamespace() *WithIndexes

+ func (ns *WithIndexes) AddIndex(index indexes.Index)

+ func (ns *WithIndexes) Delete(id int64) error

+ func (ns *WithIndexes) Get(id int64) record.Record

+ func (ns *WithIndexes) Insert(item record.Record) error

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

+ func (ns *WithIndexes) SetLogger(logger Logger)

+ func (ns *WithIndexes) Upsert(item record.Record) error

Dec 29, 2022

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