examples

package
v0.0.0-...-9899e16 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2022 License: BSD-3-Clause Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// BusiAPI busi api prefix
	BusiAPI = "/api/busi"
	// BusiPort busi server port
	BusiPort = 8081
	// BusiGrpcPort busi server port
	BusiGrpcPort = 58081
)

Variables

View Source 
var Busi string = fmt.Sprintf("http://localhost:%d%s", BusiPort, BusiAPI)

Busi busi service url prefix

View Source 
var BusiGrpc string = fmt.Sprintf("localhost:%d", BusiGrpcPort)

BusiGrpc busi service grpc address

View Source 
var Busi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "examples.Busi",
	HandlerType: (*BusiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CanSubmit",
			Handler:    _Busi_CanSubmit_Handler,
		},
		{
			MethodName: "TransIn",
			Handler:    _Busi_TransIn_Handler,
		},
		{
			MethodName: "TransOut",
			Handler:    _Busi_TransOut_Handler,
		},
		{
			MethodName: "TransInRevert",
			Handler:    _Busi_TransInRevert_Handler,
		},
		{
			MethodName: "TransOutRevert",
			Handler:    _Busi_TransOutRevert_Handler,
		},
		{
			MethodName: "TransInConfirm",
			Handler:    _Busi_TransInConfirm_Handler,
		},
		{
			MethodName: "TransOutConfirm",
			Handler:    _Busi_TransOutConfirm_Handler,
		},
		{
			MethodName: "XaNotify",
			Handler:    _Busi_XaNotify_Handler,
		},
		{
			MethodName: "TransInXa",
			Handler:    _Busi_TransInXa_Handler,
		},
		{
			MethodName: "TransOutXa",
			Handler:    _Busi_TransOutXa_Handler,
		},
		{
			MethodName: "TransInTcc",
			Handler:    _Busi_TransInTcc_Handler,
		},
		{
			MethodName: "TransOutTcc",
			Handler:    _Busi_TransOutTcc_Handler,
		},
		{
			MethodName: "TransInTccNested",
			Handler:    _Busi_TransInTccNested_Handler,
		},
		{
			MethodName: "TransInBSaga",
			Handler:    _Busi_TransInBSaga_Handler,
		},
		{
			MethodName: "TransOutBSaga",
			Handler:    _Busi_TransOutBSaga_Handler,
		},
		{
			MethodName: "TransInRevertBSaga",
			Handler:    _Busi_TransInRevertBSaga_Handler,
		},
		{
			MethodName: "TransOutRevertBSaga",
			Handler:    _Busi_TransOutRevertBSaga_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "examples/busi.proto",
}

Busi_ServiceDesc is the grpc.ServiceDesc for Busi 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 DtmClient dtmgimp.DtmClient = nil

DtmClient grpc client for dtm

View Source 
var DtmGrpcServer = fmt.Sprintf("localhost:%d", common.DtmGrpcPort)

DtmGrpcServer dtm grpc service address

View Source 
var DtmHttpServer = fmt.Sprintf("http://localhost:%d/api/dtmsvr", common.DtmHttpPort)

DtmHttpServer dtm service address

View Source 
var File_examples_busi_proto protoreflect.FileDescriptor
View Source 
var MainSwitch mainSwitchType

MainSwitch controls busi success or fail

View Source 
var Samples = map[string]*sampleInfo{}

Samples 所有的示例都会注册到这里

View Source 
var XaClient *dtmcli.XaClient = nil

XaClient XA client connection

View Source 
var XaGrpcClient *dtmgrpc.XaGrpcClient = nil

XaGrpcClient XA client connection

Functions

func BaseAddRoute 

func BaseAddRoute(app *gin.Engine)

BaseAddRoute add base route handler

func BaseAppStartup 

func BaseAppStartup() *gin.Engine

BaseAppStartup base app startup

func GrpcStartup 

func GrpcStartup()

GrpcStartup for grpc

func MustBarrierFromGin 

func MustBarrierFromGin(c *gin.Context) *dtmcli.BranchBarrier

MustBarrierFromGin 1

func MustBarrierFromGrpc 

func MustBarrierFromGrpc(ctx context.Context) *dtmcli.BranchBarrier

MustBarrierFromGrpc 1

func PopulateDB 

func PopulateDB(skipDrop bool)

PopulateDB populate example mysql data

func QsFireRequest 

func QsFireRequest() string

QsFireRequest 1

func QsStartSvr 

func QsStartSvr()

QsStartSvr 1

func RegisterBusiServer 

func RegisterBusiServer(s grpc.ServiceRegistrar, srv BusiServer)

func RunSQLScript 

func RunSQLScript(conf map[string]string, script string, skipDrop bool)

RunSQLScript 1

func TccBarrierTransOutCancel 

func TccBarrierTransOutCancel(c *gin.Context) (interface{}, error)

TccBarrierTransOutCancel will be use in test

Types

type AutoEmptyString 

type AutoEmptyString struct {
	// contains filtered or unexported fields
}

AutoEmptyString auto reset to empty when used once

func (*AutoEmptyString) Fetch 

func (s *AutoEmptyString) Fetch() string

Fetch fetch the stored value, then reset the value to empty

func (*AutoEmptyString) SetOnce 

func (s *AutoEmptyString) SetOnce(v string)

SetOnce set a value once

type BusiClient 

type BusiClient interface {
	CanSubmit(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransIn(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransOut(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransInRevert(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransOutRevert(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransInConfirm(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransOutConfirm(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	XaNotify(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransInXa(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransOutXa(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransInTcc(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransOutTcc(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransInTccNested(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransInBSaga(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransOutBSaga(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransInRevertBSaga(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TransOutRevertBSaga(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

BusiClient is the client API for Busi 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 NewBusiClient 

func NewBusiClient(cc grpc.ClientConnInterface) BusiClient

type BusiReq 

type BusiReq struct {
	Amount         int64  `protobuf:"varint,1,opt,name=Amount,proto3" json:"Amount,omitempty"`
	TransOutResult string `protobuf:"bytes,2,opt,name=TransOutResult,proto3" json:"TransOutResult,omitempty"`
	TransInResult  string `protobuf:"bytes,3,opt,name=TransInResult,proto3" json:"TransInResult,omitempty"`
	// contains filtered or unexported fields
}

DtmRequest request sent to dtm server

func GenBusiReq 

func GenBusiReq(amount int, outFailed bool, inFailed bool) *BusiReq

GenBusiReq 1

func (*BusiReq) Descriptor deprecated 

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

Deprecated: Use BusiReq.ProtoReflect.Descriptor instead.

func (*BusiReq) GetAmount 

func (x *BusiReq) GetAmount() int64

func (*BusiReq) GetTransInResult 

func (x *BusiReq) GetTransInResult() string

func (*BusiReq) GetTransOutResult 

func (x *BusiReq) GetTransOutResult() string

func (*BusiReq) ProtoMessage 

func (*BusiReq) ProtoMessage()

func (*BusiReq) ProtoReflect 

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

func (*BusiReq) Reset 

func (x *BusiReq) Reset()

func (*BusiReq) String 

func (x *BusiReq) String() string

type BusiServer 

type BusiServer interface {
	CanSubmit(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransIn(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransOut(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransInRevert(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransOutRevert(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransInConfirm(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransOutConfirm(context.Context, *BusiReq) (*emptypb.Empty, error)
	XaNotify(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	TransInXa(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransOutXa(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransInTcc(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransOutTcc(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransInTccNested(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransInBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransOutBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransInRevertBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)
	TransOutRevertBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

BusiServer is the server API for Busi service. All implementations must embed UnimplementedBusiServer for forward compatibility

type TransReq 

type TransReq struct {
	Amount         int    `json:"amount"`
	TransInResult  string `json:"transInResult"`
	TransOutResult string `json:"transOutResult"`
}

TransReq transaction request payload

func GenTransReq 

func GenTransReq(amount int, outFailed bool, inFailed bool) *TransReq

GenTransReq 1

func (*TransReq) String 

func (t *TransReq) String() string

type UnimplementedBusiServer 

type UnimplementedBusiServer struct {
}

UnimplementedBusiServer must be embedded to have forward compatible implementations.

func (UnimplementedBusiServer) CanSubmit 

func (UnimplementedBusiServer) CanSubmit(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransIn 

func (UnimplementedBusiServer) TransIn(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransInBSaga 

func (UnimplementedBusiServer) TransInBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransInConfirm 

func (UnimplementedBusiServer) TransInConfirm(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransInRevert 

func (UnimplementedBusiServer) TransInRevert(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransInRevertBSaga 

func (UnimplementedBusiServer) TransInRevertBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransInTcc 

func (UnimplementedBusiServer) TransInTcc(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransInTccNested 

func (UnimplementedBusiServer) TransInTccNested(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransInXa 

func (UnimplementedBusiServer) TransInXa(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransOut 

func (UnimplementedBusiServer) TransOut(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransOutBSaga 

func (UnimplementedBusiServer) TransOutBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransOutConfirm 

func (UnimplementedBusiServer) TransOutConfirm(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransOutRevert 

func (UnimplementedBusiServer) TransOutRevert(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransOutRevertBSaga 

func (UnimplementedBusiServer) TransOutRevertBSaga(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransOutTcc 

func (UnimplementedBusiServer) TransOutTcc(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) TransOutXa 

func (UnimplementedBusiServer) TransOutXa(context.Context, *BusiReq) (*emptypb.Empty, error)

func (UnimplementedBusiServer) XaNotify 

func (UnimplementedBusiServer) XaNotify(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnsafeBusiServer 

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

UnsafeBusiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BusiServer 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.