postgres

Documentation

Index

• func IsNoRows(err error) bool
• func IsUniqueViolation(err error) bool
• type ConnectionPool
  • func NewConnectionPool(ctx context.Context, conf config.PostgresConfig) (*ConnectionPool, error)
• type GroupRepo
  • func NewGroupRepo(conn *ConnectionPool) *GroupRepo
  • func (g *GroupRepo) CreateGroup(userID int64, telegramID int64, openAIModel string) error
  • func (g *GroupRepo) GetGroupByTelegramID(telegramID int64) (models.Group, error)
  • func (g *GroupRepo) SetGroupOpenAIModel(telegramID int64, openAIModel string) error
• type MessageRepo
  • func NewMessageRepo(conn *ConnectionPool) *MessageRepo
  • func (m *MessageRepo) CreateMessage(telegramID int64, text string, topicID int64, sender string) error
  • func (m *MessageRepo) GetMessagesByTopicID(topicID int64, after time.Time, limit int) ([]models.Message, error)
• type TopicRepo
  • func NewTopicRepo(conn *ConnectionPool) *TopicRepo
  • func (t *TopicRepo) CreateTopic(threadID int64, groupID int64, name string, openaiModel string) error
  • func (t *TopicRepo) DeleteTopicByThreadID(threadID int) error
  • func (t *TopicRepo) GetTopicByThreadID(threadID int) (models.Topic, error)
• type UserRepo
  • func NewUserRepo(conn *ConnectionPool) *UserRepo
  • func (u *UserRepo) CreateUser(telegramID int64) error
  • func (u *UserRepo) GetUserByTelegramID(telegramID int64) (models.User, error)

Functions

func IsNoRows

func IsNoRows(err error) bool

func IsUniqueViolation

func IsUniqueViolation(err error) bool

Types

type ConnectionPool

type ConnectionPool struct {
	*pgxpool.Pool
}

func NewConnectionPool

func NewConnectionPool(ctx context.Context, conf config.PostgresConfig) (*ConnectionPool, error)

type GroupRepo

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

func NewGroupRepo

func NewGroupRepo(conn *ConnectionPool) *GroupRepo

func (*GroupRepo) CreateGroup

func (g *GroupRepo) CreateGroup(userID int64, telegramID int64, openAIModel string) error

func (*GroupRepo) GetGroupByTelegramID

func (g *GroupRepo) GetGroupByTelegramID(telegramID int64) (models.Group, error)

func (*GroupRepo) SetGroupOpenAIModel

func (g *GroupRepo) SetGroupOpenAIModel(telegramID int64, openAIModel string) error

type MessageRepo

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

func NewMessageRepo

func NewMessageRepo(conn *ConnectionPool) *MessageRepo

func (*MessageRepo) CreateMessage

func (m *MessageRepo) CreateMessage(telegramID int64, text string, topicID int64, sender string) error

func (*MessageRepo) GetMessagesByTopicID

func (m *MessageRepo) GetMessagesByTopicID(topicID int64, after time.Time, limit int) ([]models.Message, error)

type TopicRepo

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

func NewTopicRepo

func NewTopicRepo(conn *ConnectionPool) *TopicRepo

func (*TopicRepo) CreateTopic

func (t *TopicRepo) CreateTopic(threadID int64, groupID int64, name string, openaiModel string) error

func (*TopicRepo) DeleteTopicByThreadID

func (t *TopicRepo) DeleteTopicByThreadID(threadID int) error

func (*TopicRepo) GetTopicByThreadID

func (t *TopicRepo) GetTopicByThreadID(threadID int) (models.Topic, error)

type UserRepo

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

func NewUserRepo

func NewUserRepo(conn *ConnectionPool) *UserRepo

func (*UserRepo) CreateUser

func (u *UserRepo) CreateUser(telegramID int64) error

func (*UserRepo) GetUserByTelegramID

func (u *UserRepo) GetUserByTelegramID(telegramID int64) (models.User, error)