dtx

README

dtx

distributed transaction

Documentation

Index

• type Codec
• type Context
  • func (c *Context) End()
  • func (c *Context) IsAbout() bool
  • func (c *Context) Message() proto.Message
• type HandleFunc
• type Handler
• type Option
  • func Debug() Option
  • func SetCodec(c Codec) Option
• type Options
• type Task
• type Tx
  • func New(ctx context.Context, id string, opts ...Option) Tx

Types

type Codec

type Codec int8

const (
	JSON Codec = iota
	PROTO
)

type Context

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

func (*Context) End

func (c *Context) End()

func (*Context) IsAbout

func (c *Context) IsAbout() bool

func (*Context) Message

func (c *Context) Message() proto.Message

type HandleFunc

type HandleFunc func(*Context) error

type Handler

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

type Option

type Option func(o *Options)

func Debug

func Debug() Option

func SetCodec

func SetCodec(c Codec) Option

type Options

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

type Task

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

type Tx

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

Tx is pipeline transaction interface.

func New

func New(ctx context.Context, id string, opts ...Option) Tx

New is create transcation pipeline instance.