Skip to content
This repository has been archived by the owner on Jul 11, 2023. It is now read-only.

Commit

Permalink
Removed log messages used for testing
Browse files Browse the repository at this point in the history
  • Loading branch information
Jont828 committed Jul 13, 2020
1 parent 2f5291f commit 2b4db74
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 3 deletions.
1 change: 0 additions & 1 deletion cmd/ads/ads.go
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,6 @@ func main() {

namespaceController := namespace.NewNamespaceController(kubeConfig, meshName, stop)
meshSpec := smi.NewMeshSpecClient(kubeConfig, osmNamespace, namespaceController, stop)
log.Info().Msgf("Backpressure enabled: %v\n", optionalFeatures.BackpressureEnabled)

certManager, certDebugger := certManagers[certificateManagerKind(*certManagerKind)](kubeConfig, enableDebugServer)

Expand Down
3 changes: 1 addition & 2 deletions pkg/smi/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ import (
backpressure "github.com/open-service-mesh/osm/experimental/pkg/apis/policy/v1alpha1"
backpressureClient "github.com/open-service-mesh/osm/experimental/pkg/client/clientset/versioned"
backpressureInformers "github.com/open-service-mesh/osm/experimental/pkg/client/informers/externalversions"

target "github.com/servicemeshinterface/smi-sdk-go/pkg/apis/access/v1alpha1"
spec "github.com/servicemeshinterface/smi-sdk-go/pkg/apis/specs/v1alpha2"
split "github.com/servicemeshinterface/smi-sdk-go/pkg/apis/split/v1alpha2"
Expand Down Expand Up @@ -125,7 +124,7 @@ func newSMIClient(kubeClient *kubernetes.Clientset, smiTrafficSplitClient *smiTr
TrafficSpec: informerCollection.TrafficSpec.GetStore(),
TrafficTarget: informerCollection.TrafficTarget.GetStore(),
}
log.Info().Msgf("Backpressure enabled in client.go?: %v", featureflags.IsBackpressureEnabled())

if featureflags.IsBackpressureEnabled() {
informerCollection.Backpressure = backPressureInformerFactory.Policy().V1alpha1().Backpressures().Informer()
cacheCollection.Backpressure = informerCollection.Backpressure.GetStore()
Expand Down

0 comments on commit 2b4db74

Please sign in to comment.