Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 28 for NewEncoder (0.25 seconds)

  1. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/ConsoleIconTest.java

                assertNotNull(result, "Icon result should not be null for " + icon);
    
                // Result should be consistent with charset's canEncode capability
                boolean canEncode = StandardCharsets.ISO_8859_1.newEncoder().canEncode(icon.getUnicodeChar());
                String expected = canEncode ? String.valueOf(icon.getUnicodeChar()) : icon.getAsciiFallback();
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Jul 15 09:35:08 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  2. cmd/storage-datatypes_test.go

    		FSType:    "xfs",
    		RootDisk:  true,
    		Healing:   true,
    		Endpoint:  "http://localhost:9001/tmp/drive1",
    		MountPath: "/tmp/drive1",
    		ID:        "uuid",
    		Error:     "",
    	}
    
    	var buf bytes.Buffer
    	gob.NewEncoder(&buf).Encode(v)
    	encoded := buf.Bytes()
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    
    	for b.Loop() {
    		dec := gob.NewDecoder(bytes.NewBuffer(encoded))
    		err := dec.Decode(&v)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  3. cmd/api-headers.go

    	var buf bytes.Buffer
    	buf.WriteString(xxml.Header)
    	if err := xxml.NewEncoder(&buf).Encode(response); err != nil {
    		bugLogIf(GlobalContext, err)
    		return nil
    	}
    	return buf.Bytes()
    }
    
    // Encodes the response headers into JSON format.
    func encodeResponseJSON(response any) []byte {
    	var bytesBuffer bytes.Buffer
    	e := json.NewEncoder(&bytesBuffer)
    	e.Encode(response)
    	return bytesBuffer.Bytes()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  4. cmd/admin-handlers-site-replication.go

    		return
    	}
    
    	info, err := globalSiteReplicationSys.GetClusterInfo(ctx)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	if err = json.NewEncoder(w).Encode(info); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    func (a adminAPIHandlers) SRPeerGetIDPSettings(w http.ResponseWriter, r *http.Request) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  5. cmd/peer-rest-server.go

    		return
    	}
    
    	ctx := newContext(r, w, "DownloadProfiling")
    	profileData, err := getProfileData()
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	peersLogIf(ctx, gob.NewEncoder(w).Encode(profileData))
    }
    
    func (s *peerRESTServer) LocalStorageInfoHandler(mss *grid.MSS) (*grid.JSON[madmin.StorageInfo], *grid.RemoteErr) {
    	objLayer := newObjectLayerFn()
    	if objLayer == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  6. cmd/admin-handlers-pools.go

    		return
    	}
    
    	status, err := pools.Status(r.Context(), idx)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	adminLogIf(r.Context(), json.NewEncoder(w).Encode(&status))
    }
    
    func (a adminAPIHandlers) ListPools(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/ConsoleIcon.java

         * @return the Unicode character if supported, otherwise the ASCII fallback
         */
        public String getIcon(Terminal terminal) {
            Charset charset = getTerminalCharset(terminal);
            return charset.newEncoder().canEncode(unicodeChar) ? String.valueOf(unicodeChar) : asciiFallback;
        }
    
        /**
         * Gets the charset used by the terminal for output.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Jul 15 09:35:08 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  8. internal/event/target/elasticsearch.go

    func (c *esClientV7) updateEntry(ctx context.Context, index string, key string, eventData event.Event) error {
    	doc := map[string]any{
    		"Records": []event.Event{eventData},
    	}
    	var buf bytes.Buffer
    	enc := json.NewEncoder(&buf)
    	err := enc.Encode(doc)
    	if err != nil {
    		return err
    	}
    	res, err := c.Index(
    		index,
    		&buf,
    		c.Index.WithDocumentID(key),
    		c.Index.WithContext(ctx),
    	)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  9. internal/s3select/csv/record.go

    	var kvs jstream.KVS = make([]jstream.KV, 0, len(r.columnNames))
    	for i, cn := range r.columnNames {
    		if i < len(r.csvRecord) {
    			kvs = append(kvs, jstream.KV{Key: cn, Value: r.csvRecord[i]})
    		}
    	}
    	return json.NewEncoder(writer).Encode(kvs)
    }
    
    // Raw - returns the underlying data with format info.
    func (r *Record) Raw() (sql.SelectObjectFormat, any) {
    	return sql.SelectFmtCSV, r
    }
    
    // Replace - is not supported for CSV
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  10. schema/serializer.go

    }
    
    // Value implements serializer interface
    func (GobSerializer) Value(ctx context.Context, field *Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	buf := new(bytes.Buffer)
    	err := gob.NewEncoder(buf).Encode(fieldValue)
    	return buf.Bytes(), err
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun Oct 26 12:29:44 GMT 2025
    - 5.1K bytes
    - Click Count (0)
Back to Top