- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 134 for Marshall (0.14 sec)
-
cmd/iam-etcd-store.go
func (ies *IAMEtcdStore) getUsersSysType() UsersSysType { return ies.usersSysType } func (ies *IAMEtcdStore) saveIAMConfig(ctx context.Context, item interface{}, itemPath string, opts ...options) error { data, err := json.Marshal(item) if err != nil { return err } if GlobalKMS != nil { data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{ minioMetaBucket: path.Join(minioMetaBucket, itemPath), })
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) -
istioctl/pkg/workload/workload_test.go
} } func TestWorkloadEntryToPodPortsMeta(t *testing.T) { cases := []struct { description string ports map[string]uint32 want string }{ { description: "test json marshal", ports: map[string]uint32{ "HTTP": 80, "HTTPS": 443, }, want: `[{"name":"HTTP","containerPort":80,"protocol":""},{"name":"HTTPS","containerPort":443,"protocol":""}]`, }, }
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) -
istioctl/pkg/writer/envoy/configdump/listener.go
if filter.Verify(listener) { filteredListeners = append(filteredListeners, listener) } } out, err := json.MarshalIndent(filteredListeners, "", " ") if err != nil { return fmt.Errorf("failed to marshal listeners: %v", err) } if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cmd/batch-expire.go
// immediately one last time before we exit this method. xioutil.SafeClose(saverQuitCh) // Notify expire jobs final status to the configured endpoint buf, _ := json.Marshal(ri) if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil { batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err)) } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/peer-rest-client.go
func (client *peerRESTClient) doTrace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) { gridConn := client.gridConn() if gridConn == nil { return } payload, err := json.Marshal(traceOpts) if err != nil { bugLogIf(ctx, err) return } st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload) if err != nil { return } st.Results(func(b []byte) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/test-utils_test.go
return &pem.Block{Type: "RSA PRIVATE KEY", Bytes: x509.MarshalPKCS1PrivateKey(k)} case *ecdsa.PrivateKey: b, err := x509.MarshalECPrivateKey(k) if err != nil { fmt.Fprintf(os.Stderr, "Unable to marshal ECDSA private key: %v", err) os.Exit(2) } return &pem.Block{Type: "EC PRIVATE KEY", Bytes: b} default: return nil } } var priv interface{} var err error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
case serviceRestart, serviceStop: dryRun := vars.Get("dry-run") == "true" // This is only supported for `restart/stop` waitingDisks := waitingDrivesNode() if len(waitingDisks) > 0 { buf, err := json.Marshal(waitingDisks) if err != nil { return np, grid.NewRemoteErr(err) } return np, grid.NewRemoteErrString(string(buf)) } if !dryRun { globalServiceSignalCh <- signal }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
return } tgtBytes, err := json.Marshal(&targets) if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrAdminConfigBadJSON, err), r.URL) return } if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketTargetsFile, tgtBytes); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } data, err := json.Marshal(target.Arn) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/bucket-encryption-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, errKMSKeyNotFound), r.URL) return } writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } configData, err := xml.Marshal(encConfig) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Store the bucket encryption configuration in the object layer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/event/name_test.go
{ObjectRemovedNoOP, []byte("<Name>s3:ObjectRemoved:NoOP</Name>"), false}, {blankName, []byte("<Name></Name>"), false}, } for i, testCase := range testCases { data, err := xml.Marshal(testCase.name) expectErr := (err != nil) if expectErr != testCase.expectErr { t.Fatalf("test %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr) } if !testCase.expectErr {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 7.4K bytes - Viewed (0)