2021-02-03 04:06:34 +00:00
|
|
|
package store
|
|
|
|
|
|
|
|
import (
|
|
|
|
"github.com/TwinProduction/gatus/core"
|
|
|
|
"github.com/TwinProduction/gatus/storage/store/memory"
|
|
|
|
)
|
|
|
|
|
|
|
|
// Store is the interface that each stores should implement
|
|
|
|
type Store interface {
|
2021-05-19 05:19:02 +00:00
|
|
|
// GetAllServiceStatusesWithResultPagination returns the JSON encoding of all monitored core.ServiceStatus
|
2021-02-25 03:41:36 +00:00
|
|
|
// with a subset of core.Result defined by the page and pageSize parameters
|
|
|
|
GetAllServiceStatusesWithResultPagination(page, pageSize int) map[string]*core.ServiceStatus
|
2021-02-03 04:06:34 +00:00
|
|
|
|
|
|
|
// GetServiceStatus returns the service status for a given service name in the given group
|
|
|
|
GetServiceStatus(groupName, serviceName string) *core.ServiceStatus
|
|
|
|
|
|
|
|
// GetServiceStatusByKey returns the service status for a given key
|
|
|
|
GetServiceStatusByKey(key string) *core.ServiceStatus
|
|
|
|
|
|
|
|
// Insert adds the observed result for the specified service into the store
|
|
|
|
Insert(service *core.Service, result *core.Result)
|
|
|
|
|
|
|
|
// DeleteAllServiceStatusesNotInKeys removes all ServiceStatus that are not within the keys provided
|
|
|
|
//
|
|
|
|
// Used to delete services that have been persisted but are no longer part of the configured services
|
|
|
|
DeleteAllServiceStatusesNotInKeys(keys []string) int
|
|
|
|
|
|
|
|
// Clear deletes everything from the store
|
|
|
|
Clear()
|
2021-02-06 01:45:28 +00:00
|
|
|
|
|
|
|
// Save persists the data if and where it needs to be persisted
|
|
|
|
Save() error
|
2021-02-03 04:06:34 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
var (
|
|
|
|
// Validate interface implementation on compile
|
|
|
|
_ Store = (*memory.Store)(nil)
|
|
|
|
)
|