rpcx

Documentation

Index

• func CallByName(serviceName string, rpcFn RpcFn) errcode.IErr
• func InitClient(ctx contextx.Context, d registry.Discovery, opfs ...func(cfctx Config))
• type Config
• type Option
• type RpcFn
• type Server
  • func NewServer(ctx contextx.Context, opfs ...func(opt *Option)) *Server
  • func (s *Server) RegistryService(registryFunc func(svr *grpc.Server))

Functions

func CallByName

func CallByName(serviceName string, rpcFn RpcFn) errcode.IErr

func InitClient

func InitClient(ctx contextx.Context, d registry.Discovery, opfs ...func(cfctx Config))

Types

type Config

type Config interface {
	SetCallTimeout(callTimeout time.Duration)
}

type Option

type Option struct {
	ID           string
	Name         string
	Ip           string
	Port         int // 端口最大值：65535
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	CloseTimeout time.Duration
	Registrar    registry.Registrar // 服务注册接口
	Endpoint     string
}

type RpcFn

type RpcFn func(cc *grpc.ClientConn)

type Server

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

func NewServer

func NewServer(ctx contextx.Context, opfs ...func(opt *Option)) *Server

func (*Server) RegistryService

func (s *Server) RegistryService(registryFunc func(svr *grpc.Server))