Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 189 for Read (0.12 sec)

  1. cmd/object-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	api.getObjectAttributesHandler(ctx, objectAPI, bucket, object, w, r)
    }
    
    // HeadObjectHandler - HEAD Object
    // -----------
    // The HEAD operation retrieves metadata from an object without returning the object itself.
    func (api objectAPIHandlers) HeadObjectHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "HeadObject")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  2. cmd/sts-handlers_test.go

    	}
    
    	gotBuckets := set.NewStringSet()
    	for _, b := range accInfo.Buckets {
    		gotBuckets.Add(b.Name)
    		if !(b.Access.Read && b.Access.Write) {
    			c.Fatalf("root user should have read and write access to bucket: %v", b.Name)
    		}
    	}
    	shouldHaveBuckets := set.CreateStringSet(bucket2, bucket)
    	if !gotBuckets.Equals(shouldHaveBuckets) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  3. docs/debugging/inspect/export.go

    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(v))
    			if e != nil {
    				return nil, e
    			}
    			data = b
    		case 3:
    			v, b, e := msgp.ReadBytesZC(b)
    			if e != nil {
    				return nil, e
    			}
    			if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil {
    				// Read metadata CRC (added in v2, ignore if not found)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 08 15:58:02 GMT 2022
    - 9.1K bytes
    - Viewed (0)
  4. cmd/erasure-decode_test.go

    			t.Errorf("Test %d: should fail but it passed", i)
    		}
    		if err == nil {
    			if content := writer.Bytes(); !bytes.Equal(content, data[test.offset:test.offset+test.length]) {
    				t.Errorf("Test %d: read returns wrong file content.", i)
    			}
    		}
    
    		for i, r := range bitrotReaders {
    			if r == nil {
    				disks[i] = OfflineDisk
    			}
    		}
    		if err == nil && !test.shouldFail {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  5. cmd/storage-rest-server.go

    // the Close() function is called.
    type closeNotifier struct {
    	rc   io.ReadCloser
    	done chan struct{}
    }
    
    func (c *closeNotifier) Read(p []byte) (n int, err error) {
    	n, err = c.rc.Read(p)
    	if err != nil {
    		if c.done != nil {
    			xioutil.SafeClose(c.done)
    			c.done = nil
    		}
    	}
    	return n, err
    }
    
    func (c *closeNotifier) Close() error {
    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)
  6. cmd/erasure-healing-common_test.go

    		t.Fatalf("Failed to read xl meta data %v", reducedErr)
    	}
    
    	// Test 1: Test that all disks are returned without any failures with
    	// unmodified meta data
    	partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    	if err != nil {
    		t.Fatalf("Failed to read xl meta data %v", err)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  7. cmd/object-api-utils.go

    	minioMetaTmpDeletedBucket = minioMetaTmpBucket + "/.trash"
    
    	// DNS separator (period), used for bucket name validation.
    	dnsDelimiter = "."
    	// On compressed files bigger than this;
    	compReadAheadSize = 100 << 20
    	// Read this many buffers ahead.
    	compReadAheadBuffers = 5
    	// Size of each buffer.
    	compReadAheadBufSize = 1 << 20
    	// Pad Encrypted+Compressed files to a multiple of this.
    	compPadEncrypted = 256
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  8. internal/s3select/csv/reader_contrib_test.go

    			}
    		})
    	}
    }
    
    type errReader struct {
    	err error
    }
    
    func (e errReader) Read(p []byte) (n int, err error) {
    	return 0, e.err
    }
    
    func TestReadFailures(t *testing.T) {
    	customErr := errors.New("unable to read file :(")
    	cases := []struct {
    		file            string
    		recordDelimiter string
    		fieldDelimiter  string
    		sendErr         error
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 38.5K bytes
    - Viewed (0)
  9. internal/config/identity/ldap/help.go

    		},
    		config.HelpKV{
    			Key:         LookupBindDN,
    			Description: `DN for LDAP read-only service account used to perform DN and group lookups` + defaultHelpPostfix(LookupBindDN),
    			Optional:    true,
    			Type:        "string",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         LookupBindPassword,
    			Description: `Password for LDAP read-only service account used to perform DN and group lookups` + defaultHelpPostfix(LookupBindPassword),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Jun 23 14:45:27 GMT 2023
    - 3.6K bytes
    - Viewed (0)
  10. internal/grid/stream.go

    	"context"
    	"errors"
    )
    
    // A Stream is a two-way stream.
    // All responses *must* be read by the caller.
    // If the call is canceled through the context,
    // the appropriate error will be returned.
    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 18:05:18 GMT 2024
    - 2.8K bytes
    - Viewed (0)
Back to top