core

Documentation

Index

• type Client
  • func NewClient(connections map[string]*grpc.ClientConn) *Client
  • func (c *Client) Connection(name string) *grpc.ClientConn
• type Gateway
  • func NewGateway(logger log.Logger) *Gateway
  • func (g *Gateway) NewError(code codes.Code, err error) error
  • func (g *Gateway) NewException(code codes.Code, exception exc.Exception) error
  • func (g *Gateway) NewNotfoundError(err error) error
  • func (g *Gateway) NewServerError(err error) error
  • func (g *Gateway) NewServerException(exception exc.Exception) error
  • func (g *Gateway) NewValidationError(err error) error
  • func (g *Gateway) Status(ctx context.Context, code int)
• type Handler
• type Handlers
• type Register
• type Server
  • func NewServer(rpc *grpc.Server, mux *http.ServeMux, server *config.Server, ...) *Server
  • func (s *Server) Serve(register Register) (err error)
  • func (s *Server) Stop(ctx context.Context) (err error)

Types

type Client

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

Client gRPC客户端封装

func NewClient

func NewClient(connections map[string]*grpc.ClientConn) *Client

func (*Client) Connection

func (c *Client) Connection(name string) *grpc.ClientConn

type Gateway

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

func NewGateway

func NewGateway(logger log.Logger) *Gateway

func (*Gateway) NewError

func (g *Gateway) NewError(code codes.Code, err error) error

func (*Gateway) NewException

func (g *Gateway) NewException(code codes.Code, exception exc.Exception) error

func (*Gateway) NewNotfoundError

func (g *Gateway) NewNotfoundError(err error) error

func (*Gateway) NewServerError

func (g *Gateway) NewServerError(err error) error

func (*Gateway) NewServerException

func (g *Gateway) NewServerException(exception exc.Exception) error

func (*Gateway) NewValidationError

func (g *Gateway) NewValidationError(err error) error

func (*Gateway) Status

func (g *Gateway) Status(ctx context.Context, code int)

type Handler

type Handler func(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

Handler 端点注册方法

type Handlers

type Handlers []Handler

Handlers 端点注册接口组

type Register

type Register interface {
	// Grpc gRPC服务
	Grpc(server *grpc.Server)

	// Gateway 网关服务
	Gateway(mux *runtime.ServeMux, opts *[]grpc.DialOption) (ctx context.Context, handlers Handlers)
}

type Server

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

Server gRPC服务器封装

func NewServer

func NewServer(
	rpc *grpc.Server,
	mux *http.ServeMux,
	server *config.Server, gateway *config.Gateway,
	logger log.Logger,
) *Server

func (*Server) Serve

func (s *Server) Serve(register Register) (err error)

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) (err error)