rpc

Documentation

Index

• Constants
• Variables
• func DSN(service string) string
• func GetListenAddr(port int, mod string) (string, error)
• func Init(etcdAddr string)
• func NewClient(service string, newClient func(cc *grpc.ClientConn))
• type OptionFunc
  • func WithMod(mod string) OptionFunc
• type Options
• type Server
  • func NewServer(service, etcdAddr string, listenPort int, optsF ...OptionFunc) (*Server, error)
  • func (s *Server) Register(registerServer func(grpc.ServiceRegistrar))
  • func (s *Server) Serve()
  • func (s *Server) Stop()
• type SignBuilder
  • func (sb *SignBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (sb *SignBuilder) Scheme() string
• type SignResolver
  • func (sr *SignResolver) Close()
  • func (sr *SignResolver) ResolveNow(rno resolver.ResolveNowOptions)

Constants

const (
	SignScheme = "sign"
)

Variables

var (
	ErrInvalidServiceName = errors.New("invalid service name")
	ErrListenAddrNotFound = errors.New("listen addr not found")
)

Functions

func DSN

func DSN(service string) string

func GetListenAddr

func GetListenAddr(port int, mod string) (string, error)

func Init

func Init(etcdAddr string)

func NewClient

func NewClient(service string, newClient func(cc *grpc.ClientConn))

Types

type OptionFunc

type OptionFunc func(opts *Options)

func WithMod

func WithMod(mod string) OptionFunc

type Options

type Options struct {
	Mod string
}

type Server

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

func NewServer

func NewServer(service, etcdAddr string, listenPort int, optsF ...OptionFunc) (*Server, error)

func (*Server) Register

func (s *Server) Register(registerServer func(grpc.ServiceRegistrar))

func (*Server) Serve

func (s *Server) Serve()

func (*Server) Stop

func (s *Server) Stop()

type SignBuilder

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

func (*SignBuilder) Build

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

func (*SignBuilder) Scheme

func (sb *SignBuilder) Scheme() string

type SignResolver

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

func (*SignResolver) Close

func (sr *SignResolver) Close()

Close closes the resolver.

func (*SignResolver) ResolveNow

func (sr *SignResolver) ResolveNow(rno resolver.ResolveNowOptions)