dtmgpb

Jan 15, 2023

Changes in this version

+ var File_dtmgimp_proto protoreflect.FileDescriptor

Nov 15, 2022

Changes in this version

type DtmClient

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

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

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

type DtmServer

+ DeleteTopic func(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)

+ Subscribe func(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)

+ Unsubscribe func(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)

+ type DtmTopicRequest struct

+ Remark string

+ Topic string

+ URL string

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

+ func (*DtmTopicRequest) ProtoMessage()

+ func (x *DtmTopicRequest) GetRemark() string

+ func (x *DtmTopicRequest) GetTopic() string

+ func (x *DtmTopicRequest) GetURL() string

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

+ func (x *DtmTopicRequest) Reset()

+ func (x *DtmTopicRequest) String() string

type UnimplementedDtmServer

+ func (UnimplementedDtmServer) DeleteTopic(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)

+ func (UnimplementedDtmServer) Subscribe(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)

+ func (UnimplementedDtmServer) Unsubscribe(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)

Sep 5, 2022

Changes in this version

type DtmTransOptions

+ RetryLimit int64

+ func (x *DtmTransOptions) GetRetryLimit() int64

Aug 11, 2022

Changes in this version

type DtmTransaction

+ Result string

+ func (x *DtmTransaction) GetResult() string

Jul 14, 2022

Changes in this version

+ var Dtm_ServiceDesc = grpc.ServiceDesc

+ var File_client_dtmgrpc_dtmgpb_dtmgimp_proto protoreflect.FileDescriptor

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

+ type DtmBranchRequest struct

+ BranchID string

+ BusiPayload []byte

+ Data map[string]string

+ Gid string

+ Op string

+ TransType string

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

+ func (*DtmBranchRequest) ProtoMessage()

+ func (x *DtmBranchRequest) GetBranchID() string

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

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

+ func (x *DtmBranchRequest) GetGid() string

+ func (x *DtmBranchRequest) GetOp() string

+ func (x *DtmBranchRequest) GetTransType() string

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

+ func (x *DtmBranchRequest) Reset()

+ func (x *DtmBranchRequest) 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)

+ PrepareWorkflow func(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*DtmProgressesReply, error)

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

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

+ 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 DtmProgress struct

+ BinData []byte

+ BranchID string

+ Op string

+ Status string

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

+ func (*DtmProgress) ProtoMessage()

+ func (x *DtmProgress) GetBinData() []byte

+ func (x *DtmProgress) GetBranchID() string

+ func (x *DtmProgress) GetOp() string

+ func (x *DtmProgress) GetStatus() string

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

+ func (x *DtmProgress) Reset()

+ func (x *DtmProgress) String() string

+ type DtmProgressesReply struct

+ Progresses []*DtmProgress

+ Transaction *DtmTransaction

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

+ func (*DtmProgressesReply) ProtoMessage()

+ func (x *DtmProgressesReply) GetProgresses() []*DtmProgress

+ func (x *DtmProgressesReply) GetTransaction() *DtmTransaction

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

+ func (x *DtmProgressesReply) Reset()

+ func (x *DtmProgressesReply) String() string

+ type DtmRequest struct

+ BinPayloads [][]byte

+ CustomedData string

+ Gid string

+ QueryPrepared string

+ ReqExtra map[string]string

+ RollbackReason string

+ Steps string

+ TransOptions *DtmTransOptions

+ TransType string

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

+ func (*DtmRequest) ProtoMessage()

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

+ func (x *DtmRequest) GetCustomedData() string

+ func (x *DtmRequest) GetGid() string

+ func (x *DtmRequest) GetQueryPrepared() string

+ func (x *DtmRequest) GetReqExtra() map[string]string

+ func (x *DtmRequest) GetRollbackReason() string

+ func (x *DtmRequest) GetSteps() string

+ func (x *DtmRequest) GetTransOptions() *DtmTransOptions

+ func (x *DtmRequest) GetTransType() string

+ 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)

+ PrepareWorkflow func(context.Context, *DtmRequest) (*DtmProgressesReply, error)

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

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

+ type DtmTransOptions struct

+ BranchHeaders map[string]string

+ PassthroughHeaders []string

+ RequestTimeout int64

+ RetryInterval int64

+ TimeoutToFail int64

+ WaitResult bool

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

+ func (*DtmTransOptions) ProtoMessage()

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

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

+ func (x *DtmTransOptions) GetRequestTimeout() int64

+ func (x *DtmTransOptions) GetRetryInterval() int64

+ func (x *DtmTransOptions) GetTimeoutToFail() int64

+ func (x *DtmTransOptions) GetWaitResult() bool

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

+ func (x *DtmTransOptions) Reset()

+ func (x *DtmTransOptions) String() string

+ type DtmTransaction struct

+ Gid string

+ RollbackReason string

+ Status string

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

+ func (*DtmTransaction) ProtoMessage()

+ func (x *DtmTransaction) GetGid() string

+ func (x *DtmTransaction) GetRollbackReason() string

+ func (x *DtmTransaction) GetStatus() string

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

+ func (x *DtmTransaction) Reset()

+ func (x *DtmTransaction) String() string

+ 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) PrepareWorkflow(context.Context, *DtmRequest) (*DtmProgressesReply, error)

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

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

+ type UnsafeDtmServer interface