connection

type CacheDriver interface {
	Name() string
	Connect(ctx context.Context, cfg any) (any, error)
	Close(conn any) error
	Ping(ctx context.Context, conn any) error
}

type Connections struct {
	DBM *DBManager
	RC  any
	MS  any
	ES  any
	OS  any
	MGM any
	Neo any
	RMQ any
	KFK any
	// contains filtered or unexported fields
}

type DBManager struct {
	// contains filtered or unexported fields
}

type DatabaseDriver interface {
	Name() string
	Connect(ctx context.Context, cfg any) (any, error)
	Close(conn any) error
	Ping(ctx context.Context, conn any) error
}

type DriverRegistry interface {
	GetDatabaseDriver(name string) (DatabaseDriver, error)
	GetCacheDriver(name string) (CacheDriver, error)
	GetSearchDriver(name string) (SearchDriver, error)
	GetMessageDriver(name string) (MessageDriver, error)
}

type LoadBalancer interface {
	Next([]*sql.DB) (*sql.DB, error)
}

type MessageDriver interface {
	Name() string
	Connect(ctx context.Context, cfg any) (any, error)
	Close(conn any) error
}

type RandomBalancer struct{}

type RoundRobinBalancer struct {
	// contains filtered or unexported fields
}

type SearchDriver interface {
	Name() string
	Connect(ctx context.Context, cfg any) (any, error)
	Close(conn any) error
}

type WeightBalancer struct {
	// contains filtered or unexported fields
}