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
- 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
- type FenceTx
- type SeataFenceConnector
Constants ¶
View Source
const (
// SeataFenceMySQLDriver MySQL driver for fence
SeataFenceMySQLDriver = "seata-fence-mysql"
)
Variables ¶
This section is empty.
Functions ¶
func DoFence ¶
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.
Types ¶
type Config ¶
type FenceConn ¶
func (*FenceConn) ExecContext ¶
func (*FenceConn) PrepareContext ¶
func (*FenceConn) QueryContext ¶
type FenceDriver ¶
func (*FenceDriver) OpenConnector ¶
func (fd *FenceDriver) OpenConnector(name string) (connector driver.Connector, re error)
type SeataFenceConnector ¶
func (*SeataFenceConnector) Driver ¶
func (connector *SeataFenceConnector) Driver() driver.Driver
Source Files
¶
Click to show internal directories.
Click to hide internal directories.