internal

Documentation

Index

• func NewElasticSearch(conf *envvar.Configuration) (es *esv7.Client, err error)
• func NewMemcached(conf *envvar.Configuration) (*memcache.Client, error)
• func NewOTExporter(conf *envvar.Configuration) (*prometheus.Exporter, error)
• func NewPostgreSQL(conf *envvar.Configuration) (*pgxpool.Pool, error)
• func NewRedis(conf *envvar.Configuration) (*redis.Client, error)
• func NewVaultProvider() (*vault.Provider, error)
• type KafkaConsumer
  • func NewKafkaConsumer(conf *envvar.Configuration, groupID string) (*KafkaConsumer, error)
• type KafkaProducer
  • func NewKafkaProducer(conf *envvar.Configuration) (*KafkaProducer, error)
• type RabbitMQ
  • func NewRabbitMQ(conf *envvar.Configuration) (*RabbitMQ, error)
  • func (r *RabbitMQ) Close()

Functions

func NewElasticSearch

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

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

func NewMemcached

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

func NewOTExporter

func NewOTExporter(conf *envvar.Configuration) (*prometheus.Exporter, error)

NewOTExporter instantiates the OpenTelemetry exporters using configuration defined in environment variables.

func NewPostgreSQL

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

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

func NewRedis

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

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

func NewVaultProvider

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

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

Types

type KafkaConsumer

type KafkaConsumer struct {
	Consumer *kafka.Consumer
}

func NewKafkaConsumer

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

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

type KafkaProducer

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

func NewKafkaProducer

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

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

type RabbitMQ

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

RabbitMQ ...

func NewRabbitMQ

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

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

func (*RabbitMQ) Close

func (r *RabbitMQ) Close()

Close ...