Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 1,387 for Take (0.01 sec)

  1. internal/config/notify/config.go

    func NewConfig() Config {
    	// Make sure to initialize notification targets
    	cfg := Config{
    		NSQ:           make(map[string]target.NSQArgs),
    		AMQP:          make(map[string]target.AMQPArgs),
    		MQTT:          make(map[string]target.MQTTArgs),
    		NATS:          make(map[string]target.NATSArgs),
    		Redis:         make(map[string]target.RedisArgs),
    		MySQL:         make(map[string]target.MySQLArgs),
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  2. CONTRIBUTING.md

    ### Create your feature branch
    
    Before making code changes, make sure you create a separate branch for these changes
    
    ```
    git checkout -b my-new-feature
    ```
    
    ### Test MinIO server changes
    
    After your code changes, make sure
    
    - To add test cases for the new code. If you have questions about how to do it, please ask on our [Slack](https://slack.min.io) channel.
    - To run `make verifiers`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  4. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.8K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  6. 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 Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Apr 14 12:32:57 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  7. .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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  8. cmd/erasure-metadata-utils.go

    func shuffleDisksAndPartsMetadataByIndex(disks []StorageAPI, metaArr []FileInfo, fi FileInfo) (shuffledDisks []StorageAPI, shuffledPartsMetadata []FileInfo) {
    	shuffledDisks = make([]StorageAPI, len(disks))
    	shuffledPartsMetadata = make([]FileInfo, len(disks))
    	distribution := fi.Erasure.Distribution
    
    	var inconsistent int
    	for i, meta := range metaArr {
    		if disks[i] == nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  9. internal/ringbuffer/ring_buffer_benchmark_test.go

    	rb := New(1024)
    	data := []byte(strings.Repeat("a", 512))
    	buf := make([]byte, 512)
    
    	for b.Loop() {
    		rb.Write(data)
    		rb.Read(buf)
    	}
    }
    
    func BenchmarkRingBuffer_AsyncRead(b *testing.B) {
    	// Pretty useless benchmark, but it's here for completeness.
    	rb := New(1024)
    	data := []byte(strings.Repeat("a", 512))
    	buf := make([]byte, 512)
    
    	go func() {
    		for {
    			rb.Read(buf)
    		}
    	}()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  10. internal/bucket/bandwidth/monitor_test.go

    	m0.incrementBytes(0)
    	m1MiBPS := newBucketMeasurement(start)
    	m1MiBPS.incrementBytes(oneMiB)
    
    	test1Want := make(map[BucketOptions]Details)
    	test1Want[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{LimitInBytesPerSecond: 1024 * 1024, CurrentBandwidthInBytesPerSecond: 0}
    	test1Want2 := make(map[BucketOptions]Details)
    	test1Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
Back to top