dtmgimp

package
v1.7.2 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2021 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Dtm_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dtmgimp.Dtm",
	HandlerType: (*DtmServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewGid",
			Handler:    _Dtm_NewGid_Handler,
		},
		{
			MethodName: "Submit",
			Handler:    _Dtm_Submit_Handler,
		},
		{
			MethodName: "Prepare",
			Handler:    _Dtm_Prepare_Handler,
		},
		{
			MethodName: "Abort",
			Handler:    _Dtm_Abort_Handler,
		},
		{
			MethodName: "RegisterBranch",
			Handler:    _Dtm_RegisterBranch_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dtmgrpc/dtmgimp/dtmgimp.proto",
}

Dtm_ServiceDesc is the grpc.ServiceDesc for Dtm service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_dtmgrpc_dtmgimp_dtmgimp_proto protoreflect.FileDescriptor

Functions

func DtmGrpcCall 

func DtmGrpcCall(s *dtmimp.TransBase, operation string) error

DtmGrpcCall make a convenient call to dtm

func GetGrpcConn 

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

GetGrpcConn 1

func GrpcClientLog 

func GrpcClientLog(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

GrpcClientLog 打印grpc服务端的日志

func GrpcServerLog 

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

GrpcServerLog 打印grpc服务端的日志

func LogDtmCtx 

func LogDtmCtx(ctx context.Context)

LogDtmCtx logout dtm info in context metadata

func MustGetGrpcConn 

func MustGetGrpcConn(grpcServer string, isRaw bool) *grpc.ClientConn

MustGetGrpcConn 1

func MustProtoMarshal 

func MustProtoMarshal(msg proto.Message) []byte

MustProtoMarshal must version of proto.Marshal

func RegisterDtmServer 

func RegisterDtmServer(s grpc.ServiceRegistrar, srv DtmServer)

func Result2Error 

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

Result2Error 将通用的result转成grpc的error

func TransBaseFromGrpc 

func TransBaseFromGrpc(ctx context.Context) *dtmimp.TransBase

TransBaseFromGrpc get trans base info from a context metadata

func TransInfo2Ctx 

func TransInfo2Ctx(gid, transType, branchID, op, dtm string) context.Context

TransInfo2Ctx add trans info to grpc context

Types

type DtmBranchRequest 

type DtmBranchRequest struct {
	Gid         string            `protobuf:"bytes,1,opt,name=Gid,proto3" json:"Gid,omitempty"`
	TransType   string            `protobuf:"bytes,2,opt,name=TransType,proto3" json:"TransType,omitempty"`
	BranchID    string            `protobuf:"bytes,3,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	Op          string            `protobuf:"bytes,4,opt,name=Op,proto3" json:"Op,omitempty"`
	Data        map[string]string `` /* 149-byte string literal not displayed */
	BusiPayload []byte            `protobuf:"bytes,6,opt,name=BusiPayload,proto3" json:"BusiPayload,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmBranchRequest) Descriptor deprecated 

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

Deprecated: Use DtmBranchRequest.ProtoReflect.Descriptor instead.

func (*DtmBranchRequest) GetBranchID 

func (x *DtmBranchRequest) GetBranchID() string

func (*DtmBranchRequest) GetBusiPayload 

func (x *DtmBranchRequest) GetBusiPayload() []byte

func (*DtmBranchRequest) GetData 

func (x *DtmBranchRequest) GetData() map[string]string

func (*DtmBranchRequest) GetGid 

func (x *DtmBranchRequest) GetGid() string

func (*DtmBranchRequest) GetOp added in v1.5.3 

func (x *DtmBranchRequest) GetOp() string

func (*DtmBranchRequest) GetTransType 

func (x *DtmBranchRequest) GetTransType() string

func (*DtmBranchRequest) ProtoMessage 

func (*DtmBranchRequest) ProtoMessage()

func (*DtmBranchRequest) ProtoReflect 

func (x *DtmBranchRequest) ProtoReflect() protoreflect.Message

func (*DtmBranchRequest) Reset 

func (x *DtmBranchRequest) Reset()

func (*DtmBranchRequest) String 

func (x *DtmBranchRequest) String() string

type DtmClient 

type DtmClient interface {
	NewGid(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DtmGidReply, error)
	Submit(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Prepare(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Abort(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RegisterBranch(ctx context.Context, in *DtmBranchRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DtmClient is the client API for Dtm service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func MustGetDtmClient 

func MustGetDtmClient(grpcServer string) DtmClient

MustGetDtmClient 1

func MustGetRawDtmClient 

func MustGetRawDtmClient(grpcServer string) DtmClient

MustGetRawDtmClient must get raw codec grpc conn

func NewDtmClient 

func NewDtmClient(cc grpc.ClientConnInterface) DtmClient

type DtmGidReply 

type DtmGidReply struct {
	Gid string `protobuf:"bytes,1,opt,name=Gid,proto3" json:"Gid,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmGidReply) Descriptor deprecated 

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

Deprecated: Use DtmGidReply.ProtoReflect.Descriptor instead.

func (*DtmGidReply) GetGid 

func (x *DtmGidReply) GetGid() string

func (*DtmGidReply) ProtoMessage 

func (*DtmGidReply) ProtoMessage()

func (*DtmGidReply) ProtoReflect 

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

func (*DtmGidReply) Reset 

func (x *DtmGidReply) Reset()

func (*DtmGidReply) String 

func (x *DtmGidReply) String() string

type DtmRequest 

type DtmRequest struct {
	Gid           string           `protobuf:"bytes,1,opt,name=Gid,proto3" json:"Gid,omitempty"`
	TransType     string           `protobuf:"bytes,2,opt,name=TransType,proto3" json:"TransType,omitempty"`
	TransOptions  *DtmTransOptions `protobuf:"bytes,3,opt,name=TransOptions,proto3" json:"TransOptions,omitempty"`
	CustomedData  string           `protobuf:"bytes,4,opt,name=CustomedData,proto3" json:"CustomedData,omitempty"`
	BinPayloads   [][]byte         `protobuf:"bytes,5,rep,name=BinPayloads,proto3" json:"BinPayloads,omitempty"`     // for MSG/SAGA branch payloads
	QueryPrepared string           `protobuf:"bytes,6,opt,name=QueryPrepared,proto3" json:"QueryPrepared,omitempty"` // for MSG
	Steps         string           `protobuf:"bytes,7,opt,name=Steps,proto3" json:"Steps,omitempty"`
	// contains filtered or unexported fields
}

DtmRequest request sent to dtm server

func (*DtmRequest) Descriptor deprecated 

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

Deprecated: Use DtmRequest.ProtoReflect.Descriptor instead.

func (*DtmRequest) GetBinPayloads 

func (x *DtmRequest) GetBinPayloads() [][]byte

func (*DtmRequest) GetCustomedData 

func (x *DtmRequest) GetCustomedData() string

func (*DtmRequest) GetGid 

func (x *DtmRequest) GetGid() string

func (*DtmRequest) GetQueryPrepared 

func (x *DtmRequest) GetQueryPrepared() string

func (*DtmRequest) GetSteps 

func (x *DtmRequest) GetSteps() string

func (*DtmRequest) GetTransOptions 

func (x *DtmRequest) GetTransOptions() *DtmTransOptions

func (*DtmRequest) GetTransType 

func (x *DtmRequest) GetTransType() string

func (*DtmRequest) ProtoMessage 

func (*DtmRequest) ProtoMessage()

func (*DtmRequest) ProtoReflect 

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

func (*DtmRequest) Reset 

func (x *DtmRequest) Reset()

func (*DtmRequest) String 

func (x *DtmRequest) String() string

type DtmServer 

type DtmServer interface {
	NewGid(context.Context, *emptypb.Empty) (*DtmGidReply, error)
	Submit(context.Context, *DtmRequest) (*emptypb.Empty, error)
	Prepare(context.Context, *DtmRequest) (*emptypb.Empty, error)
	Abort(context.Context, *DtmRequest) (*emptypb.Empty, error)
	RegisterBranch(context.Context, *DtmBranchRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DtmServer is the server API for Dtm service. All implementations must embed UnimplementedDtmServer for forward compatibility

type DtmTransOptions 

type DtmTransOptions struct {
	WaitResult    bool  `protobuf:"varint,1,opt,name=WaitResult,proto3" json:"WaitResult,omitempty"`
	TimeoutToFail int64 `protobuf:"varint,2,opt,name=TimeoutToFail,proto3" json:"TimeoutToFail,omitempty"`
	RetryInterval int64 `protobuf:"varint,3,opt,name=RetryInterval,proto3" json:"RetryInterval,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmTransOptions) Descriptor deprecated 

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

Deprecated: Use DtmTransOptions.ProtoReflect.Descriptor instead.

func (*DtmTransOptions) GetRetryInterval 

func (x *DtmTransOptions) GetRetryInterval() int64

func (*DtmTransOptions) GetTimeoutToFail 

func (x *DtmTransOptions) GetTimeoutToFail() int64

func (*DtmTransOptions) GetWaitResult 

func (x *DtmTransOptions) GetWaitResult() bool

func (*DtmTransOptions) ProtoMessage 

func (*DtmTransOptions) ProtoMessage()

func (*DtmTransOptions) ProtoReflect 

func (x *DtmTransOptions) ProtoReflect() protoreflect.Message

func (*DtmTransOptions) Reset 

func (x *DtmTransOptions) Reset()

func (*DtmTransOptions) String 

func (x *DtmTransOptions) String() string

type UnimplementedDtmServer 

type UnimplementedDtmServer struct {
}

UnimplementedDtmServer must be embedded to have forward compatible implementations.

func (UnimplementedDtmServer) Abort 

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

func (UnimplementedDtmServer) NewGid 

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

func (UnimplementedDtmServer) Prepare 

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

func (UnimplementedDtmServer) RegisterBranch 

func (UnimplementedDtmServer) RegisterBranch(context.Context, *DtmBranchRequest) (*emptypb.Empty, error)

func (UnimplementedDtmServer) Submit 

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

type UnsafeDtmServer 

type UnsafeDtmServer interface {
	// contains filtered or unexported methods
}

UnsafeDtmServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DtmServer will result in compilation errors.

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.