utils

Documentation

Index

• Constants
• Variables
• func CreateJwtToken(name string, dcId int) (string, error)
• func GetLogger() *zap.Logger
• func JaegerClientMiddleware(tracer opentracing.Tracer) grpc.UnaryClientInterceptor
• func JaegerServerMiddleware(tracer opentracing.Tracer) grpc.UnaryServerInterceptor
• func NewJaegerTracer(serviceName string) (tracer opentracing.Tracer, closer io.Closer, err error)
• func NewLoggerServer()
• func ParseToken(token string) (jwt.MapClaims, error)
• type Hystrix
  • func NewHystrix(msg string) *Hystrix
  • func (s *Hystrix) Run(name string, run runFunc) error
• type LogErrorHandler
  • func NewZapLogErrorHandler(logger *zap.Logger) *LogErrorHandler
  • func (h *LogErrorHandler) Handle(ctx context.Context, err error)
• type MDReaderWriter
  • func (c MDReaderWriter) ForeachKey(handler func(key, val string) error) error
  • func (c MDReaderWriter) Set(key, val string)
• type Token

Constants

const ContextReqUUid = "req_uuid"

const JWT_CONTEXT_KEY = "jwt_context_key"

Variables

var (
	TracingComponentTag = opentracing.Tag{Key: string(ext.Component), Value: "grpc"}
)

Functions

func CreateJwtToken

func CreateJwtToken(name string, dcId int) (string, error)

func GetLogger

func GetLogger() *zap.Logger

func JaegerClientMiddleware

func JaegerClientMiddleware(tracer opentracing.Tracer) grpc.UnaryClientInterceptor

func JaegerServerMiddleware

func JaegerServerMiddleware(tracer opentracing.Tracer) grpc.UnaryServerInterceptor

func NewJaegerTracer

func NewJaegerTracer(serviceName string) (tracer opentracing.Tracer, closer io.Closer, err error)

func NewLoggerServer

func NewLoggerServer()

func ParseToken

func ParseToken(token string) (jwt.MapClaims, error)

Types

type Hystrix

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

func NewHystrix

func NewHystrix(msg string) *Hystrix

func (*Hystrix) Run

func (s *Hystrix) Run(name string, run runFunc) error

type LogErrorHandler

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

func NewZapLogErrorHandler

func NewZapLogErrorHandler(logger *zap.Logger) *LogErrorHandler

func (*LogErrorHandler) Handle

func (h *LogErrorHandler) Handle(ctx context.Context, err error)

type MDReaderWriter

type MDReaderWriter struct {
	metadata.MD
}

func (MDReaderWriter) ForeachKey

func (c MDReaderWriter) ForeachKey(handler func(key, val string) error) error

func (MDReaderWriter) Set

func (c MDReaderWriter) Set(key, val string)

type Token

type Token struct {
	Name string
	DcId int
	jwt.StandardClaims
}