- Sort Score
- Result 10 results
- Languages All
Results 51 - 57 of 57 for Messages (0.07 sec)
-
pilot/pkg/config/kube/crdclient/client_test.go
} return nil }, retry.Timeout(time.Second*5), retry.Converge(5)) retry.UntilOrFail(t, func() bool { return store.Get(r.GroupVersionKind(), configMeta.Name, configMeta.Namespace) == nil }, retry.Message("expected no items returned for unknown CRD"), retry.Timeout(time.Second*5), retry.Converge(5)) } // Ensure that the client can run without CRDs present, but then added later func TestClientDelayedCRDs(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/config/validation/envoyfilter/envoyfilter_test.go
t.Fatalf("got warning=%v but wanted warning=%v", gotWarning, wantWarning) } } func TestValidateEnvoyFilter(t *testing.T) { tests := []struct { name string in proto.Message error string warning string }{ {name: "empty filters", in: &networking.EnvoyFilter{}, error: ""}, {name: "labels not defined in workload selector", in: &networking.EnvoyFilter{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/config/constants/constants.go
// This used to use the no longer supported default K8S signer. // Deprecated - used to detect the old setting and generate the error message. CertProviderKubernetes = "kubernetes" // CertProviderKubernetesSignerPrefix uses the Kubernetes CSR API and the specified signer to generate a DNS certificate for the control plane
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 10K bytes - Viewed (0) -
pkg/log/config_test.go
zap.L().Warn("zap-warn") zap.L().Info("zap-info") zap.L().Debug("zap-debug") l := zap.L().With(zap.String("a", "b")) l.Error("zap-with") entry := zapcore.Entry{ Message: "zap-write", Level: zapcore.ErrorLevel, } _ = zap.L().Core().Write(entry, nil) defaultScope.SetOutputLevel(NoneLevel) grpcScope.SetOutputLevel(NoneLevel)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 26 20:38:10 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
// Intentionally no lock. The controller today requires that handlers are registered before execution and not in parallel. c.handlers = append(c.handlers, h) } // Run starts the controller until it receives a message over stopCh func (c *Controller) Run(stopCh <-chan struct{}) error { // run handlers for the config cluster; do not store this *Cluster in the ClusterStore or give it a SyncTimeout
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
Healthy: true, }) checkHealthOrFail(t, store, p, true) }) t.Run("auto registered unhealthy health", func(t *testing.T) { ig.QueueWorkloadEntryHealth(p, HealthEvent{ Healthy: false, Message: "lol health bad", }) checkHealthOrFail(t, store, p, false) }) } func TestWorkloadEntryFromGroup(t *testing.T) { group := config.Config{ Meta: config.Meta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0)