Skip to content

Commit

Permalink
Add changes
Browse files Browse the repository at this point in the history
Signed-off-by: FlamingSaint <[email protected]>
  • Loading branch information
FlamingSaint committed Jul 21, 2024
1 parent 9d2f9b2 commit 4f87e23
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 17 deletions.
6 changes: 0 additions & 6 deletions cmd/jaeger/internal/extension/jaegerquery/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@ import (

"go.opentelemetry.io/collector/component"
"go.opentelemetry.io/collector/extension"
"go.uber.org/zap"

"github.com/jaegertracing/jaeger/cmd/jaeger/internal/extension/jaegerstorage"
queryApp "github.com/jaegertracing/jaeger/cmd/query/app"
Expand All @@ -19,7 +18,6 @@ import (
"github.com/jaegertracing/jaeger/pkg/telemetery"
"github.com/jaegertracing/jaeger/pkg/tenancy"
"github.com/jaegertracing/jaeger/plugin/metrics/disabled"
"github.com/jaegertracing/jaeger/storage"
"github.com/jaegertracing/jaeger/storage/metricsstore"
)

Expand Down Expand Up @@ -142,10 +140,6 @@ func (s *server) createMetricStorage(host component.Host) (metricsstore.Reader,
}

metricsReader, err := mf.CreateMetricsReader()
if errors.Is(err, storage.ErrMetricStorageNotConfigured) || errors.Is(err, storage.ErrMetricStorageNotSupported) {
s.telset.Logger.Info("Metric storage not created", zap.Error(err))
return disabled.NewMetricsReader()
}
return metricsReader, err

Check warning on line 143 in cmd/jaeger/internal/extension/jaegerquery/server.go

View check run for this annotation

Codecov / codecov/patch

cmd/jaeger/internal/extension/jaegerquery/server.go#L142-L143

Added lines #L142 - L143 were not covered by tests
}

Expand Down
12 changes: 9 additions & 3 deletions scripts/spm-integration-test.sh
Original file line number Diff line number Diff line change
Expand Up @@ -89,13 +89,19 @@ validate_service_metrics() {
echo "Metric datapoints found for service '$service': " "${metric_points[@]}"
# Check that atleast some values are non-zero after the threshold
local non_zero_count=0
local expected_non_zero_count=3
local expected_non_zero_count=5
local zero_count=0
local expected_max_zero_count=3
local expected_max_zero_count=4
local flag=false # Becomes true after first non-zero value
for value in "${metric_points[@]}"; do
if [[ $(echo "$value > 0.0" | bc) == "1" ]]; then
flag=true
non_zero_count=$((non_zero_count + 1))
else
if [ $flag == true ]; then
echo "❌ ERROR: Zero values appearing after a non-zero value not expected"
return 1
fi
zero_count=$((zero_count + 1))
fi

Expand All @@ -105,7 +111,7 @@ validate_service_metrics() {
fi
done
if [ $non_zero_count -lt $expected_non_zero_count ]; then
echo "⏳ Expecting at least 3 non-zero data points"
echo "⏳ Expecting at least 4 non-zero data points"
return 1
fi
return 0
Expand Down
8 changes: 0 additions & 8 deletions storage/factory.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,14 +83,6 @@ type ArchiveFactory interface {
CreateArchiveSpanWriter() (spanstore.Writer, error)
}

var (
// ErrMetricStorageNotConfigured can be returned by the MetricsFactory when the metric storage is not configured.
ErrMetricStorageNotConfigured = errors.New("Metric storage not configured")

// ErrMetricStorageNotSupported can be returned by the MetricsFactory when the metric storage is not supported by the backend.
ErrMetricStorageNotSupported = errors.New("Metric storage not supported")
)

// MetricsFactory defines an interface for a factory that can create implementations of different metrics storage components.
// Implementations are also encouraged to implement plugin.Configurable interface.
//
Expand Down

0 comments on commit 4f87e23

Please sign in to comment.