conns

Documentation

Index

• Variables
• type Conns
  • func NewConns(logger *zap.Logger, elastic *elasticsearch.Client, ...) *Conns
  • func (c *Conns) Close()
  • func (c *Conns) GetDB() (*sqlx.DB, error)
  • func (c *Conns) GetElastic() (*elasticsearch.Client, error)
  • func (c *Conns) GetGoQuConn(nameConn string) (connectors.DBConnector[*goqu.Database, *goqu.TxDatabase], error)
  • func (c *Conns) GetKafka() (*kafka.Kafka, error)
  • func (c *Conns) GetPGXConnByName(nameConn string) (connectors.DBConnector[dbtypes.PgxConn, dbtypes.PgxTx], error)
  • func (c *Conns) GetSQLConn() (connectors.DBConnector[*sqlx.DB, *sqlx.Tx], error)
  • func (c *Conns) GetSQLConnByName(nameConn string) (connectors.DBConnector[*sqlx.DB, *sqlx.Tx], error)

Variables

var Module = types.Module{
	{CreateFunc: NewConns},
}.
	Append(postrgres.Module).
	Append(elastic.Module).
	Append(kafka.Module)

Types

type Conns

type Conns struct {
	// contains filtered or unexported fields
}

func NewConns

func NewConns(
	logger *zap.Logger,
	elastic *elasticsearch.Client,
	sqlxPoolDB map[string]*sqlx.DB,
	pgxPoolDB map[string]*pgxpool.Pool,
	sqlConns map[string]connectors.DBConnector[*sqlx.DB, *sqlx.Tx],
	goquConns map[string]connectors.DBConnector[*goqu.Database, *goqu.TxDatabase],
	pgxConns map[string]connectors.DBConnector[dbtypes.PgxConn, dbtypes.PgxTx],
	kafka *kafka.Kafka,
) *Conns

func (*Conns) Close

func (c *Conns) Close()

func (*Conns) GetDB

func (c *Conns) GetDB() (*sqlx.DB, error)

Deprecated: Use GetSQLConnByName instead

func (*Conns) GetElastic

func (c *Conns) GetElastic() (*elasticsearch.Client, error)

GetElastic возвращает клиент для работы с эластиком

func (*Conns) GetGoQuConn

func (c *Conns) GetGoQuConn(nameConn string) (connectors.DBConnector[*goqu.Database, *goqu.TxDatabase], error)

GetGoQuConn создает слой sql-builder'а для конструирования запросов в БД. Также он умеет делать scan в структуры

func (*Conns) GetKafka

func (c *Conns) GetKafka() (*kafka.Kafka, error)

GetKafka возвращает абстракцию над кафкой

func (*Conns) GetPGXConnByName

func (c *Conns) GetPGXConnByName(nameConn string) (connectors.DBConnector[dbtypes.PgxConn, dbtypes.PgxTx], error)

GetPGXConnByName возвращает коннект к бд, если он есть

func (*Conns) GetSQLConn

func (c *Conns) GetSQLConn() (connectors.DBConnector[*sqlx.DB, *sqlx.Tx], error)

Deprecated: Use GetSQLConnByName instead

func (*Conns) GetSQLConnByName

func (c *Conns) GetSQLConnByName(nameConn string) (connectors.DBConnector[*sqlx.DB, *sqlx.Tx], error)

GetSQLConnByName возвращает коннект к бд, если он есть