- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 75 for items (0.18 sec)
-
internal/store/batch_test.go
t.Errorf("failed to get the item by key %v after adding", item) } }(i) } wg.Wait() keys, items, err := batch.GetAll() if err != nil { t.Fatalf("unable to get the items from the batch; %v", err) } if len(items) != int(limit) { t.Fatalf("expected batch length %v but got %v", limit, len(items)) } if len(keys) != int(limit) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 3.8K bytes - Viewed (0) -
istioctl/pkg/writer/compare/sds/writer_test.go
name string format Format items []SecretItem expected []string unexpected []string }{ { name: "test tabular output with no secret items is equivalent to the header", format: TABULAR, items: []SecretItem{}, expected: []string{}, unexpected: secretItemColumns, }, { name: "test tabular output with a single secret item", format: TABULAR,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri May 29 20:42:01 GMT 2020 - 4.9K bytes - Viewed (0) -
internal/store/queuestore_test.go
t.Fatal("Failed to Get the item from the queue store ", eErr) } if !reflect.DeepEqual(testItem, item) { t.Fatalf("Failed to read the item: error: expected = %v, got = %v", testItem, item) } } } else { t.Fatalf("List() Expected: 10, got %d", len(itemKeys)) } } // TestQueueStoreDel - tests for store.Del func TestQueueStoreDel(t *testing.T) { defer func() {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 04 17:52:24 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/store/store.go
// Target - store target interface type Target interface { Name() string SendFromStore(key Key) error } // Store - Used to persist items. type Store[I any] interface { Put(item I) error PutMultiple(item []I) error Get(key string) (I, error) GetRaw(key string) ([]byte, error) Len() int List() ([]string, error) Del(key string) error DelList(key []string) error Open() error
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 3.5K bytes - Viewed (0) -
buildscripts/heal-manual.go
fmt.Println("Healstatus on items ===") for _, item := range status.Items { if err = enc.Encode(&item); err != nil { log.Fatalln(err) } } break } if status.Summary == "stopped" { fmt.Println("Healstatus on items ===") fmt.Println("Heal failed with", status.FailureDetail) break } for _, item := range status.Items { if err = enc.Encode(&item); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 2.3K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
} if len(pl.Items) < 1 { return errors.New("no pods found") } if len(pl.Items) > 1 { log.Warnf("more than 1 pods fits selector: %s; will use pod: %s", istiodLabelSelector, pl.Items[0].Name) } // only use the first pod in the list podName = pl.Items[0].Name ns = pl.Items[0].Namespace } else if len(args) == 1 {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/tag/util.go
LabelSelector: fmt.Sprintf("%s=%s", label.IoIstioRev.Name, tag), }) if err != nil { return nil, err } nsNames := make([]string, len(namespaces.Items)) for i, ns := range namespaces.Items { nsNames[i] = ns.Name } return nsNames, nil } // GetWebhookTagName extracts tag name from webhook object. func GetWebhookTagName(wh admitv1.MutatingWebhookConfiguration) string {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Jan 16 17:43:42 GMT 2024 - 5.4K bytes - Viewed (1) -
istioctl/pkg/kubeinject/kubeinject.go
podList, err := client.Pods(namespace).List(context.TODO(), options) if err != nil { return nil, err } pods := make([]*corev1.Pod, 0, len(podList.Items)) for i := range podList.Items { pod := podList.Items[i] pods = append(pods, &pod) } if len(pods) > 0 { sort.Sort(sortBy(pods)) return pods[0], nil }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
internal/store/queuestore.go
buf.Reset() if err != nil { return err } // Increment the item count. store.entries[key] = time.Now().UnixNano() return nil } // write - writes an item to the directory. func (store *QueueStore[I]) write(key string, item I) error { // Marshalls the item. eventData, err := json.Marshal(item) if err != nil { return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
} foundIngresses := []*ingressInfo{} for _, ns := range ingressNss.UnsortedList() { // Currently no support for non-standard gateways selecting non ingressgateway pods serviceList, err := kubeClient.CoreV1().Services(ns).List(context.TODO(), metav1.ListOptions{}) if err == nil { for i, s := range serviceList.Items { iInfo := &ingressInfo{ service: serviceList.Items[i].DeepCopy(),
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0)