storage

Documentation

Index

• type SessionRepository
  • func NewSessionRepository(options map[string]interface{}) (*SessionRepository, error)
  • func (st *SessionRepository) DeleteSession(s domain.Session) error
  • func (st *SessionRepository) GetSessionByID(id string) (*domain.Session, error)
  • func (st *SessionRepository) PutSession(s domain.Session) error
• type UserRepository
  • func NewRepository(ctx context.Context, options map[string]interface{}, logger *log.Logger) (*UserRepository, error)
  • func (r *UserRepository) Add(p domain.User) error
  • func (r *UserRepository) GetUserByCredentials(credentials domain.Credentials) (*domain.User, error)
  • func (r *UserRepository) GetUserByID(id string) (*domain.User, error)
  • func (r *UserRepository) SetLock(id string, lock *domain.Lock) error
  • func (r *UserRepository) SetPassword(id, password string) error

Types

type SessionRepository

type SessionRepository struct {
	RedisClient *redis.Client
}

func NewSessionRepository

func NewSessionRepository(options map[string]interface{}) (*SessionRepository, error)

func (*SessionRepository) DeleteSession

func (st *SessionRepository) DeleteSession(s domain.Session) error

func (*SessionRepository) GetSessionByID

func (st *SessionRepository) GetSessionByID(id string) (*domain.Session, error)

func (*SessionRepository) PutSession

func (st *SessionRepository) PutSession(s domain.Session) error

type UserRepository

type UserRepository struct {
	Adapter *storage.PSQL
}

func NewRepository

func NewRepository(ctx context.Context, options map[string]interface{}, logger *log.Logger) (*UserRepository, error)

NewRepository creates a PSQL implementation of a secrets repository

func (*UserRepository) Add

func (r *UserRepository) Add(p domain.User) error

func (*UserRepository) GetUserByCredentials

func (r *UserRepository) GetUserByCredentials(credentials domain.Credentials) (*domain.User, error)

func (*UserRepository) GetUserByID

func (r *UserRepository) GetUserByID(id string) (*domain.User, error)

func (*UserRepository) SetLock

func (r *UserRepository) SetLock(id string, lock *domain.Lock) error

func (*UserRepository) SetPassword

func (r *UserRepository) SetPassword(id, password string) error