repositories

Documentation

Index

• Variables
• type MongoCommentRepository
  • func NewMongoCommentRepository(db *mongo.Database) *MongoCommentRepository
  • func (r *MongoCommentRepository) FindByPostID(ctx context.Context, postId int) ([]*models.Comment, error)
  • func (r *MongoCommentRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error
  • func (r *MongoCommentRepository) Save(ctx context.Context, m *models.Comment) error
• type MongoPostRepository
  • func NewMongoPostRepository(db *mongo.Database) *MongoPostRepository
  • func (r *MongoPostRepository) FindByID(ctx context.Context, id int) (*models.Post, error)
  • func (r *MongoPostRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error
  • func (r *MongoPostRepository) Save(ctx context.Context, m *models.Post) error
• type SqlCommentRepository
  • func NewSqlCommentRepository(db *sqlx.DB) *SqlCommentRepository
  • func (r *SqlCommentRepository) FindByPostID(ctx context.Context, postID int) ([]*models.Comment, error)
  • func (r *SqlCommentRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error
  • func (r *SqlCommentRepository) Save(ctx context.Context, c *models.Comment) error
• type SqlPostRepository
  • func NewSqlPostRepository(db *sqlx.DB) *SqlPostRepository
  • func (r *SqlPostRepository) FindByID(ctx context.Context, id int) (*models.Post, error)
  • func (r *SqlPostRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error
  • func (r *SqlPostRepository) Save(ctx context.Context, p *models.Post) error

Variables

var ErrInvalidTxType = errors.New("invalid tx type, tx type should be *sqlx.Tx")

Types

type MongoCommentRepository

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

func NewMongoCommentRepository

func NewMongoCommentRepository(db *mongo.Database) *MongoCommentRepository

func (*MongoCommentRepository) FindByPostID

func (r *MongoCommentRepository) FindByPostID(ctx context.Context, postId int) ([]*models.Comment, error)

func (*MongoCommentRepository) InTransaction

func (r *MongoCommentRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error

func (*MongoCommentRepository) Save

func (r *MongoCommentRepository) Save(ctx context.Context, m *models.Comment) error

type MongoPostRepository

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

func NewMongoPostRepository

func NewMongoPostRepository(db *mongo.Database) *MongoPostRepository

func (*MongoPostRepository) FindByID

func (r *MongoPostRepository) FindByID(ctx context.Context, id int) (*models.Post, error)

func (*MongoPostRepository) InTransaction

func (r *MongoPostRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error

func (*MongoPostRepository) Save

func (r *MongoPostRepository) Save(ctx context.Context, m *models.Post) error

type SqlCommentRepository

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

func NewSqlCommentRepository

func NewSqlCommentRepository(db *sqlx.DB) *SqlCommentRepository

func (*SqlCommentRepository) FindByPostID

func (r *SqlCommentRepository) FindByPostID(ctx context.Context, postID int) ([]*models.Comment, error)

func (*SqlCommentRepository) InTransaction

func (r *SqlCommentRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error

func (*SqlCommentRepository) Save

func (r *SqlCommentRepository) Save(ctx context.Context, c *models.Comment) error

type SqlPostRepository

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

func NewSqlPostRepository

func NewSqlPostRepository(db *sqlx.DB) *SqlPostRepository

func (*SqlPostRepository) FindByID

func (r *SqlPostRepository) FindByID(ctx context.Context, id int) (*models.Post, error)

func (*SqlPostRepository) InTransaction

func (r *SqlPostRepository) InTransaction(ctx context.Context, fn func(context.Context) error) error

func (*SqlPostRepository) Save

func (r *SqlPostRepository) Save(ctx context.Context, p *models.Post) error