wmo

package

v0.0.166 Latest Latest Go to latest Published: Jun 19, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gogs.mikescher.com/BlackForestBytes/goext

Documentation ¶

Index ¶

func CreatePagination[TData any](coll *Coll[TData], token ct.CursorToken, fieldPrimary string, ...) ([]bson.D, error)
type Coll
- func W[TData any](collection *mongo.Collection) *Coll[TData]
type Cursorable
type Decodable
type EntityID

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreatePagination ¶

func CreatePagination[TData any](coll *Coll[TData], token ct.CursorToken, fieldPrimary string, sortPrimary ct.SortDirection, fieldSecondary *string, sortSecondary *ct.SortDirection, pageSize *int) ([]bson.D, error)

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]) 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.Filter) (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]) InsertOne ¶ added in v0.0.138

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

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]) Name ¶

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

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]

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
}

Source Files ¶

View all Source files

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