connector

Documentation

Index

• Variables
• func CloseMongoConn() *error
• func CloseRabbitMQConn() *error
• func CloseRedisConn() error
• func GetESClient() *elasticsearch.Client
• func GetMongoDBClient() (*mongo.Client, error)
• func GetRdbmsDB() *gorm.DB
• func GetRedisClient() (*redis.Client, error)
• func InitBinanceConn() error
• func InitESConnection() *error
• func InitMongoDBConn() error
• func InitRabbitMQConn() *error
• func InitRdbmsDB() *gorm.DB
• func InitRedisConn() error
• func OpenCollection(collectionName string) (*mongo.Collection, error)
• func PingMongoConn() 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

Redis global variable for access

Functions

func CloseMongoConn

func CloseMongoConn() *error

func CloseRabbitMQConn

func CloseRabbitMQConn() *error

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() error

func InitESConnection

func InitESConnection() *error

func InitMongoDBConn

func InitMongoDBConn() error

func InitRabbitMQConn

func InitRabbitMQConn() *error

func InitRdbmsDB

func InitRdbmsDB() *gorm.DB

InitRdbmsDB - function to initialize db

func InitRedisConn

func InitRedisConn() error

func OpenCollection

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

func PingMongoConn

func PingMongoConn() error

func PingRedisConn

func PingRedisConn() error