Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 189 for Stuart (0.15 sec)

  1. internal/event/config.go

    func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if filter.isEmpty() {
    		return nil
    	}
    	type filterRuleWrapper FilterRule
    	return e.EncodeElement(filterRuleWrapper(filter), start)
    }
    
    // UnmarshalXML - decodes XML data.
    func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 16 17:28:29 GMT 2021
    - 8.4K bytes
    - Viewed (0)
  2. internal/grid/grid_test.go

    		start := time.Now()
    		resp, err := remoteConn.Request(context.Background(), handlerTest2, []byte(testPayload))
    		t.Log("Roundtrip:", time.Since(start))
    		if len(resp) != 0 {
    			t.Errorf("want nil, got %q", string(resp))
    		}
    		if err != RemoteErr(testPayload) {
    			t.Errorf("want error %v(%T), got %v(%T)", RemoteErr(testPayload), RemoteErr(testPayload), err, err)
    		}
    		t.Log("Roundtrip:", time.Since(start))
    	})
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  3. cmd/copy-part-range_test.go

    		}
    
    		start, length, err1 := rs.GetOffsetLength(objectSize)
    		if err1 != nil {
    			t.Fatalf("expected: <nil>, got: %s", err1)
    		}
    
    		if start != successCase.offsetBegin {
    			t.Fatalf("expected: %d, got: %d", successCase.offsetBegin, start)
    		}
    
    		if start+length-1 != successCase.offsetEnd {
    			t.Fatalf("expected: %d, got: %d", successCase.offsetEnd, start+length-1)
    		}
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/informers_test.go

    		"",
    	).Return(nil)
    
    	server := &meshDataplane{
    		kubeClient: client.Kube(),
    		netServer:  fs,
    	}
    
    	fs.Start(ctx)
    	handlers := setupHandlers(ctx, client, server, "istio-system")
    	client.RunAndWait(ctx.Done())
    	go handlers.Start()
    
    	// label the namespace
    	labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 01:03:24 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  5. internal/bucket/replication/filter.go

    }
    
    // MarshalXML - produces the xml representation of the Filter struct
    // only one of Prefix, And and Tag should be present in the output.
    func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if err := e.EncodeToken(start); err != nil {
    		return err
    	}
    
    	switch {
    	case !f.And.isEmpty():
    		if err := e.EncodeElement(f.And, xml.StartElement{Name: xml.Name{Local: "And"}}); err != nil {
    			return err
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Sep 28 18:25:46 GMT 2022
    - 3.5K bytes
    - Viewed (2)
  6. internal/bucket/lifecycle/prefix.go

    type Prefix struct {
    	string
    	set    bool
    	Unused struct{} // Needed for GOB compatibility
    }
    
    // UnmarshalXML - decodes XML data.
    func (p *Prefix) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var s string
    	if err = d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    	*p = Prefix{string: s, set: true}
    	return nil
    }
    
    // MarshalXML - decodes XML data.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Aug 15 14:45:25 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  7. internal/bucket/replication/rule.go

    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (d *DeleteReplication) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type deleteReplication DeleteReplication
    	drep := deleteReplication{}
    
    	if err := dec.DecodeElement(&drep, &start); err != nil {
    		return err
    	}
    	if len(drep.Status) == 0 {
    		drep.Status = Disabled
    	}
    	d.Status = drep.Status
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jan 24 23:22:20 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/noncurrentversion.go

    }
    
    // MarshalXML if non-current days not set to non zero value
    func (n NoncurrentVersionExpiration) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if n.IsNull() {
    		return nil
    	}
    	type noncurrentVersionExpirationWrapper NoncurrentVersionExpiration
    	return e.EncodeElement(noncurrentVersionExpirationWrapper(n), start)
    }
    
    // UnmarshalXML decodes NoncurrentVersionExpiration
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Dec 14 17:41:44 GMT 2021
    - 5.3K bytes
    - Viewed (1)
  9. cmd/server-main.go

    {{if .VisibleFlags}}
    FLAGS:
      {{range .VisibleFlags}}{{.}}
      {{end}}{{end}}
    EXAMPLES:
      1. Start MinIO server on "/home/shared" directory.
         {{.Prompt}} {{.HelpName}} /home/shared
    
      2. Start single node server with 64 local drives "/mnt/data1" to "/mnt/data64".
         {{.Prompt}} {{.HelpName}} /mnt/data{1...64}
    
      3. Start distributed MinIO server on an 32 node setup with 32 drives each, run following command on all the nodes
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 32.7K bytes
    - Viewed (1)
  10. cmd/api-headers.go

    		}
    
    		if !isSet {
    			w.Header().Set(k, v)
    		}
    	}
    
    	var start, rangeLen int64
    	totalObjectSize, err := objInfo.GetActualSize()
    	if err != nil {
    		return err
    	}
    
    	if rs == nil && opts.PartNumber > 0 {
    		rs = partNumberToRangeSpec(objInfo, opts.PartNumber)
    	}
    
    	// For providing ranged content
    	start, rangeLen, err = rs.GetOffsetLength(totalObjectSize)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.9K bytes
    - Viewed (1)
Back to top