proto

type BranchRegister struct {
	XID             string
	ResourceID      string
	LockKey         string
	BranchType      api.BranchSession_BranchType
	ApplicationData []byte
}

type BranchResource interface {
	Commit(ctx context.Context, bs *api.BranchSession) (api.BranchSession_BranchStatus, error)
	Rollback(ctx context.Context, bs *api.BranchSession) (api.BranchSession_BranchStatus, error)
}

type TransactionManager interface {
	// Begin return xid
	Begin(ctx context.Context, transactionName string, timeout int32) (string, error)
	Commit(ctx context.Context, xid string) (api.GlobalSession_GlobalStatus, error)
	Rollback(ctx context.Context, xid string) (api.GlobalSession_GlobalStatus, error)
	BranchRegister(ctx context.Context, in *BranchRegister) (string, int64, error)
	BranchReport(ctx context.Context, branchID string, status api.BranchSession_BranchStatus) error
	ReleaseLockKeys(ctx context.Context, resourceID string, lockKeys []string) (bool, error)
	IsLockable(ctx context.Context, resourceID, lockKey string) (bool, error)
	IsLockableWithXID(ctx context.Context, resourceID, lockKey, xid string) (bool, error)
}