adapters

Documentation

Index

• func CreateMongoClient(ctx context.Context, cfg *config.Config) *mongo.Client
• func CreatePostgresClient(ctx context.Context, cfg *config.Config) *gorm.DB
• func CreateRedisClient(ctx context.Context, cfg *config.Config) *redis.Client
• func CreateSentry(cfg *config.Config) error
• func NewKafkaConn(cfg *config.Config) (*kafka.Conn, error)
• type Adapter

Functions

func CreateMongoClient

func CreateMongoClient(ctx context.Context, cfg *config.Config) *mongo.Client

func CreatePostgresClient

func CreatePostgresClient(ctx context.Context, cfg *config.Config) *gorm.DB

func CreateRedisClient

func CreateRedisClient(ctx context.Context, cfg *config.Config) *redis.Client

func CreateSentry

func CreateSentry(cfg *config.Config) error

func NewKafkaConn

func NewKafkaConn(cfg *config.Config) (*kafka.Conn, error)

Types

type Adapter

type Adapter interface {
	CreateClient(ctx context.Context, options *models.DBOptions) interface{}
}