databasex

Documentation

Index

• Variables
• func NewDB(ctx context.Context, options *Options) (*sql.DB, error)
• func NewDBs(ctx context.Context, config *Config) *lazyloadx.Group[*sql.DB]
• func NewGormDB(ctx context.Context, options *Options) (*gorm.DB, error)
• func NewGormDBs(ctx context.Context, config *Config) *lazyloadx.Group[*gorm.DB]
• func NewSqlxDB(ctx context.Context, options *Options) (*sqlx.DB, error)
• func NewSqlxDBs(ctx context.Context, config *Config) *lazyloadx.Group[*sqlx.DB]
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (x *Config) GetConfigs() map[string]*Options
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (x *Config) String() string
• type Options
  • func (*Options) Descriptor() ([]byte, []int)
  • func (x *Options) GetConnMaxIdleTime() *durationpb.Duration
  • func (x *Options) GetConnMaxLifetime() *durationpb.Duration
  • func (x *Options) GetDriverName() *wrapperspb.StringValue
  • func (x *Options) GetDsn() *wrapperspb.StringValue
  • func (x *Options) GetMaxIdleConns() *wrapperspb.Int32Value
  • func (x *Options) GetMaxOpenConns() *wrapperspb.Int32Value
  • func (x *Options) GetPingTimeout() *durationpb.Duration
  • func (*Options) ProtoMessage()
  • func (x *Options) ProtoReflect() protoreflect.Message
  • func (x *Options) Reset()
  • func (x *Options) String() string

Variables

var File_pkg_databasex_config_proto protoreflect.FileDescriptor

var Provider = wire.NewSet(
	NewDBs,
	NewSqlxDBs,
	NewGormDBs,
)

Functions

func NewDB

func NewDB(ctx context.Context, options *Options) (*sql.DB, error)

func NewDBs

func NewDBs(ctx context.Context, config *Config) *lazyloadx.Group[*sql.DB]

func NewGormDB

func NewGormDB(ctx context.Context, options *Options) (*gorm.DB, error)

func NewGormDBs

func NewGormDBs(ctx context.Context, config *Config) *lazyloadx.Group[*gorm.DB]

func NewSqlxDB

func NewSqlxDB(ctx context.Context, options *Options) (*sqlx.DB, error)

func NewSqlxDBs

func NewSqlxDBs(ctx context.Context, config *Config) *lazyloadx.Group[*sqlx.DB]

Types

type Config

type Config struct {
	Configs map[string]*Options `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Config) Descriptor

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetConfigs

func (x *Config) GetConfigs() map[string]*Options

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type Options

type Options struct {
	DriverName      *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=driver_name,json=driverName,proto3" json:"driver_name,omitempty"`
	Dsn             *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	PingTimeout     *durationpb.Duration    `protobuf:"bytes,3,opt,name=ping_timeout,json=pingTimeout,proto3" json:"ping_timeout,omitempty"`
	MaxIdleConns    *wrapperspb.Int32Value  `protobuf:"bytes,4,opt,name=max_idle_conns,json=maxIdleConns,proto3" json:"max_idle_conns,omitempty"`
	MaxOpenConns    *wrapperspb.Int32Value  `protobuf:"bytes,5,opt,name=max_open_conns,json=maxOpenConns,proto3" json:"max_open_conns,omitempty"`
	ConnMaxLifetime *durationpb.Duration    `protobuf:"bytes,6,opt,name=conn_max_lifetime,json=connMaxLifetime,proto3" json:"conn_max_lifetime,omitempty"`
	ConnMaxIdleTime *durationpb.Duration    `protobuf:"bytes,7,opt,name=conn_max_idle_time,json=connMaxIdleTime,proto3" json:"conn_max_idle_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Options) Descriptor

func (*Options) Descriptor() ([]byte, []int)

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetConnMaxIdleTime

func (x *Options) GetConnMaxIdleTime() *durationpb.Duration

func (*Options) GetConnMaxLifetime

func (x *Options) GetConnMaxLifetime() *durationpb.Duration

func (*Options) GetDriverName

func (x *Options) GetDriverName() *wrapperspb.StringValue

func (*Options) GetDsn

func (x *Options) GetDsn() *wrapperspb.StringValue

func (*Options) GetMaxIdleConns

func (x *Options) GetMaxIdleConns() *wrapperspb.Int32Value

func (*Options) GetMaxOpenConns

func (x *Options) GetMaxOpenConns() *wrapperspb.Int32Value

func (*Options) GetPingTimeout

func (x *Options) GetPingTimeout() *durationpb.Duration

func (*Options) ProtoMessage

func (*Options) ProtoMessage()

func (*Options) ProtoReflect

func (x *Options) ProtoReflect() protoreflect.Message

func (*Options) Reset

func (x *Options) Reset()

func (*Options) String

func (x *Options) String() string