rpcx

README

xxx

介绍

1. xxxx
2. xxxx
3. xxxx

安装教程

go get github.com/jageros/hawox

使用例子

package main

import (
	"fmt"
	"github.com/jageros/hawox/xxx"
)

func main() {
	/*
	xxxxx
	xxxxx
	xxxxx
	*/
}

使用说明

1. xxxx
2. xxxx
3. xxxx

Documentation

Index

• func CallByName(serviceName string, rpcFn RpcFn) errcode.IErr
• func InitClient(ctx contextx.Context, d registry.Discovery, opfs ...func(cfctx Config))
• func RegistryRpcServer(s *grpc.Server)
• 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))

func RegistryRpcServer

func RegistryRpcServer(s *grpc.Server)

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))