dtmgpb

Jul 8, 2022

Changes in this version

type DtmClient

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

+ 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

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

+ func (*DtmProgressesReply) ProtoMessage()

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

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

+ func (x *DtmProgressesReply) Reset()

+ func (x *DtmProgressesReply) String() string

type DtmRequest

+ ReqExtra map[string]string

+ RollbackReason string

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

+ func (x *DtmRequest) GetRollbackReason() string

type DtmServer

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

type UnimplementedDtmServer

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

Mar 29, 2022

Changes in this version

type DtmTransOptions

+ RequestTimeout int64

+ func (x *DtmTransOptions) GetRequestTimeout() int64

Jan 1, 2022

Changes in this version

type DtmTransOptions

+ BranchHeaders map[string]string

+ PassthroughHeaders []string

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

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

Dec 24, 2021

Changes in this version

+ var Dtm_ServiceDesc = grpc.ServiceDesc

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

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

+ BinPayloads [][]byte

+ CustomedData string

+ Gid string

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

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

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

+ type DtmTransOptions struct

+ RetryInterval int64

+ TimeoutToFail int64

+ WaitResult bool

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

+ func (*DtmTransOptions) ProtoMessage()

+ 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 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) RegisterBranch(context.Context, *DtmBranchRequest) (*emptypb.Empty, error)

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

+ type UnsafeDtmServer interface