mongorec

package

v0.0.0-...-0174093 Latest Latest Go to latest Published: Feb 17, 2024 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ischenkx/kantoku

Documentation ¶

Index ¶

type DistinctCursor
type DistinctIter
- func (iter *DistinctIter[Item]) Close(ctx context.Context) error
- func (iter *DistinctIter[Item]) Next(ctx context.Context) (Item, error)
type FilterCursor
type FilterIter
- func (iter *FilterIter[Item]) Close(ctx context.Context) error
- func (iter *FilterIter[Item]) Next(ctx context.Context) (Item, error)
type Set
type Storage
- func New[Item any](collection *mongo.Collection, codec codec.Codec[Item, record.R]) *Storage[Item]

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DistinctCursor ¶

type DistinctCursor[Item any] struct {
	// contains filtered or unexported fields
}

func (DistinctCursor[Item]) Count ¶

func (cursor DistinctCursor[Item]) Count(ctx context.Context) (int, error)

func (DistinctCursor[Item]) Iter ¶

func (cursor DistinctCursor[Item]) Iter() record.Iter[Item]

func (DistinctCursor[Item]) Limit ¶

func (cursor DistinctCursor[Item]) Limit(num int) record.Cursor[Item]

func (DistinctCursor[Item]) Mask ¶

func (cursor DistinctCursor[Item]) Mask(masks ...record.Mask) record.Cursor[Item]

func (DistinctCursor[Item]) Skip ¶

func (cursor DistinctCursor[Item]) Skip(num int) record.Cursor[Item]

func (DistinctCursor[Item]) Sort ¶

func (cursor DistinctCursor[Item]) Sort(sorters ...record.Sorter) record.Cursor[Item]

type DistinctIter ¶

type DistinctIter[Item any] struct {
	DistinctCursor[Item]
	// contains filtered or unexported fields
}

func (*DistinctIter[Item]) Close ¶

func (iter *DistinctIter[Item]) Close(ctx context.Context) error

func (*DistinctIter[Item]) Next ¶

func (iter *DistinctIter[Item]) Next(ctx context.Context) (Item, error)

type FilterCursor ¶

type FilterCursor[Item any] struct {
	// contains filtered or unexported fields
}

func (FilterCursor[Item]) Count ¶

func (f FilterCursor[Item]) Count(ctx context.Context) (int, error)

func (FilterCursor[Item]) Iter ¶

func (f FilterCursor[Item]) Iter() record.Iter[Item]

func (FilterCursor[Item]) Limit ¶

func (f FilterCursor[Item]) Limit(num int) record.Cursor[Item]

func (FilterCursor[Item]) Mask ¶

func (f FilterCursor[Item]) Mask(masks ...record.Mask) record.Cursor[Item]

func (FilterCursor[Item]) Skip ¶

func (f FilterCursor[Item]) Skip(num int) record.Cursor[Item]

func (FilterCursor[Item]) Sort ¶

func (f FilterCursor[Item]) Sort(sorters ...record.Sorter) record.Cursor[Item]

type FilterIter ¶

type FilterIter[Item any] struct {
	FilterCursor[Item]
	// contains filtered or unexported fields
}

func (*FilterIter[Item]) Close ¶

func (iter *FilterIter[Item]) Close(ctx context.Context) error

func (*FilterIter[Item]) Next ¶

func (iter *FilterIter[Item]) Next(ctx context.Context) (Item, error)

type Set ¶

type Set[Item any] struct {
	// contains filtered or unexported fields
}

func (Set[Item]) Cursor ¶

func (set Set[Item]) Cursor() record.Cursor[Item]

func (Set[Item]) Distinct ¶

func (set Set[Item]) Distinct(keys ...string) record.Cursor[Item]

func (Set[Item]) Erase ¶

func (set Set[Item]) Erase(ctx context.Context) error

func (Set[Item]) Filter ¶

func (set Set[Item]) Filter(rec record.R) record.Set[Item]

func (Set[Item]) Update ¶

func (set Set[Item]) Update(ctx context.Context, update, upsert record.R) error

type Storage ¶

type Storage[Item any] struct {
	// contains filtered or unexported fields
}

func New ¶

func New[Item any](collection *mongo.Collection, codec codec.Codec[Item, record.R]) *Storage[Item]

func (*Storage[Item]) Cursor ¶

func (storage *Storage[Item]) Cursor() record.Cursor[Item]

func (*Storage[Item]) Distinct ¶

func (storage *Storage[Item]) Distinct(keys ...string) record.Cursor[Item]

func (*Storage[Item]) Erase ¶

func (storage *Storage[Item]) Erase(ctx context.Context) error

func (*Storage[Item]) Filter ¶

func (storage *Storage[Item]) Filter(record record.Record) record.Set[Item]

func (*Storage[Item]) Insert ¶

func (storage *Storage[Item]) Insert(ctx context.Context, item Item) error

func (*Storage[Item]) Update ¶

func (storage *Storage[Item]) Update(ctx context.Context, update, upsert record.R) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL