Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 243 for decode (0.04 sec)

  1. internal/event/name.go

    // MarshalXML - encodes to XML data.
    func (name Name) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	return e.EncodeElement(name.String(), start)
    }
    
    // UnmarshalXML - decodes XML data.
    func (name *Name) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    
    	eventName, err := ParseName(s)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. cmd/utils.go

    	// On form submission, the last redirect response contains the auth
    	// code, which we now have in `lastReq`. Exchange it for a JWT id_token.
    	q := lastReq.URL.Query()
    	// fmt.Printf("lastReq.URL: %#v q: %#v\n", lastReq.URL, q)
    	code := q.Get("code")
    	oauth2Token, err := oauth2Config.Exchange(ctx, code)
    	if err != nil {
    		return "", fmt.Errorf("unable to exchange code for id token: %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. internal/s3select/simdj/reader.go

    	input   chan simdjson.Stream
    	decoded chan simdjson.Object
    
    	// err will only be returned after decoded has been closed.
    	err          *error
    	readCloser   io.ReadCloser
    	onReaderExit func()
    
    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.decoded
    	if !ok {
    		if r.err != nil && *r.err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  4. internal/s3select/jstream/decoder_test.go

    		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 {
    		t.Fatalf("decoder error: %s", err)
    	}
    }
    
    func TestDecoderNested(t *testing.T) {
    	var (
    		counter int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. docs/screenshots/erasure-code.svg

    erasure-code.svg...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Apr 15 00:21:57 UTC 2017
    - 17.4K bytes
    - Viewed (0)
  6. internal/s3select/json/reader.go

    // Reader - JSON record reader for S3Select.
    type Reader struct {
    	args       *ReaderArgs
    	decoder    *jstream.Decoder
    	valueCh    chan *jstream.MetaValue
    	readCloser io.ReadCloser
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.valueCh
    	if !ok {
    		if err := r.decoder.Err(); err != nil {
    			return nil, errJSONParsingError(err)
    		}
    		return nil, io.EOF
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. docs/sts/wso2.md

      "token_type": "Bearer",
      "expires_in": 3600
    }
    ```
    
    ### 4. JWT Claims
    
    The id_token received is a signed JSON Web Token (JWT). Use a JWT decoder to decode the id_token to access the payload of the token that includes following JWT claims:
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 8.7K bytes
    - Viewed (0)
  8. docs/distributed/decom-encrypted-sse-s3.sh

    ./mc ls -r myminio/versioned/ >expanded_ns.txt
    ./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt
    
    ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}
    
    until $(./mc admin decom status myminio/ | grep -q Complete); do
    	echo "waiting for decom to finish..."
    	sleep 1
    done
    
    kill $pid_1
    kill $pid_2
    
    sleep 5
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  9. docs/distributed/decom.sh

    ./mc ls -r myminio/versioned/ >expanded_ns.txt
    ./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt
    
    ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}
    
    count=0
    until $(./mc admin decom status myminio/ | grep -q Complete); do
    	echo "waiting for decom to finish..."
    	count=$((count + 1))
    	if [ ${count} -eq 120 ]; then
    		./mc cat /tmp/expanded_*.log
    	fi
    	sleep 1
    done
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  10. internal/event/targetid.go

    	return ARN{TargetID: tid, region: region}
    }
    
    // MarshalJSON - encodes to JSON data.
    func (tid TargetID) MarshalJSON() ([]byte, error) {
    	return json.Marshal(tid.String())
    }
    
    // UnmarshalJSON - decodes JSON data.
    func (tid *TargetID) UnmarshalJSON(data []byte) error {
    	var s string
    	if err := json.Unmarshal(data, &s); err != nil {
    		return err
    	}
    
    	targetID, err := parseTargetID(s)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.8K bytes
    - Viewed (0)
Back to top