wmo

package

v0.0.439 Latest Latest Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 13 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

gogs.mikescher.com/BlackForestBytes/goext

Links

Open Source Insights

Documentation ¶

Index ¶

type Coll
- func W[TData any](collection *mongo.Collection) *Coll[TData]
type Cursorable
type Decodable
type EntityID
type IColl

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Coll ¶

type Coll[TData any] struct {
	// contains filtered or unexported fields
}

func W ¶

func W[TData any](collection *mongo.Collection) *Coll[TData]

func (*Coll[TData]) Aggregate ¶

func (c *Coll[TData]) Aggregate(ctx context.Context, pipeline mongo.Pipeline, opts ...*options.AggregateOptions) ([]TData, error)

func (*Coll[TData]) AggregateOne ¶ added in v0.0.170

func (c *Coll[TData]) AggregateOne(ctx context.Context, pipeline mongo.Pipeline, opts ...*options.AggregateOptions) (TData, error)

func (*Coll[TData]) AggregateOneOpt ¶ added in v0.0.158

func (c *Coll[TData]) AggregateOneOpt(ctx context.Context, pipeline mongo.Pipeline, opts ...*options.AggregateOptions) (*TData, error)

func (*Coll[TData]) Collection ¶

func (c *Coll[TData]) Collection() *mongo.Collection

func (*Coll[TData]) Count ¶ added in v0.0.137

func (c *Coll[TData]) Count(ctx context.Context, filter ct.RawFilter) (int64, error)

func (*Coll[TData]) DeleteMany ¶ added in v0.0.134

func (c *Coll[TData]) DeleteMany(ctx context.Context, filterQuery bson.M) (*mongo.DeleteResult, error)

func (*Coll[TData]) DeleteOne ¶

func (c *Coll[TData]) DeleteOne(ctx context.Context, filterQuery bson.M) error

func (*Coll[TData]) DeleteOneByID ¶ added in v0.0.154

func (c *Coll[TData]) DeleteOneByID(ctx context.Context, id EntityID) error

func (*Coll[TData]) Drop ¶

func (c *Coll[TData]) Drop(ctx context.Context) error

func (*Coll[TData]) EnsureInitializedReflection ¶ added in v0.0.159

func (c *Coll[TData]) EnsureInitializedReflection(v TData)

func (*Coll[TData]) Find ¶

func (c *Coll[TData]) Find(ctx context.Context, filter bson.M, opts ...*options.FindOptions) ([]TData, error)

func (*Coll[TData]) FindOne ¶

func (c *Coll[TData]) FindOne(ctx context.Context, filter bson.M) (TData, error)

func (*Coll[TData]) FindOneAndReplace ¶ added in v0.0.139

func (c *Coll[TData]) FindOneAndReplace(ctx context.Context, filterQuery bson.M, value TData) (TData, error)

func (*Coll[TData]) FindOneAndUpdate ¶ added in v0.0.136

func (c *Coll[TData]) FindOneAndUpdate(ctx context.Context, filterQuery bson.M, updateQuery bson.M) (TData, error)

func (*Coll[TData]) FindOneByID ¶

func (c *Coll[TData]) FindOneByID(ctx context.Context, id EntityID) (TData, error)

func (*Coll[TData]) FindOneOpt ¶

func (c *Coll[TData]) FindOneOpt(ctx context.Context, filter bson.M) (*TData, error)

func (*Coll[TData]) FindOneOptByID ¶

func (c *Coll[TData]) FindOneOptByID(ctx context.Context, id EntityID) (*TData, error)

func (*Coll[TData]) Indexes ¶

func (c *Coll[TData]) Indexes() mongo.IndexView

func (*Coll[TData]) InsertMany ¶ added in v0.0.186

func (c *Coll[TData]) InsertMany(ctx context.Context, valueIn []TData) (*mongo.InsertManyResult, error)

func (*Coll[TData]) InsertManyUnchecked ¶ added in v0.0.306

func (c *Coll[TData]) InsertManyUnchecked(ctx context.Context, valueIn []any) (*mongo.InsertManyResult, error)

InsertManyUnchecked behaves the same as InsertOne, but allows arbitrary data to be inserted (valueIn is []any instead of []TData)

func (*Coll[TData]) InsertOne ¶ added in v0.0.138

func (c *Coll[TData]) InsertOne(ctx context.Context, valueIn TData) (TData, error)

func (*Coll[TData]) InsertOneUnchecked ¶ added in v0.0.305

func (c *Coll[TData]) InsertOneUnchecked(ctx context.Context, valueIn any) (TData, error)

InsertOneUnchecked behaves the same as InsertOne, but allows arbitrary data to be inserted (valueIn is any instead of TData)

func (*Coll[TData]) List ¶

func (c *Coll[TData]) List(ctx context.Context, filter ct.Filter, pageSize *int, inTok ct.CursorToken) ([]TData, ct.CursorToken, error)

func (*Coll[TData]) ListWithCount ¶ added in v0.0.265

func (c *Coll[TData]) ListWithCount(ctx context.Context, filter ct.Filter, pageSize *int, inTok ct.CursorToken) ([]TData, ct.CursorToken, int64, error)

func (*Coll[TData]) Name ¶

func (c *Coll[TData]) Name() string

func (*Coll[TData]) Paginate ¶ added in v0.0.301

func (c *Coll[TData]) Paginate(ctx context.Context, filter pag.MongoFilter, page int, limit *int) ([]TData, pag.Pagination, error)

func (*Coll[TData]) ReplaceOne ¶

func (c *Coll[TData]) ReplaceOne(ctx context.Context, filterQuery bson.M, value TData) error

func (*Coll[TData]) UpdateMany ¶ added in v0.0.141

func (c *Coll[TData]) UpdateMany(ctx context.Context, filterQuery bson.M, updateQuery bson.M) (*mongo.UpdateResult, error)

func (*Coll[TData]) UpdateOne ¶

func (c *Coll[TData]) UpdateOne(ctx context.Context, filterQuery bson.M, updateQuery bson.M) error

func (*Coll[TData]) UpdateOneByID ¶ added in v0.0.134

func (c *Coll[TData]) UpdateOneByID(ctx context.Context, id EntityID, updateQuery bson.M) error

func (*Coll[TData]) WithDecodeFunc ¶ added in v0.0.157

func (c *Coll[TData]) WithDecodeFunc(cdf func(ctx context.Context, dec Decodable) (TData, error), example TData) *Coll[TData]

func (*Coll[TData]) WithModifyingPipeline ¶ added in v0.0.304

func (c *Coll[TData]) WithModifyingPipeline(p mongo.Pipeline) *Coll[TData]

func (*Coll[TData]) WithModifyingPipelineFunc ¶ added in v0.0.363

func (c *Coll[TData]) WithModifyingPipelineFunc(fn func(ctx context.Context) mongo.Pipeline) *Coll[TData]

func (*Coll[TData]) WithUnmarshalHook ¶ added in v0.0.300

func (c *Coll[TData]) WithUnmarshalHook(fn func(d TData) TData) *Coll[TData]

type Cursorable ¶ added in v0.0.157

type Cursorable interface {
	Decode(v any) error
	Err() error
	Close(ctx context.Context) error
	All(ctx context.Context, results any) error
	RemainingBatchLength() int
	Next(ctx context.Context) bool
}

type Decodable ¶ added in v0.0.157

type Decodable interface {
	Decode(v any) error
}

type EntityID ¶ added in v0.0.135

type EntityID interface {
	MarshalBSONValue() (bsontype.Type, []byte, error)
	String() string
}

type IColl ¶ added in v0.0.397

type IColl interface {
	Collection() *mongo.Collection
	Name() string
	Indexes() mongo.IndexView
	Drop(ctx context.Context) error
}

Source Files ¶

View all Source files

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