mongo

Documentation

Index

• Constants
• func Close(client *mongo.Client, ctx context.Context, cancel context.CancelFunc)
• func Connect(uri string) (*mongo.Client, context.Context, context.CancelFunc, error)
• func HealthCheck(client *mongo.Client, ctx context.Context)
• func Ping(client *mongo.Client, ctx context.Context) bool
• func Query(client *mongo.Client, ctx context.Context, dataBase, col string, ...) (result *mongo.Cursor, err error)
• type ShopRepository
  • func NewShopRepository() ShopRepository

Constants

const (
	DATABASE   = "db"
	COLLECTION = "shop"
)

Functions

func Close

func Close(client *mongo.Client, ctx context.Context,
	cancel context.CancelFunc)

This is a user defined method to close resources. This method closes mongoDB connection and cancel context.

func Connect

func Connect(uri string) (*mongo.Client, context.Context,
	context.CancelFunc, error)

func HealthCheck

func HealthCheck(client *mongo.Client, ctx context.Context)

func Ping

func Ping(client *mongo.Client, ctx context.Context) bool

This is a user defined method that accepts mongo.Client and context.Context This method used to ping the mongoDB, return error if any.

func Query

func Query(client *mongo.Client, ctx context.Context,
	dataBase, col string, query, field interface{}) (result *mongo.Cursor, err error)

Types

type ShopRepository

type ShopRepository interface {
	Save(shop *model.Shop)
	FindAll() []*model.Shop
}

func NewShopRepository

func NewShopRepository() ShopRepository