From a5838b976223ff1bae2bcb7b90182a4d13c8adb1 Mon Sep 17 00:00:00 2001 From: guzeng Date: Fri, 20 Aug 2021 11:44:46 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=96=B9=E6=B3=95=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- supplier.pb.go | 64 +++++++++++++++++++++++++------------------------- supplier.proto | 2 +- 2 files changed, 33 insertions(+), 33 deletions(-) diff --git a/supplier.pb.go b/supplier.pb.go index 0fded25..d455077 100644 --- a/supplier.pb.go +++ b/supplier.pb.go @@ -116,18 +116,18 @@ func (m *BoolResponse) GetValue() bool { func init() { } -type ProductService interface { +type SupplierService interface { Get(in *GetRequest, out *GetResponse) error GetByUuid(in *GetUuidRequest, out *GetResponse) error IsOpen(in *GetRequest, out *BoolResponse) error } -// AcceptProductServiceClient accepts connections on the listener and serves requests +// AcceptSupplierServiceClient accepts connections on the listener and serves requests // for each incoming connection. Accept blocks; the caller typically // invokes it in a go statement. -func AcceptProductServiceClient(lis net.Listener, x ProductService) { +func AcceptSupplierServiceClient(lis net.Listener, x SupplierService) { srv := rpc.NewServer() - if err := srv.RegisterName("ProductService", x); err != nil { + if err := srv.RegisterName("SupplierService", x); err != nil { log.Fatal(err) } @@ -140,26 +140,26 @@ func AcceptProductServiceClient(lis net.Listener, x ProductService) { } } -// RegisterProductService publish the given ProductService implementation on the server. -func RegisterProductService(srv *rpc.Server, x ProductService) error { - if err := srv.RegisterName("ProductService", x); err != nil { +// RegisterSupplierService publish the given SupplierService implementation on the server. +func RegisterSupplierService(srv *rpc.Server, x SupplierService) error { + if err := srv.RegisterName("SupplierService", x); err != nil { return err } return nil } -// NewProductServiceServer returns a new ProductService Server. -func NewProductServiceServer(x ProductService) *rpc.Server { +// NewSupplierServiceServer returns a new SupplierService Server. +func NewSupplierServiceServer(x SupplierService) *rpc.Server { srv := rpc.NewServer() - if err := srv.RegisterName("ProductService", x); err != nil { + if err := srv.RegisterName("SupplierService", x); err != nil { log.Fatal(err) } return srv } -// ListenAndServeProductService listen announces on the local network address laddr -// and serves the given ProductService implementation. -func ListenAndServeProductService(network, addr string, x ProductService) error { +// ListenAndServeSupplierService listen announces on the local network address laddr +// and serves the given SupplierService implementation. +func ListenAndServeSupplierService(network, addr string, x SupplierService) error { lis, err := net.Listen(network, addr) if err != nil { return err @@ -167,7 +167,7 @@ func ListenAndServeProductService(network, addr string, x ProductService) error defer lis.Close() srv := rpc.NewServer() - if err := srv.RegisterName("ProductService", x); err != nil { + if err := srv.RegisterName("SupplierService", x); err != nil { return err } @@ -180,42 +180,42 @@ func ListenAndServeProductService(network, addr string, x ProductService) error } } -type ProductServiceClient struct { +type SupplierServiceClient struct { *rpc.Client } -// NewProductServiceClient returns a ProductService rpc.Client and stub to handle -// requests to the set of ProductService at the other end of the connection. -func NewProductServiceClient(conn io.ReadWriteCloser) (*ProductServiceClient, *rpc.Client) { +// NewSupplierServiceClient returns a SupplierService rpc.Client and stub to handle +// requests to the set of SupplierService at the other end of the connection. +func NewSupplierServiceClient(conn io.ReadWriteCloser) (*SupplierServiceClient, *rpc.Client) { c := rpc.NewClientWithCodec(protorpc.NewClientCodec(conn)) - return &ProductServiceClient{c}, c + return &SupplierServiceClient{c}, c } -func (c *ProductServiceClient) Get(in *GetRequest, out *GetResponse) error { - return c.Call("ProductService.Get", in, out) +func (c *SupplierServiceClient) Get(in *GetRequest, out *GetResponse) error { + return c.Call("SupplierService.Get", in, out) } -func (c *ProductServiceClient) GetByUuid(in *GetUuidRequest, out *GetResponse) error { - return c.Call("ProductService.GetByUuid", in, out) +func (c *SupplierServiceClient) GetByUuid(in *GetUuidRequest, out *GetResponse) error { + return c.Call("SupplierService.GetByUuid", in, out) } -func (c *ProductServiceClient) IsOpen(in *GetRequest, out *BoolResponse) error { - return c.Call("ProductService.IsOpen", in, out) +func (c *SupplierServiceClient) IsOpen(in *GetRequest, out *BoolResponse) error { + return c.Call("SupplierService.IsOpen", in, out) } -// DialProductService connects to an ProductService at the specified network address. -func DialProductService(network, addr string) (*ProductServiceClient, *rpc.Client, error) { +// DialSupplierService connects to an SupplierService at the specified network address. +func DialSupplierService(network, addr string) (*SupplierServiceClient, *rpc.Client, error) { c, err := protorpc.Dial(network, addr) if err != nil { return nil, nil, err } - return &ProductServiceClient{c}, c, nil + return &SupplierServiceClient{c}, c, nil } -// DialProductServiceTimeout connects to an ProductService at the specified network address. -func DialProductServiceTimeout(network, addr string, - timeout time.Duration) (*ProductServiceClient, *rpc.Client, error) { +// DialSupplierServiceTimeout connects to an SupplierService at the specified network address. +func DialSupplierServiceTimeout(network, addr string, + timeout time.Duration) (*SupplierServiceClient, *rpc.Client, error) { c, err := protorpc.DialTimeout(network, addr, timeout) if err != nil { return nil, nil, err } - return &ProductServiceClient{c}, c, nil + return &SupplierServiceClient{c}, c, nil } diff --git a/supplier.proto b/supplier.proto index 704b16f..68266ce 100644 --- a/supplier.proto +++ b/supplier.proto @@ -23,7 +23,7 @@ message BoolResponse { } // rpc方法 -service ProductService { +service SupplierService { rpc Get (GetRequest) returns (GetResponse); // 使用id查询 rpc GetByUuid (GetUuidRequest) returns (GetResponse); // 使用uuid查询 rpc IsOpen (GetRequest) returns (BoolResponse); // 是否营业中