Pass location parameter to event exporter.

Location passed based on ZONE from kube-env.
This commit is contained in:
Marek Siarkowicz
2018-01-10 16:22:46 +01:00
parent aa02c0f519
commit bbfcd681b5
6 changed files with 15 additions and 2 deletions

View File

@@ -48,6 +48,9 @@ func UntilFirstEntryFromLog(log string) IngestionPred {
return func(_ string, entries []LogEntry) (bool, error) {
for _, e := range entries {
if e.LogName == log {
if e.Location != framework.TestContext.CloudConfig.Zone {
return false, fmt.Errorf("Bad location in logs '%s' != '%d'", e.Location, framework.TestContext.CloudConfig.Zone)
}
return true, nil
}
}