dtmgpb

package
v1.17.5 Latest Latest
Warning

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

 Go to latest Published: Sep 23, 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,
		},
		{
			MethodName: "PrepareWorkflow",
			Handler:    _Dtm_PrepareWorkflow_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _Dtm_Subscribe_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _Dtm_Unsubscribe_Handler,
		},
		{
			MethodName: "DeleteTopic",
			Handler:    _Dtm_DeleteTopic_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "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_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)
	PrepareWorkflow(ctx context.Context, in *DtmRequest, opts ...grpc.CallOption) (*DtmProgressesReply, error)
	Subscribe(ctx context.Context, in *DtmTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Unsubscribe(ctx context.Context, in *DtmTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteTopic(ctx context.Context, in *DtmTopicRequest, 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 DtmProgress 

type DtmProgress struct {
	Status   string `protobuf:"bytes,1,opt,name=Status,json=status,proto3" json:"Status,omitempty"`
	BinData  []byte `protobuf:"bytes,2,opt,name=BinData,json=bin_data,proto3" json:"BinData,omitempty"`
	BranchID string `protobuf:"bytes,3,opt,name=BranchID,json=branch_id,proto3" json:"BranchID,omitempty"`
	Op       string `protobuf:"bytes,4,opt,name=Op,json=op,proto3" json:"Op,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmProgress) Descriptor deprecated 

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

Deprecated: Use DtmProgress.ProtoReflect.Descriptor instead.

func (*DtmProgress) GetBinData 

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

func (*DtmProgress) GetBranchID 

func (x *DtmProgress) GetBranchID() string

func (*DtmProgress) GetOp 

func (x *DtmProgress) GetOp() string

func (*DtmProgress) GetStatus 

func (x *DtmProgress) GetStatus() string

func (*DtmProgress) ProtoMessage 

func (*DtmProgress) ProtoMessage()

func (*DtmProgress) ProtoReflect 

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

func (*DtmProgress) Reset 

func (x *DtmProgress) Reset()

func (*DtmProgress) String 

func (x *DtmProgress) String() string

type DtmProgressesReply 

type DtmProgressesReply struct {
	Transaction *DtmTransaction `protobuf:"bytes,1,opt,name=Transaction,json=transaction,proto3" json:"Transaction,omitempty"`
	Progresses  []*DtmProgress  `protobuf:"bytes,2,rep,name=Progresses,json=progresses,proto3" json:"Progresses,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmProgressesReply) Descriptor deprecated 

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

Deprecated: Use DtmProgressesReply.ProtoReflect.Descriptor instead.

func (*DtmProgressesReply) GetProgresses 

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

func (*DtmProgressesReply) GetTransaction 

func (x *DtmProgressesReply) GetTransaction() *DtmTransaction

func (*DtmProgressesReply) ProtoMessage 

func (*DtmProgressesReply) ProtoMessage()

func (*DtmProgressesReply) ProtoReflect 

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

func (*DtmProgressesReply) Reset 

func (x *DtmProgressesReply) Reset()

func (*DtmProgressesReply) String 

func (x *DtmProgressesReply) 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/Workflow 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"`
	ReqExtra       map[string]string `` /* 157-byte string literal not displayed */
	RollbackReason string            `protobuf:"bytes,9,opt,name=RollbackReason,proto3" json:"RollbackReason,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) GetReqExtra 

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

func (*DtmRequest) GetRollbackReason 

func (x *DtmRequest) GetRollbackReason() 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)
	PrepareWorkflow(context.Context, *DtmRequest) (*DtmProgressesReply, error)
	Subscribe(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)
	Unsubscribe(context.Context, *DtmTopicRequest) (*emptypb.Empty, error)
	DeleteTopic(context.Context, *DtmTopicRequest) (*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 DtmTopicRequest added in v1.16.4 

type DtmTopicRequest struct {
	Topic  string `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	URL    string `protobuf:"bytes,2,opt,name=URL,proto3" json:"URL,omitempty"`
	Remark string `protobuf:"bytes,3,opt,name=Remark,proto3" json:"Remark,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmTopicRequest) Descriptor deprecated added in v1.16.4 

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

Deprecated: Use DtmTopicRequest.ProtoReflect.Descriptor instead.

func (*DtmTopicRequest) GetRemark added in v1.16.4 

func (x *DtmTopicRequest) GetRemark() string

func (*DtmTopicRequest) GetTopic added in v1.16.4 

func (x *DtmTopicRequest) GetTopic() string

func (*DtmTopicRequest) GetURL added in v1.16.4 

func (x *DtmTopicRequest) GetURL() string

func (*DtmTopicRequest) ProtoMessage added in v1.16.4 

func (*DtmTopicRequest) ProtoMessage()

func (*DtmTopicRequest) ProtoReflect added in v1.16.4 

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

func (*DtmTopicRequest) Reset added in v1.16.4 

func (x *DtmTopicRequest) Reset()

func (*DtmTopicRequest) String added in v1.16.4 

func (x *DtmTopicRequest) String() string

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"`
	// repeated string PassthroughHeaders = 4; // depreceated
	BranchHeaders  map[string]string `` /* 167-byte string literal not displayed */
	RequestTimeout int64             `protobuf:"varint,6,opt,name=RequestTimeout,proto3" json:"RequestTimeout,omitempty"`
	RetryLimit     int64             `protobuf:"varint,7,opt,name=RetryLimit,proto3" json:"RetryLimit,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) GetRequestTimeout 

func (x *DtmTransOptions) GetRequestTimeout() int64

func (*DtmTransOptions) GetRetryInterval 

func (x *DtmTransOptions) GetRetryInterval() int64

func (*DtmTransOptions) GetRetryLimit added in v1.16.2 

func (x *DtmTransOptions) GetRetryLimit() 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 DtmTransaction 

type DtmTransaction struct {
	Gid            string `protobuf:"bytes,1,opt,name=Gid,json=gid,proto3" json:"Gid,omitempty"`
	Status         string `protobuf:"bytes,2,opt,name=Status,json=status,proto3" json:"Status,omitempty"`
	RollbackReason string `protobuf:"bytes,3,opt,name=RollbackReason,json=rollback_reason,proto3" json:"RollbackReason,omitempty"`
	Result         string `protobuf:"bytes,4,opt,name=Result,json=result,proto3" json:"Result,omitempty"`
	// contains filtered or unexported fields
}

func (*DtmTransaction) Descriptor deprecated 

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

Deprecated: Use DtmTransaction.ProtoReflect.Descriptor instead.

func (*DtmTransaction) GetGid 

func (x *DtmTransaction) GetGid() string

func (*DtmTransaction) GetResult added in v1.16.1 

func (x *DtmTransaction) GetResult() string

func (*DtmTransaction) GetRollbackReason 

func (x *DtmTransaction) GetRollbackReason() string

func (*DtmTransaction) GetStatus 

func (x *DtmTransaction) GetStatus() string

func (*DtmTransaction) ProtoMessage 

func (*DtmTransaction) ProtoMessage()

func (*DtmTransaction) ProtoReflect 

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

func (*DtmTransaction) Reset 

func (x *DtmTransaction) Reset()

func (*DtmTransaction) String 

func (x *DtmTransaction) 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) DeleteTopic added in v1.16.4 

func (UnimplementedDtmServer) DeleteTopic(context.Context, *DtmTopicRequest) (*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) PrepareWorkflow 

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

func (UnimplementedDtmServer) Subscribe added in v1.16.4 

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

func (UnimplementedDtmServer) Unsubscribe added in v1.16.4 

func (UnimplementedDtmServer) Unsubscribe(context.Context, *DtmTopicRequest) (*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.