Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 1,713 for Fake (0.02 sec)

  1. internal/event/rules_test.go

    	rulesCase1 := make(Rules)
    	rules2Case1 := make(Rules)
    	expectedResultCase1 := make(Rules)
    
    	rulesCase2 := make(Rules)
    	rules2Case2 := make(Rules)
    	rules2Case2.Add(NewPattern("*", "*"), TargetID{"1", "webhook"})
    	expectedResultCase2 := make(Rules)
    
    	rulesCase3 := make(Rules)
    	rulesCase3.Add(NewPattern("*", "*"), TargetID{"1", "webhook"})
    	rules2Case3 := make(Rules)
    	expectedResultCase3 := make(Rules)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.8K bytes
    - Viewed (0)
  2. internal/event/rulesmap_test.go

    			t.Fatalf("test %v: result: expected: not equal, got: equal", i+1)
    		}
    	}
    }
    
    func TestRulesMapAdd(t *testing.T) {
    	rulesMapCase1 := make(RulesMap)
    	rulesMapToAddCase1 := make(RulesMap)
    	expectedResultCase1 := make(RulesMap)
    
    	rulesMapCase2 := make(RulesMap)
    	rulesMapToAddCase2 := NewRulesMap([]Name{ObjectCreatedAll}, "*", TargetID{"1", "webhook"})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		return
    	}
    
    	updateStatus := madmin.ServerUpdateStatusV2{
    		DryRun:  dryRun,
    		Results: make([]madmin.ServerPeerUpdateStatus, 0, len(globalNotificationSys.allPeerClients)),
    	}
    	peerResults := make(map[string]madmin.ServerPeerUpdateStatus, len(globalNotificationSys.allPeerClients))
    	failedClients := make(map[int]bool, len(globalNotificationSys.allPeerClients))
    
    	if lrTime.Sub(currentReleaseTime) <= 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    	postPolicyBucketTagging = "tagging"
    )
    
    // Check if there are buckets on server without corresponding entry in etcd backend and
    // make entries. Here is the general flow
    // - Range over all the available buckets
    // - Check if a bucket has an entry in etcd backend
    // -- If no, make an entry
    // -- If yes, check if the entry matches local IP check if we
    //
    //	need to update the entry then proceed to update
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  5. cmd/peer-s3-client.go

    			return nil
    		}, idx)
    	}
    
    	errs := g.Wait()
    
    	// The list of buckets in a map to avoid duplication
    	resultMap := make(map[string]BucketInfo)
    
    	for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ {
    		perPoolErrs := make([]error, 0, len(sys.peerClients))
    		for i, client := range sys.peerClients {
    			if slices.Contains(client.GetPools(), poolIdx) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. CONTRIBUTING.md

    Getting Started
    ---------------
    
    + Make sure you have a [JIRA account](https://issues.apache.org/jira/).
    + Make sure you have a [GitHub account](https://github.com/signup/free).
    + If you're planning to implement a new feature, it makes sense to discuss your changes
      on the [dev list](https://maven.apache.org/mailing-lists.html) first.
      This way you can make sure you're not wasting your time on something that isn't
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Sun Oct 10 09:48:27 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  7. src/bytes/buffer_test.go

    		}
    
    		rlen := rand.Intn(len(testString))
    		fub := make([]byte, rlen)
    		n, _ := buf.Read(fub)
    		s = s[n:]
    	}
    	empty(t, "TestMixedReadsAndWrites (2)", &buf, s, make([]byte, buf.Len()))
    }
    
    func TestCapWithPreallocatedSlice(t *testing.T) {
    	buf := NewBuffer(make([]byte, 10))
    	n := buf.Cap()
    	if n != 10 {
    		t.Errorf("expected 10, got %d", n)
    	}
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  8. cmd/data-scanner.go

    // and also that small branches with few objects don't take up unreasonable amounts of space.
    // This keeps the cache size at a reasonable size for all buckets.
    //
    // Whenever a branch is scanned, it is assumed that it will be un-compacted
    // before it hits any of the above limits.
    // This will make the branch rebalance itself when scanned if the distribution of objects has changed.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  9. callbacks/helper.go

    				if v, ok := selectColumns[k]; (ok && v) || (!ok && !restricted) {
    					result[k] = make([]interface{}, len(mapValues))
    					columns = append(columns, k)
    				} else {
    					continue
    				}
    			}
    
    			result[k][idx] = v
    		}
    	}
    
    	sort.Strings(columns)
    	values.Values = make([][]interface{}, len(mapValues))
    	values.Columns = make([]clause.Column, len(columns))
    	for idx, column := range columns {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Apr 14 12:32:57 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  10. .github/workflows/go-healing.yml

            run: |
              sudo sysctl net.ipv6.conf.all.disable_ipv6=0
              sudo sysctl net.ipv6.conf.default.disable_ipv6=0
              make verify-healing
              make verify-healing-inconsistent-versions
              make verify-healing-with-root-disks
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 1.2K bytes
    - Viewed (0)
Back to top