connpool

Documentation

Index

• Constants
• type DoubleWritePool
  • func NewDoubleWritePool(src gorm.ConnPool, dst gorm.ConnPool, pattern string) *DoubleWritePool
  • func (d *DoubleWritePool) BeginTx(ctx context.Context, opts *sql.TxOptions) (gorm.ConnPool, error)
  • func (d *DoubleWritePool) ChangePattern(pattern string)
  • func (d *DoubleWritePool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (d *DoubleWritePool) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (d *DoubleWritePool) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (d *DoubleWritePool) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
• type DoubleWriteTx
  • func (d *DoubleWriteTx) Commit() error
  • func (d *DoubleWriteTx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (d *DoubleWriteTx) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (d *DoubleWriteTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (d *DoubleWriteTx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
  • func (d *DoubleWriteTx) Rollback() error

Constants

const (
	PatternSrcOnly  = "SRC_ONLY"
	PatternSrcFirst = "SRC_FIRST"
	PatternDstFirst = "DST_FIRST"
	PatternDstOnly  = "DST_ONLY"
)

Types

type DoubleWritePool

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

func NewDoubleWritePool

func NewDoubleWritePool(src gorm.ConnPool, dst gorm.ConnPool, pattern string) *DoubleWritePool

func (*DoubleWritePool) BeginTx

func (d *DoubleWritePool) BeginTx(ctx context.Context, opts *sql.TxOptions) (gorm.ConnPool, error)

func (*DoubleWritePool) ChangePattern

func (d *DoubleWritePool) ChangePattern(pattern string)

func (*DoubleWritePool) ExecContext

func (d *DoubleWritePool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*DoubleWritePool) PrepareContext

func (d *DoubleWritePool) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (*DoubleWritePool) QueryContext

func (d *DoubleWritePool) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (*DoubleWritePool) QueryRowContext

func (d *DoubleWritePool) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

type DoubleWriteTx

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

func (*DoubleWriteTx) Commit

func (d *DoubleWriteTx) Commit() error

func (*DoubleWriteTx) ExecContext

func (d *DoubleWriteTx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*DoubleWriteTx) PrepareContext

func (d *DoubleWriteTx) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (*DoubleWriteTx) QueryContext

func (d *DoubleWriteTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (*DoubleWriteTx) QueryRowContext

func (d *DoubleWriteTx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

func (*DoubleWriteTx) Rollback

func (d *DoubleWriteTx) Rollback() error