database

Documentation

Index

• Variables
• func ConnectES(ctx context.Context, foreverLoopDelay time.Duration) error
• func ConnectSQL() error
• func GetEsConn(ctx context.Context, foreverLoopDelay time.Duration) (*elastic.Client, error)
• type Config
• type ConfigEs

Variables

var (
	DbConn *sql.DB
)

DbConn stores the connexion to the database

var EsConn *elastic.Client

EsConn stores ES client

Functions

func ConnectES

func ConnectES(ctx context.Context, foreverLoopDelay time.Duration) error

ConnectES creates a new ES client and stores it

func ConnectSQL

func ConnectSQL() error

ConnectSQL connection to database

func GetEsConn

func GetEsConn(ctx context.Context, foreverLoopDelay time.Duration) (*elastic.Client, error)

GetEsConn returns the es client connexion.

Types

type Config

type Config struct {
	DbHost     string `env:"DB_HOST"`
	DbName     string `env:"MYSQL_DATABASE"`
	DbUser     string `env:"MYSQL_USER"`
	DbPassword string `env:"MYSQL_PASSWORD"`
	DbConn     *sql.DB
}

Config for DB connection

type ConfigEs

type ConfigEs struct {
	URL string `env:"ES_URL"`
}

ConfigEs to configure ES client