- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 28 for NewEncoder (0.25 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
schema/serializer.go
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)