Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dtmgrpc

package module

Go to main page

Versions in this module

v1

v1.6.2

Dec 4, 2021

v1.6.0

Dec 3, 2021

v1.5.1

Nov 8, 2021

Changes in this version

+ func GetCurrentDBType() string

type SagaGrpc

+ func NewSagaGrpc(server string, gid string) *SagaGrpc

+ func (s *SagaGrpc) AddBranchOrder(branch int, preBranches []int) *SagaGrpc

+ func (s *SagaGrpc) EnableConcurrent() *SagaGrpc

type TccGrpc

+ func TccFromGrpc(ctx context.Context) (*TccGrpc, error)

v1.3.0

Oct 16, 2021

v1.2.4

Oct 15, 2021

v1.2.3

Oct 15, 2021

v1.2.2

Oct 15, 2021

v1.2.1

Oct 15, 2021

Changes in this version

+ var Dtm_ServiceDesc = grpc.ServiceDesc

+ var File_dtmgrpc_dtmgrpc_proto protoreflect.FileDescriptor

+ func GetGrpcConn(grpcServer string) (conn *grpc.ClientConn, rerr error)

+ func GetServerAndMethod(grpcURL string) (string, string)

+ func GrpcClientLog(ctx context.Context, method string, req, reply interface{}, ...) error

+ func GrpcServerLog(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ func MustGenGid(grpcServer string) string

+ func MustGetGrpcConn(grpcServer string) *grpc.ClientConn

+ func RegisterDtmServer(s grpc.ServiceRegistrar, srv DtmServer)

+ func Result2Error(res interface{}, err error) error

+ func SetCurrentDBType(dbType string)

+ func TccGlobalTransaction(dtm string, gid string, tccFunc TccGlobalFunc) (rerr error)

+ type BranchBarrier struct

+ func BarrierFromGrpc(in *BusiRequest) (*BranchBarrier, error)

+ func (bb *BranchBarrier) Call(tx dtmcli.Tx, busiCall dtmcli.BusiFunc) (rerr error)

+ type BranchInfo struct

+ BranchID string

+ BranchType string

+ Gid string

+ TransType string

+ func (*BranchInfo) Descriptor() ([]byte, []int)

+ func (*BranchInfo) ProtoMessage()

+ func (x *BranchInfo) GetBranchID() string

+ func (x *BranchInfo) GetBranchType() string

+ func (x *BranchInfo) GetGid() string

+ func (x *BranchInfo) GetTransType() string

+ func (x *BranchInfo) ProtoReflect() protoreflect.Message

+ func (x *BranchInfo) Reset()

+ func (x *BranchInfo) String() string

+ type BusiReply struct

+ BusiData []byte

+ func (*BusiReply) Descriptor() ([]byte, []int)

+ func (*BusiReply) ProtoMessage()

+ func (x *BusiReply) GetBusiData() []byte

+ func (x *BusiReply) ProtoReflect() protoreflect.Message

+ func (x *BusiReply) Reset()

+ func (x *BusiReply) String() string

+ type BusiRequest struct

+ BusiData []byte

+ Dtm string

+ Info *BranchInfo

+ func (*BusiRequest) Descriptor() ([]byte, []int)

+ func (*BusiRequest) ProtoMessage()

+ func (x *BusiRequest) GetBusiData() []byte

+ func (x *BusiRequest) GetDtm() string

+ func (x *BusiRequest) GetInfo() *BranchInfo

+ func (x *BusiRequest) ProtoReflect() protoreflect.Message

+ func (x *BusiRequest) Reset()

+ func (x *BusiRequest) String() string

+ type DtmClient interface

+ Abort func(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ NewGid func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DtmGidReply, error)

+ Prepare func(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ RegisterTccBranch func(ctx context.Context, in *DtmTccBranchRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ RegisterXaBranch func(ctx context.Context, in *DtmXaBranchRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Submit func(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func MustGetDtmClient(grpcServer string) DtmClient

+ func NewDtmClient(cc grpc.ClientConnInterface) DtmClient

+ type DtmGidReply struct

+ Gid string

+ func (*DtmGidReply) Descriptor() ([]byte, []int)

+ func (*DtmGidReply) ProtoMessage()

+ func (x *DtmGidReply) GetGid() string

+ func (x *DtmGidReply) ProtoReflect() protoreflect.Message

+ func (x *DtmGidReply) Reset()

+ func (x *DtmGidReply) String() string

+ type DtmRequest struct

+ Data string

+ Gid string

+ QueryPrepared string

+ TransType string

+ WaitResult bool

+ func (*DtmRequest) Descriptor() ([]byte, []int)

+ func (*DtmRequest) ProtoMessage()

+ func (x *DtmRequest) GetData() string

+ func (x *DtmRequest) GetGid() string

+ func (x *DtmRequest) GetQueryPrepared() string

+ func (x *DtmRequest) GetTransType() string

+ func (x *DtmRequest) GetWaitResult() bool

+ func (x *DtmRequest) ProtoReflect() protoreflect.Message

+ func (x *DtmRequest) Reset()

+ func (x *DtmRequest) String() string

+ type DtmServer interface

+ Abort func(context.Context, *DtmRequest) (*emptypb.Empty, error)

+ NewGid func(context.Context, *emptypb.Empty) (*DtmGidReply, error)

+ Prepare func(context.Context, *DtmRequest) (*emptypb.Empty, error)

+ RegisterTccBranch func(context.Context, *DtmTccBranchRequest) (*emptypb.Empty, error)

+ RegisterXaBranch func(context.Context, *DtmXaBranchRequest) (*emptypb.Empty, error)

+ Submit func(context.Context, *DtmRequest) (*emptypb.Empty, error)

+ type DtmTccBranchRequest struct

+ BusiData string

+ Cancel string

+ Confirm string

+ Info *BranchInfo

+ Try string

+ func (*DtmTccBranchRequest) Descriptor() ([]byte, []int)

+ func (*DtmTccBranchRequest) ProtoMessage()

+ func (x *DtmTccBranchRequest) GetBusiData() string

+ func (x *DtmTccBranchRequest) GetCancel() string

+ func (x *DtmTccBranchRequest) GetConfirm() string

+ func (x *DtmTccBranchRequest) GetInfo() *BranchInfo

+ func (x *DtmTccBranchRequest) GetTry() string

+ func (x *DtmTccBranchRequest) ProtoReflect() protoreflect.Message

+ func (x *DtmTccBranchRequest) Reset()

+ func (x *DtmTccBranchRequest) String() string

+ type DtmXaBranchRequest struct

+ BusiData string

+ Info *BranchInfo

+ Notify string

+ func (*DtmXaBranchRequest) Descriptor() ([]byte, []int)

+ func (*DtmXaBranchRequest) ProtoMessage()

+ func (x *DtmXaBranchRequest) GetBusiData() string

+ func (x *DtmXaBranchRequest) GetInfo() *BranchInfo

+ func (x *DtmXaBranchRequest) GetNotify() string

+ func (x *DtmXaBranchRequest) ProtoReflect() protoreflect.Message

+ func (x *DtmXaBranchRequest) Reset()

+ func (x *DtmXaBranchRequest) String() string

+ type MsgGrpc struct

+ QueryPrepared string

+ Steps []dtmcli.MsgStep

+ func NewMsgGrpc(server string, gid string) *MsgGrpc

+ func (s *MsgGrpc) Add(action string, data []byte) *MsgGrpc

+ func (s *MsgGrpc) Prepare(queryPrepared string) error

+ func (s *MsgGrpc) Submit() error

+ type SagaGrpc struct

+ Steps []dtmcli.SagaStep

+ func NewSaga(server string, gid string) *SagaGrpc

+ func (s *SagaGrpc) Add(action string, compensate string, busiData []byte) *SagaGrpc

+ func (s *SagaGrpc) Submit() error

+ type TccGlobalFunc func(tcc *TccGrpc) error

+ type TccGrpc struct

+ func TccFromRequest(br *BusiRequest) (*TccGrpc, error)

+ func (t *TccGrpc) CallBranch(busiData []byte, tryURL string, confirmURL string, cancelURL string) (*BusiReply, error)

+ type UnimplementedDtmServer struct

+ func (UnimplementedDtmServer) Abort(context.Context, *DtmRequest) (*emptypb.Empty, error)

+ func (UnimplementedDtmServer) NewGid(context.Context, *emptypb.Empty) (*DtmGidReply, error)

+ func (UnimplementedDtmServer) Prepare(context.Context, *DtmRequest) (*emptypb.Empty, error)

+ func (UnimplementedDtmServer) RegisterTccBranch(context.Context, *DtmTccBranchRequest) (*emptypb.Empty, error)

+ func (UnimplementedDtmServer) RegisterXaBranch(context.Context, *DtmXaBranchRequest) (*emptypb.Empty, error)

+ func (UnimplementedDtmServer) Submit(context.Context, *DtmRequest) (*emptypb.Empty, error)

+ type UnsafeDtmServer interface

+ type XaGrpc struct

+ func XaGrpcFromRequest(br *BusiRequest) (*XaGrpc, error)

+ func (x *XaGrpc) CallBranch(busiData []byte, url string) (*BusiReply, error)

+ type XaGrpcClient struct

+ func NewXaGrpcClient(server string, mysqlConf map[string]string, notifyURL string) *XaGrpcClient

+ func (xc *XaGrpcClient) HandleCallback(gid string, branchID string, action string) error

+ func (xc *XaGrpcClient) XaGlobalTransaction(gid string, xaFunc XaGrpcGlobalFunc) (rerr error)

+ func (xc *XaGrpcClient) XaLocalTransaction(br *BusiRequest, xaFunc XaGrpcLocalFunc) (rerr error)

+ type XaGrpcGlobalFunc func(xa *XaGrpc) error

+ type XaGrpcLocalFunc func(db *sql.DB, xa *XaGrpc) error