Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 1,179 for funcs (0.03 sec)

  1. cmd/encryption-v1.go

    	return encrypted, nil
    }
    
    type (
    	objectMetaEncryptFn func(baseKey string, data []byte) []byte
    	objectMetaDecryptFn func(baseKey string, data []byte) ([]byte, error)
    )
    
    // metadataEncrypter returns a function that will read data from input,
    // encrypt it using the provided key and return the result.
    // 0 sized inputs are passed through.
    func metadataEncrypter(key crypto.ObjectKey) objectMetaEncryptFn {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  2. internal/s3select/sql/aggregation.go

    	}
    
    	return err
    }
    
    func (e *AliasedExpression) aggregateRow(r Record, tableAlias string) error {
    	return e.Expression.aggregateRow(r, tableAlias)
    }
    
    func (e *Expression) aggregateRow(r Record, tableAlias string) error {
    	for _, ex := range e.And {
    		err := ex.aggregateRow(r, tableAlias)
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. cmd/object-api-options.go

    	return opts, nil
    }
    
    func getAndValidateAttributesOpts(ctx context.Context, w http.ResponseWriter, r *http.Request, bucket, object string) (opts ObjectOptions, valid bool) {
    	var argumentName string
    	var argumentValue string
    	var apiErr APIError
    	var err error
    	valid = true
    
    	defer func() {
    		if valid {
    			return
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  4. internal/config/identity/ldap/ldap.go

    	}
    	return dur, nil
    }
    
    // ParsesAsDN determines if the given string could be a valid DN based on
    // parsing alone.
    func (l Config) ParsesAsDN(dn string) bool {
    	_, err := ldap.ParseDN(dn)
    	return err == nil
    }
    
    // IsLDAPUserDN determines if the given string could be a user DN from LDAP.
    func (l Config) IsLDAPUserDN(user string) bool {
    	udn, err := ldap.ParseDN(user)
    	if err != nil {
    		return false
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 01:04:53 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. internal/s3select/json/preader.go

    func (r *PReader) startReaders() {
    	r.bufferPool.New = func() interface{} {
    		return make([]byte, jsonSplitSize+1024)
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  6. internal/event/name.go

    }
    
    // Mask returns the type as mask.
    // Compound "All" types are expanded.
    func (name Name) Mask() uint64 {
    	if name < objectSingleTypesEnd {
    		return 1 << (name - 1)
    	}
    	var mask uint64
    	for _, n := range name.Expand() {
    		mask |= 1 << (n - 1)
    	}
    	return mask
    }
    
    // String - returns string representation of event type.
    func (name Name) String() string {
    	switch name {
    	case BucketCreated:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  7. cmd/last-minute_gen.go

    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z AccElem) Msgsize() (s int) {
    	s = 1 + 6 + msgp.Int64Size + 5 + msgp.Int64Size + 2 + msgp.Int64Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *LastMinuteHistogram) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0001 uint32
    	zb0001, err = dc.ReadArrayHeader()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 17.2K bytes
    - Viewed (0)
  8. internal/s3select/json/preader_test.go

    import (
    	"bytes"
    	"io"
    	"os"
    	"path/filepath"
    	"testing"
    
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    func TestNewPReader(t *testing.T) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		t.Fatal(err)
    	}
    	for _, file := range files {
    		t.Run(file.Name(), func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  9. internal/s3select/json/reader_test.go

    import (
    	"bytes"
    	"io"
    	"os"
    	"path/filepath"
    	"testing"
    
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    func TestNewReader(t *testing.T) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		t.Fatal(err)
    	}
    	for _, file := range files {
    		t.Run(file.Name(), func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  10. cmd/background-newdisks-heal-ops.go

    	h.HealedBuckets = nil
    	h.Object = ""
    	h.Bucket = ""
    }
    
    func (h *healingTracker) getLastUpdate() time.Time {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.LastUpdate
    }
    
    func (h *healingTracker) getBucket() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Bucket
    }
    
    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top