handlers

Documentation

Index

• type ClickHouse
• type ClickHouseHandler
  • func (h *ClickHouseHandler) GetClickHouse() (ch clickhouse.Conn, err error)
  • func (h *ClickHouseHandler) ShutdownClickHouse() (err error)
• type Kafka
• type KafkaHandler
  • func (h *KafkaHandler) GetKafka(group string) (kafka *kgo.Client, err error)
  • func (h *KafkaHandler) ShutdownKafka() (err error)
• type Postgres
• type PostgresHandler
  • func (h *PostgresHandler) GetPostgres() (db *gorm.DB, err error)
  • func (h *PostgresHandler) ShutdownPostgres() (err error)
• type Redis
• type RedisHandler
  • func (h *RedisHandler) GetRedis() redis.UniversalClient
  • func (h *RedisHandler) ShutdownRedis() (err error)
• type YandexDB
• type YandexDBHandler
  • func (h *YandexDBHandler) GetYandexDB(ctx context.Context) (db *ydb.Driver, err error)
  • func (h *YandexDBHandler) ShutdownYandexDB(ctx context.Context) (err error)

Types

type ClickHouse

type ClickHouse interface {
	GetClickHouse() (clickhouse.Conn, error)
	ShutdownClickHouse() error
}

type ClickHouseHandler

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

func (*ClickHouseHandler) GetClickHouse

func (h *ClickHouseHandler) GetClickHouse() (ch clickhouse.Conn, err error)

func (*ClickHouseHandler) ShutdownClickHouse

func (h *ClickHouseHandler) ShutdownClickHouse() (err error)

type Kafka

type Kafka interface {
	GetKafka(string) (*kgo.Client, error)
	ShutdownKafka() error
}

type KafkaHandler

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

func (*KafkaHandler) GetKafka

func (h *KafkaHandler) GetKafka(group string) (kafka *kgo.Client, err error)

func (*KafkaHandler) ShutdownKafka

func (h *KafkaHandler) ShutdownKafka() (err error)

type Postgres

type Postgres interface {
	GetPostgres() (*gorm.DB, error)
	ShutdownPostgres() error
}

type PostgresHandler

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

func (*PostgresHandler) GetPostgres

func (h *PostgresHandler) GetPostgres() (db *gorm.DB, err error)

func (*PostgresHandler) ShutdownPostgres

func (h *PostgresHandler) ShutdownPostgres() (err error)

type Redis

type Redis interface {
	GetRedis() redis.UniversalClient
	ShutdownRedis() error
}

type RedisHandler

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

func (*RedisHandler) GetRedis

func (h *RedisHandler) GetRedis() redis.UniversalClient

func (*RedisHandler) ShutdownRedis

func (h *RedisHandler) ShutdownRedis() (err error)

type YandexDB

type YandexDB interface {
	GetYandexDB() (*ydb.Driver, error)
	ShutdownYandexDB() error
}

type YandexDBHandler

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

func (*YandexDBHandler) GetYandexDB

func (h *YandexDBHandler) GetYandexDB(ctx context.Context) (db *ydb.Driver, err error)

func (*YandexDBHandler) ShutdownYandexDB

func (h *YandexDBHandler) ShutdownYandexDB(ctx context.Context) (err error)