grpc

Documentation

Index

• Constants
• func ClientConn(target string) (conn *grpc.ClientConn, err error)
• func NewClientConn(etcdClient *etcd.Client, target string) (conn *grpc.ClientConn, err error)
• type Server
  • func NewServer(target, host string, port int, register ServiceRegister) *Server
  • func NewServerWithOption(target, host string, port int, register ServiceRegister, ...) *Server
  • func (s *Server) GetServiceInfo() map[string]grpc.ServiceInfo
  • func (s *Server) GracefulStop()
  • func (s *Server) RegisterService(sd *grpc.ServiceDesc, ss interface{})
  • func (s *Server) Serve() (err error)
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ServiceRegister

Constants

const ServiceLeaseTTL = 3

Functions

func ClientConn

func ClientConn(target string) (conn *grpc.ClientConn, err error)

func NewClientConn

func NewClientConn(etcdClient *etcd.Client, target string) (conn *grpc.ClientConn, err error)

Types

type Server

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

func NewServer

func NewServer(target, host string, port int, register ServiceRegister) *Server

func NewServerWithOption

func NewServerWithOption(target, host string, port int, register ServiceRegister, opt ...grpc.ServerOption) *Server

func (*Server) GetServiceInfo

func (s *Server) GetServiceInfo() map[string]grpc.ServiceInfo

func (*Server) GracefulStop

func (s *Server) GracefulStop()

func (*Server) RegisterService

func (s *Server) RegisterService(sd *grpc.ServiceDesc, ss interface{})

func (*Server) Serve

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

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServiceRegister

type ServiceRegister func(s *grpc.Server)