redis

Documentation

Index

• func NewRepository(db redis.IDB) *repository
• type Repository
• type SessionRepository
  • func NewSessionRepository(repository Repository, sessionLifeTimeInHours uint) (*SessionRepository, error)
  • func (r *SessionRepository) Delete(ctx context.Context, ID string) error
  • func (r *SessionRepository) Get(ctx context.Context, ID string) (*session.Session, error)
  • func (r *SessionRepository) Set(ctx context.Context, entity *session.Session) error
• type TgSessionRepository
  • func NewTgSessionRepository(repository Repository) *TgSessionRepository
  • func (r *TgSessionRepository) Delete(ctx context.Context, ID string) error
  • func (r *TgSessionRepository) Get(ctx context.Context, ID string) (*tg.Session, error)
  • func (r *TgSessionRepository) Set(ctx context.Context, entity *tg.Session) error

Functions

func NewRepository

func NewRepository(db redis.IDB) *repository

Types

type Repository

type Repository interface {
	DB() goredis.Cmdable
	Close() error
}

Repository is an interface of repository

type SessionRepository

type SessionRepository struct {
	Repository
	SessionLifeTime time.Duration
}

SessionRepository is a repository for the session entity

func NewSessionRepository

func NewSessionRepository(repository Repository, sessionLifeTimeInHours uint) (*SessionRepository, error)

NewSessionRepository creates a new SessionRepository

func (*SessionRepository) Delete

func (r *SessionRepository) Delete(ctx context.Context, ID string) error

Delete removes the entity with given ID from the storage.

func (*SessionRepository) Get

func (r *SessionRepository) Get(ctx context.Context, ID string) (*session.Session, error)

Get returns the Session with the specified ID.

func (*SessionRepository) Set

func (r *SessionRepository) Set(ctx context.Context, entity *session.Session) error

type TgSessionRepository

type TgSessionRepository struct {
	Repository
	ID string
}

SessionRepository is a repository for the tg session

func NewTgSessionRepository

func NewTgSessionRepository(repository Repository) *TgSessionRepository

NewTgSessionRepository creates a new TgSessionRepository

func (*TgSessionRepository) Delete

func (r *TgSessionRepository) Delete(ctx context.Context, ID string) error

Delete removes the entity with given ID from the storage.

func (*TgSessionRepository) Get

func (r *TgSessionRepository) Get(ctx context.Context, ID string) (*tg.Session, error)

Get returns the TgSession with the specified ID.

func (*TgSessionRepository) Set

func (r *TgSessionRepository) Set(ctx context.Context, entity *tg.Session) error