initialize

Documentation

Index

• func ConnectDB(databaseURL string) *sqlx.DB
• func ConnectGCS(cfg *config.Config) (*storage.Client, error)
• func NewKafkaProducer(brokers []string, clientID string) (*kgo.Client, error)
• func SetupRouter(handler transport.Handler) *gin.Engine

Functions

func ConnectDB

func ConnectDB(databaseURL string) *sqlx.DB

ConnectDBWithRetry establishes a connection to the database with retry logic

func ConnectGCS

func ConnectGCS(cfg *config.Config) (*storage.Client, error)

func NewKafkaProducer

func NewKafkaProducer(brokers []string, clientID string) (*kgo.Client, error)

func SetupRouter

func SetupRouter(handler transport.Handler) *gin.Engine

SetupRouter initializes the router and sets up the routes for the application.