connector

Documentation

Index

• Variables
• func CloseMongoConn() *error
• func CloseRabbitMQConn()
• func CloseRedisConn() error
• func GetESClient() *elasticsearch.Client
• func GetMongoDBClient() (*mongo.Client, error)
• func GetRdbmsDB() *gorm.DB
• func GetRedisClient() (*redis.Client, error)
• func InitBinanceConn(config config.BinanceConfig) error
• func InitESConnection(config config.ElasticConfig) *error
• func InitMongoDBConn(config config.MongoConfig) error
• func InitRabbitMQConn(config config.RabbitMQConfig) error
• func InitRdbmsDB(config config.RDBMSConfig) *gorm.DB
• func InitRedisConn(config config.RedisConfig) error
• func OpenCollection(config config.MongoConfig, collectionName string) (*mongo.Collection, error)
• func PingMongoConn(config config.MongoConfig) error
• func PingRedisConn() error

Variables

var BinanceClient *binance.Client

Redis global variable for access

var DB *gorm.DB

DB global variable to access gorm

var EsClient *elasticsearch.Client

Elastic search global variable for access

var RabbitMQConn *amqp.Connection

Functions

func CloseMongoConn

func CloseMongoConn() *error

func CloseRabbitMQConn

func CloseRabbitMQConn()

func CloseRedisConn

func CloseRedisConn() error

func GetESClient

func GetESClient() *elasticsearch.Client

func GetMongoDBClient

func GetMongoDBClient() (*mongo.Client, error)

func GetRdbmsDB

func GetRdbmsDB() *gorm.DB

GetRdbmsDB - get a connection

func GetRedisClient

func GetRedisClient() (*redis.Client, error)

func InitBinanceConn

func InitBinanceConn(config config.BinanceConfig) error

func InitESConnection

func InitESConnection(config config.ElasticConfig) *error

func InitMongoDBConn

func InitMongoDBConn(config config.MongoConfig) error

func InitRabbitMQConn

func InitRabbitMQConn(config config.RabbitMQConfig) error

func InitRdbmsDB

func InitRdbmsDB(config config.RDBMSConfig) *gorm.DB

InitRdbmsDB - function to initialize db

func InitRedisConn

func InitRedisConn(config config.RedisConfig) error

func OpenCollection

func OpenCollection(config config.MongoConfig, collectionName string) (*mongo.Collection, error)

func PingMongoConn

func PingMongoConn(config config.MongoConfig) error

func PingRedisConn

func PingRedisConn() error