db

Documentation

Overview

Package db impls db functionality

Package db impls db functionality

Package db impls db functionality

Index

• func NewDBConnection(options *pg.Options) *pg.DB
• type Logger
  • func (d Logger) AfterQuery(ctx context.Context, q *pg.QueryEvent) error
  • func (d Logger) BeforeQuery(ctx context.Context, q *pg.QueryEvent) (context.Context, error)
• type MeetupRepo
  • func NewMeetupRepo(db *pg.DB) *MeetupRepo
  • func (mr *MeetupRepo) CreateMeetup(meetup *model.Meetup) (*model.Meetup, error)
  • func (mr *MeetupRepo) DeleteMeetup(meetup *model.Meetup) error
  • func (mr *MeetupRepo) GetMeetUps(filter *model.MeetupFilter, limit, offset *int) ([]*model.Meetup, error)
  • func (mr *MeetupRepo) GetMeetupByID(id string) (*model.Meetup, error)
  • func (mr *MeetupRepo) GetMeetupForUser(user *model.User) ([]*model.Meetup, error)
  • func (mr *MeetupRepo) UpdateMeetup(meetup *model.Meetup) (*model.Meetup, error)
• type UserRepo
  • func NewUserRepo(db *pg.DB) *UserRepo
  • func (ur *UserRepo) CreateUser(user *model.User) (*model.User, error)
  • func (ur *UserRepo) GetUserByField(field, value string) (*model.User, error)
  • func (ur *UserRepo) GetUserByID(id string) (*model.User, error)
  • func (ur *UserRepo) GetUserByUserEmail(email string) (*model.User, error)
  • func (ur *UserRepo) GetUserByUserName(username string) (*model.User, error)

Functions

func NewDBConnection

func NewDBConnection(options *pg.Options) *pg.DB

NewDBConnection connects to a db

Types

type Logger

type Logger struct{}

Logger godoc

func (Logger) AfterQuery

func (d Logger) AfterQuery(ctx context.Context, q *pg.QueryEvent) error

AfterQuery godoc

func (Logger) BeforeQuery

func (d Logger) BeforeQuery(ctx context.Context, q *pg.QueryEvent) (context.Context, error)

BeforeQuery godoc

type MeetupRepo

type MeetupRepo struct {
	DB *pg.DB
}

MeetupRepo impls meetup storage

func NewMeetupRepo

func NewMeetupRepo(db *pg.DB) *MeetupRepo

NewMeetupRepo inits a new MeetupRepo

func (*MeetupRepo) CreateMeetup

func (mr *MeetupRepo) CreateMeetup(meetup *model.Meetup) (*model.Meetup, error)

CreateMeetup creates a new meetup in db

func (*MeetupRepo) DeleteMeetup

func (mr *MeetupRepo) DeleteMeetup(meetup *model.Meetup) error

DeleteMeetup deletes a meetup

func (*MeetupRepo) GetMeetUps

func (mr *MeetupRepo) GetMeetUps(filter *model.MeetupFilter, limit, offset *int) ([]*model.Meetup, error)

GetMeetUps returns all meetups

func (*MeetupRepo) GetMeetupByID

func (mr *MeetupRepo) GetMeetupByID(id string) (*model.Meetup, error)

GetMeetupByID returns a meetup for given id

func (*MeetupRepo) GetMeetupForUser

func (mr *MeetupRepo) GetMeetupForUser(user *model.User) ([]*model.Meetup, error)

GetMeetupForUser returns all meetups for a given user

func (*MeetupRepo) UpdateMeetup

func (mr *MeetupRepo) UpdateMeetup(meetup *model.Meetup) (*model.Meetup, error)

UpdateMeetup updates an existing meetup

type UserRepo

type UserRepo struct {
	DB *pg.DB
}

UserRepo impls user storage

func NewUserRepo

func NewUserRepo(db *pg.DB) *UserRepo

NewUserRepo inits a new UserRepo

func (*UserRepo) CreateUser

func (ur *UserRepo) CreateUser(user *model.User) (*model.User, error)

CreateUser creates a new user in db

func (*UserRepo) GetUserByField

func (ur *UserRepo) GetUserByField(field, value string) (*model.User, error)

GetUserByField returns a user record against any filter

func (*UserRepo) GetUserByID

func (ur *UserRepo) GetUserByID(id string) (*model.User, error)

GetUserByID return a user by ID

func (*UserRepo) GetUserByUserEmail

func (ur *UserRepo) GetUserByUserEmail(email string) (*model.User, error)

GetUserByUserEmail returns a user by email

func (*UserRepo) GetUserByUserName

func (ur *UserRepo) GetUserByUserName(username string) (*model.User, error)

GetUserByUserName returns a user by username