grpcserver

Documentation

Index

• type EtcdRegisterFinder
  • func (r *EtcdRegisterFinder) Register(name string, addr string) error
• type GRPCServer
  • func NewGRPCServer(name string, conf *config.RpcServerConfig) (*GRPCServer, error)
  • func (svr *GRPCServer) AddServiceHandler(f HandlerFunc)
  • func (svr *GRPCServer) AddServiceRegister(r IServiceRegister)
  • func (svr *GRPCServer) Run() error
• type HandlerFunc
• type IServiceDiscovery
• type IServiceRegister
  • func NewEtcdSrvRegister(etcdAddr string) (IServiceRegister, error)

Types

type EtcdRegisterFinder

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

func (*EtcdRegisterFinder) Register

func (r *EtcdRegisterFinder) Register(name string, addr string) error

type GRPCServer

type GRPCServer struct {
	log.InvokeLog

	HandlerFunc HandlerFunc
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(name string, conf *config.RpcServerConfig) (*GRPCServer, error)

func (*GRPCServer) AddServiceHandler

func (svr *GRPCServer) AddServiceHandler(f HandlerFunc)

add服务处理handler

func (*GRPCServer) AddServiceRegister

func (svr *GRPCServer) AddServiceRegister(r IServiceRegister)

add服务注册中心

func (*GRPCServer) Run

func (svr *GRPCServer) Run() error

type HandlerFunc

type HandlerFunc = func(*grpc.Server)

type IServiceDiscovery

type IServiceDiscovery interface {
	Discovery()
}

服务发现者 接口

type IServiceRegister

type IServiceRegister interface {
	Register(name string, addr string) error
}

服务注册者 接口

func NewEtcdSrvRegister

func NewEtcdSrvRegister(etcdAddr string) (IServiceRegister, error)