- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for verifyActions (0.19 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/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/authentication/request/x509/x509.go
} // DefaultVerifyOptions returns VerifyOptions that use the system root certificates, current time, // and requires certificates to be valid for client auth (x509.ExtKeyUsageClientAuth) func DefaultVerifyOptions() x509.VerifyOptions { return x509.VerifyOptions{ KeyUsages: []x509.ExtKeyUsage{x509.ExtKeyUsageClientAuth}, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 18 01:31:22 UTC 2023 - 10.3K bytes - Viewed (0) -
src/crypto/x509/root_windows.go
// The store is automatically freed when the CertContext is freed using // syscall.CertFreeCertificateContext. func createStoreContext(leaf *Certificate, opts *VerifyOptions) (*syscall.CertContext, error) { var storeCtx *syscall.CertContext leafCtx, err := syscall.CertCreateCertificateContext(syscall.X509_ASN_ENCODING|syscall.PKCS_7_ASN_ENCODING, &leaf.Raw[0], uint32(len(leaf.Raw)))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 19:41:40 UTC 2023 - 8.7K bytes - Viewed (0) -
src/crypto/x509/root_darwin.go
// license that can be found in the LICENSE file. package x509 import ( macOS "crypto/x509/internal/macos" "errors" "fmt" ) func (c *Certificate) systemVerify(opts *VerifyOptions) (chains [][]*Certificate, err error) { certs := macOS.CFArrayCreateMutable() defer macOS.ReleaseCFArray(certs) leaf, err := macOS.SecCertificateCreateWithData(c.Raw) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 01 00:36:38 UTC 2023 - 3.5K bytes - Viewed (0)