api

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 27, 2022 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BranchSession_BranchStatus_name = map[int32]string{
	0: "Registered",
	1: "PhaseOneFailed",
	2: "PhaseTwoCommitting",
	3: "PhaseTwoRollbacking",
	4: "Complete",
}
View Source 
var BranchSession_BranchStatus_value = map[string]int32{
	"Registered":          0,
	"PhaseOneFailed":      1,
	"PhaseTwoCommitting":  2,
	"PhaseTwoRollbacking": 3,
	"Complete":            4,
}
View Source 
var BranchSession_BranchType_name = map[int32]string{
	0: "AT",
	1: "TCC",
	2: "SAGA",
	3: "XA",
}
View Source 
var BranchSession_BranchType_value = map[string]int32{
	"AT":   0,
	"TCC":  1,
	"SAGA": 2,
	"XA":   3,
}
View Source 
var GlobalSession_GlobalStatus_name = map[int32]string{
	0: "Begin",
	1: "Committing",
	2: "Rollbacking",
	3: "Finished",
}
View Source 
var GlobalSession_GlobalStatus_value = map[string]int32{
	"Begin":       0,
	"Committing":  1,
	"Rollbacking": 2,
	"Finished":    3,
}
View Source 
var ResultCode_name = map[int32]string{
	0: "ResultCodeFailed",
	1: "ResultCodeSuccess",
}
View Source 
var ResultCode_value = map[string]int32{
	"ResultCodeFailed":  0,
	"ResultCodeSuccess": 1,
}

Functions

This section is empty.

Types

type BranchSession 

type BranchSession struct {
	BranchID        string                     `protobuf:"bytes,1,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	ApplicationID   string                     `protobuf:"bytes,2,opt,name=ApplicationID,proto3" json:"ApplicationID,omitempty"`
	BranchSessionID int64                      `protobuf:"varint,3,opt,name=BranchSessionID,proto3" json:"BranchSessionID,omitempty"`
	XID             string                     `protobuf:"bytes,4,opt,name=XID,proto3" json:"XID,omitempty"`
	TransactionID   int64                      `protobuf:"varint,5,opt,name=TransactionID,proto3" json:"TransactionID,omitempty"`
	ResourceID      string                     `protobuf:"bytes,6,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	LockKey         string                     `protobuf:"bytes,7,opt,name=LockKey,proto3" json:"LockKey,omitempty"`
	Type            BranchSession_BranchType   `protobuf:"varint,8,opt,name=Type,proto3,enum=api.BranchSession_BranchType" json:"Type,omitempty"`
	Status          BranchSession_BranchStatus `protobuf:"varint,9,opt,name=Status,proto3,enum=api.BranchSession_BranchStatus" json:"Status,omitempty"`
	ApplicationData []byte                     `protobuf:"bytes,10,opt,name=ApplicationData,proto3" json:"ApplicationData,omitempty"`
	BeginTime       int64                      `protobuf:"varint,11,opt,name=BeginTime,proto3" json:"BeginTime,omitempty"`
}

func (*BranchSession) Descriptor 

func (*BranchSession) Descriptor() ([]byte, []int)

func (*BranchSession) Equal 

func (this *BranchSession) Equal(that interface{}) bool

func (*BranchSession) GetApplicationData 

func (m *BranchSession) GetApplicationData() []byte

func (*BranchSession) GetApplicationID 

func (m *BranchSession) GetApplicationID() string

func (*BranchSession) GetBeginTime 

func (m *BranchSession) GetBeginTime() int64

func (*BranchSession) GetBranchID 

func (m *BranchSession) GetBranchID() string

func (*BranchSession) GetBranchSessionID 

func (m *BranchSession) GetBranchSessionID() int64

func (*BranchSession) GetLockKey 

func (m *BranchSession) GetLockKey() string

func (*BranchSession) GetResourceID 

func (m *BranchSession) GetResourceID() string

func (*BranchSession) GetStatus 

func (m *BranchSession) GetStatus() BranchSession_BranchStatus

func (*BranchSession) GetTransactionID 

func (m *BranchSession) GetTransactionID() int64

func (*BranchSession) GetType 

func (m *BranchSession) GetType() BranchSession_BranchType

func (*BranchSession) GetXID 

func (m *BranchSession) GetXID() string

func (*BranchSession) GoString 

func (this *BranchSession) GoString() string

func (*BranchSession) Marshal 

func (m *BranchSession) Marshal() (dAtA []byte, err error)

func (*BranchSession) MarshalTo 

func (m *BranchSession) MarshalTo(dAtA []byte) (int, error)

func (*BranchSession) MarshalToSizedBuffer 

func (m *BranchSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchSession) ProtoMessage 

func (*BranchSession) ProtoMessage()

func (*BranchSession) Reset 

func (m *BranchSession) Reset()

func (*BranchSession) Size 

func (m *BranchSession) Size() (n int)

func (*BranchSession) String 

func (this *BranchSession) String() string

func (*BranchSession) Unmarshal 

func (m *BranchSession) Unmarshal(dAtA []byte) error

func (*BranchSession) XXX_DiscardUnknown 

func (m *BranchSession) XXX_DiscardUnknown()

func (*BranchSession) XXX_Marshal 

func (m *BranchSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchSession) XXX_Merge 

func (m *BranchSession) XXX_Merge(src proto.Message)

func (*BranchSession) XXX_Size 

func (m *BranchSession) XXX_Size() int

func (*BranchSession) XXX_Unmarshal 

func (m *BranchSession) XXX_Unmarshal(b []byte) error

type BranchSession_BranchStatus 

type BranchSession_BranchStatus int32
const (
	Registered          BranchSession_BranchStatus = 0
	PhaseOneFailed      BranchSession_BranchStatus = 1
	PhaseTwoCommitting  BranchSession_BranchStatus = 2
	PhaseTwoRollbacking BranchSession_BranchStatus = 3
	Complete            BranchSession_BranchStatus = 4
)

func (BranchSession_BranchStatus) EnumDescriptor 

func (BranchSession_BranchStatus) EnumDescriptor() ([]byte, []int)

func (BranchSession_BranchStatus) String 

func (x BranchSession_BranchStatus) String() string

type BranchSession_BranchType 

type BranchSession_BranchType int32
const (
	AT   BranchSession_BranchType = 0
	TCC  BranchSession_BranchType = 1
	SAGA BranchSession_BranchType = 2
	XA   BranchSession_BranchType = 3
)

func (BranchSession_BranchType) EnumDescriptor 

func (BranchSession_BranchType) EnumDescriptor() ([]byte, []int)

func (BranchSession_BranchType) String 

func (x BranchSession_BranchType) String() string

type GlobalSession 

type GlobalSession struct {
	XID             string                     `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
	ApplicationID   string                     `protobuf:"bytes,2,opt,name=ApplicationID,proto3" json:"ApplicationID,omitempty"`
	TransactionID   int64                      `protobuf:"varint,3,opt,name=TransactionID,proto3" json:"TransactionID,omitempty"`
	TransactionName string                     `protobuf:"bytes,4,opt,name=TransactionName,proto3" json:"TransactionName,omitempty"`
	Timeout         int32                      `protobuf:"varint,5,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	BeginTime       int64                      `protobuf:"varint,6,opt,name=BeginTime,proto3" json:"BeginTime,omitempty"`
	Status          GlobalSession_GlobalStatus `protobuf:"varint,7,opt,name=Status,proto3,enum=api.GlobalSession_GlobalStatus" json:"Status,omitempty"`
}

func (*GlobalSession) Descriptor 

func (*GlobalSession) Descriptor() ([]byte, []int)

func (*GlobalSession) Equal 

func (this *GlobalSession) Equal(that interface{}) bool

func (*GlobalSession) GetApplicationID 

func (m *GlobalSession) GetApplicationID() string

func (*GlobalSession) GetBeginTime 

func (m *GlobalSession) GetBeginTime() int64

func (*GlobalSession) GetStatus 

func (m *GlobalSession) GetStatus() GlobalSession_GlobalStatus

func (*GlobalSession) GetTimeout 

func (m *GlobalSession) GetTimeout() int32

func (*GlobalSession) GetTransactionID 

func (m *GlobalSession) GetTransactionID() int64

func (*GlobalSession) GetTransactionName 

func (m *GlobalSession) GetTransactionName() string

func (*GlobalSession) GetXID 

func (m *GlobalSession) GetXID() string

func (*GlobalSession) GoString 

func (this *GlobalSession) GoString() string

func (*GlobalSession) Marshal 

func (m *GlobalSession) Marshal() (dAtA []byte, err error)

func (*GlobalSession) MarshalTo 

func (m *GlobalSession) MarshalTo(dAtA []byte) (int, error)

func (*GlobalSession) MarshalToSizedBuffer 

func (m *GlobalSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalSession) ProtoMessage 

func (*GlobalSession) ProtoMessage()

func (*GlobalSession) Reset 

func (m *GlobalSession) Reset()

func (*GlobalSession) Size 

func (m *GlobalSession) Size() (n int)

func (*GlobalSession) String 

func (this *GlobalSession) String() string

func (*GlobalSession) Unmarshal 

func (m *GlobalSession) Unmarshal(dAtA []byte) error

func (*GlobalSession) XXX_DiscardUnknown 

func (m *GlobalSession) XXX_DiscardUnknown()

func (*GlobalSession) XXX_Marshal 

func (m *GlobalSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalSession) XXX_Merge 

func (m *GlobalSession) XXX_Merge(src proto.Message)

func (*GlobalSession) XXX_Size 

func (m *GlobalSession) XXX_Size() int

func (*GlobalSession) XXX_Unmarshal 

func (m *GlobalSession) XXX_Unmarshal(b []byte) error

type GlobalSession_GlobalStatus 

type GlobalSession_GlobalStatus int32
const (
	Begin       GlobalSession_GlobalStatus = 0
	Committing  GlobalSession_GlobalStatus = 1
	Rollbacking GlobalSession_GlobalStatus = 2
	Finished    GlobalSession_GlobalStatus = 3
)

func (GlobalSession_GlobalStatus) EnumDescriptor 

func (GlobalSession_GlobalStatus) EnumDescriptor() ([]byte, []int)

func (GlobalSession_GlobalStatus) String 

func (x GlobalSession_GlobalStatus) String() string

type ResultCode 

type ResultCode int32
const (
	ResultCodeFailed  ResultCode = 0
	ResultCodeSuccess ResultCode = 1
)

func (ResultCode) EnumDescriptor 

func (ResultCode) EnumDescriptor() ([]byte, []int)

func (ResultCode) String 

func (x ResultCode) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.