Documentation
¶
Index ¶
- Constants
- Variables
- func GrpcNewServer() *grpc.Server
- func GrpcStartup(s *grpc.Server)
- func RegisterBusiServer(s grpc.ServiceRegistrar, srv BusiServer)
- type BusiClient
- type BusiReply
- type BusiReq
- func (*BusiReq) Descriptor() ([]byte, []int)deprecated
- func (x *BusiReq) GetAmount() int64
- func (x *BusiReq) GetTransInResult() string
- func (x *BusiReq) GetTransOutResult() string
- func (x *BusiReq) GetUserID() int64
- func (*BusiReq) ProtoMessage()
- func (x *BusiReq) ProtoReflect() protoreflect.Message
- func (x *BusiReq) Reset()
- func (x *BusiReq) String() string
- type BusiServer
- type UnimplementedBusiServer
- func (UnimplementedBusiServer) TransIn(context.Context, *BusiReq) (*BusiReply, error)
- func (UnimplementedBusiServer) TransInRevert(context.Context, *BusiReq) (*BusiReply, error)
- func (UnimplementedBusiServer) TransOut(context.Context, *BusiReq) (*BusiReply, error)
- func (UnimplementedBusiServer) TransOutRevert(context.Context, *BusiReq) (*BusiReply, error)
- type UnsafeBusiServer
Constants ¶
const BusiGrpcPort = 50589
BusiGrpcPort 1
const DtmGrpcServer = "localhost:36790"
DtmGrpcServer dtm grpc service address
Variables ¶
var BusiGrpc string = fmt.Sprintf("localhost:%d", BusiGrpcPort)
BusiGrpc busi service grpc address
var Busi_ServiceDesc = grpc.ServiceDesc{ ServiceName: "busi.Busi", HandlerType: (*BusiServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "TransInRevert", Handler: _Busi_TransInRevert_Handler, }, { MethodName: "TransOutRevert", Handler: _Busi_TransOutRevert_Handler, }, { MethodName: "TransIn", Handler: _Busi_TransIn_Handler, }, { MethodName: "TransOut", Handler: _Busi_TransOut_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "busi/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)
var File_busi_busi_proto protoreflect.FileDescriptor
Functions ¶
func RegisterBusiServer ¶
func RegisterBusiServer(s grpc.ServiceRegistrar, srv BusiServer)
Types ¶
type BusiClient ¶
type BusiClient interface {
TransInRevert(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*BusiReply, error)
TransOutRevert(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*BusiReply, error)
TransIn(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*BusiReply, error)
TransOut(ctx context.Context, in *BusiReq, opts ...grpc.CallOption) (*BusiReply, 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 BusiReply ¶
type BusiReply struct {
Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
// contains filtered or unexported fields
}
func (*BusiReply) Descriptor
deprecated
func (*BusiReply) GetMessage ¶
func (*BusiReply) ProtoMessage ¶
func (*BusiReply) ProtoMessage()
func (*BusiReply) ProtoReflect ¶
func (x *BusiReply) ProtoReflect() protoreflect.Message
type BusiReq ¶
type BusiReq struct {
Amount int64 `protobuf:"varint,1,opt,name=Amount,proto3" json:"Amount,omitempty"`
UserID int64 `protobuf:"varint,2,opt,name=UserID,proto3" json:"UserID,omitempty"`
TransOutResult string `protobuf:"bytes,3,opt,name=TransOutResult,proto3" json:"TransOutResult,omitempty"`
TransInResult string `protobuf:"bytes,4,opt,name=TransInResult,proto3" json:"TransInResult,omitempty"`
// contains filtered or unexported fields
}
func (*BusiReq) Descriptor
deprecated
func (*BusiReq) GetTransInResult ¶
func (*BusiReq) GetTransOutResult ¶
func (*BusiReq) ProtoMessage ¶
func (*BusiReq) ProtoMessage()
func (*BusiReq) ProtoReflect ¶
func (x *BusiReq) ProtoReflect() protoreflect.Message
type BusiServer ¶
type BusiServer interface {
TransInRevert(context.Context, *BusiReq) (*BusiReply, error)
TransOutRevert(context.Context, *BusiReq) (*BusiReply, error)
TransIn(context.Context, *BusiReq) (*BusiReply, error)
TransOut(context.Context, *BusiReq) (*BusiReply, error)
// contains filtered or unexported methods
}
BusiServer is the server API for Busi service. All implementations must embed UnimplementedBusiServer for forward compatibility
type UnimplementedBusiServer ¶
type UnimplementedBusiServer struct {
}
UnimplementedBusiServer must be embedded to have forward compatible implementations.
func (UnimplementedBusiServer) TransInRevert ¶
func (UnimplementedBusiServer) TransOutRevert ¶
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.