helper

Jun 3, 2025

Changes in this version

+ const UserContextKey

+ func ClientContextInterceptor() grpc.UnaryClientInterceptor

+ func Coalesce[T comparable](value, def T) T

+ func EncodeUserContext(userCtx *UserContext) (string, error)

+ func GetBool(key string, defaultValue bool) bool

+ func GetFloat64(key string, defaultValue float64) float64

+ func GetInt(key string, defaultValue int) int

+ func GetInt64(key string, defaultValue int64) int64

+ func GetString(key, defaultValue string) string

+ func GrpcDialCredentials(ctx context.Context, host string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

+ func GzipCompressData(data []byte) ([]byte, error)

+ func GzipDecompressData(compressedData []byte) ([]byte, error)

+ func ServerContextInterceptor(requireAuth bool) grpc.UnaryServerInterceptor

+ func WithUserContext(ctx context.Context, userCtx *UserContext) context.Context

+ type RedisExtend struct

+ func (r RedisExtend) GetDel(ctx context.Context, key string) *redis.Cmd

+ func (r RedisExtend) IncByExpire(ctx context.Context, key string, value int, expire time.Duration) *redis.Cmd

+ func (r RedisExtend) LPopCount(ctx context.Context, key string, count int) *redis.Cmd

+ type UserContext struct

+ AccessToken string

+ TeamId string

+ UserId string

+ func DecodeUserContext(encodedValue string) (*UserContext, error)

+ func ExtractFromIncoming(md metadata.MD) (*UserContext, bool)

+ func FromContext(ctx context.Context) (*UserContext, error)

+ func (userCtx *UserContext) GetTeamId() string

+ func (userCtx *UserContext) GetUserId() string