grpcserver

Documentation

Index

• Variables
• type EtcdRegisterFinder
  • func (r *EtcdRegisterFinder) Register(name string, addr string) error
• type GRPCServer
  • func NewGRPCServer(name string, addr string, ops ...ServerOps) (*GRPCServer, error)
  • func (svr *GRPCServer) AddServiceRegister(r IServiceRegister)
  • func (svr *GRPCServer) Run() error
• type HandlerFunc
• type IServiceDiscovery
• type IServiceRegister
  • func NewEtcdSrvRegister(etcdAddr string) (IServiceRegister, error)
• type ServerOps

Variables

var WithOpsHandler = func(h HandlerFunc) ServerOps {
	return func(server *GRPCServer) {
		server.HandlerFunc = h
	}
}

var WithOpsRequestIp = func(ip string) ServerOps {
	return func(server *GRPCServer) {
		server.RequestIp = ip
	}
}

var WithOpsRequestPort = func(port string) ServerOps {
	return func(server *GRPCServer) {
		server.RequestPort = port
	}
}

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 {
	HandlerFunc HandlerFunc

	RequestIp   string
	RequestPort string
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(name string, addr string, ops ...ServerOps) (*GRPCServer, error)

func (*GRPCServer) AddServiceRegister

func (svr *GRPCServer) AddServiceRegister(r IServiceRegister)

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)

type ServerOps

type ServerOps = func(*GRPCServer)