mongodb

Documentation

Index

• type MongoRepository
  • func NewMongoRepository(uri, database, collection string) (*MongoRepository, error)
  • func (r *MongoRepository) Close(ctx context.Context) error
  • func (r *MongoRepository) CreateReport(ctx context.Context, report *domain.Report) error
  • func (r *MongoRepository) GetReport(ctx context.Context, id string) (*domain.Report, error)
  • func (r *MongoRepository) GetTopIPs(ctx context.Context) ([]application.TopIPResult, error)
  • func (r *MongoRepository) GetTopViolatedDirectives(ctx context.Context) ([]application.TopDirectiveResult, error)
  • func (r *MongoRepository) ListReports(ctx context.Context) ([]domain.Report, error)

Types

type MongoRepository

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

MongoRepository implements the application.Repository interface

func NewMongoRepository

func NewMongoRepository(uri, database, collection string) (*MongoRepository, error)

NewMongoRepository creates a new MongoDB repository instance

func (*MongoRepository) Close

func (r *MongoRepository) Close(ctx context.Context) error

Close implements the Close method required by the Repository interface

func (*MongoRepository) CreateReport

func (r *MongoRepository) CreateReport(ctx context.Context, report *domain.Report) error

CreateReport implements ReportsRepository.CreateReport

func (*MongoRepository) GetReport

func (r *MongoRepository) GetReport(ctx context.Context, id string) (*domain.Report, error)

GetReport implements ReportsRepository.GetReport

func (*MongoRepository) GetTopIPs

func (r *MongoRepository) GetTopIPs(ctx context.Context) ([]application.TopIPResult, error)

GetTopIPs implements StatisticsRepository.GetTopIPs

func (*MongoRepository) GetTopViolatedDirectives

func (r *MongoRepository) GetTopViolatedDirectives(ctx context.Context) ([]application.TopDirectiveResult, error)

GetTopViolatedDirectives implements StatisticsRepository.GetTopViolatedDirectives

func (*MongoRepository) ListReports

func (r *MongoRepository) ListReports(ctx context.Context) ([]domain.Report, error)

ListReports implements ReportsRepository.ListReports