database

Documentation

Index

• func GetMongo() *mgo.Session
• func GetPostgreDb(postgre PostgreSystem) *sqlx.DB
• func SystemConnection() map[string]interface{}
• type MongoHost
  • func (m *MongoHost) Connect() *mgo.Session
• type PostgreHost
  • func (p *PostgreHost) Connect() *sqlx.DB
  • func (p PostgreHost) Init()
• type PostgreSystem
• type RedisHost
  • func (self *RedisHost) Connect() (*redis.Client, error)
• type RedisSytem

Functions

func GetMongo

func GetMongo() *mgo.Session

func GetPostgreDb

func GetPostgreDb(postgre PostgreSystem) *sqlx.DB

func SystemConnection

func SystemConnection() map[string]interface{}

we create different types of databse connection here.

Types

type MongoHost

type MongoHost struct {
	Host string
	Port string
}

func (*MongoHost) Connect

func (m *MongoHost) Connect() *mgo.Session

type PostgreHost

type PostgreHost struct {
	Driver   string
	Database string
	Username string
	Ssl      string
	Password string
}

func (*PostgreHost) Connect

func (p *PostgreHost) Connect() *sqlx.DB

func (PostgreHost) Init

func (p PostgreHost) Init()

type PostgreSystem

type PostgreSystem interface {
	Init()
	Connect() *sqlx.DB
}

type RedisHost

type RedisHost struct {
	Address  string
	Password string
	DB       int
}

func (*RedisHost) Connect

func (self *RedisHost) Connect() (*redis.Client, error)

connect to Redis and return the connection if succesful and error if otherwise

type RedisSytem

type RedisSytem interface {
	Connect() (*redis.Client, error)
}