grpc

Documentation

Index

• func GetV2ResponseCode(rsp interface{}) (uint32, bool)
• type RateLimitServiceV2
  • func (s *RateLimitServiceV2) Service(stream apiv2.RateLimitGRPCV2_ServiceServer) error
  • func (s *RateLimitServiceV2) TimeAdjust(ctx context.Context, req *apiv2.TimeAdjustRequest) (*apiv2.TimeAdjustResponse, error)
• type Server
  • func (g *Server) GetPort() uint32
  • func (g *Server) GetProtocol() string
  • func (g *Server) Initialize(option map[string]interface{}) error
  • func (g *Server) Run(errCh chan error)
  • func (g *Server) Stop()

Functions

func GetV2ResponseCode

func GetV2ResponseCode(rsp interface{}) (uint32, bool)

GetV2ResponseCode 获取返回码

Types

type RateLimitServiceV2

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

RateLimitServiceV2 限流Server：v2接口

func (*RateLimitServiceV2) Service

func (s *RateLimitServiceV2) Service(stream apiv2.RateLimitGRPCV2_ServiceServer) error

Service 限流KEY初始化

func (*RateLimitServiceV2) TimeAdjust

func (s *RateLimitServiceV2) TimeAdjust(
	ctx context.Context, req *apiv2.TimeAdjustRequest) (*apiv2.TimeAdjustResponse, error)

TimeAdjust 获取时间戳

type Server

type Server struct {
	IP   string
	Port uint32
	// contains filtered or unexported fields
}

Server grpc server

func (*Server) GetPort

func (g *Server) GetPort() uint32

GetPort 返回port

func (*Server) GetProtocol

func (g *Server) GetProtocol() string

GetProtocol 返回协议

func (*Server) Initialize

func (g *Server) Initialize(option map[string]interface{}) error

Initialize 初始化函数

func (*Server) Run

func (g *Server) Run(errCh chan error)

Run 入口函数

func (*Server) Stop

func (g *Server) Stop()

Stop 停止