pg

Documentation

Index

• type ChannelPgRepo
  • func NewChannelRepo(db *DB) *ChannelPgRepo
  • func (repo ChannelPgRepo) CreateChannel(channel *model.DBChannel) error
  • func (repo ChannelPgRepo) GetChannelByName(name string) (*model.Channel, error)
  • func (repo ChannelPgRepo) GetChannelStats(channelID int) (*model.Stat, error)
  • func (repo ChannelPgRepo) GetChannels() ([]model.Channel, error)
  • func (repo ChannelPgRepo) GetChannelsByPage(page int) ([]model.Channel, error)
• type DB
  • func Init(cfg *config.Config) (*DB, error)
• type MessageRepo
  • func NewMessageRepo(db *DB) *MessageRepo
  • func (repo MessageRepo) CreateMessage(message *model.DBMessage) (int, error)
  • func (repo MessageRepo) GetFullMessageByID(messageID int) (*model.FullMessage, error)
  • func (repo MessageRepo) GetFullMessagesByChannelIDAndPage(channelID, page int) ([]model.FullMessage, error)
  • func (repo MessageRepo) GetFullMessagesByPage(page int) ([]model.FullMessage, error)
  • func (repo MessageRepo) GetFullMessagesByUserID(id int) ([]model.FullMessage, error)
  • func (repo MessageRepo) GetMessageByTitle(title string) (*model.DBMessage, error)
  • func (repo MessageRepo) GetMessagesCount() (int, error)
  • func (repo MessageRepo) GetMessagesCountByChannelID(channelID int) (int, error)
• type ReplyRepo
  • func NewReplyRepo(db *DB) *ReplyRepo
  • func (repo ReplyRepo) CreateReply(reply *model.DBReply) error
  • func (repo ReplyRepo) GetFullRepliesByMessageID(messageID int) ([]model.FullReply, error)
• type SavedRepo
  • func NewSavedRepo(db *DB) *SavedRepo
  • func (repo SavedRepo) CreateSavedMessage(saved *model.Saved) error
  • func (repo SavedRepo) DeleteSavedMessage(id int) error
  • func (repo SavedRepo) GetSavedMessageByID(id int) (*model.Saved, error)
  • func (repo SavedRepo) GetSavedMessages(userID int) ([]model.Saved, error)
• type UserRepo
  • func NewUserRepo(db *DB) *UserRepo
  • func (repo UserRepo) CreateUser(user *model.User) (int, error)
  • func (repo UserRepo) GetUserByID(id int) (*model.User, error)
  • func (repo UserRepo) GetUserByUsername(username string) (*model.User, error)
• type WebUserRepo
  • func NewWebUserRepo(db *DB) *WebUserRepo
  • func (repo WebUserRepo) CreateWebUser(user *model.WebUser) error
  • func (repo WebUserRepo) GetWebUserByEmail(email string) (*model.WebUser, error)

Types

type ChannelPgRepo

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

func NewChannelRepo

func NewChannelRepo(db *DB) *ChannelPgRepo

func (ChannelPgRepo) CreateChannel

func (repo ChannelPgRepo) CreateChannel(channel *model.DBChannel) error

func (ChannelPgRepo) GetChannelByName

func (repo ChannelPgRepo) GetChannelByName(name string) (*model.Channel, error)

func (ChannelPgRepo) GetChannelStats

func (repo ChannelPgRepo) GetChannelStats(channelID int) (*model.Stat, error)

func (ChannelPgRepo) GetChannels

func (repo ChannelPgRepo) GetChannels() ([]model.Channel, error)

func (ChannelPgRepo) GetChannelsByPage

func (repo ChannelPgRepo) GetChannelsByPage(page int) ([]model.Channel, error)

type DB

type DB struct {
	*sqlx.DB
}

func Init

func Init(cfg *config.Config) (*DB, error)

type MessageRepo

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

func NewMessageRepo

func NewMessageRepo(db *DB) *MessageRepo

func (MessageRepo) CreateMessage

func (repo MessageRepo) CreateMessage(message *model.DBMessage) (int, error)

func (MessageRepo) GetFullMessageByID

func (repo MessageRepo) GetFullMessageByID(messageID int) (*model.FullMessage, error)

func (MessageRepo) GetFullMessagesByChannelIDAndPage

func (repo MessageRepo) GetFullMessagesByChannelIDAndPage(channelID, page int) ([]model.FullMessage, error)

func (MessageRepo) GetFullMessagesByPage

func (repo MessageRepo) GetFullMessagesByPage(page int) ([]model.FullMessage, error)

func (MessageRepo) GetFullMessagesByUserID

func (repo MessageRepo) GetFullMessagesByUserID(id int) ([]model.FullMessage, error)

func (MessageRepo) GetMessageByTitle

func (repo MessageRepo) GetMessageByTitle(title string) (*model.DBMessage, error)

func (MessageRepo) GetMessagesCount

func (repo MessageRepo) GetMessagesCount() (int, error)

func (MessageRepo) GetMessagesCountByChannelID

func (repo MessageRepo) GetMessagesCountByChannelID(channelID int) (int, error)

type ReplyRepo

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

func NewReplyRepo

func NewReplyRepo(db *DB) *ReplyRepo

func (ReplyRepo) CreateReply

func (repo ReplyRepo) CreateReply(reply *model.DBReply) error

func (ReplyRepo) GetFullRepliesByMessageID

func (repo ReplyRepo) GetFullRepliesByMessageID(messageID int) ([]model.FullReply, error)

type SavedRepo

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

func NewSavedRepo

func NewSavedRepo(db *DB) *SavedRepo

func (SavedRepo) CreateSavedMessage

func (repo SavedRepo) CreateSavedMessage(saved *model.Saved) error

func (SavedRepo) DeleteSavedMessage

func (repo SavedRepo) DeleteSavedMessage(id int) error

func (SavedRepo) GetSavedMessageByID

func (repo SavedRepo) GetSavedMessageByID(id int) (*model.Saved, error)

func (SavedRepo) GetSavedMessages

func (repo SavedRepo) GetSavedMessages(userID int) ([]model.Saved, error)

type UserRepo

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

func NewUserRepo

func NewUserRepo(db *DB) *UserRepo

func (UserRepo) CreateUser

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

func (UserRepo) GetUserByID

func (repo UserRepo) GetUserByID(id int) (*model.User, error)

func (UserRepo) GetUserByUsername

func (repo UserRepo) GetUserByUsername(username string) (*model.User, error)

type WebUserRepo

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

func NewWebUserRepo

func NewWebUserRepo(db *DB) *WebUserRepo

func (WebUserRepo) CreateWebUser

func (repo WebUserRepo) CreateWebUser(user *model.WebUser) error

func (WebUserRepo) GetWebUserByEmail

func (repo WebUserRepo) GetWebUserByEmail(email string) (*model.WebUser, error)