mongo

Documentation

Index

• type MongoRecordRepository
  • func NewMongoRecordRepository(dbClient database.DatabaseClient) (*MongoRecordRepository, error)
  • func (repo *MongoRecordRepository) CountRecords(ctx context.Context, entity *domain.Entity) (uint64, error)
  • func (repo *MongoRecordRepository) CreateRecord(ctx context.Context, entity *domain.Entity, record *pubdomain.Record) (*pubdomain.Record, error)
  • func (repo *MongoRecordRepository) DeleteRecord(ctx context.Context, entity *domain.Entity, recordId string) error
  • func (repo *MongoRecordRepository) GetRecord(ctx context.Context, entity *domain.Entity, recordId string) (*pubdomain.Record, error)
  • func (repo *MongoRecordRepository) ListRecords(ctx context.Context, entity *domain.Entity, pager *pubdomain.Pager) ([]*pubdomain.Record, error)
  • func (repo *MongoRecordRepository) UpdateRecord(ctx context.Context, entity *domain.Entity, recordId string, ...) (*pubdomain.Record, error)

Types

type MongoRecordRepository

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

RecordRepository defines the repository that stores, modifies and deletes record in Mongo

func NewMongoRecordRepository

func NewMongoRecordRepository(
	dbClient database.DatabaseClient,
) (*MongoRecordRepository, error)

NewMongoRecordRepository creates an instace of MongoRecordRepository

func (*MongoRecordRepository) CountRecords

func (repo *MongoRecordRepository) CountRecords(
	ctx context.Context,
	entity *domain.Entity,
) (uint64, error)

CountRecords returns the count of the records in the data store related to an entity

func (*MongoRecordRepository) CreateRecord

func (repo *MongoRecordRepository) CreateRecord(
	ctx context.Context,
	entity *domain.Entity,
	record *pubdomain.Record,
) (*pubdomain.Record, error)

CreateRecord creates a new record in the data store related to an entity

func (*MongoRecordRepository) DeleteRecord

func (repo *MongoRecordRepository) DeleteRecord(
	ctx context.Context,
	entity *domain.Entity,
	recordId string,
) error

DeleteRecord deletes a record in the data store related to an entity

func (*MongoRecordRepository) GetRecord

func (repo *MongoRecordRepository) GetRecord(
	ctx context.Context,
	entity *domain.Entity,
	recordId string,
) (*pubdomain.Record, error)

GetRecord gets a record from the data store related to an entity

func (*MongoRecordRepository) ListRecords

func (repo *MongoRecordRepository) ListRecords(
	ctx context.Context,
	entity *domain.Entity,
	pager *pubdomain.Pager,
) ([]*pubdomain.Record, error)

ListRecords gets a record list from the data store related to an entity

func (*MongoRecordRepository) UpdateRecord

func (repo *MongoRecordRepository) UpdateRecord(
	ctx context.Context,
	entity *domain.Entity,
	recordId string,
	partialRecord *pubdomain.Record,
) (*pubdomain.Record, error)

UpdateRecord updates a record in the data store related to an entity