grpc

Documentation

Index

• Constants
• func ClientWithProject(register registry.Registry, balancerName string, ...) (grpcProject.ProjectServiceClient, error)
• func ClientWithUser(register registry.Registry, balancerName string, ...) (grpcUser.UserServiceClient, error)
• func NewClient(register registry.Registry, balancerName, serviceName string, ...) (*grpc.ClientConn, error)
• type Options
  • func WithLogger(log *logs.ZapLogger) Options
  • func WithRegistry(r registry.Registry) Options
  • func WithUnaryInterceptor(middleware ...grpc.UnaryServerInterceptor) Options
• type RegisterFunc
• type Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(options resolver.ResolveNowOptions)
• type ResolverBuilder
  • func NewResolverBuilder(r registry.Registry) *ResolverBuilder
  • func (b *ResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (b *ResolverBuilder) Scheme() string
• type Server
  • func NewServer(si registry.ServiceInstance, registerService RegisterFunc, opts ...Options) *Server
  • func (s *Server) Close(sig os.Signal)
  • func (s *Server) Start()

Constants

const (
	UserServiceName    = "project-user"
	ProjectServiceName = "project-project"
)

const SCHEME = "etcd"

Functions

func ClientWithProject

func ClientWithProject(register registry.Registry, balancerName string, interceptor ...grpc.UnaryClientInterceptor) (grpcProject.ProjectServiceClient, error)

func ClientWithUser

func ClientWithUser(register registry.Registry, balancerName string, interceptor ...grpc.UnaryClientInterceptor) (grpcUser.UserServiceClient, error)

func NewClient

func NewClient(register registry.Registry, balancerName, serviceName string, interceptor ...grpc.UnaryClientInterceptor) (*grpc.ClientConn, error)

NewClient 创建一个grpc客户端

Types

type Options

type Options func(s *Server)

func WithLogger

func WithLogger(log *logs.ZapLogger) Options

WithLogger 注入日志

func WithRegistry

func WithRegistry(r registry.Registry) Options

WithRegistry 注入注册中心

func WithUnaryInterceptor

func WithUnaryInterceptor(middleware ...grpc.UnaryServerInterceptor) Options

WithUnaryInterceptor 注入中间件

type RegisterFunc

type RegisterFunc func(s grpc.ServiceRegistrar)

type Resolver

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

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

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

type ResolverBuilder

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

func NewResolverBuilder

func NewResolverBuilder(r registry.Registry) *ResolverBuilder

func (*ResolverBuilder) Build

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

func (*ResolverBuilder) Scheme

func (b *ResolverBuilder) Scheme() string

type Server

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

func NewServer

func NewServer(si registry.ServiceInstance, registerService RegisterFunc, opts ...Options) *Server

func (*Server) Close

func (s *Server) Close(sig os.Signal)

func (*Server) Start

func (s *Server) Start()