dtmgpb

package
v1.14.2-tls-1 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2023 License: BSD-3-Clause Imports: 9 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/dtmgpb/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_dtmgpb_dtmgimp_proto protoreflect.FileDescriptor

Functions

func RegisterDtmServer 

func RegisterDtmServer(s grpc.ServiceRegistrar, srv DtmServer)

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 

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 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"`
	PassthroughHeaders []string          `protobuf:"bytes,4,rep,name=PassthroughHeaders,proto3" json:"PassthroughHeaders,omitempty"`
	BranchHeaders      map[string]string `` /* 167-byte string literal not displayed */
	RequestTimeout     int64             `protobuf:"varint,6,opt,name=RequestTimeout,proto3" json:"RequestTimeout,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmTransOptions) Descriptor deprecated 

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

Deprecated: Use DtmTransOptions.ProtoReflect.Descriptor instead.

func (*DtmTransOptions) GetBranchHeaders 

func (x *DtmTransOptions) GetBranchHeaders() map[string]string

func (*DtmTransOptions) GetPassthroughHeaders 

func (x *DtmTransOptions) GetPassthroughHeaders() []string

func (*DtmTransOptions) GetRequestTimeout 

func (x *DtmTransOptions) GetRequestTimeout() int64

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.