- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 89 for newDecoder (0.13 seconds)
-
internal/s3select/jstream/decoder_test.go
func TestDecoderSimple(t *testing.T) { var ( counter int mv *MetaValue body = `[{"bio":"bada bing bada boom","id":1,"name":"Charles","falseVal":false}]` ) decoder := NewDecoder(mkReader(body), 1) for mv = range decoder.Stream() { counter++ t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value) } if err := decoder.Err(); err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6.6K bytes - Click Count (0) -
internal/s3select/jstream/decoder.go
err error // follow line position to add context to errors lineNo int lineStart int64 } // NewDecoder creates new Decoder to read JSON values at the provided // emitDepth from the provider io.Reader. // If emitDepth is < 0, values at every depth will be emitted. func NewDecoder(r io.Reader, emitDepth int) *Decoder { d := &Decoder{ scanner: newScanner(r), emitDepth: emitDepth,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (0) -
src/bytes/example_test.go
b.WriteTo(os.Stdout) // Output: Hello world! } func ExampleBuffer_reader() { // A Buffer can turn a string or a []byte into an io.Reader. buf := bytes.NewBufferString("R29waGVycyBydWxlIQ==") dec := base64.NewDecoder(base64.StdEncoding, buf) io.Copy(os.Stdout, dec) // Output: Gophers rule! } func ExampleBuffer_Bytes() { buf := bytes.Buffer{} buf.Write([]byte{'h', 'e', 'l', 'l', 'o', ' ', 'w', 'o', 'r', 'l', 'd'})
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon May 12 16:07:54 GMT 2025 - 16.5K bytes - Click Count (0) -
api/go1.10.txt
pkg encoding/asn1, func MarshalWithParams(interface{}, string) ([]uint8, error) pkg encoding/csv, type ParseError struct, StartLine int pkg encoding/hex, func NewDecoder(io.Reader) io.Reader pkg encoding/hex, func NewEncoder(io.Writer) io.Writer pkg encoding/json, method (*Decoder) DisallowUnknownFields() pkg encoding/xml, func NewTokenDecoder(TokenReader) *Decoder pkg encoding/xml, type TokenReader interface { Token }
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Tue Feb 06 05:00:01 GMT 2018 - 30.1K bytes - Click Count (0) -
docs/debugging/healing-bin/main.go
if err != nil { return err } buf := bytes.NewBuffer(nil) if _, err = msgp.CopyToJSON(buf, bytes.NewReader(b)); err != nil { return err } dec := json.NewDecoder(buf) // Use number to preserve integers. dec.UseNumber() var htr map[string]any if err = dec.Decode(&htr); err != nil { return err } ht[file.Name] = htr } }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.1K bytes - Click Count (0) -
internal/config/policy/opa/config.go
type opaResult struct { Result bool `json:"result"` } respBody := bytes.NewReader(opaRespBytes) var result opaResult if err = json.NewDecoder(respBody).Decode(&result); err != nil { respBody.Seek(0, 0) var resultAllow opaResultAllow if err = json.NewDecoder(respBody).Decode(&resultAllow); err != nil { return false, err } return resultAllow.Result.Allow, nil } return result.Result, nilCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
internal/s3select/jstream/README.md
<img width="85%" src="https://bradley.codes/static/img/jstream-levels.gif" alt="jstream"/> we can choose to extract and act only the objects within the top-level array: ```go f, _ := os.Open("input.json") decoder := jstream.NewDecoder(f, 1) // extract JSON values at a depth level of 1 for mv := range decoder.Stream() { fmt.Printf("%v\n ", mv.Value) } ``` output: ``` map[desc:RGB colors:[red green blue]]
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 3.2K bytes - Click Count (0) -
cmd/storage-datatypes_test.go
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) if err != nil { b.Fatal(err) } } }
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) -
internal/config/identity/openid/provider/keycloak.go
} req.Header.Set("Content-Type", "application/x-www-form-urlencoded") resp, err := k.client.Do(req) if err != nil { return err } defer resp.Body.Close() var accessToken Token if err = json.NewDecoder(resp.Body).Decode(&accessToken); err != nil { return err } k.Lock() k.accessToken = accessToken k.Unlock() return nil } // LookupUser lookup user by their userid.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jul 14 18:12:07 GMT 2024 - 4.6K bytes - Click Count (0) -
internal/config/policy/plugin/config.go
type opaResult struct { Result bool `json:"result"` } respBody := bytes.NewReader(opaRespBytes) var result opaResult if err = json.NewDecoder(respBody).Decode(&result); err != nil { respBody.Seek(0, 0) var resultAllow opaResultAllow if err = json.NewDecoder(respBody).Decode(&resultAllow); err != nil { return false, err } return resultAllow.Result.Allow, nil } return result.Result, nilCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.8K bytes - Click Count (0)