Documentation
¶
Index ¶
- Variables
- func GetTx(ctx context.Context) (*sql.Tx, error)
- type ContextKey
- type Data
- func (d *Data) Close() []error
- func (d *Data) ConsumeFromKafka(ctx context.Context, topic, groupID string, handler func([]byte) error) error
- func (d *Data) ConsumeFromRabbitMQ(queue string, handler func([]byte) error) error
- func (d *Data) DB() *sql.DB
- func (d *Data) DBRead() (*sql.DB, error)
- func (d *Data) GetDBManager() *connection2.DBManager
- func (d *Data) GetElasticsearch() *elastic.Client
- func (d *Data) GetMeilisearch() *meili.Client
- func (d *Data) GetMongoManager() *connection2.MongoManager
- func (d *Data) GetRedis() *redis.Client
- func (d *Data) Ping(ctx context.Context) error
- func (d *Data) PublishToKafka(ctx context.Context, topic string, key, value []byte) error
- func (d *Data) PublishToRabbitMQ(exchange, routingKey string, body []byte) error
- func (d *Data) WithTx(ctx context.Context, fn func(ctx context.Context) error) error
- func (d *Data) WithTxRead(ctx context.Context, fn func(ctx context.Context) error) error
- type Option
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrRabbitMQNotInitialized = errors.New("RabbitMQ service not initialized") ErrKafkaNotInitialized = errors.New("kafka service not initialized") )
Functions ¶
Types ¶
type ContextKey ¶
type ContextKey string
const ( // ContextKeyTransaction is context key ContextKeyTransaction ContextKey = "tx" )
type Data ¶
type Data struct {
Conn *connection2.Connections
RabbitMQ *rabbitmq.RabbitMQ
Kafka *kafka.Kafka
}
Data represents the data layer implementation
func (*Data) ConsumeFromKafka ¶
func (d *Data) ConsumeFromKafka(ctx context.Context, topic, groupID string, handler func([]byte) error) error
ConsumeFromKafka consumes messages from Kafka
func (*Data) ConsumeFromRabbitMQ ¶
ConsumeFromRabbitMQ consumes messages from RabbitMQ
func (*Data) GetDBManager ¶
func (d *Data) GetDBManager() *connection2.DBManager
GetDBManager get database manager
func (*Data) GetElasticsearch ¶
GetElasticsearch get elasticsearch
func (*Data) GetMeilisearch ¶
GetMeilisearch get meilisearch
func (*Data) GetMongoManager ¶
func (d *Data) GetMongoManager() *connection2.MongoManager
GetMongoManager get mongo manager
func (*Data) PublishToKafka ¶
PublishToKafka publishes message to Kafka
func (*Data) PublishToRabbitMQ ¶
PublishToRabbitMQ publishes message to RabbitMQ
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.