cacheInterceptor

Documentation

Index

• func CtxLogger(ctx context.Context) *logrus.Entry
• func GetLogger() *logrus.Logger
• type CacheInterceptor
  • func New(redisClient redis.UniversalClient, prefix string, ...) *CacheInterceptor
  • func (c *CacheInterceptor) AddMethodToCache(method string, opt *Option)
  • func (c *CacheInterceptor) Interceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type Option

Functions

func CtxLogger

func CtxLogger(ctx context.Context) *logrus.Entry

func GetLogger

func GetLogger() *logrus.Logger

Types

type CacheInterceptor

type CacheInterceptor struct {
	MethodToCache map[string]*Option
	// contains filtered or unexported fields
}

func New

func New(redisClient redis.UniversalClient, prefix string, methodToCache map[string]*Option, opt *Option) *CacheInterceptor

func (*CacheInterceptor) AddMethodToCache

func (c *CacheInterceptor) AddMethodToCache(method string, opt *Option)

func (*CacheInterceptor) Interceptor

func (c *CacheInterceptor) Interceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

type Option

type Option struct {
	TTL                     int64
	MetadataDistinguishable bool
}