helpers

Documentation

Index

• func InitRedis(cnfg *config.Config) *redis.Pool
• func StreamServerInterceptor(srv interface{}, stream grpc.ServerStream, _ *grpc.StreamServerInfo, ...) (err error)
• func ToChan(stream grpc.ServerStream, factory func() interface{}) <-chan interface{}
• func UnaryServerInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, ...) (resp interface{}, err error)

Functions

func InitRedis

func InitRedis(cnfg *config.Config) *redis.Pool

func StreamServerInterceptor

func StreamServerInterceptor(srv interface{}, stream grpc.ServerStream, _ *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)

func ToChan

func ToChan(stream grpc.ServerStream, factory func() interface{}) <-chan interface{}

func UnaryServerInterceptor

func UnaryServerInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)