Documentation ¶
Index ¶
- type Adaptor
- func (adaptor *Adaptor) Connect(ctx context.Context, uri string)
- func (adaptor *Adaptor) GetDate() string
- func (adaptor *Adaptor) GetEventName(ctx context.Context, ID string, result *string) error
- func (adaptor *Adaptor) GetNameRecommendationByCallSign(ctx context.Context, callSign string) (string, error)
- func (adaptor *Adaptor) GetReportLog(ctx context.Context, request models.TRequestCallSignReport, ...) error
- func (adaptor *Adaptor) Modeling(jsonByte *[]byte, collName string) error
- func (adaptor *Adaptor) Pagination(docLimit, page, totalDoc int64, opt *options.FindOptions) int64
- func (adaptor *Adaptor) ParseCertificateFormat(certificateAttribute *models.CertificateAttribute)
- func (adaptor *Adaptor) ParseOptions(payload models.Payload, options *options.FindOptions)
- func (adaptor *Adaptor) ParsePayload(jsonByte []byte, out interface{}, c *gin.Context)
- func (adaptor *Adaptor) QueryConfirm(ctx context.Context, collName, key, value string) bool
- func (adaptor *Adaptor) QueryCount(ctx context.Context, collName string, query bson.M) (int64, error)
- func (adaptor *Adaptor) QueryCreateCollection(ctx context.Context, collName string) error
- func (adaptor *Adaptor) QueryEventCounterValue(ctx context.Context, id, frequency string, countResult *int) error
- func (adaptor *Adaptor) QueryFind(ctx context.Context, collName string, byteQuery []byte) ([]byte, error)
- func (adaptor *Adaptor) QueryFindAndUpdate(ctx context.Context, collName string, queryFilter bson.M, setQuery bson.M, ...) (int64, error)
- func (adaptor *Adaptor) QueryFindAndUpdateV2(ctx context.Context, collName string, ...) error
- func (adaptor *Adaptor) QueryFindMany(ctx context.Context, collName string, byteQuery []byte, ...) ([]byte, error)
- func (adaptor *Adaptor) QueryFindManyV2(ctx context.Context, collName string, findOptions *options.FindOptions, ...) error
- func (adaptor *Adaptor) QueryFindV2(ctx context.Context, collName string, findOneOptions *options.FindOneOptions, ...) error
- func (adaptor *Adaptor) QueryIncreaseEventCounter(ctx context.Context, id, frequency string) (bool, error)
- func (adaptor *Adaptor) QueryInsert(ctx context.Context, collName string, byteQuery []byte) (interface{}, error)
- func (adaptor *Adaptor) QueryInsertV2(ctx context.Context, collName string, query interface{}, result interface{}) error
- func (adaptor *Adaptor) QueryInsertV3(ctx context.Context, collName string, query interface{}) (*mongo.InsertOneResult, error)
- func (adaptor *Adaptor) QueryRemoveMany(ctx context.Context, collName string, queryFilter interface{}) (int64, error)
- func (adaptor *Adaptor) QueryRemoveOne(ctx context.Context, collName string, queryFilter interface{}) (int64, error)
- func (adaptor *Adaptor) QuerySetIdentityCounter(ctx context.Context, count int, callSign, frequency string, mode ...string) (bool, error)
- func (adaptor *Adaptor) QueryUpdateMany(ctx context.Context, collName string, filterQuery bson.M, updateQuery bson.M) error
- func (adaptor *Adaptor) QueryUpdateOne(ctx context.Context, collName string, updateOpt *options.UpdateOptions, ...) error
- func (adaptor *Adaptor) SetDownloadLog(ctx context.Context, downloadLogData models.DownloadLog) error
- type Parser
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Adaptor ¶
Adaptor Type
func (*Adaptor) GetEventName ¶
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) 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 ¶
ParsePayload method
func (*Adaptor) QueryConfirm ¶
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 ¶
QueryCreateCollection create collection in mongodb
func (*Adaptor) QueryEventCounterValue ¶
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) 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) 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