Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 127 for marshal (0.06 seconds)

  1. internal/s3select/json/record.go

    		case nil:
    			columnValue = ""
    		case RawJSON:
    			columnValue = string([]byte(val))
    		case []any:
    			b, err := json.Marshal(val)
    			if err != nil {
    				return err
    			}
    			columnValue = string(b)
    		default:
    			return fmt.Errorf("Cannot marshal unhandled type: %T", kv.Value)
    		}
    		csvRecord = append(csvRecord, columnValue)
    	}
    
    	w := csv.NewWriter(writer)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  2. cmd/fmt-gen.go

    				if deploymentID != "" {
    					newFormat.ID = deploymentID
    				}
    				drive := pool.Endpoints[i*setDriveCount+j]
    				fmtBytes, err := json.Marshal(newFormat)
    				if err != nil {
    					//nolint:gocritic
    					log.Fatalf("failed to marshal format.json for %s: %v", drive.String(), err)
    				}
    				fmtJSON := filepath.Join(drive.Host, drive.Path, minioMetaBucket, "format.json")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  3. cmd/admin-handlers.go

    				Host:           client.String(),
    				Err:            fmt.Sprintf("server is running the latest version: %s", Version),
    				CurrentVersion: Version,
    			})
    		}
    
    		// Marshal API response
    		jsonBytes, err := json.Marshal(updateStatus)
    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    
    		writeSuccessResponseJSON(w, jsonBytes)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  4. internal/grid/types.go

    		}
    	}
    
    	return s
    }
    
    // JSONPool is a pool for JSON objects that unmarshal into T.
    type JSONPool[T any] struct {
    	pool    sync.Pool
    	emptySz int
    }
    
    // NewJSONPool returns a new JSONPool.
    func NewJSONPool[T any]() *JSONPool[T] {
    	var t T
    	sz := 128
    	if b, err := json.Marshal(t); err != nil {
    		sz = len(b)
    	}
    	return &JSONPool[T]{
    		pool: sync.Pool{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  5. cmd/bucket-metadata.go

    )
    
    //go:generate msgp -file $GOFILE
    
    // BucketMetadata contains bucket metadata.
    // When adding/removing fields, regenerate the marshal code using the go generate above.
    // Only changing meaning of fields requires a version bump.
    // bucketMetadataFormat refers to the format.
    // bucketMetadataVersion can be used to track a rolling upgrade of a field.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  6. internal/s3select/simdj/record.go

    			b, err := tmp.MarshalJSON()
    			if err != nil {
    				return err
    			}
    			columnValue = string(b)
    		case simdjson.TypeNone:
    			break allElems
    		default:
    			return fmt.Errorf("cannot marshal unhandled type: %s", typ.String())
    		}
    		csvRecord = append(csvRecord, columnValue)
    	}
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  7. cmd/data-scanner_test.go

    </LifecycleConfiguration>
    `
    	lc, err := lifecycle.ParseLifecycleConfig(strings.NewReader(lcXML))
    	if err != nil {
    		t.Fatalf("Failed to unmarshal lifecycle config: %v", err)
    	}
    
    	vcfg := versioning.Versioning{
    		Status: "Enabled",
    	}
    	vcfgXML, err := xml.Marshal(vcfg)
    	if err != nil {
    		t.Fatalf("Failed to marshal versioning config: %v", err)
    	}
    
    	bucket := "bucket"
    	now := time.Now()
    	meta := BucketMetadata{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12K bytes
    - Click Count (0)
  8. cmd/sftp-server.go

    			key2, _, _, _, err := ssh.ParseAuthorizedKey([]byte(attribValue[0]))
    			if err != nil {
    				return nil, errSFTPPublicKeyBadFormat
    			}
    
    			if subtle.ConstantTimeCompare(key2.Marshal(), key.Marshal()) != 1 {
    				return nil, errAuthentication
    			}
    		}
    		// Save each attribute to claims.
    		claims[ldapAttribPrefix+attribKey] = attribValue[0]
    	}
    
    	if key != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  9. cmd/format-erasure.go

    }
    
    func saveFormatErasure(disk StorageAPI, format *formatErasureV3, healID string) error {
    	if disk == nil || format == nil {
    		return errDiskNotFound
    	}
    
    	// Marshal and write to disk.
    	formatData, err := json.Marshal(format)
    	if err != nil {
    		return err
    	}
    
    	tmpFormat := mustGetUUID()
    
    	// Purge any existing temporary file, okay to ignore errors here.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  10. cmd/bucket-handlers_test.go

    		}
    		errorResponse := APIErrorResponse{}
    		err = xml.Unmarshal(rec.Body.Bytes(), &errorResponse)
    		if err != nil && !testCase.shouldPass {
    			t.Fatalf("Test %d: %s: Unable to marshal response body %s", i+1, instanceType, rec.Body.String())
    		}
    		if errorResponse.Resource != testCase.errorResponse.Resource {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 39.8K bytes
    - Click Count (0)
Back to Top