mongo

Documentation

Index

• func HandleEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})
• func HandleGreaterThan(pipeline *[]bson.M, fieldName string, fieldValue interface{})
• func HandleGreaterThanEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})
• func HandleLessThan(pipeline *[]bson.M, fieldName string, fieldValue interface{})
• func HandleLessThanEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})
• func HandleNotEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})
• type DBClient
• type EmployeeDetails
• type MockMongoClient
  • func NewMockMongoClient(mongo *mongo.Client, database string) MockMongoClient
• type MockMongoClientStruct
  • func (c *MockMongoClientStruct) GetAllDataFromMongo() []EmployeeDetails
  • func (c *MockMongoClientStruct) QueryMongo(pipeline []Queries) (Result, error)
• type Mongo
  • func (c *Mongo) CreateConnection() (*mongo.Client, error)
  • func (c *Mongo) CreateTestData()
  • func (c *Mongo) GetAllDataFromMongo() []EmployeeDetails
  • func (c *Mongo) QueryMongo(pipeline []Queries) (Result, error)
• type Queries
• type Result

Functions

func HandleEquals

func HandleEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})

Parse the == into equivalent mongo query.

func HandleGreaterThan

func HandleGreaterThan(pipeline *[]bson.M, fieldName string, fieldValue interface{})

Parse the > into equivalent mongo query.

func HandleGreaterThanEquals

func HandleGreaterThanEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})

Parse the >= into equivalent mongo query.

func HandleLessThan

func HandleLessThan(pipeline *[]bson.M, fieldName string, fieldValue interface{})

Parse the < into equivalent mongo query.

func HandleLessThanEquals

func HandleLessThanEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})

Parse the <= into equivalent mongo query.

func HandleNotEquals

func HandleNotEquals(pipeline *[]bson.M, fieldName string, fieldValue interface{})

Parse the != into equivalent mongo query.

Types

type DBClient

type DBClient interface {
	QueryMongo(pipeline []Queries) (Result, error)
	GetAllDataFromMongo() []EmployeeDetails
}

type EmployeeDetails

type EmployeeDetails struct {
	Name        string
	Designation string
	Salary      int64
	Email       string
	Mobile      string
	Manager     string
}

type MockMongoClient

type MockMongoClient interface {
	QueryMongo(pipeline []Queries) (Result, error)
	GetAllDataFromMongo() []EmployeeDetails
}

func NewMockMongoClient

func NewMockMongoClient(mongo *mongo.Client, database string) MockMongoClient

type MockMongoClientStruct

type MockMongoClientStruct struct {
	Mongo         *mongo.Client
	Database      string
	ClientOptions *options.ClientOptions
	Logger        *zap.Logger
}

func (*MockMongoClientStruct) GetAllDataFromMongo

func (c *MockMongoClientStruct) GetAllDataFromMongo() []EmployeeDetails

func (*MockMongoClientStruct) QueryMongo

func (c *MockMongoClientStruct) QueryMongo(pipeline []Queries) (Result, error)

type Mongo

type Mongo struct {
	Mongo         *mongo.Client
	Database      string
	ClientOptions *options.ClientOptions
	Logger        *zap.Logger
}

func (*Mongo) CreateConnection

func (c *Mongo) CreateConnection() (*mongo.Client, error)

Create a connection with mongo DB.

func (*Mongo) CreateTestData

func (c *Mongo) CreateTestData()

func (*Mongo) GetAllDataFromMongo

func (c *Mongo) GetAllDataFromMongo() []EmployeeDetails

Fetches all the employees data from mongo DB.

func (*Mongo) QueryMongo

func (c *Mongo) QueryMongo(pipeline []Queries) (Result, error)

Queries the mongo DB

type Queries

type Queries struct {
	Pipeline bson.M
}

type Result

type Result struct {
	Defined bool
	Data    []EmployeeDetails
}

Result contains output of partially evaluating a query.