mongo

Documentation

Index

• type DiscussionRepository
  • func NewDiscussionRepository(DB *mongo.Database) *DiscussionRepository
  • func (dr DiscussionRepository) AddMember(discussionID interface{}, userID interface{}) error
  • func (dr DiscussionRepository) Create(param entity.CreateDiscussionParam) (*entity.Discussion, error)
  • func (dr DiscussionRepository) DeleteByID(discussionID interface{}) error
  • func (dr DiscussionRepository) GetDiscussionByCode(code string) (*entity.Discussion, error)
  • func (dr DiscussionRepository) GetDiscussionsByID(discussionID interface{}) (*entity.Discussion, error)
  • func (dr DiscussionRepository) GetDiscussionsByUserID(userID interface{}) ([]*entity.Discussion, error)
  • func (dr DiscussionRepository) RemoveMember(discussionID, userID interface{}) error
  • func (dr DiscussionRepository) UpdateByID(discussionID interface{}, param entity.UpdateDiscussionParam) error
  • func (dr DiscussionRepository) UpdatePasswordByID(discussionID interface{}, password string) error
  • func (dr DiscussionRepository) UpdatePhotoByID(discussionID interface{}, url string) error
• type MessageRepository
  • func NewMessageRepository(DB *mongo.Database) *MessageRepository
  • func (mr MessageRepository) Create(param entity.CreateMessage) (*entity.Message, error)
  • func (mr MessageRepository) GetPaginatedMessagesByDiscussionID(discussionID interface{}, size int, page int) ([]*entity.Message, error)
• type UserRepository
  • func NewUserRepository(DB *mongo.Database) *UserRepository
  • func (ur UserRepository) Create(param entity.CreateUserParam) (*entity.User, error)
  • func (ur UserRepository) GetUserByEmail(email string) (*entity.User, error)
  • func (ur UserRepository) GetUserByID(userID interface{}) (*entity.User, error)

Types

type DiscussionRepository

type DiscussionRepository struct {
	DB *mongo.Database
}

func NewDiscussionRepository

func NewDiscussionRepository(DB *mongo.Database) *DiscussionRepository

func (DiscussionRepository) AddMember

func (dr DiscussionRepository) AddMember(discussionID interface{}, userID interface{}) error

func (DiscussionRepository) Create

func (dr DiscussionRepository) Create(param entity.CreateDiscussionParam) (*entity.Discussion, error)

func (DiscussionRepository) DeleteByID

func (dr DiscussionRepository) DeleteByID(discussionID interface{}) error

func (DiscussionRepository) GetDiscussionByCode

func (dr DiscussionRepository) GetDiscussionByCode(code string) (*entity.Discussion, error)

func (DiscussionRepository) GetDiscussionsByID

func (dr DiscussionRepository) GetDiscussionsByID(discussionID interface{}) (*entity.Discussion, error)

func (DiscussionRepository) GetDiscussionsByUserID

func (dr DiscussionRepository) GetDiscussionsByUserID(userID interface{}) ([]*entity.Discussion, error)

func (DiscussionRepository) RemoveMember

func (dr DiscussionRepository) RemoveMember(discussionID, userID interface{}) error

func (DiscussionRepository) UpdateByID

func (dr DiscussionRepository) UpdateByID(discussionID interface{}, param entity.UpdateDiscussionParam) error

func (DiscussionRepository) UpdatePasswordByID

func (dr DiscussionRepository) UpdatePasswordByID(discussionID interface{}, password string) error

func (DiscussionRepository) UpdatePhotoByID

func (dr DiscussionRepository) UpdatePhotoByID(discussionID interface{}, url string) error

type MessageRepository

type MessageRepository struct {
	DB *mongo.Database
}

func NewMessageRepository

func NewMessageRepository(DB *mongo.Database) *MessageRepository

func (MessageRepository) Create

func (mr MessageRepository) Create(param entity.CreateMessage) (*entity.Message, error)

func (MessageRepository) GetPaginatedMessagesByDiscussionID

func (mr MessageRepository) GetPaginatedMessagesByDiscussionID(discussionID interface{}, size int, page int) ([]*entity.Message, error)

type UserRepository

type UserRepository struct {
	DB *mongo.Database
}

func NewUserRepository

func NewUserRepository(DB *mongo.Database) *UserRepository

func (UserRepository) Create

func (ur UserRepository) Create(param entity.CreateUserParam) (*entity.User, error)

func (UserRepository) GetUserByEmail

func (ur UserRepository) GetUserByEmail(email string) (*entity.User, error)

func (UserRepository) GetUserByID

func (ur UserRepository) GetUserByID(userID interface{}) (*entity.User, error)