fence

Documentation

Index

• Constants
• func DoFence(ctx context.Context, tx *sql.Tx) error
• func WithFence(ctx context.Context, tx *sql.Tx, callback func() error) (err error)
• type Config
  • func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
• type FenceConn
  • func (c *FenceConn) Begin() (driver.Tx, error)
  • func (c *FenceConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)
  • func (c *FenceConn) Close() error
  • func (c *FenceConn) Exec(query string, args []driver.Value) (driver.Result, error)
  • func (c *FenceConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)
  • func (c *FenceConn) Prepare(query string) (driver.Stmt, error)
  • func (c *FenceConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)
  • func (c *FenceConn) Query(query string, args []driver.Value) (driver.Rows, error)
  • func (c *FenceConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)
  • func (c *FenceConn) ResetSession(ctx context.Context) error
• type FenceDriver
  • func (fd *FenceDriver) Open(name string) (driver.Conn, error)
  • func (fd *FenceDriver) OpenConnector(name string) (connector driver.Connector, re error)
• type FenceTx
  • func (tx *FenceTx) Commit() error
  • func (tx *FenceTx) Rollback() error
• type SeataFenceConnector
  • func (connector *SeataFenceConnector) Connect(ctx context.Context) (driver.Conn, error)
  • func (connector *SeataFenceConnector) Driver() driver.Driver

Constants

const (
	// SeataFenceMySQLDriver MySQL driver for fence
	SeataFenceMySQLDriver = "seata-fence-mysql"
)

Functions

func DoFence

func DoFence(ctx context.Context, tx *sql.Tx) error

DeFence This method is a suspended API interface that asserts the phase timing of a transaction and performs corresponding database operations to ensure transaction consistency case 1: if fencePhase is FencePhaseNotExist, will return a fence not found error. case 2: if fencePhase is FencePhasePrepare, will do prepare fence operation. case 3: if fencePhase is FencePhaseCommit, will do commit fence operation. case 4: if fencePhase is FencePhaseRollback, will do rollback fence operation. case 5: if fencePhase not in above case, will return a fence phase illegal error.

func WithFence

func WithFence(ctx context.Context, tx *sql.Tx, callback func() error) (err error)

WithFence Execute the fence database operation first and then call back the business method

Types

type Config

type Config struct {
	LogTableName string        `yaml:"log-table-name" json:"log-table-name" koanf:"log-table-name"`
	CleanPeriod  time.Duration `yaml:"clean-period" json:"clean-period" koanf:"clean-period"`
}

func (*Config) RegisterFlagsWithPrefix

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

RegisterFlagsWithPrefix for Config.

type FenceConn

type FenceConn struct {
	TargetConn driver.Conn
	TargetDB   *sql.DB
}

func (*FenceConn) Begin

func (c *FenceConn) Begin() (driver.Tx, error)

func (*FenceConn) BeginTx

func (c *FenceConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

func (*FenceConn) Close

func (c *FenceConn) Close() error

func (*FenceConn) Exec

func (c *FenceConn) Exec(query string, args []driver.Value) (driver.Result, error)

func (*FenceConn) ExecContext

func (c *FenceConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

func (*FenceConn) Prepare

func (c *FenceConn) Prepare(query string) (driver.Stmt, error)

func (*FenceConn) PrepareContext

func (c *FenceConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

func (*FenceConn) Query

func (c *FenceConn) Query(query string, args []driver.Value) (driver.Rows, error)

func (*FenceConn) QueryContext

func (c *FenceConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

func (*FenceConn) ResetSession

func (c *FenceConn) ResetSession(ctx context.Context) error

type FenceDriver

type FenceDriver struct {
	TargetDriver driver.Driver
	TargetDB     *sql.DB
}

func (*FenceDriver) Open

func (fd *FenceDriver) Open(name string) (driver.Conn, error)

func (*FenceDriver) OpenConnector

func (fd *FenceDriver) OpenConnector(name string) (connector driver.Connector, re error)

type FenceTx

type FenceTx struct {
	Ctx           context.Context
	TargetTx      driver.Tx
	TargetFenceTx *sql.Tx
}

func (*FenceTx) Commit

func (tx *FenceTx) Commit() error

func (*FenceTx) Rollback

func (tx *FenceTx) Rollback() error

type SeataFenceConnector

type SeataFenceConnector struct {
	TargetConnector driver.Connector
	TargetDB        *sql.DB
}

func (*SeataFenceConnector) Connect

func (connector *SeataFenceConnector) Connect(ctx context.Context) (driver.Conn, error)

func (*SeataFenceConnector) Driver

func (connector *SeataFenceConnector) Driver() driver.Driver