lib

Documentation

Index

• func NewLib() database.Database
• type Modules
  • func (c *Modules) Init(lo logger.Logger)
  • func (c *Modules) LoadEmbedded(config database.EmbeddedOptions) database.Embedded
  • func (c *Modules) LoadKafka(tag string, config database.KafkaProviderConfig) database.Kafka
  • func (c *Modules) LoadRabbitMQ(tag string, config database.RabbitMQProviderConfig) database.RabbitMQ
  • func (c *Modules) LoadRedis(tag string, config database.RedisProviderConfig) database.Redis
  • func (c *Modules) LoadSQL(tag string, config database.SQLConfig) database.SQL
  • func (c *Modules) SetTracer(tr tracing.Tracing)

Functions

func NewLib

func NewLib() database.Database

Types

type Modules

type Modules struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Modules) Init

func (c *Modules) Init(lo logger.Logger)

func (*Modules) LoadEmbedded

func (c *Modules) LoadEmbedded(config database.EmbeddedOptions) database.Embedded

func (*Modules) LoadKafka

func (c *Modules) LoadKafka(tag string, config database.KafkaProviderConfig) database.Kafka

func (*Modules) LoadRabbitMQ

func (c *Modules) LoadRabbitMQ(tag string, config database.RabbitMQProviderConfig) database.RabbitMQ

func (*Modules) LoadRedis

func (c *Modules) LoadRedis(tag string, config database.RedisProviderConfig) database.Redis

func (*Modules) LoadSQL

func (c *Modules) LoadSQL(tag string, config database.SQLConfig) database.SQL

func (*Modules) SetTracer

func (c *Modules) SetTracer(tr tracing.Tracing)