grpc

Documentation

Index

• func NewRPCClient(cfg *ClientConfig) *grpc.ClientConn
• func TracingInterceptor() grpc.UnaryServerInterceptor
• func UnaryClientInterceptor(cb *circuitbreaker.CircuitBreaker, handler OpenStateHandler) grpc.UnaryClientInterceptor
• type Circuitbreaker
• type ClientConfig
• type OpenStateHandler
• type Server
  • func NewServer(c *ServerConfig, opts ...xgprc.ServerOption) (s *Server, err error)
  • func (s *Server) Serve(lis net.Listener) error
  • func (s *Server) Server() *xgprc.Server
  • func (s *Server) Start()
  • func (s *Server) Stop()
  • func (s *Server) Use(interceptors ...xgprc.UnaryServerInterceptor) *Server
• type ServerConfig

Functions

func NewRPCClient

func NewRPCClient(cfg *ClientConfig) *grpc.ClientConn

func TracingInterceptor

func TracingInterceptor() grpc.UnaryServerInterceptor

Tracing Interceptor ....

func UnaryClientInterceptor

func UnaryClientInterceptor(cb *circuitbreaker.CircuitBreaker, handler OpenStateHandler) grpc.UnaryClientInterceptor

Types

type Circuitbreaker

type Circuitbreaker struct {
	CounterResetInterval xtime.Duration // 断路器间隔时间
	Threshold            int64          // 计数器阈值
	OpenTimeout          xtime.Duration // 超时时间
	HalfOpenMaxSuccesses int64          // HalfOpen 次数
}

type ClientConfig

type ClientConfig struct {
	Addr           string
	LoadBalancing  string
	Timeout        xtime.Duration
	RequestTimeout xtime.Duration
	Circuitbreaker Circuitbreaker
}

type OpenStateHandler

type OpenStateHandler func(ctx context.Context, method string, req interface{})

type Server

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

func NewServer

func NewServer(c *ServerConfig, opts ...xgprc.ServerOption) (s *Server, err error)

func (*Server) Serve

func (s *Server) Serve(lis net.Listener) error

func (*Server) Server

func (s *Server) Server() *xgprc.Server

func (*Server) Start

func (s *Server) Start()

func (*Server) Stop

func (s *Server) Stop()

func (*Server) Use

func (s *Server) Use(interceptors ...xgprc.UnaryServerInterceptor) *Server

type ServerConfig

type ServerConfig struct {
	Network           string
	Addr              string
	Timeout           xtime.Duration
	IdleTimeout       xtime.Duration
	MaxLifeTime       xtime.Duration
	ForceCloseWait    xtime.Duration
	KeepAliveInterval xtime.Duration
	KeepAliveTimeout  xtime.Duration
	LogFlag           int8
}