extern/gatus
1
0
Fork 0
mirror of https://github.com/TwiN/gatus.git synced 2024-11-22 07:53:38 +01:00
Code Issues Packages Projects Releases Wiki Activity

Rename deleteOldResults and deleteOldEvents to deleteOldServiceResults and deleteOldServiceEvents

Browse Source
This commit is contained in:
TwinProduction 2021-07-12 23:11:33 -04:00 committed by Chris
parent 14316cfd31
commit 1291e86a6f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
storage/store/database/database.go
View File

@ -221,7 +221,7 @@ func (s *Store) Insert(service *core.Service, result *core.Result) {
// This lets us both keep the table clean without impacting performance too much // This lets us both keep the table clean without impacting performance too much
// (since we're only deleting MaximumNumberOfEvents at a time instead of 1) // (since we're only deleting MaximumNumberOfEvents at a time instead of 1)
if numberOfEvents > core.MaximumNumberOfEvents*2 { if numberOfEvents > core.MaximumNumberOfEvents*2 {
err = s.deleteOldEvents(tx, serviceID) err = s.deleteOldServiceEvents(tx, serviceID)
if err != nil { if err != nil {
log.Printf("[database][Insert] Failed to delete old events for group=%s; service=%s: %s", service.Group, service.Name, err.Error()) log.Printf("[database][Insert] Failed to delete old events for group=%s; service=%s: %s", service.Group, service.Name, err.Error())
} }
@ -239,7 +239,7 @@ func (s *Store) Insert(service *core.Service, result *core.Result) {
return return
} }
if numberOfResults > core.MaximumNumberOfResults*2 { if numberOfResults > core.MaximumNumberOfResults*2 {
err = s.deleteOldResults(tx, serviceID) err = s.deleteOldServiceResults(tx, serviceID)
if err != nil { if err != nil {
log.Printf("[database][Insert] Failed to delete old results for group=%s; service=%s: %s", service.Group, service.Name, err.Error()) log.Printf("[database][Insert] Failed to delete old results for group=%s; service=%s: %s", service.Group, service.Name, err.Error())
} }
@ -513,8 +513,8 @@ func (s *Store) insertConditionResults(tx *sql.Tx, serviceResultID int64, condit
return nil return nil
} }
// deleteOldEvents deletes old service events that are no longer needed // deleteOldServiceEvents deletes old service events that are no longer needed
func (s *Store) deleteOldEvents(tx *sql.Tx, serviceID int64) error { func (s *Store) deleteOldServiceEvents(tx *sql.Tx, serviceID int64) error {
_, err := tx.Exec( _, err := tx.Exec(
` `
DELETE FROM service_event DELETE FROM service_event
@ -538,8 +538,8 @@ func (s *Store) deleteOldEvents(tx *sql.Tx, serviceID int64) error {
return nil return nil
} }
// deleteOldResults deletes old service results that are no longer needed // deleteOldServiceResults deletes old service results that are no longer needed
func (s *Store) deleteOldResults(tx *sql.Tx, serviceID int64) error { func (s *Store) deleteOldServiceResults(tx *sql.Tx, serviceID int64) error {
_, err := tx.Exec( _, err := tx.Exec(
` `
DELETE FROM service_result DELETE FROM service_result