mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-08-01 16:57:28 +00:00
Fixed oas query (#1076)
This commit is contained in:
parent
36d59ede07
commit
2fac0009ea
@ -104,7 +104,7 @@ func (g *defaultOasGenerator) runGenerator() {
|
|||||||
g.dbMutex.Lock()
|
g.dbMutex.Lock()
|
||||||
defer g.dbMutex.Unlock()
|
defer g.dbMutex.Unlock()
|
||||||
logger.Log.Infof("Querying DB for OAS generator with query '%s'", g.entriesQuery)
|
logger.Log.Infof("Querying DB for OAS generator with query '%s'", g.entriesQuery)
|
||||||
if err := g.dbConn.Query("", g.entriesQuery, dataChan, metaChan); err != nil {
|
if err := g.dbConn.Query("latest", g.entriesQuery, dataChan, metaChan); err != nil {
|
||||||
logger.Log.Errorf("Query mode call failed: %v", err)
|
logger.Log.Errorf("Query mode call failed: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -327,7 +327,7 @@ BasenineReconnect:
|
|||||||
go handleMetaChannel(&wg, connection, meta)
|
go handleMetaChannel(&wg, connection, meta)
|
||||||
wg.Add(2)
|
wg.Add(2)
|
||||||
|
|
||||||
if err = connection.Query("", query, data, meta); err != nil {
|
if err = connection.Query("latest", query, data, meta); err != nil {
|
||||||
logger.Log.Errorf("Query mode call failed: %v", err)
|
logger.Log.Errorf("Query mode call failed: %v", err)
|
||||||
connection.Close()
|
connection.Close()
|
||||||
time.Sleep(shared.BasenineReconnectInterval * time.Second)
|
time.Sleep(shared.BasenineReconnectInterval * time.Second)
|
||||||
|
Loading…
Reference in New Issue
Block a user