Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 396 for Dadd (0.18 sec)

  1. cmd/routers.go

    	}
    
    	// Add Admin router, all APIs are enabled in server mode.
    	registerAdminRouter(router, true)
    
    	// Add healthCheck router
    	registerHealthCheckRouter(router)
    
    	// Add server metrics router
    	registerMetricsRouter(router)
    
    	// Add STS router always.
    	registerSTSRouter(router)
    
    	// Add KMS router
    	registerKMSRouter(router)
    
    	// Add API router
    	registerAPIRouter(router)
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 3.6K bytes
    - Viewed (1)
  2. internal/store/batch_test.go

    	var limit uint32 = 100
    	batch := NewBatch[int, int](limit)
    	for i := 0; i < int(limit); i++ {
    		if err := batch.Add(i, i); err != nil {
    			t.Fatalf("failed to add %v; %v", i, err)
    		}
    		if _, ok := batch.GetByKey(i); !ok {
    			t.Fatalf("failed to get the item by key %v after adding", i)
    		}
    	}
    	err := batch.Add(101, 101)
    	if err == nil || !errors.Is(err, ErrBatchFull) {
    		t.Fatalf("Expected err %v but got %v", ErrBatchFull, err)
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  3. internal/event/targetlist_test.go

    	if err := targetListCase2.Add(&ExampleTarget{TargetID{"2", "testcase"}, false, false}); err != nil {
    		panic(err)
    	}
    
    	targetListCase3 := NewTargetList(context.Background())
    	if err := targetListCase3.Add(&ExampleTarget{TargetID{"3", "testcase"}, false, false}); err != nil {
    		panic(err)
    	}
    	if err := targetListCase3.Add(&ExampleTarget{TargetID{"1", "webhook"}, false, false}); err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  4. internal/config/lambda/event/targetidset.go

    		setCopy[k] = v
    	}
    	return setCopy
    }
    
    // add - adds TargetID to the set.
    func (set TargetIDSet) add(targetID TargetID) {
    	set[targetID] = struct{}{}
    }
    
    // Union - returns union with given set as new set.
    func (set TargetIDSet) Union(sset TargetIDSet) TargetIDSet {
    	nset := set.Clone()
    
    	for k := range sset {
    		nset.add(k)
    	}
    
    	return nset
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  5. internal/bucket/bandwidth/monitor_test.go

    	test1Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{
    		LimitInBytesPerSecond:            1024 * 1024,
    		CurrentBandwidthInBytesPerSecond: (1024 * 1024) / start.Add(2*time.Second).Sub(start.Add(1*time.Second)).Seconds(),
    	}
    
    	test2Want := make(map[BucketOptions]Details)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Sep 06 03:21:59 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  6. docs/bucket/replication/README.md

    ```
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 24 23:46:33 GMT 2023
    - 18.2K bytes
    - Viewed (0)
  7. helm/minio/templates/configmap.yaml

        heritage: {{ .Release.Service }}
    data:
      initialize: |-
        {{- include (print $.Template.BasePath "/_helper_create_bucket.txt") . | nindent 4 }}
      add-user: |-
        {{- include (print $.Template.BasePath "/_helper_create_user.txt") . | nindent 4 }}
      add-policy: |-
        {{- include (print $.Template.BasePath "/_helper_create_policy.txt") . | nindent 4 }}
      {{- range $idx, $policy := .Values.policies }}
    Others
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 17 06:04:15 GMT 2023
    - 1.2K bytes
    - Viewed (0)
  8. helm/minio/templates/post-job.yaml

              {{- if .Values.makePolicyJob.exitCommand }}
              command: [ "/bin/sh", "-c" ]
              args: [ "/bin/sh /config/add-policy; EV=$?; {{ .Values.makePolicyJob.exitCommand }} && exit $EV" ]
              {{- else }}
              command: [ "/bin/sh", "/config/add-policy" ]
              {{- end }}
              env:
                - name: MINIO_ENDPOINT
                  value: {{ template "minio.fullname" . }}
    Others
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Jul 08 19:18:31 GMT 2023
    - 10.4K bytes
    - Viewed (0)
  9. cmd/erasure.go

    	xioutil.SafeClose(bucketCh)
    
    	bucketResults := make(chan dataUsageEntryInfo, len(disks))
    
    	// Start async collector/saver.
    	// This goroutine owns the cache.
    	var saverWg sync.WaitGroup
    	saverWg.Add(1)
    	go func() {
    		// Add jitter to the update time so multiple sets don't sync up.
    		updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64())
    		t := time.NewTicker(updateTime)
    		defer t.Stop()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 10:02:39 GMT 2024
    - 16K bytes
    - Viewed (1)
  10. cmd/data-usage-cache.go

    			objects uint64
    			path    dataUsageHash
    		}{objects: sz.Objects, path: path})
    		for ch := range e.Children {
    			add(dataUsageHash(ch))
    		}
    	}
    
    	// Add path recursively.
    	add(path)
    	sort.Slice(leaves, func(i, j int) bool {
    		return leaves[i].objects < leaves[j].objects
    	})
    	for remove > 0 && len(leaves) > 0 {
    		// Remove top entry.
    		e := leaves[0]
    		candidate := e.path
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 41.3K bytes
    - Viewed (1)
Back to top