postgres

Documentation

Index

• func NewConnPool(conf config.Postgres) (*pgxpool.Pool, error)
• type DialogRepository
  • func NewDialogRepository(pool *pgxpool.Pool) *DialogRepository
  • func (r *DialogRepository) Create(ctx context.Context, dialog *entity.Dialog) error
  • func (r *DialogRepository) GetByID(ctx context.Context, dialogID int) (entity.Dialog, error)
  • func (r *DialogRepository) List(ctx context.Context) ([]entity.Dialog, error)
  • func (r *DialogRepository) Update(ctx context.Context, dialog *entity.Dialog) error
• type GroupParticipantRepository
  • func NewGroupParticipantRepository(pool *pgxpool.Pool) *GroupParticipantRepository
  • func (r *GroupParticipantRepository) Create(ctx context.Context, participant *entity.GroupParticipant) error
  • func (r *GroupParticipantRepository) Get(ctx context.Context, groupID, userID int, withLock bool) (entity.GroupParticipant, error)
  • func (r *GroupParticipantRepository) List(ctx context.Context, groupID int) ([]entity.GroupParticipant, error)
  • func (r *GroupParticipantRepository) Update(ctx context.Context, participant *entity.GroupParticipant) error
• type GroupRepository
  • func NewGroupRepository(pool *pgxpool.Pool) *GroupRepository
  • func (r *GroupRepository) Create(ctx context.Context, group *entity.Group) error
  • func (r *GroupRepository) Delete(ctx context.Context, groupID int) error
  • func (r *GroupRepository) GetByID(ctx context.Context, groupID int) (entity.Group, error)
  • func (r *GroupRepository) List(ctx context.Context) ([]entity.Group, error)
  • func (r *GroupRepository) Update(ctx context.Context, group *entity.Group) error
• type MessageRepository
  • func NewMessageRepository(pool *pgxpool.Pool) *MessageRepository
  • func (r *MessageRepository) Create(ctx context.Context, message *entity.Message) error
  • func (r *MessageRepository) List(ctx context.Context, obj dto.MessageList) ([]entity.Message, error)
• type TransactionManager
  • func NewTransactionManager(pool *pgxpool.Pool) *TransactionManager
  • func (txm *TransactionManager) Do(ctx context.Context, fn func(ctx context.Context) error) error
• type UserRepository
  • func NewUserRepository(pool *pgxpool.Pool) *UserRepository
  • func (r *UserRepository) Create(ctx context.Context, user *entity.User) error
  • func (r *UserRepository) Delete(ctx context.Context, id int) error
  • func (r *UserRepository) GetByID(ctx context.Context, id int) (entity.User, error)
  • func (r *UserRepository) GetByUsername(ctx context.Context, username string) (entity.User, error)
  • func (r *UserRepository) List(ctx context.Context) ([]entity.User, error)
  • func (r *UserRepository) Update(ctx context.Context, user *entity.User) error
  • func (r *UserRepository) UpdatePassword(ctx context.Context, userID int, pwdHash string) error

Functions

func NewConnPool

func NewConnPool(conf config.Postgres) (*pgxpool.Pool, error)

Types

type DialogRepository

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

func NewDialogRepository

func NewDialogRepository(pool *pgxpool.Pool) *DialogRepository

func (*DialogRepository) Create

func (r *DialogRepository) Create(ctx context.Context, dialog *entity.Dialog) error

func (*DialogRepository) GetByID

func (r *DialogRepository) GetByID(ctx context.Context, dialogID int) (entity.Dialog, error)

func (*DialogRepository) List

func (r *DialogRepository) List(ctx context.Context) ([]entity.Dialog, error)

func (*DialogRepository) Update

func (r *DialogRepository) Update(ctx context.Context, dialog *entity.Dialog) error

type GroupParticipantRepository

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

func NewGroupParticipantRepository

func NewGroupParticipantRepository(pool *pgxpool.Pool) *GroupParticipantRepository

func (*GroupParticipantRepository) Create

func (r *GroupParticipantRepository) Create(ctx context.Context, participant *entity.GroupParticipant) error

func (*GroupParticipantRepository) Get

func (r *GroupParticipantRepository) Get(ctx context.Context, groupID, userID int, withLock bool) (entity.GroupParticipant, error)

func (*GroupParticipantRepository) List

func (r *GroupParticipantRepository) List(ctx context.Context, groupID int) ([]entity.GroupParticipant, error)

func (*GroupParticipantRepository) Update

func (r *GroupParticipantRepository) Update(ctx context.Context, participant *entity.GroupParticipant) error

type GroupRepository

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

func NewGroupRepository

func NewGroupRepository(pool *pgxpool.Pool) *GroupRepository

func (*GroupRepository) Create

func (r *GroupRepository) Create(ctx context.Context, group *entity.Group) error

func (*GroupRepository) Delete

func (r *GroupRepository) Delete(ctx context.Context, groupID int) error

func (*GroupRepository) GetByID

func (r *GroupRepository) GetByID(ctx context.Context, groupID int) (entity.Group, error)

func (*GroupRepository) List

func (r *GroupRepository) List(ctx context.Context) ([]entity.Group, error)

func (*GroupRepository) Update

func (r *GroupRepository) Update(ctx context.Context, group *entity.Group) error

type MessageRepository

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

func NewMessageRepository

func NewMessageRepository(pool *pgxpool.Pool) *MessageRepository

func (*MessageRepository) Create

func (r *MessageRepository) Create(ctx context.Context, message *entity.Message) error

func (*MessageRepository) List

func (r *MessageRepository) List(ctx context.Context, obj dto.MessageList) ([]entity.Message, error)

type TransactionManager

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

func NewTransactionManager

func NewTransactionManager(pool *pgxpool.Pool) *TransactionManager

func (*TransactionManager) Do

func (txm *TransactionManager) Do(ctx context.Context, fn func(ctx context.Context) error) error

type UserRepository

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

func NewUserRepository

func NewUserRepository(pool *pgxpool.Pool) *UserRepository

func (*UserRepository) Create

func (r *UserRepository) Create(ctx context.Context, user *entity.User) error

func (*UserRepository) Delete

func (r *UserRepository) Delete(ctx context.Context, id int) error

func (*UserRepository) GetByID

func (r *UserRepository) GetByID(ctx context.Context, id int) (entity.User, error)

func (*UserRepository) GetByUsername

func (r *UserRepository) GetByUsername(ctx context.Context, username string) (entity.User, error)

func (*UserRepository) List

func (r *UserRepository) List(ctx context.Context) ([]entity.User, error)

func (*UserRepository) Update

func (r *UserRepository) Update(ctx context.Context, user *entity.User) error

func (*UserRepository) UpdatePassword

func (r *UserRepository) UpdatePassword(ctx context.Context, userID int, pwdHash string) error