grpc

Documentation

Index

• Constants
• type Options
  • func WithLogger(log *logs.ZapLogger) Options
  • func WithRegistry(r registry.Registry) Options
• 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, opts ...Options) *Server
  • func (s *Server) Close()
  • func (s *Server) Start()

Constants

const SCHEME = "etcd"

Types

type Options

type Options func(s *Server)

func WithLogger

func WithLogger(log *logs.ZapLogger) Options

func WithRegistry

func WithRegistry(r registry.Registry) Options

WithRegistry 注入注册中心

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
	// contains filtered or unexported fields
}

func NewServer

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

func (*Server) Close

func (s *Server) Close()

func (*Server) Start

func (s *Server) Start()