diff options
Diffstat (limited to 'store/sqlstore/cluster_discovery_store.go')
| -rw-r--r-- | store/sqlstore/cluster_discovery_store.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/store/sqlstore/cluster_discovery_store.go b/store/sqlstore/cluster_discovery_store.go index 14810cadb..6ac49199e 100644 --- a/store/sqlstore/cluster_discovery_store.go +++ b/store/sqlstore/cluster_discovery_store.go @@ -47,7 +47,7 @@ func (s sqlClusterDiscoveryStore) Delete(ClusterDiscovery *model.ClusterDiscover if count, err := s.GetMaster().SelectInt( ` - DELETE + DELETE FROM ClusterDiscovery WHERE @@ -76,7 +76,7 @@ func (s sqlClusterDiscoveryStore) Exists(ClusterDiscovery *model.ClusterDiscover if count, err := s.GetMaster().SelectInt( ` - SELECT + SELECT COUNT(*) FROM ClusterDiscovery @@ -108,7 +108,7 @@ func (s sqlClusterDiscoveryStore) GetAll(ClusterDiscoveryType, clusterName strin if _, err := s.GetMaster().Select( &list, ` - SELECT + SELECT * FROM ClusterDiscovery @@ -134,8 +134,8 @@ func (s sqlClusterDiscoveryStore) SetLastPingAt(ClusterDiscovery *model.ClusterD return store.Do(func(result *store.StoreResult) { if _, err := s.GetMaster().Exec( ` - UPDATE ClusterDiscovery - SET + UPDATE ClusterDiscovery + SET LastPingAt = :LastPingAt WHERE Type = :Type @@ -158,7 +158,7 @@ func (s sqlClusterDiscoveryStore) Cleanup() store.StoreChannel { return store.Do(func(result *store.StoreResult) { if _, err := s.GetMaster().Exec( ` - DELETE FROM ClusterDiscovery + DELETE FROM ClusterDiscovery WHERE LastPingAt < :LastPingAt `, |