- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 132 for items (0.14 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) -
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) -
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) -
helm/minio/templates/post-job.yaml
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Jul 08 19:18:31 GMT 2023 - 10.4K 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) -
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) -
helm-releases/minio-4.0.12.tgz
{{ template "minio.secretName" . }} {{- range .Values.users }} {{- if .existingSecret }} - secret: name: {{ tpl .existingSecret $global }} items: - key: {{ .existingSecretKey }} path: secrets/{{ tpl .existingSecretKey $global }} {{- end }} {{- end }} {{- if .Values.tls.enabled }} - name: cert-secret-volume-mc secret: secretName: {{ .Values.tls.certSecret }} items: - key: {{ .Values.tls.publicCrt }} path: CAs/public.crt {{ end }} containers: - name: minio-mc image: "{{ .Values.mcImage.repository }}:{{...
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Aug 14 05:50:43 GMT 2022 - 19.4K bytes - Viewed (0) -
helm-releases/minio-4.0.7.tgz
name: {{ template "minio.secretName" . }} {{- range .Values.users }} {{- if .existingSecret }} - secret: name: {{ tpl .existingSecret $global }} items: - key: {{ .existingSecretKey }} path: secrets/{{ tpl .accessKey $global }} {{- end }} {{- end }} {{- if .Values.tls.enabled }} - name: cert-secret-volume-mc secret: secretName: {{ .Values.tls.certSecret }} items: - key: {{ .Values.tls.publicCrt }} path: CAs/public.crt {{ end }} containers: - name: minio-mc image: "{{ .Values.mcImage.repository }}:{{ .Values.mcImage.tag...
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jul 28 03:54:38 GMT 2022 - 18.6K bytes - Viewed (0) -
helm-releases/minio-1.0.0.tgz
template "minio.fullname" . }}.{{ .Release.Namespace }}.svc.cluster.local To access Minio from localhost, run the below commands: 1. export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "release={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}") 2. kubectl port-forward $POD_NAME 9000 --namespace {{ .Release.Namespace }} Read more about port forwarding here: http://kubernetes.io/docs/user-guide/kubectl/kubectl_port-forward/ You can now access Minio server on http://localhost:9000....
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Aug 20 22:30:54 GMT 2021 - 13.5K bytes - Viewed (0) -
helm-releases/minio-3.4.1.tgz
template "minio.fullname" . }}.{{ .Release.Namespace }}.svc.cluster.local To access MinIO from localhost, run the below commands: 1. export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "release={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}") 2. kubectl port-forward $POD_NAME 9000 --namespace {{ .Release.Namespace }} Read more about port forwarding here: http://kubernetes.io/docs/user-guide/kubectl/kubectl_port-forward/ You can now access MinIO server on http://localhost:9000....
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Dec 20 21:11:50 GMT 2021 - 15.2K bytes - Viewed (0)