db

Documentation

Index

• Variables
• type MongoDB
  • func ConnectMongoDB() (*MongoDB, error)
  • func (db *MongoDB) FetchDataFromMongoDB(startTime time.Time, endTime time.Time, minCount int, maxCount int) ([]models.FetchRecordsArrayModel, string, int)
• type RedisDatabase
  • func NewRedisDatabase() (*RedisDatabase, error)
  • func (db *RedisDatabase) GetKeyFromRedis(key string) ([]byte, int)
  • func (db *RedisDatabase) InsertKeyToRedis(key string, value string) string

Variables

var (
	Ctx = context.TODO()
)

Types

type MongoDB

type MongoDB struct {
	MongoClient *mongo.Client
}

func ConnectMongoDB

func ConnectMongoDB() (*MongoDB, error)

Create a mongodb clients

func (*MongoDB) FetchDataFromMongoDB

func (db *MongoDB) FetchDataFromMongoDB(startTime time.Time, endTime time.Time, minCount int, maxCount int) ([]models.FetchRecordsArrayModel, string, int)

Fetches data from MongoDB

type RedisDatabase

type RedisDatabase struct {
	Client *redis.Client
}

func NewRedisDatabase

func NewRedisDatabase() (*RedisDatabase, error)

Creates a new redis client

func (*RedisDatabase) GetKeyFromRedis

func (db *RedisDatabase) GetKeyFromRedis(key string) ([]byte, int)

Gets the value using its key from redis

func (*RedisDatabase) InsertKeyToRedis

func (db *RedisDatabase) InsertKeyToRedis(key string, value string) string

Insert a key value pair to redis