database

Apr 20, 2026

Changes in this version

type NamedRedisRegistry

+ func (r *NamedRedisRegistry) Profiles() []redisruntime.RedisProfile

type RedisConnection

+ func (r *RedisConnection) Client() goredis.UniversalClient

+ func (r *RedisConnection) Config() *RedisConfig

Apr 18, 2026

Changes in this version

type RedisProfileStatus

+ NextRetryAt time.Time

Apr 17, 2026

Changes in this version

type NamedRedisRegistry

+ func (r *NamedRedisRegistry) ProfileStatus(name string) RedisProfileStatus

+ func (r *NamedRedisRegistry) ProfileStatuses() map[string]RedisProfileStatus

+ type RedisProfileState string

+ const RedisProfileStateAvailable

+ const RedisProfileStateMissing

+ const RedisProfileStateUnavailable

+ type RedisProfileStatus struct

+ Err error

+ Name string

+ State RedisProfileState

Apr 17, 2026

Changes in this version

+ type NamedRedisRegistry struct

+ func NewNamedRedisRegistry(defaultConfig *RedisConfig, profiles map[string]*RedisConfig) *NamedRedisRegistry

+ func (r *NamedRedisRegistry) Close() error

+ func (r *NamedRedisRegistry) Connect() error

+ func (r *NamedRedisRegistry) GetClient(name string) (goredis.UniversalClient, error)

+ func (r *NamedRedisRegistry) GetConnection(name string) (*RedisConnection, error)

+ func (r *NamedRedisRegistry) HasConnections() bool

+ func (r *NamedRedisRegistry) HealthCheck(ctx context.Context) error

Apr 16, 2026

Changes in this version

type MongoConfig

+ DirectConnection bool

+ LogCommandDetail bool

+ LogReplyDetail bool

+ LogStarted bool

+ ReplicaSet string

Jan 13, 2026

Changes in this version

type RedisConfig

+ DialTimeout int

+ MinIdleConns int

+ PoolTimeout int

+ ReadTimeout int

+ WriteTimeout int

Dec 11, 2025

Changes in this version

type MongoConfig

+ EnableLogger bool

+ SlowThreshold time.Duration

Dec 3, 2025

Changes in this version

type MongoConfig

+ Database string

+ Host string

+ Password string

+ Username string

+ func (c *MongoConfig) BuildURL() string

Nov 24, 2025

Changes in this version

type RedisConfig

+ Username string

Nov 16, 2025

Changes in this version

+ type DatabaseConnection interface

+ Close func() error

+ Connect func() error

+ GetClient func() interface{}

+ HealthCheck func(ctx context.Context) error

+ Type func() DatabaseType

+ type DatabaseType string

+ const MongoDB

+ const MySQL

+ const Redis

+ type MongoConfig struct

+ SSLAllowInvalidHostnames bool

+ SSLCAFile string

+ SSLInsecureSkipVerify bool

+ SSLPEMKeyfile string

+ URL string

+ UseSSL bool

+ type MongoDBConnection struct

+ func NewMongoDBConnection(config *MongoConfig) *MongoDBConnection

+ func (m *MongoDBConnection) Close() error

+ func (m *MongoDBConnection) Connect() error

+ func (m *MongoDBConnection) GetClient() interface{}

+ func (m *MongoDBConnection) HealthCheck(ctx context.Context) error

+ func (m *MongoDBConnection) Type() DatabaseType

+ type MySQLConfig struct

+ Database string

+ Host string

+ LogLevel int

+ Logger logger.Interface

+ MaxConnectionLifeTime time.Duration

+ MaxIdleConnections int

+ MaxOpenConnections int

+ Password string

+ Username string

+ type MySQLConnection struct

+ func NewMySQLConnection(config *MySQLConfig) *MySQLConnection

+ func (m *MySQLConnection) Close() error

+ func (m *MySQLConnection) Connect() error

+ func (m *MySQLConnection) GetClient() interface{}

+ func (m *MySQLConnection) HealthCheck(ctx context.Context) error

+ func (m *MySQLConnection) Type() DatabaseType

+ type RedisConfig struct

+ Addrs []string

+ Database int

+ EnableCluster bool

+ Host string

+ MaxActive int

+ MaxIdle int

+ Password string

+ Port int

+ SSLInsecureSkipVerify bool

+ Timeout int

+ UseSSL bool

+ type RedisConnection struct

+ func NewRedisConnection(config *RedisConfig) *RedisConnection

+ func (r *RedisConnection) Close() error

+ func (r *RedisConnection) Connect() error

+ func (r *RedisConnection) GetClient() interface{}

+ func (r *RedisConnection) HealthCheck(ctx context.Context) error

+ func (r *RedisConnection) Type() DatabaseType

Oct 27, 2025

Changes in this version

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Close() error

+ func (r *Registry) GetClient(dbType connecter.DatabaseType) (interface{}, error)

+ func (r *Registry) GetConnection(dbType connecter.DatabaseType) (connecter.DatabaseConnection, error)

+ func (r *Registry) HealthCheck(ctx context.Context) error

+ func (r *Registry) Init() error

+ func (r *Registry) Register(dbType connecter.DatabaseType, config interface{}, ...) error