gorm

Documentation

Index

• func NewLogAdapter(l kitlog.Logger, slowThreshold time.Duration, tracer trace.Tracer) logger.Interface
• func WithConnContext[T ConnType](ctx context.Context, conn T) context.Context
• type Client
  • func NewGormSQLiteClient(ctx context.Context, options *SQLiteOptions) (clt *Client, err error)
  • func NewMySQLClient(ctx context.Context, options MySQLOptions) (clt *Client, err error)
  • func (c *Client) Session(ctx context.Context) *gorm.DB
• type ConnType
• type DBOptions
• type MySQLClient
  • func (c MySQLClient) MarshalJSON() ([]byte, error)
  • func (c MySQLClient) Options() MySQLOptions
  • func (c *MySQLClient) SetOptions(o *MySQLOptions)
  • func (c *MySQLClient) UnmarshalJSON(data []byte) (err error)
• type MySQLOptions
  • func NewMySQLOptions() *MySQLOptions
  • func (x *MySQLOptions) GetConnectionString() string
  • func (x *MySQLOptions) GetDBName() string
  • func (x *MySQLOptions) GetPeer() (string, int)
  • func (x *MySQLOptions) GetStdMaxConnectionLifeTime() time.Duration
  • func (x *MySQLOptions) GetType() string
  • func (x *MySQLOptions) GetUsername() string
• type MySQLStatsCollector
  • func (m *MySQLStatsCollector) Collect(metrics chan<- prometheus.Metric)
  • func (m *MySQLStatsCollector) Describe(descs chan<- *prometheus.Desc)
• type Processor
• type SQLiteClient
  • func NewSQLiteClient(ctx context.Context, options *SQLiteOptions) (clt *SQLiteClient, err error)
  • func (c SQLiteClient) MarshalJSON() ([]byte, error)
  • func (c *SQLiteClient) UnmarshalJSON(data []byte) (err error)
• type SQLiteOptions
  • func NewSQLiteOptions() *SQLiteOptions
  • func (o SQLiteOptions) GetConnectionString() string
  • func (o SQLiteOptions) GetDBName() string
  • func (o SQLiteOptions) GetPeer() (string, int)
  • func (o SQLiteOptions) GetType() string
  • func (o SQLiteOptions) GetUsername() string
• type SessionClient
• type TLSOptions
  • func (o TLSOptions) MarshalJSON() ([]byte, error)
  • func (o *TLSOptions) UnmarshalJSON(data []byte) (err error)

Functions

func NewLogAdapter

func NewLogAdapter(l kitlog.Logger, slowThreshold time.Duration, tracer trace.Tracer) logger.Interface

func WithConnContext

func WithConnContext[T ConnType](ctx context.Context, conn T) context.Context

Types

type Client

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

func NewGormSQLiteClient

func NewGormSQLiteClient(ctx context.Context, options *SQLiteOptions) (clt *Client, err error)

func NewMySQLClient

func NewMySQLClient(ctx context.Context, options MySQLOptions) (clt *Client, err error)

func (*Client) Session

func (c *Client) Session(ctx context.Context) *gorm.DB

type ConnType

type ConnType interface {
	*gorm.DB
}

type DBOptions

type DBOptions interface {
	GetConnectionString() string
	GetPeer() (string, int)
	GetDBName() string
	GetUsername() string
	GetType() string
}

type MySQLClient

type MySQLClient struct {
	*Client
	// contains filtered or unexported fields
}

func (MySQLClient) MarshalJSON

func (c MySQLClient) MarshalJSON() ([]byte, error)

func (MySQLClient) Options

func (c MySQLClient) Options() MySQLOptions

func (*MySQLClient) SetOptions

func (c *MySQLClient) SetOptions(o *MySQLOptions)

func (*MySQLClient) UnmarshalJSON

func (c *MySQLClient) UnmarshalJSON(data []byte) (err error)

type MySQLOptions

type MySQLOptions struct {
	Host                  string          `json:"host,omitempty"`
	Username              string          `json:"username,omitempty"`
	Password              safe.String     `json:"password,omitempty"`
	Schema                string          `json:"schema,omitempty"`
	MaxIdle               int32           `json:"max_idle,omitempty"`
	MaxIdleConnections    int32           `json:"max_idle_connections,omitempty"`
	MaxOpenConnections    int32           `json:"max_open_connections,omitempty"`
	MaxConnectionLifeTime *model.Duration `json:"max_connection_life_time,omitempty"`
	Charset               string          `json:"charset,omitempty"`
	Collation             string          `json:"collation,omitempty"`
	TablePrefix           string          `json:"table_prefix,omitempty"`
	SlowThreshold         *model.Duration `json:"slow_threshold,omitempty"`
	TLSConfig             *TLSOptions     `json:"tls_config" yaml:"tls_config" mapstructure:"tls_config"`
}

func NewMySQLOptions

func NewMySQLOptions() *MySQLOptions

func (*MySQLOptions) GetConnectionString

func (x *MySQLOptions) GetConnectionString() string

func (*MySQLOptions) GetDBName

func (x *MySQLOptions) GetDBName() string

func (*MySQLOptions) GetPeer

func (x *MySQLOptions) GetPeer() (string, int)

func (*MySQLOptions) GetStdMaxConnectionLifeTime

func (x *MySQLOptions) GetStdMaxConnectionLifeTime() time.Duration

func (*MySQLOptions) GetType

func (x *MySQLOptions) GetType() string

func (*MySQLOptions) GetUsername

func (x *MySQLOptions) GetUsername() string

type MySQLStatsCollector

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

func (*MySQLStatsCollector) Collect

func (m *MySQLStatsCollector) Collect(metrics chan<- prometheus.Metric)

func (*MySQLStatsCollector) Describe

func (m *MySQLStatsCollector) Describe(descs chan<- *prometheus.Desc)

type Processor

type Processor interface {
	Get(name string) func(*gorm.DB)
	Replace(name string, handler func(*gorm.DB)) error
}

type SQLiteClient

type SQLiteClient struct {
	*Client
	// contains filtered or unexported fields
}

func NewSQLiteClient

func NewSQLiteClient(ctx context.Context, options *SQLiteOptions) (clt *SQLiteClient, err error)

func (SQLiteClient) MarshalJSON

func (c SQLiteClient) MarshalJSON() ([]byte, error)

func (*SQLiteClient) UnmarshalJSON

func (c *SQLiteClient) UnmarshalJSON(data []byte) (err error)

type SQLiteOptions

type SQLiteOptions struct {
	Path                 string          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	TablePrefix          string          `protobuf:"bytes,2,opt,name=table_prefix,json=tablePrefix,proto3" json:"table_prefix,omitempty"`
	SlowThreshold        *types.Duration `protobuf:"bytes,12,opt,name=slow_threshold,json=slowThreshold,proto3" json:"slow_threshold,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"` //nolint:revive
	XXX_unrecognized     []byte          `json:"-"` //nolint:revive
	XXX_sizecache        int32           `json:"-"` //nolint:revive
}

func NewSQLiteOptions

func NewSQLiteOptions() *SQLiteOptions

func (SQLiteOptions) GetConnectionString

func (o SQLiteOptions) GetConnectionString() string

func (SQLiteOptions) GetDBName

func (o SQLiteOptions) GetDBName() string

func (SQLiteOptions) GetPeer

func (o SQLiteOptions) GetPeer() (string, int)

func (SQLiteOptions) GetType

func (o SQLiteOptions) GetType() string

func (SQLiteOptions) GetUsername

func (o SQLiteOptions) GetUsername() string

type SessionClient

type SessionClient interface {
	Session(ctx context.Context) *gorm.DB
}

type TLSOptions

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

func (TLSOptions) MarshalJSON

func (o TLSOptions) MarshalJSON() ([]byte, error)

func (*TLSOptions) UnmarshalJSON

func (o *TLSOptions) UnmarshalJSON(data []byte) (err error)