Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 357 for an (0.19 sec)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // SASLprep fails, the method returns an error.
    func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
    	x.Client, err = x.HashGeneratorFcn.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  2. cmd/api-errors.go

    	},
    	ErrInvalidMaxUploads: {
    		Code:           "InvalidArgument",
    		Description:    "Argument max-uploads must be an integer between 0 and 2147483647",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidMaxKeys: {
    		Code:           "InvalidArgument",
    		Description:    "Argument maxKeys must be an integer between 0 and 2147483647",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidEncodingMethod: {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (6)
  3. cmd/object-api-deleteobject_test.go

    		pathToDelete       string
    		objectsAfterDelete []string
    	}{
    		// Test 1: removes an object and checks it is the only object
    		// that has been deleted.
    		{
    			"bucket1",
    			[]objectUpload{{"object0", "content"}, {"object1", "content"}},
    			"object0",
    			[]string{"object1"},
    		},
    		// Test 2: remove an object inside a directory and checks it is deleted
    		// with its parent since this former becomes empty
    		{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  4. internal/grid/types.go

    func (NoPayload) MarshalMsg(bytes []byte) ([]byte, error) {
    	return bytes, nil
    }
    
    // NewNoPayload returns an empty NoPayload struct.
    func NewNoPayload() NoPayload {
    	return NoPayload{}
    }
    
    // Recycle is a no-op.
    func (NoPayload) Recycle() {}
    
    // ArrayOf wraps an array of Messagepack compatible objects.
    type ArrayOf[T RoundTripper] struct {
    	aPool sync.Pool // Arrays
    	ePool sync.Pool // Elements
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_string.go

    // Code generated by "stringer -type VersionType,ErasureAlgo -output=xl-storage-format-v2_string.go xl-storage-format-v2.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[invalidVersionType-0]
    	_ = x[ObjectType-1]
    	_ = x[DeleteType-2]
    	_ = x[LegacyType-3]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Dec 02 19:29:16 GMT 2021
    - 1.4K bytes
    - Viewed (0)
  6. cmd/metrics-v2_gen.go

    			}
    		default:
    			bts, err = msgp.Skip(bts)
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z *MetricDescription) Msgsize() (s int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  7. cmd/tier-journal.go

    //msgp:ignore TierJournal tierDiskJournal walkfn
    
    type tierDiskJournal struct {
    	sync.RWMutex
    	diskPath string
    	file     *os.File // active journal file
    }
    
    // TierJournal holds an in-memory and an on-disk delete journal of tiered content.
    type TierJournal struct {
    	*tierDiskJournal // for processing legacy journal entries
    	*tierMemJournal  // for processing new journal entries
    }
    
    type jentry struct {
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  8. internal/mountinfo/mountinfo_linux.go

    		fields := strings.Fields(line)
    		if len(fields) != expectedNumFieldsPerLine {
    			// ignore incorrect lines.
    			continue
    		}
    
    		// Freq should be an integer.
    		if _, err := strconv.Atoi(fields[4]); err != nil {
    			return nil, err
    		}
    
    		// Pass should be an integer.
    		if _, err := strconv.Atoi(fields[5]); err != nil {
    			return nil, err
    		}
    
    		mounts = append(mounts, mountInfo{
    			Device:  fields[0],
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  9. internal/grid/msg_gen.go

    	{
    		var zb0001 uint8
    		zb0001, bts, err = msgp.ReadUint8Bytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = Flags(zb0001)
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z Flags) Msgsize() (s int) {
    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 18.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    		// from older format, for older format we will rewrite them as
    		// newer using PutObject() - this is an optimization to save space
    		if dstOpts.Versioned && srcOpts.VersionID != dstOpts.VersionID && !srcInfo.Legacy {
    			// CopyObject optimization where we don't create an entire copy
    			// of the content, instead we add a reference.
    			srcInfo.versionOnly = true
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
Back to top