save_my_money/smm_core
2
0
Fork 0
Code Issues 5 Pull Requests Packages Projects 1 Releases Wiki Activity

add server

Browse Source
This commit is contained in:
Владимир Фёдоров
2024-11-09 18:18:51 +07:00
parent 93e9f98b5b
commit d566529a90
10 changed files with 163 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proto/smm_core.pb.go
+9 -10
View File
@@ -108,14 +108,13 @@ var file_smm_core_proto_rawDesc = []byte{
0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69,
0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x09, 0x0a, 0x07, 0x50, 0x69, 0x6e,
0x67, 0x52, 0x65, 0x71, 0x22, 0x09, 0x0a, 0x07, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x73, 0x70, 0x32,
0x58, 0x0a, 0x07, 0x53, 0x6d, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x12, 0x4d, 0x0a, 0x0a, 0x47, 0x65,
0x74, 0x43, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x12, 0x17, 0x2e, 0x63, 0x72, 0x61, 0x62, 0x73,
0x2e, 0x73, 0x6d, 0x6d, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65,
0x71, 0x1a, 0x17, 0x2e, 0x63, 0x72, 0x61, 0x62, 0x73, 0x2e, 0x73, 0x6d, 0x6d, 0x5f, 0x63, 0x6f,
0x72, 0x65, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x73, 0x70, 0x22, 0x0d, 0x82, 0xd3, 0xe4, 0x93,
0x02, 0x07, 0x12, 0x05, 0x2f, 0x70, 0x69, 0x6e, 0x67, 0x42, 0x0e, 0x92, 0x41, 0x00, 0x5a, 0x09,
0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x33,
0x52, 0x0a, 0x07, 0x53, 0x6d, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x12, 0x47, 0x0a, 0x04, 0x50, 0x69,
0x6e, 0x67, 0x12, 0x17, 0x2e, 0x63, 0x72, 0x61, 0x62, 0x73, 0x2e, 0x73, 0x6d, 0x6d, 0x5f, 0x63,
0x6f, 0x72, 0x65, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x1a, 0x17, 0x2e, 0x63, 0x72,
0x61, 0x62, 0x73, 0x2e, 0x73, 0x6d, 0x6d, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x69, 0x6e,
0x67, 0x52, 0x73, 0x70, 0x22, 0x0d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x07, 0x12, 0x05, 0x2f, 0x70,
0x69, 0x6e, 0x67, 0x42, 0x0e, 0x92, 0x41, 0x00, 0x5a, 0x09, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72,
0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
@@ -136,8 +135,8 @@ var file_smm_core_proto_goTypes = []any{
(*PingRsp)(nil), // 1: crabs.smm_core.PingRsp
}
var file_smm_core_proto_depIdxs = []int32{
0, // 0: crabs.smm_core.SmmCore.GetCatalog:input_type -> crabs.smm_core.PingReq
1, // 1: crabs.smm_core.SmmCore.GetCatalog:output_type -> crabs.smm_core.PingRsp
0, // 0: crabs.smm_core.SmmCore.Ping:input_type -> crabs.smm_core.PingReq
1, // 1: crabs.smm_core.SmmCore.Ping:output_type -> crabs.smm_core.PingRsp
1, // [1:2] is the sub-list for method output_type
0, // [0:1] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
proto/smm_core.pb.gw.go
+14 -14
View File
@@ -31,20 +31,20 @@ var _ = runtime.String
var _ = utilities.NewDoubleArray
var _ = metadata.Join
func request_SmmCore_GetCatalog_0(ctx context.Context, marshaler runtime.Marshaler, client SmmCoreClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
func request_SmmCore_Ping_0(ctx context.Context, marshaler runtime.Marshaler, client SmmCoreClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq PingReq
var metadata runtime.ServerMetadata
msg, err := client.GetCatalog(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
msg, err := client.Ping(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
return msg, metadata, err
}
func local_request_SmmCore_GetCatalog_0(ctx context.Context, marshaler runtime.Marshaler, server SmmCoreServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
func local_request_SmmCore_Ping_0(ctx context.Context, marshaler runtime.Marshaler, server SmmCoreServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq PingReq
var metadata runtime.ServerMetadata
msg, err := server.GetCatalog(ctx, &protoReq)
msg, err := server.Ping(ctx, &protoReq)
return msg, metadata, err
}
@@ -56,7 +56,7 @@ func local_request_SmmCore_GetCatalog_0(ctx context.Context, marshaler runtime.M
// GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.
func RegisterSmmCoreHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SmmCoreServer) error {
mux.Handle("GET", pattern_SmmCore_GetCatalog_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
mux.Handle("GET", pattern_SmmCore_Ping_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(req.Context())
defer cancel()
var stream runtime.ServerTransportStream
@@ -64,12 +64,12 @@ func RegisterSmmCoreHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
var err error
var annotatedContext context.Context
annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.smm_core.SmmCore/GetCatalog", runtime.WithHTTPPathPattern("/ping"))
annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.smm_core.SmmCore/Ping", runtime.WithHTTPPathPattern("/ping"))
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
resp, md, err := local_request_SmmCore_GetCatalog_0(annotatedContext, inboundMarshaler, server, req, pathParams)
resp, md, err := local_request_SmmCore_Ping_0(annotatedContext, inboundMarshaler, server, req, pathParams)
md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
if err != nil {
@@ -77,7 +77,7 @@ func RegisterSmmCoreHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
return
}
forward_SmmCore_GetCatalog_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
forward_SmmCore_Ping_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
@@ -122,25 +122,25 @@ func RegisterSmmCoreHandler(ctx context.Context, mux *runtime.ServeMux, conn *gr
// "SmmCoreClient" to call the correct interceptors. This client ignores the HTTP middlewares.
func RegisterSmmCoreHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SmmCoreClient) error {
mux.Handle("GET", pattern_SmmCore_GetCatalog_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
mux.Handle("GET", pattern_SmmCore_Ping_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(req.Context())
defer cancel()
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
var err error
var annotatedContext context.Context
annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.smm_core.SmmCore/GetCatalog", runtime.WithHTTPPathPattern("/ping"))
annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.smm_core.SmmCore/Ping", runtime.WithHTTPPathPattern("/ping"))
if err != nil {
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
return
}
resp, md, err := request_SmmCore_GetCatalog_0(annotatedContext, inboundMarshaler, client, req, pathParams)
resp, md, err := request_SmmCore_Ping_0(annotatedContext, inboundMarshaler, client, req, pathParams)
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
if err != nil {
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
return
}
forward_SmmCore_GetCatalog_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
forward_SmmCore_Ping_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
})
@@ -148,9 +148,9 @@ func RegisterSmmCoreHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
}
var (
pattern_SmmCore_GetCatalog_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0}, []string{"ping"}, ""))
pattern_SmmCore_Ping_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0}, []string{"ping"}, ""))
)
var (
forward_SmmCore_GetCatalog_0 = runtime.ForwardResponseMessage
forward_SmmCore_Ping_0 = runtime.ForwardResponseMessage
)
proto/smm_core_grpc.pb.go
+13 -13
View File
@@ -19,14 +19,14 @@ import (
const _ = grpc.SupportPackageIsVersion9
const (
SmmCore_GetCatalog_FullMethodName = "/crabs.smm_core.SmmCore/GetCatalog"
SmmCore_Ping_FullMethodName = "/crabs.smm_core.SmmCore/Ping"
)
// SmmCoreClient is the client API for SmmCore 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.
type SmmCoreClient interface {
GetCatalog(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRsp, error)
Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRsp, error)
}
type smmCoreClient struct {
@@ -37,10 +37,10 @@ func NewSmmCoreClient(cc grpc.ClientConnInterface) SmmCoreClient {
return &smmCoreClient{cc}
}
func (c *smmCoreClient) GetCatalog(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRsp, error) {
func (c *smmCoreClient) Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRsp, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(PingRsp)
err := c.cc.Invoke(ctx, SmmCore_GetCatalog_FullMethodName, in, out, cOpts...)
err := c.cc.Invoke(ctx, SmmCore_Ping_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -51,7 +51,7 @@ func (c *smmCoreClient) GetCatalog(ctx context.Context, in *PingReq, opts ...grp
// All implementations must embed UnimplementedSmmCoreServer
// for forward compatibility.
type SmmCoreServer interface {
GetCatalog(context.Context, *PingReq) (*PingRsp, error)
Ping(context.Context, *PingReq) (*PingRsp, error)
mustEmbedUnimplementedSmmCoreServer()
}
@@ -62,8 +62,8 @@ type SmmCoreServer interface {
// pointer dereference when methods are called.
type UnimplementedSmmCoreServer struct{}
func (UnimplementedSmmCoreServer) GetCatalog(context.Context, *PingReq) (*PingRsp, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetCatalog not implemented")
func (UnimplementedSmmCoreServer) Ping(context.Context, *PingReq) (*PingRsp, error) {
return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented")
}
func (UnimplementedSmmCoreServer) mustEmbedUnimplementedSmmCoreServer() {}
func (UnimplementedSmmCoreServer) testEmbeddedByValue() {}
@@ -86,20 +86,20 @@ func RegisterSmmCoreServer(s grpc.ServiceRegistrar, srv SmmCoreServer) {
s.RegisterService(&SmmCore_ServiceDesc, srv)
}
func _SmmCore_GetCatalog_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
func _SmmCore_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PingReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SmmCoreServer).GetCatalog(ctx, in)
return srv.(SmmCoreServer).Ping(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: SmmCore_GetCatalog_FullMethodName,
FullMethod: SmmCore_Ping_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SmmCoreServer).GetCatalog(ctx, req.(*PingReq))
return srv.(SmmCoreServer).Ping(ctx, req.(*PingReq))
}
return interceptor(ctx, in, info, handler)
}
@@ -112,8 +112,8 @@ var SmmCore_ServiceDesc = grpc.ServiceDesc{
HandlerType: (*SmmCoreServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetCatalog",
Handler: _SmmCore_GetCatalog_Handler,
MethodName: "Ping",
Handler: _SmmCore_Ping_Handler,
},
},
Streams: []grpc.StreamDesc{},