- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 71 for puts (0.13 sec)
-
internal/bucket/lifecycle/lifecycle_test.go
Name: "obj-1", }, hasRules: false, }, { // PUT version with no matching tags lc: Lifecycle{ Rules: []Rule{ rules[0], }, }, opts: ObjectOpts{ IsLatest: true, Name: "obj-1", Size: 1 * humanize.MiByte, }, hasRules: false, }, { // PUT version with matching tags lc: Lifecycle{ Rules: []Rule{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0) -
cmd/admin-handlers-idp-ldap.go
return } writeSuccessResponseJSON(w, encryptedData) } // AddServiceAccountLDAP adds a new service account for provided LDAP username or DN // // PUT /minio/admin/v3/idp/ldap/add-service-account func (a adminAPIHandlers) AddServiceAccountLDAP(w http.ResponseWriter, r *http.Request) { ctx, cred, opts, createReq, targetUser, APIError := commonAddServiceAccount(r)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 13.3K bytes - Viewed (0) -
internal/event/target/mysql.go
} // Save - saves the events to the store which will be replayed when the SQL connection is active. func (target *MySQLTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) } if err := target.init(); err != nil { return err } _, err := target.isActive() if err != nil { return err } return target.send(eventData) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0) -
cmd/server-main.go
} bootLogIf(GlobalContext, err) } if !globalServerCtxt.StrictS3Compat { warnings = append(warnings, color.YellowBold("- Strict AWS S3 compatible incoming PUT, POST content payload validation is turned off, caution is advised do not use in production")) } }) if globalActiveCred.Equal(auth.DefaultCredentials) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
cmd/data-scanner.go
default: } f.lastUpdate = time.Now() } } // scanFolder will scan the provided folder. // Files found in the folders will be added to f.newCache. // If final is provided folders will be put into f.newFolders or f.existingFolders. // If final is not provided the folders found are returned from the function. func (f *folderScanner) scanFolder(ctx context.Context, folder cachedFolder, into *dataUsageEntry) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
internal/event/config_test.go
<Value>jpg</Value> </FilterRule> </S3Key> </Filter> <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue> <Event>s3:ObjectCreated:Put</Event> <Event>s3:ObjectCreated:Put</Event> </QueueConfiguration>`) testCases := []struct { data []byte expectErr bool }{ {dataCase1, false}, {dataCase2, false}, {dataCase3, true}, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 29K bytes - Viewed (0) -
internal/rest/client_test.go
err error target interface{} want bool }{ { name: "url.Error", err: &url.Error{Op: "PUT", URL: "http://localhost/1234", Err: restError("remote server offline")}, target: &url.Error{}, want: true, }, { name: "net.Error", err: &url.Error{Op: "PUT", URL: "http://localhost/1234", Err: restError("remote server offline")}, want: true, }, { name: "net.Error-unmatched",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 1.9K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
} sort.Slice(srvRecords, func(i int, j int) bool { return srvRecords[i].Key < srvRecords[j].Key }) return srvRecords, nil } // Put - Adds DNS entries into etcd endpoint in CoreDNS etcd message format. func (c *CoreDNS) Put(bucket string) error { c.Delete(bucket) // delete any existing entries. t := time.Now().UTC() for ip := range c.domainIPs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 8.3K bytes - Viewed (0) -
internal/s3select/json/preader.go
if !ok { r.err = io.EOF return nil, r.err } //nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer. r.kvDstPool.Put(r.current) r.current = <-item.dst r.err = item.err r.recordsRead = 0 } kvRecord := r.current[r.recordsRead] r.recordsRead++ dstRec, ok := dst.(*Record) if !ok { dstRec = &Record{} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
cmd/bucket-handlers.go
for _, os := range oss { if os == nil { // skip objects that weren't deleted due to invalid versionID etc. continue } os.Sweep() } } // PutBucketHandler - PUT Bucket // ---------- // This implementation of the PUT operation creates a new bucket for authenticated request func (api objectAPIHandlers) PutBucketHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "PutBucket")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0)