postgres

Documentation

Index

• func NewPostgresDB(cfg Config) (*sqlx.DB, error)
• type ChatPg
  • func NewChatPg(db *sqlx.DB) *ChatPg
  • func (r *ChatPg) Create(chat *model.Chat) (string, error)
  • func (r *ChatPg) ExistenceCheck(chatId string) error
  • func (r *ChatPg) GetAllForUser(userId string) ([]*model.Chat, error)
  • func (r *ChatPg) GetById(chatId string) (*model.Chat, error)
• type Config
• type MessagePg
  • func NewMessagePg(db *sqlx.DB) *MessagePg
  • func (r *MessagePg) Create(message *model.Message) (string, error)
  • func (r *MessagePg) GetAllForChat(chatId string) ([]*model.Message, error)
• type UserPg
  • func NewUserPg(db *sqlx.DB) *UserPg
  • func (r *UserPg) Create(user *model.User) (string, error)
  • func (r *UserPg) ExistenceCheck(userId string) error

Functions

func NewPostgresDB

func NewPostgresDB(cfg Config) (*sqlx.DB, error)

Types

type ChatPg

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

func NewChatPg

func NewChatPg(db *sqlx.DB) *ChatPg

func (*ChatPg) Create

func (r *ChatPg) Create(chat *model.Chat) (string, error)

func (*ChatPg) ExistenceCheck

func (r *ChatPg) ExistenceCheck(chatId string) error

func (*ChatPg) GetAllForUser

func (r *ChatPg) GetAllForUser(userId string) ([]*model.Chat, error)

func (*ChatPg) GetById

func (r *ChatPg) GetById(chatId string) (*model.Chat, error)

type Config

type Config struct {
	Host     string
	Port     string
	Username string
	Password string
	DBName   string
	SSLMode  string
}

type MessagePg

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

func NewMessagePg

func NewMessagePg(db *sqlx.DB) *MessagePg

func (*MessagePg) Create

func (r *MessagePg) Create(message *model.Message) (string, error)

func (*MessagePg) GetAllForChat

func (r *MessagePg) GetAllForChat(chatId string) ([]*model.Message, error)

type UserPg

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

func NewUserPg

func NewUserPg(db *sqlx.DB) *UserPg

func (*UserPg) Create

func (r *UserPg) Create(user *model.User) (string, error)

func (*UserPg) ExistenceCheck

func (r *UserPg) ExistenceCheck(userId string) error