db

Documentation

Index

• type CryptoRepository
  • func NewCryptoRepository(db *pg.DB, log *zap.SugaredLogger) *CryptoRepository
  • func (r *CryptoRepository) AssignAddress(model *domain.Crypto, address domain.Address) error
  • func (r *CryptoRepository) FindOutdated(date time.Time, limit int) ([]*domain.Crypto, error)
  • func (r *CryptoRepository) Get(user *domain2.User, currency domain.CryptoCurrency) *domain.Crypto
  • func (r *CryptoRepository) UpdateBalance(model *domain.Crypto) error
• type SessionsRepository
  • func NewSessionsRepository(db *pg.DB) *SessionsRepository
  • func (s *SessionsRepository) Create(user *domain.User, token string) error
• type UserRepository
  • func NewUserRepository(db *pg.DB) *UserRepository
  • func (db *UserRepository) Create(user *domain.User) error
  • func (db *UserRepository) GetByExternalId(auth domain.Oauth, id string) (*domain.User, error)
  • func (db *UserRepository) Update(user *domain.User) error

Types

type CryptoRepository

type CryptoRepository struct {
	// contains filtered or unexported fields
}

func NewCryptoRepository

func NewCryptoRepository(db *pg.DB, log *zap.SugaredLogger) *CryptoRepository

func (*CryptoRepository) AssignAddress

func (r *CryptoRepository) AssignAddress(model *domain.Crypto, address domain.Address) error

func (*CryptoRepository) FindOutdated

func (r *CryptoRepository) FindOutdated(date time.Time, limit int) ([]*domain.Crypto, error)

func (*CryptoRepository) Get

func (r *CryptoRepository) Get(user *domain2.User, currency domain.CryptoCurrency) *domain.Crypto

func (*CryptoRepository) UpdateBalance

func (r *CryptoRepository) UpdateBalance(model *domain.Crypto) error

type SessionsRepository

type SessionsRepository struct {
	// contains filtered or unexported fields
}

func NewSessionsRepository

func NewSessionsRepository(db *pg.DB) *SessionsRepository

func (*SessionsRepository) Create

func (s *SessionsRepository) Create(user *domain.User, token string) error

type UserRepository

type UserRepository struct {
	// contains filtered or unexported fields
}

func NewUserRepository

func NewUserRepository(db *pg.DB) *UserRepository

func (*UserRepository) Create

func (db *UserRepository) Create(user *domain.User) error

func (*UserRepository) GetByExternalId

func (db *UserRepository) GetByExternalId(auth domain.Oauth, id string) (*domain.User, error)

func (*UserRepository) Update

func (db *UserRepository) Update(user *domain.User) error