cache

Documentation

Index

• Variables
• type Client
  • func NewClient(config configs.Cache, logger *zap.Logger) (Client, error)
  • func NewRamClient(logger *zap.Logger) Client
  • func NewRedisClient(config configs.Cache, logger *zap.Logger) Client
• type RefreshToken
  • func NewRefreshToken(client Client, logger *zap.Logger) RefreshToken
• type UsernamesTaken
  • func NewUsernamesTaken(client Client, logger *zap.Logger) UsernamesTaken

Variables

var (
	ErrCacheMiss = errors.New("cache miss")
)

var Module = fx.Module(
	"cache",
	fx.Provide(
		NewClient,
		NewUsernamesTaken,
		NewRefreshToken,
	),
)

Types

type Client

type Client interface {
	Set(ctx context.Context, key string, data any, ttl time.Duration) error
	Get(ctx context.Context, key string) (any, error)
	Del(ctx context.Context, key ...string) error
	AddToSet(ctx context.Context, key string, data ...any) error
	IsDataInSet(ctx context.Context, key string, data any) (bool, error)
}

func NewClient

func NewClient(
	config configs.Cache,
	logger *zap.Logger,
) (Client, error)

func NewRamClient

func NewRamClient(
	logger *zap.Logger,
) Client

func NewRedisClient

func NewRedisClient(
	config configs.Cache,
	logger *zap.Logger,
) Client

type RefreshToken

type RefreshToken interface {
	Set(ctx context.Context, key string, id uint64, ttl time.Duration) error
	Get(ctx context.Context, key string) (id uint64, err error)
	Del(ctx context.Context, key string) (bool, error)
}

func NewRefreshToken

func NewRefreshToken(
	client Client,
	logger *zap.Logger,
) RefreshToken

type UsernamesTaken

type UsernamesTaken interface {
	Add(ctx context.Context, username string) error
	Has(ctx context.Context, username string) (bool, error)
}

func NewUsernamesTaken

func NewUsernamesTaken(
	client Client,
	logger *zap.Logger,
) UsernamesTaken