goo_grpc

README

goo-grpc

服务端

var cfg = goo_etcd.Config{
    User: "test",
    Password: "123456",
    Endpoints: []string{"localhost:23791", "localhost:23792", "localhost:23793"},
}

func init() {
	goo_etcd.Init(cfg)
}

func main() {
	s := goo_grpc.New(goo_grpc.Config{
		ENV:         "test",
		ServiceName: "lpro/grpc-user",
		Version:     "v100",
		Addr:        "127.0.0.1:10011",
	}).Register2Etcd(goo_etcd.CLI())

	pb_user_v1.RegisterGetterServer(s.Server, &Server{})

	s.Serve()
}

客户端

var cfg = goo_etcd.Config{
    User: "test",
    Password: "123456",
    Endpoints: []string{"localhost:23791", "localhost:23792", "localhost:23793"},
}

func init() {
	goo_etcd.Init(cfg)
}

func main() {
	serviceName := "/test/lproj/grpc-user/v100"

	cc, err := goo_grpc.DialWithEtcd(context.TODO(), serviceName, goo_etcd.CLI())
	if err != nil {
		goo_log.Error(err.Error())
	}

	// -------------------------------------
	// -------------------------------------

	cli := pb_user_v1.NewGetterClient(cc)

	for {
		select {
		case <-goo_context.Cancel().Done():
			return
		default:
			cli.Info(context.TODO(), &pb_user_v1.InfoParams{Id: 1})
			time.Sleep(time.Second)
		}
	}
}

Documentation

Index

• func Context(c *gin.Context) context.Context
• func Dial(ctx context.Context, addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func DialWithEtcd(ctx context.Context, serviceName string, cli *goo_etcd.Client) (*grpc.ClientConn, error)
• func GRPCInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (rsp interface{}, err error)
• type Config
• type GRPCGraceful
  • func NewGRPCGraceful(nett, addr string, s *grpc.Server) *GRPCGraceful
  • func (g *GRPCGraceful) Serve() error
• type Health
  • func (Health) Check(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (Health) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error
• type Option
  • func EnvOption(env string) Option
  • func EtcdOption(cli *goo_etcd.Client) Option
  • func ProjectNameOption(projectName string) Option
  • func ServiceNameOption(serviceName string) Option
  • func VersionOption(version string) Option
• type Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)
• type ResolverEtcd
  • func NewResolverEtcd(ctx context.Context, cli *goo_etcd.Client) *ResolverEtcd
  • func (b *ResolverEtcd) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (b *ResolverEtcd) Scheme() string
• type Server
  • func New(cfg Config) *Server
  • func (s *Server) Register2Etcd(cli *goo_etcd.Client) *Server
  • func (s *Server) Serve() error

Functions

func Context

func Context(c *gin.Context) context.Context

func Dial

func Dial(ctx context.Context, addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func DialWithEtcd

func DialWithEtcd(ctx context.Context, serviceName string, cli *goo_etcd.Client) (*grpc.ClientConn, error)

func GRPCInterceptor

func GRPCInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (rsp interface{}, err error)

Types

type Config

type Config struct {
	ENV         string
	ServiceName string
	Version     string
	Addr        string
	PProfEnable bool
	PProfAddr   string
}

type GRPCGraceful

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

func NewGRPCGraceful

func NewGRPCGraceful(nett, addr string, s *grpc.Server) *GRPCGraceful

func (*GRPCGraceful) Serve

func (g *GRPCGraceful) Serve() error

type Health

type Health struct{}

func (Health) Check

func (Health) Check(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (Health) Watch

func (Health) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error

type Option

type Option struct {
	Name  string
	Value interface{}
}

func EnvOption

func EnvOption(env string) Option

func EtcdOption

func EtcdOption(cli *goo_etcd.Client) Option

func ProjectNameOption

func ProjectNameOption(projectName string) Option

func ServiceNameOption

func ServiceNameOption(serviceName string) Option

func VersionOption

func VersionOption(version string) Option

type Resolver

type Resolver struct {
}

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)

type ResolverEtcd

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

func NewResolverEtcd

func NewResolverEtcd(ctx context.Context, cli *goo_etcd.Client) *ResolverEtcd

func (*ResolverEtcd) Build

func (b *ResolverEtcd) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*ResolverEtcd) Scheme

func (b *ResolverEtcd) Scheme() string

type Server

type Server struct {
	*grpc.Server
	// contains filtered or unexported fields
}

func New

func New(cfg Config) *Server

func (*Server) Register2Etcd

func (s *Server) Register2Etcd(cli *goo_etcd.Client) *Server

func (*Server) Serve

func (s *Server) Serve() error