core

Documentation

Index

• type Client
  • func NewClient(connections map[string]*grpc.ClientConn) *Client
  • func (c *Client) Connection(name string) *grpc.ClientConn
• type Handler
• type Handlers
• type Register
• type Server
  • func NewServer(server *grpc.Server, mux *http.ServeMux, config *config.Server, ...) *Server
  • func (s *Server) Serve(register Register) (err error)
  • func (s *Server) Stop()

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 Handler

type Handler func(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) 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(server *grpc.Server, mux *http.ServeMux, config *config.Server, logger simaqian.Logger) *Server

func (*Server) Serve

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

func (*Server) Stop

func (s *Server) Stop()