- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for verifyActions (0.27 sec)
-
pkg/controller/bootstrap/bootstrapsigner_test.go
} return ret } func TestNoConfigMap(t *testing.T) { signer, cl, _, _, err := newSigner() if err != nil { t.Fatalf("error creating Signer: %v", err) } signer.signConfigMap(context.TODO()) verifyActions(t, []core.Action{}, cl.Actions()) } func TestSimpleSign(t *testing.T) { signer, cl, secrets, configMaps, err := newSigner() if err != nil { t.Fatalf("error creating Signer: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner_test.go
} secret := newTokenSecret("tokenID", "tokenSecret") secrets.Informer().GetIndexer().Add(secret) cleaner.evalSecret(context.TODO(), secret) expected := []core.Action{} verifyActions(t, expected, cl.Actions()) } func TestCleanerExpired(t *testing.T) { cleaner, cl, secrets, err := newTokenCleaner() if err != nil { t.Fatalf("error creating TokenCleaner: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
}) syncer.SetPodStatus(getTestPod(), getRandomPodStatus()) verifyActions(t, syncer, []core.Action{getAction()}) } func TestSyncPod(t *testing.T) { syncer := newTestManager(&fake.Clientset{}) testPod := getTestPod() syncer.kubeClient = fake.NewSimpleClientset(testPod) syncer.SetPodStatus(testPod, getRandomPodStatus()) verifyActions(t, syncer, []core.Action{getAction(), patchAction()}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/bootstrap/common_test.go
s.Data[bootstrapapi.BootstrapTokenExpirationKey] = []byte(expiration) } func addSecretSigningUsage(s *v1.Secret, value string) { s.Data[bootstrapapi.BootstrapTokenUsageSigningKey] = []byte(value) } func verifyActions(t *testing.T, expected, actual []core.Action) { for i, a := range actual { if len(expected) < i+1 { t.Errorf("%d unexpected actions: %s", len(actual)-len(expected), dump.Pretty(actual[i:])) break }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 2.2K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
test.mutatePodFn(pod) } if test.mutateStatusFn != nil { test.mutateStatusFn(status) } ctx := context.Background() actions := m.computePodActions(ctx, pod, status) verifyActions(t, &test.actions, &actions, desc) if test.resetStatusFn != nil { test.resetStatusFn(status) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_cafile_content.go
return c.caBundle.Load().(*caBundleAndVerifier).caBundle } // VerifyOptions provides verifyoptions compatible with authenticators func (c *DynamicFileCAContent) VerifyOptions() (x509.VerifyOptions, bool) { uncastObj := c.caBundle.Load() if uncastObj == nil { return x509.VerifyOptions{}, false } return uncastObj.(*caBundleAndVerifier).verifyOptions, true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/union_content.go
} } return bytes.Join(caBundles, []byte("\n")) } // CurrentCABundleContent provides ca bundle byte content func (c unionCAContent) VerifyOptions() (x509.VerifyOptions, bool) { currCABundle := c.CurrentCABundleContent() if len(currCABundle) == 0 { return x509.VerifyOptions{}, false } // TODO make more efficient. This isn't actually used in any of our mainline paths. It's called to build the TLSConfig
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/interfaces.go
// contained to the controllers initializing the value. By the time you get // here, you should always be returning a value that won't fail. CurrentCABundleContent() []byte // VerifyOptions provides VerifyOptions for authenticators. VerifyOptions() (x509.VerifyOptions, bool) } // CertKeyContentProvider provides a certificate and matching private key. type CertKeyContentProvider interface { Notifier // Name is just an identifier.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
} return c.caBundle.Load().(*caBundleAndVerifier).caBundle } // VerifyOptions provides verifyoptions compatible with authenticators func (c *ConfigMapCAController) VerifyOptions() (x509.VerifyOptions, bool) { uncastObj := c.caBundle.Load() if uncastObj == nil { // This can happen if we've been unable load data from the apiserver for some reason.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/static_content.go
// CurrentCABundleContent provides ca bundle byte content func (c *staticCAContent) CurrentCABundleContent() (cabundle []byte) { return c.caBundle.caBundle } func (c *staticCAContent) VerifyOptions() (x509.VerifyOptions, bool) { return c.caBundle.verifyOptions, true } type staticCertKeyContent struct { name string cert []byte key []byte }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 3K bytes - Viewed (0)