src

Documentation

Index

• func MakeLoginEndPoint(s Service) endpoint.Endpoint
• func NewGRPCServer(endpoint EndPointServer, log *zap.Logger) pb.UserServer
• func NewGolangRateAllowMiddleware(limit *rate.Limiter) endpoint.Middleware
• func NewTracerEndpointMiddleware(tracer opentracing.Tracer) endpoint.Middleware
• func RequestGrpcLogin(_ context.Context, grpcReq interface{}) (interface{}, error)
• func ResponseGrpcLogin(_ context.Context, response interface{}) (interface{}, error)
• type EndPointServer
  • func NewEndPointServer(svc Service, limit *rate.Limiter, tracer opentracing.Tracer) EndPointServer
  • func (s EndPointServer) Login(ctx context.Context, in Login) (ack LoginAck, err error)
• type Login
• type LoginAck
• type LoginRequest
• type LoginResponse
• type NewMiddlewareServer
  • func NewLogMiddlewareServer(log *zap.Logger) NewMiddlewareServer
  • func NewMetricsMiddlewareServer(counter metrics.Counter, histogram metrics.Histogram) NewMiddlewareServer
  • func NewTracerMiddlewareServer(tracer opentracing.Tracer) NewMiddlewareServer
• type Service
  • func NewService(log *zap.Logger, counter metrics.Counter, histogram metrics.Histogram, ...) Service

Functions

func MakeLoginEndPoint

func MakeLoginEndPoint(s Service) endpoint.Endpoint

func NewGRPCServer

func NewGRPCServer(endpoint EndPointServer, log *zap.Logger) pb.UserServer

func NewGolangRateAllowMiddleware

func NewGolangRateAllowMiddleware(limit *rate.Limiter) endpoint.Middleware

func NewTracerEndpointMiddleware

func NewTracerEndpointMiddleware(tracer opentracing.Tracer) endpoint.Middleware

func RequestGrpcLogin

func RequestGrpcLogin(_ context.Context, grpcReq interface{}) (interface{}, error)

func ResponseGrpcLogin

func ResponseGrpcLogin(_ context.Context, response interface{}) (interface{}, error)

Types

type EndPointServer

type EndPointServer struct {
	LoginEndPoint endpoint.Endpoint
}

func NewEndPointServer

func NewEndPointServer(svc Service, limit *rate.Limiter, tracer opentracing.Tracer) EndPointServer

func (EndPointServer) Login

func (s EndPointServer) Login(ctx context.Context, in Login) (ack LoginAck, err error)

type Login

type Login struct {
	Account  string `json:"account"`
	Password string `json:"password"`
}

type LoginAck

type LoginAck struct {
	Token string `json:"token"`
}

type LoginRequest

type LoginRequest struct {
	In Login `json:"in"`
}

type LoginResponse

type LoginResponse struct {
	Ack LoginAck `json:"ack"`
	Err error    `json:"err"`
}

type NewMiddlewareServer

type NewMiddlewareServer func(Service) Service

func NewLogMiddlewareServer

func NewLogMiddlewareServer(log *zap.Logger) NewMiddlewareServer

func NewMetricsMiddlewareServer

func NewMetricsMiddlewareServer(counter metrics.Counter, histogram metrics.Histogram) NewMiddlewareServer

func NewTracerMiddlewareServer

func NewTracerMiddlewareServer(tracer opentracing.Tracer) NewMiddlewareServer

type Service

type Service interface {
	Login(ctx context.Context, in Login) (ack LoginAck, err error)
}

func NewService

func NewService(log *zap.Logger, counter metrics.Counter, histogram metrics.Histogram, tracer opentracing.Tracer) Service