Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 69 for encoder (0.14 sec)

  1. internal/event/name.go

    		return "s3:Scanner:BigPrefix"
    	}
    
    	return ""
    }
    
    // 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTTotalVersions, strconv.Itoa(len(versions)))
    
    	var buffer bytes.Buffer
    	encoder := msgp.NewWriter(&buffer)
    	for _, version := range versions {
    		version.EncodeMsg(encoder)
    	}
    	storageLogIf(ctx, encoder.Flush())
    
    	errs = make([]error, len(versions))
    
    	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    	setEventStreamHeaders(w)
    	encoder := gob.NewEncoder(w)
    	done := keepHTTPResponseAlive(w)
    
    	opts := DeleteOptions{}
    	errs := s.getStorage().DeleteVersions(r.Context(), volume, versions, opts)
    	done(nil)
    	for idx := range versions {
    		if errs[idx] != nil {
    			dErrsResp.Errs[idx] = StorageErr(errs[idx].Error())
    		}
    	}
    	encoder.Encode(dErrsResp)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  4. cmd/api-response.go

    }
    
    // MarshalXML - StringMap marshals into XML.
    func (s *Metadata) MarshalXML(e *xxml.Encoder, start xxml.StartElement) error {
    	if s == nil {
    		return nil
    	}
    
    	if len(s.Items) == 0 {
    		return nil
    	}
    
    	if err := e.EncodeToken(start); err != nil {
    		return err
    	}
    
    	for _, item := range s.Items {
    		if err := e.Encode(xmlKeyEntry{
    			XMLName: xxml.Name{Local: item.Key},
    			Value:   item.Value,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  5. cmd/bucket-replication-utils_gen_test.go

    	v := BucketReplicationResyncStatus{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBucketReplicationResyncStatus Msgsize() is inaccurate")
    	}
    
    	vn := BucketReplicationResyncStatus{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Aug 22 23:53:06 GMT 2022
    - 23K bytes
    - Viewed (0)
  6. cmd/batch-rotate_gen_test.go

    	v := BatchJobKeyRotateEncryption{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBatchJobKeyRotateEncryption Msgsize() is inaccurate")
    	}
    
    	vn := BatchJobKeyRotateEncryption{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 29 18:27:23 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  7. internal/hash/checksum.go

    	ChecksumIncludesMultipart
    
    	// ChecksumNone indicates no checksum.
    	ChecksumNone ChecksumType = 0
    )
    
    // Checksum is a type and base 64 encoded value.
    type Checksum struct {
    	Type    ChecksumType
    	Encoded string
    	Raw     []byte
    }
    
    // Is returns if c is all of t.
    func (c ChecksumType) Is(t ChecksumType) bool {
    	if t == ChecksumNone {
    		return c == ChecksumNone
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  8. internal/s3select/select.go

    		// writer is set later by Reset() before using it.
    		return bufio.NewWriter(xioutil.Discard)
    	},
    }
    
    // UnmarshalXML - decodes XML data.
    func (c *CompressionType) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return errMalformedXML(err)
    	}
    
    	parsedType := CompressionType(strings.ToUpper(s))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  9. cmd/data-usage_test.go

    		gotv := got.Cache[wkey]
    		if !equalAsJSON(gotv, wval) {
    			t.Errorf("deserialize mismatch, key %v\nwant: %#v\ngot:  %#v", wkey, wval, gotv)
    		}
    	}
    }
    
    // equalAsJSON returns whether the values are equal when encoded as JSON.
    func equalAsJSON(a, b interface{}) bool {
    	aj, err := json.Marshal(a)
    	if err != nil {
    		panic(err)
    	}
    	bj, err := json.Marshal(b)
    	if err != nil {
    		panic(err)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  10. cmd/metrics.go

    			}
    		}
    
    		contentType := expfmt.Negotiate(r.Header)
    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
Back to top