Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 89 for newDecoder (0.13 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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, nil
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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, nil
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.8K bytes
    - Click Count (0)
Back to Top