dtx

type Codec int8

type Context struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type HandleFunc func(*Context) error

type Handler interface {
	Commit(c *Context) error
	Rollback(c *Context) error
}

type Option func(o *Options)

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

type Task struct {
	ID                     string
	CommitMsg, RollbackMsg proto.Message
	Handler                Handler
	HandleFunc             HandleFunc
}

type Tx interface {
	Begin() Tx
	Exec(Task) Tx
	End()
	About(error)
	Rollback(tlog *packet.TxLog) error
}