entgo

Documentation

Index

• type EntgoRepository
  • func NewEntgoRepository(client *ent.Client, logger *logger.Logger) *EntgoRepository
  • func (r *EntgoRepository) CreateAnomaly(a *domain.Anomaly) (*domain.Anomaly, error)
  • func (r *EntgoRepository) CreateDetectionInstanceJob(i *domain.DetectionJobInstance) (*domain.DetectionJobInstance, error)
  • func (r *EntgoRepository) CreateDetectionJob(j *domain.DetectionJob) (*domain.DetectionJob, error)
  • func (r *EntgoRepository) DeleteDetectionJobByID(id int) error
  • func (r *EntgoRepository) FilterAnomalies(args *domain.FilterAnomaliesArgs) ([]*domain.Anomaly, error)
  • func (r *EntgoRepository) FilterDetectionJobs(args *domain.FilterDetectionJobsArgs) ([]*domain.DetectionJob, error)
  • func (r *EntgoRepository) GetDetectionJobByID(id int) (*domain.DetectionJob, error)
  • func (r *EntgoRepository) SetAnomalyStatus(anomalyID int, processed bool) error

Types

type EntgoRepository

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

func NewEntgoRepository

func NewEntgoRepository(
	client *ent.Client,
	logger *logger.Logger,
) *EntgoRepository

func (*EntgoRepository) CreateAnomaly

func (r *EntgoRepository) CreateAnomaly(a *domain.Anomaly) (*domain.Anomaly, error)

func (*EntgoRepository) CreateDetectionInstanceJob

func (r *EntgoRepository) CreateDetectionInstanceJob(i *domain.DetectionJobInstance) (*domain.DetectionJobInstance, error)

func (*EntgoRepository) CreateDetectionJob

func (r *EntgoRepository) CreateDetectionJob(j *domain.DetectionJob) (*domain.DetectionJob, error)

func (*EntgoRepository) DeleteDetectionJobByID

func (r *EntgoRepository) DeleteDetectionJobByID(id int) error

func (*EntgoRepository) FilterAnomalies

func (r *EntgoRepository) FilterAnomalies(args *domain.FilterAnomaliesArgs) ([]*domain.Anomaly, error)

func (*EntgoRepository) FilterDetectionJobs

func (r *EntgoRepository) FilterDetectionJobs(args *domain.FilterDetectionJobsArgs) ([]*domain.DetectionJob, error)

func (*EntgoRepository) GetDetectionJobByID

func (r *EntgoRepository) GetDetectionJobByID(id int) (*domain.DetectionJob, error)

func (*EntgoRepository) SetAnomalyStatus

func (r *EntgoRepository) SetAnomalyStatus(anomalyID int, processed bool) error