Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 900 for makeAs (0.09 sec)

  1. internal/rest/client.go

    	if !ok && body != nil {
    		rc = io.NopCloser(body)
    	}
    	req := &http.Request{
    		Method:     method,
    		URL:        &u,
    		Proto:      "HTTP/1.1",
    		ProtoMajor: 1,
    		ProtoMinor: 1,
    		Header:     make(http.Header),
    		Body:       rc,
    		Host:       u.Host,
    	}
    	req = req.WithContext(ctx)
    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    	subStateless map[subHandlerID]*StatelessHandler
    	subStreams   map[subHandlerID]*StreamHandler
    }
    
    func (h *handlers) init() {
    	h.subSingle = make(map[subHandlerID]SingleHandlerFn)
    	h.subStateless = make(map[subHandlerID]*StatelessHandler)
    	h.subStreams = make(map[subHandlerID]*StreamHandler)
    }
    
    func (h *handlers) hasAny(id HandlerID) bool {
    	if !id.valid() {
    		return false
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  3. cmd/xl-storage_test.go

    		case err != nil && err != test.expError:
    			t.Errorf("Test %d: Expected error: %v, but got: %v", i, test.expError, err)
    		}
    	}
    }
    
    // TestXLStorageFormatFileChange - to test if changing the diskID makes the calls fail.
    func TestXLStorageFormatFileChange(t *testing.T) {
    	volume := "fail-vol"
    	xlStorage, _, err := newXLStorageTestSetup(t)
    	if err != nil {
    		t.Fatalf("Unable to create xlStorage test setup, %s", err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  4. cmd/metacache-stream.go

    		if err != nil {
    			return nil, fmt.Errorf("metacacheWriter: unable to create writer: %w", err)
    		}
    		if w.mw == nil {
    			return nil, errors.New("metacacheWriter: writer not initialized")
    		}
    	}
    	objs := make(chan metaCacheEntry, 100)
    	w.streamErr = nil
    	w.streamWg.Add(1)
    	go func() {
    		defer w.streamWg.Done()
    		for o := range objs {
    			if len(o.name) == 0 || w.streamErr != nil {
    				continue
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  5. cmd/bitrot_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	if bw, ok := writer.(io.Closer); ok {
    		bw.Close()
    	}
    
    	reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10)
    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 10); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 20); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. internal/bucket/replication/sourceselectioncriteria.go

    		return errInvalidSourceSelectionCriteria
    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (s *SourceSelectionCriteria) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type sourceSelectionCriteria SourceSelectionCriteria
    	ssc := sourceSelectionCriteria{}
    	if err := dec.DecodeElement(&ssc, &start); err != nil {
    		return err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  7. cmd/endpoint-ellipses.go

    // we also use uniform number of drives common across all ellipses patterns.
    func possibleSetCountsWithSymmetry(setCounts []uint64, argPatterns []ellipses.ArgPattern) []uint64 {
    	newSetCounts := make(map[uint64]struct{})
    	for _, ss := range setCounts {
    		var symmetry bool
    		for _, argPattern := range argPatterns {
    			for _, p := range argPattern {
    				if uint64(len(p.Seq)) > ss {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  8. docs/nl/docs/python-types.md

    ```
    
    Het goede nieuws is dat als je eenmaal Python 3.10 gebruikt, je je daar geen zorgen meer over hoeft te maken, omdat je dan gewoon `|` kunt gebruiken om unions van types te definiëren:
    
    ```Python hl_lines="1  4"
    {!../../docs_src/python_types/tutorial009c_py310.py!}
    ```
    
    Dan hoef je je geen zorgen te maken over namen als `Optional` en `Union`. 😎
    
    #### Generieke typen
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  9. docs/auditlog/auditlog-echo.md

    2. Configure audit logging in MinIO with for example:
    
    ```
    mc admin config set myminio audit_webhook enable=on endpoint=http://localhost:8080
    ```
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 447 bytes
    - Viewed (0)
  10. internal/pubsub/pubsub.go

    package pubsub
    
    import (
    	"bytes"
    	"encoding/json"
    	"fmt"
    	"sync"
    	"sync/atomic"
    )
    
    // GetByteBuffer returns a byte buffer from the pool.
    var GetByteBuffer = func() []byte {
    	return make([]byte, 0, 4096)
    }
    
    // Sub - subscriber entity.
    type Sub[T Maskable] struct {
    	ch     chan T
    	types  Mask
    	filter func(entry T) bool
    }
    
    // PubSub holds publishers and subscribers
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top