- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 197 for Kata (0.21 sec)
-
cmd/data-usage-utils.go
} // DataUsageInfo represents data usage stats of the underlying Object API type DataUsageInfo struct { TotalCapacity uint64 `json:"capacity,omitempty"` TotalUsedCapacity uint64 `json:"usedCapacity,omitempty"` TotalFreeCapacity uint64 `json:"freeCapacity,omitempty"` // LastUpdate is the timestamp of when the data usage info was last updated. // This does not indicate a full scan.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/iam-etcd-store.go
data, err := decryptData(data, itemPath) if err != nil { return err } json := jsoniter.ConfigCompatibleWithStandardLibrary return json.Unmarshal(data, item) } func (ies *IAMEtcdStore) loadIAMConfig(ctx context.Context, item interface{}, path string) error { data, err := readKeyEtcd(ctx, ies.client, path) if err != nil { return err } return getIAMConfig(item, data, path) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/bucket-policy.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8K bytes - Viewed (0) -
lib/time/mkzip.go
if d.IsDir() { return nil } data, err := os.ReadFile(path) if err != nil { log.Fatal(err) } if strings.HasSuffix(path, ".zip") { log.Fatalf("unexpected file during walk: %s", path) } name := filepath.ToSlash(path) w, err := zw.CreateRaw(&zip.FileHeader{ Name: name, Method: zip.Store, CompressedSize64: uint64(len(data)), UncompressedSize64: uint64(len(data)),
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 17:32:07 GMT 2024 - 2.1K bytes - Viewed (0) -
cmd/etcd.go
} func saveKeyEtcd(ctx context.Context, client *etcd.Client, key string, data []byte, opts ...options) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() if len(opts) > 0 { return saveKeyEtcdWithTTL(ctx, client, key, data, opts[0].ttl) } _, err := client.Put(timeoutCtx, key, string(data)) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
tests/callbacks_test.go
err = e } } if len(data.err) > 0 && err == nil { t.Errorf("callbacks tests #%v should got error %v, but not", idx+1, data.err) } else if len(data.err) == 0 && err != nil { t.Errorf("callbacks tests #%v should not got error, but got %v", idx+1, err) } if ok, msg := assertCallbacks(callbacks.Create(), data.results); !ok { t.Errorf("callbacks tests #%v failed, got %v", idx+1, msg)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Mar 26 03:33:36 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/object-api-utils.go
// encrypt it using the provided key and return the result. func compressionIndexEncrypter(key crypto.ObjectKey, input func() []byte) func() []byte { var data []byte var fetched bool return func() []byte { if !fetched { data = input() fetched = true } return metadataEncrypter(key)("compression-index", data) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/bucket-replication.go
case resyncMetaFormat: default: return brs, fmt.Errorf("resyncMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2])) } switch binary.LittleEndian.Uint16(data[2:4]) { case resyncMetaVersion: default: return brs, fmt.Errorf("resyncMeta: unknown version: %d", binary.LittleEndian.Uint16(data[2:4])) } // OK, parse data. if _, err = brs.UnmarshalMsg(data[4:]); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
istioctl/pkg/workload/workload_test.go
ObjectMeta: metav1.ObjectMeta{Namespace: "bar", Name: "istio-ca-root-cert"}, Data: map[string]string{"root-cert.pem": string(fakeCACert)}, }, metav1.CreateOptions{}) client.Kube().CoreV1().ConfigMaps("istio-system").Create(context.Background(), &v1.ConfigMap{ ObjectMeta: metav1.ObjectMeta{Namespace: "istio-system", Name: "istio-rev-1"}, Data: map[string]string{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/object-api-datatypes.go
z, ok := o.UserDefined[archiveInfoMetadataKey] if !ok { return nil } data := []byte(z) if v, ok := o.UserDefined[archiveTypeMetadataKey]; ok && v == archiveTypeEnc { decrypted, err := o.metadataDecrypter()(archiveTypeEnc, data) if err != nil { encLogIf(GlobalContext, err) return nil } data = decrypted } return data } // Clone - Returns a cloned copy of current objectInfo
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0)