gomongo

package module
v0.0.0-...-5db6f32 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2021 License: GPL-3.0 Imports: 16 Imported by: 0

README

gomongo

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Adaptor

type Adaptor struct {
	Client mongo.Client
	DBName string
}

Adaptor Type

func (*Adaptor) Connect

func (adaptor *Adaptor) Connect(ctx context.Context, uri string)

Connect method

func (*Adaptor) GetDate

func (adaptor *Adaptor) GetDate() string

GetDate method

func (*Adaptor) GetEventName

func (adaptor *Adaptor) GetEventName(ctx context.Context, ID string, result *string) error

func (*Adaptor) GetNameRecommendationByCallSign

func (adaptor *Adaptor) GetNameRecommendationByCallSign(ctx context.Context, callSign string) (string, error)

GetNameRecommendation method

func (*Adaptor) GetReportLog

func (adaptor *Adaptor) GetReportLog(ctx context.Context, request models.TRequestCallSignReport, results *[]models.TResponseCallSignReport) error

func (*Adaptor) Modeling

func (adaptor *Adaptor) Modeling(jsonByte *[]byte, collName string) error

Modeling filler

func (*Adaptor) Pagination

func (adaptor *Adaptor) Pagination(docLimit, page, totalDoc int64, opt *options.FindOptions) int64

func (*Adaptor) ParseCertificateFormat

func (adaptor *Adaptor) ParseCertificateFormat(certificateAttribute *models.CertificateAttribute)

ParseCertificateFormat

func (*Adaptor) ParseOptions

func (adaptor *Adaptor) ParseOptions(payload models.Payload, options *options.FindOptions)

ParseOptions method

func (*Adaptor) ParsePayload

func (adaptor *Adaptor) ParsePayload(jsonByte []byte, out interface{}, c *gin.Context)

ParsePayload method

func (*Adaptor) QueryConfirm

func (adaptor *Adaptor) QueryConfirm(ctx context.Context, collName, key, value string) bool

QueryConfirm method

func (*Adaptor) QueryCount

func (adaptor *Adaptor) QueryCount(ctx context.Context, collName string, query bson.M) (int64, error)

QueryCount query find to mongodb

func (*Adaptor) QueryCreateCollection

func (adaptor *Adaptor) QueryCreateCollection(ctx context.Context, collName string) error

QueryCreateCollection create collection in mongodb

func (*Adaptor) QueryEventCounterValue

func (adaptor *Adaptor) QueryEventCounterValue(ctx context.Context, id, frequency string, countResult *int) error

func (*Adaptor) QueryFind

func (adaptor *Adaptor) QueryFind(ctx context.Context, collName string, byteQuery []byte) ([]byte, error)

QueryFind query find to mongodb

func (*Adaptor) QueryFindAndUpdate

func (adaptor *Adaptor) QueryFindAndUpdate(ctx context.Context, collName string, queryFilter bson.M, setQuery bson.M, setOnInsertQuery bson.M) (int64, error)

QueryFindAndUpdate method

func (*Adaptor) QueryFindAndUpdateV2

func (adaptor *Adaptor) QueryFindAndUpdateV2(ctx context.Context, collName string, findAndUpdateOpt *options.FindOneAndUpdateOptions, filterQuery interface{}, updateQuery interface{}, result interface{}) error

QueryFindAndUpdateV2 method

updateQuery := bson.M{
		"$set":         setQuery,
		"$setOnInsert": setOnInsertQuery,
	}

func (*Adaptor) QueryFindMany

func (adaptor *Adaptor) QueryFindMany(ctx context.Context, collName string, byteQuery []byte, findOptions *options.FindOptions) ([]byte, error)

QueryFindMany query find many to mongodb

func (*Adaptor) QueryFindManyV2

func (adaptor *Adaptor) QueryFindManyV2(ctx context.Context, collName string, findOptions *options.FindOptions, query interface{}, result interface{}) error

QueryFindManyV2 query find many to mongodb

func (*Adaptor) QueryFindV2

func (adaptor *Adaptor) QueryFindV2(ctx context.Context, collName string, findOneOptions *options.FindOneOptions, query interface{}, result interface{}) error

QueryFindV2 query find to mongodb

func (*Adaptor) QueryIncreaseEventCounter

func (adaptor *Adaptor) QueryIncreaseEventCounter(ctx context.Context, id, frequency string) (bool, error)

func (*Adaptor) QueryInsert

func (adaptor *Adaptor) QueryInsert(ctx context.Context, collName string, byteQuery []byte) (interface{}, error)

QueryInsert Query Insert to mongodb

func (*Adaptor) QueryInsertV2

func (adaptor *Adaptor) QueryInsertV2(ctx context.Context, collName string, query interface{}, result interface{}) error

QueryInsertV2 Query Insert to mongodb

func (*Adaptor) QueryInsertV3

func (adaptor *Adaptor) QueryInsertV3(ctx context.Context, collName string, query interface{}) (*mongo.InsertOneResult, error)

QueryInsertV2 Query Insert to mongodb

func (*Adaptor) QueryRemoveMany

func (adaptor *Adaptor) QueryRemoveMany(ctx context.Context, collName string, queryFilter interface{}) (int64, error)

QueryRemoveMany method

func (*Adaptor) QueryRemoveOne

func (adaptor *Adaptor) QueryRemoveOne(ctx context.Context, collName string, queryFilter interface{}) (int64, error)

QueryRemoveOne method

func (*Adaptor) QuerySetIdentityCounter

func (adaptor *Adaptor) QuerySetIdentityCounter(ctx context.Context, count int, callSign, frequency string, mode ...string) (bool, error)

func (*Adaptor) QueryUpdateMany

func (adaptor *Adaptor) QueryUpdateMany(ctx context.Context, collName string, filterQuery bson.M, updateQuery bson.M) error

QueryUpdateDocument method

func (*Adaptor) QueryUpdateOne

func (adaptor *Adaptor) QueryUpdateOne(ctx context.Context, collName string, updateOpt *options.UpdateOptions, filterQuery bson.M, updateQuery bson.M, result *mongo.UpdateResult) error

QueryUpdateOne method

func (*Adaptor) SetDownloadLog

func (adaptor *Adaptor) SetDownloadLog(ctx context.Context, downloadLogData models.DownloadLog) error

SetDownloadLog

type Parser

type Parser struct{}

Parser type

func (Parser) Parse

func (P Parser) Parse(in interface{}, out interface{}, toJSON bool)

Parse Method <out> type should have `bson` or `json` flag

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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