internal

package

v0.0.0-...-4b6ff60 Latest Latest Go to latest Published: Feb 20, 2026 License: MIT Imports: 18 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func NewElasticSearch(_ *envvar.Configuration) (es *esv7.Client, err error)

NewElasticSearch instantiates the ElasticSearch client using configuration defined in environment variables.

func NewMemcached(conf *envvar.Configuration) (*memcache.Client, error)

func NewPostgreSQL(conf *envvar.Configuration) (*pgxpool.Pool, error)

NewPostgreSQL instantiates the PostgreSQL database using configuration defined in environment variables.

func NewRedis(conf *envvar.Configuration) (*redis.Client, error)

NewRedis instantiates the Redis client using configuration defined in environment variables.

func NewVaultProvider() (*vault.Provider, error)

NewVaultProvider instantiates the Vault client using configuration defined in environment variables.

type KafkaConsumer struct {
	Consumer *kafka.Consumer
}

KafkaConsumer is the consumer implementation of Kafka.

func NewKafkaConsumer(conf *envvar.Configuration, groupID string) (*KafkaConsumer, error)

NewKafkaConsumer instantiates the Kafka consumer using configuration defined in environment variables.

type KafkaProducer struct {
	Producer *kafka.Producer
	Topic    string
}

KafkaConsumer is the producer implementation of Kafka.

func NewKafkaProducer(conf *envvar.Configuration) (*KafkaProducer, error)

NewKafkaProducer instantiates the Kafka producer using configuration defined in environment variables.

type RabbitMQ struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

RabbitMQ ...

func NewRabbitMQ(conf *envvar.Configuration) (*RabbitMQ, error)

NewRabbitMQ instantiates the RabbitMQ instances using configuration defined in environment variables.

func (r *RabbitMQ) Close() error

Close ...