grpc

Documentation

Index

• type Server
  • func NewGRPCServer(config config.GRPC, productApp app.ProductApplication) *Server
  • func (srv *Server) CheckProducts(ctx context.Context, req *pb.CheckProductsRequest) (*pb.CheckProductsResponse, error)
  • func (srv *Server) GetProducts(ctx context.Context, req *pb.GetProductsRequest) (*pb.GetProductsResponse, error)
  • func (srv *Server) GracefulStop()
  • func (srv *Server) Run() error

Types

type Server

type Server struct {
	Port string

	pb.UnimplementedProductServiceServer
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(config config.GRPC, productApp app.ProductApplication) *Server

func (*Server) CheckProducts

func (srv *Server) CheckProducts(ctx context.Context, req *pb.CheckProductsRequest) (*pb.CheckProductsResponse, error)

func (*Server) GetProducts

func (srv *Server) GetProducts(ctx context.Context, req *pb.GetProductsRequest) (*pb.GetProductsResponse, error)

func (*Server) GracefulStop

func (srv *Server) GracefulStop()

func (*Server) Run

func (srv *Server) Run() error