lxDb

Documentation

Index

• Constants
• func GetMongoDbClient(uri string) (client *mongo.Client, err error)
• func ToBsonDoc(v interface{}) (doc *bson.D, err error)
• func ToBsonMap(v interface{}) (doc bson.M, err error)
• type AuditAuth
• type IBaseRepo
  • func NewMongoBaseRepo(collection *mongo.Collection, baseRepoAudit ...IBaseRepoAudit) IBaseRepo
• type IBaseRepoAudit
• type NotFoundError
  • func NewNotFoundError(message ...interface{}) *NotFoundError
  • func (e *NotFoundError) Error() string
• type UpdateResult

Constants

const (
	DefaultTimeout = time.Second * 30
	Insert         = "insert"
	Update         = "update"
	Delete         = "delete"
)

Functions

func GetMongoDbClient

func GetMongoDbClient(uri string) (client *mongo.Client, err error)

GetMongoDbClient, return new mongo driver client

func ToBsonDoc

func ToBsonDoc(v interface{}) (doc *bson.D, err error)

ToBsonDoc, convert interface to bson.D

func ToBsonMap

func ToBsonMap(v interface{}) (doc bson.M, err error)

ToBsonMap, convert interface to bson.M

Types

type AuditAuth

type AuditAuth struct {
	User interface{}
}

AuthAudit, auth user for audit

type IBaseRepo

type IBaseRepo interface {
	InsertOne(doc interface{}, args ...interface{}) (interface{}, error)
	InsertMany(docs []interface{}, args ...interface{}) ([]interface{}, error)
	CountDocuments(filter interface{}, args ...interface{}) (int64, error)
	EstimatedDocumentCount(args ...interface{}) (int64, error)
	Find(filter interface{}, result interface{}, args ...interface{}) error
	FindOne(filter interface{}, result interface{}, args ...interface{}) error
	UpdateOne(filter interface{}, update interface{}, args ...interface{}) error
	UpdateMany(filter interface{}, update interface{}, args ...interface{}) (*UpdateResult, error)
	DeleteOne(filter interface{}, args ...interface{}) (int64, error)
	DeleteMany(filter interface{}, args ...interface{}) (int64, error)
}

IBaseRepo

func NewMongoBaseRepo

func NewMongoBaseRepo(collection *mongo.Collection, baseRepoAudit ...IBaseRepoAudit) IBaseRepo

NewMongoBaseRepo, return base repo instance

type IBaseRepoAudit

type IBaseRepoAudit interface {
	LogEntry(action string, user, data interface{}, timeout ...time.Duration) error
}

type NotFoundError

type NotFoundError struct {
	Message string
}

NotFoundError

func NewNotFoundError

func NewNotFoundError(message ...interface{}) *NotFoundError

NewApiPostError creates a new HTTPError instance.

func (*NotFoundError) Error

func (e *NotFoundError) Error() string

type UpdateResult

type UpdateResult struct {
	MatchedCount  int64
	ModifiedCount int64
	UpsertedCount int64
	UpsertedID    interface{}
}

UpdateResult