Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for cark (0.22 sec)

  1. cmd/peer-rest-server.go

    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    	err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  2. internal/s3select/select_test.go

    			wantResult: `{"Id":1,"Name":"Anshu","Address":"Templestowe","Car":"Jeep"}`,
    			withJSON:   `{ "person": [ { "Id": 1, "Name": "Anshu", "Address": "Templestowe", "Car": "Jeep" }, { "Id": 2, "Name": "Ben Mostafa", "Address": "Las Vegas", "Car": "Mustang" }, { "Id": 3, "Name": "Rohan Wood", "Address": "Wooddon", "Car": "VW" } ] }`,
    		},
    		{
    			name:       "lower-case-is",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    						VersionID: goi.VersionID,
    					}
    				}
    				return goi, ObjectNotFound{
    					Bucket: bucket,
    					Object: object,
    				}
    			}
    		}
    	}
    
    	//  Determine whether to mark object deleted for replication
    	markDelete := goi.VersionID != ""
    
    	// Default deleteMarker to true if object is under versioning
    	deleteMarker := opts.Versioned
    
    	if opts.VersionID != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. cmd/erasure-server-pool.go

    			defer wg.Done()
    			dobjects[idx], derrs[idx] = pool.DeleteObject(ctx, bucket, object, opts)
    		}(idx, pool)
    	}
    	wg.Wait()
    
    	// the poolIndices array is pre-sorted in order of latest ModTime, we care only about pool with latest object though
    	// the delete call tries to clean up other pools during DeleteObject call.
    	objInfo = dobjects[0]
    	objInfo.Name = decodeDirObject(object)
    	err = derrs[0]
    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)
  5. cmd/admin-handlers-users.go

    		return
    	}
    
    	if serviceAccount == siteReplicatorSvcAcc && globalSiteReplicationSys.isEnabled() {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidArgument), r.URL)
    		return
    	}
    	// We do not care if service account is readable or not at this point,
    	// since this is a delete call we shall allow it to be deleted if possible.
    	svcAccount, _, err := globalIAMSys.GetServiceAccount(ctx, serviceAccount)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
  6. src/archive/zip/reader_test.go

    		return
    	}
    
    	// bail if file is not zip
    	if err == ErrFormat {
    		return
    	}
    
    	// bail here if no Files expected to be tested
    	// (there may actually be files in the zip, but we don't care)
    	if zt.File == nil {
    		return
    	}
    
    	if z.Comment != zt.Comment {
    		t.Errorf("comment=%q, want %q", z.Comment, zt.Comment)
    	}
    	if len(z.File) != len(zt.File) {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 55.3K bytes
    - Viewed (0)
Back to top