- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for ctb2 (0.05 sec)
-
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager_test.go
ctb2 := mustMakeCTB("signer-a-label-a-2", "foo.bar/a", map[string]string{"label": "a"}, mustMakeRoot(t, "1")) ctb2dup := mustMakeCTB("signer-a-label-2-dup", "foo.bar/a", map[string]string{"label": "a"}, ctb2.Spec.TrustBundle) ctb3 := mustMakeCTB("signer-a-label-b-1", "foo.bar/a", map[string]string{"label": "b"}, mustMakeRoot(t, "2"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 15.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java
for (final CrawlingInfo cs : crawlingInfoList) { crawlingInfoIdList.add(cs.getId()); } crawlingInfoParamBhv.queryDelete(cb2 -> cb2.query().setCrawlingInfoId_InScope(crawlingInfoIdList)); crawlingInfoBhv.batchDelete(crawlingInfoList, op -> op.setRefreshPolicy(Constants.TRUE)); } }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 13.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator_test.go
annotations1 := audit.AuditEventFrom(ctx1).Annotations // guarantee different now times time.Sleep(time.Second) ctx2 := withAudit(context.Background()) _, _, _ = a.AuthenticateToken(ctx2, "token2") annotations2 := audit.AuditEventFrom(ctx2).Annotations if ok := len(annotations1) == 1 && len(annotations1["timestamp"]) > 0; !ok { t.Errorf("invalid annotations 1: %v", annotations1) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 20.3K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
location: expectedIP + ":12345", }, { pod: api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo"}, Spec: api.PodSpec{ Containers: []api.Container{ {Name: "ctr1"}, {Name: "ctr2", Ports: []api.ContainerPort{{ContainerPort: 9376}}}, }, }, Status: api.PodStatus{PodIPs: []api.PodIP{{IP: expectedIP}}}, }, query: "foo", location: expectedIP + ":9376", }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
func (f *fakeKubeletVolumeHost) GetTrustAnchorsByName(name string, allowMissing bool) ([]byte, error) { ctb, err := f.kubeClient.CertificatesV1alpha1().ClusterTrustBundles().Get(context.Background(), name, metav1.GetOptions{}) if err != nil { return nil, fmt.Errorf("while getting ClusterTrustBundle %s: %w", name, err) } return []byte(ctb.Spec.TrustBundle), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/g3doc/tf_dialects.md
// dependencies. // We don’t mention the control token in the return type here, it is implicit. %0, %ctl0 = tf_executor.opA %feed#0, %feed#1 : tensor<*xf32> %1, %ctl1 = tf_executor.opB : tensor<*xf32> %2, %ctl2 = tf_executor.opC %1, %ctl0 : tensor<*xf32> %3, %ctl3 = tf_executor.opD %2 : tensor<*xf32> tf_executor.fetch %3 : tensor<*xf32> } // end of the “tf_executor.graph" operation/region ```
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Oct 13 16:33:28 UTC 2021 - 16K bytes - Viewed (0) -
src/test/java/jcifs/tests/SessionTest.java
CIFSContext ctx1 = withTestNTLMCredentials(getContext()); CIFSContext ctx2 = withAnonymousCredentials(); String loc = getTestShareGuestURL(); try ( SmbResource f1 = ctx1.get(loc) ) { f1.exists(); try ( SmbResource f2 = ctx2.get(loc) ) { f2.exists(); connectionMatches(f1, f2); } }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Jan 05 13:09:03 UTC 2023 - 15.8K bytes - Viewed (0) -
src/syscall/js/js_test.go
<-c } func TestInvokeFunction(t *testing.T) { called := false cb := js.FuncOf(func(this js.Value, args []js.Value) any { cb2 := js.FuncOf(func(this js.Value, args []js.Value) any { called = true return 42 }) defer cb2.Release() return cb2.Invoke() }) defer cb.Release() if got := cb.Invoke().Int(); got != 42 { t.Errorf("got %#v, want %#v", got, 42) } if !called {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 19 14:35:26 UTC 2024 - 17.7K bytes - Viewed (0) -
src/context/x_test.go
cause := errors.New("TestCustomContextPropagation") donec := make(chan struct{}) ctx1, cancel1 := WithCancelCause(Background()) ctx2 := &customDoneContext{ Context: ctx1, donec: donec, } ctx3, cancel3 := WithCancel(ctx2) defer cancel3() cancel1(cause) close(donec) <-ctx3.Done() if got, want := ctx3.Err(), Canceled; got != want {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
// an uncached quorum read sometime after listing Pods/ControllerRevisions (see #42639). func (ssc *StatefulSetController) canAdoptFunc(ctx context.Context, set *apps.StatefulSet) func(ctx2 context.Context) error { return controller.RecheckDeletionTimestamp(func(ctx context.Context) (metav1.Object, error) { fresh, err := ssc.kubeClient.AppsV1().StatefulSets(set.Namespace).Get(ctx, set.Name, metav1.GetOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0)