- Sort Score
- Result 10 results
- Languages All
Results 391 - 400 of 1,179 for funcs (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)