gorm

Documentation

Index

• func NewLogAdapter(l kitlog.Logger, slowThreshold time.Duration, tracer trace.Tracer) logger.Interface
• func WithConnContext[T ConnType](ctx context.Context, client 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) *Database
• type ConnType
• type DBOptions
• type Database
• type Handler
• type Interceptor
• 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 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

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, client 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) *Database

type ConnType

type ConnType interface {
	*Database | *gorm.DB
}

type DBOptions

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

type Database

type Database struct {
	*gorm.DB
}

type Handler

type Handler func(*gorm.DB)

type Interceptor

type Interceptor func(name string, next Handler) Handler

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              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"`
}

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 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:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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