Search Options

Results per page
Sort
Preferred Languages
Advance

Results 551 - 560 of 808 for oper (0.03 sec)

  1. internal/event/target/mqtt.go

    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-mqtt-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of MQTT `%s`: %w", id, err)
    		}
    	}
    
    	target := &MQTTTarget{
    		id:         event.TargetID{ID: id, Name: "mqtt"},
    		args:       args,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. cmd/format-erasure.go

    		// Sets field carries the input disk order generated the first
    		// time when fresh disks were supplied, it is a two dimensional
    		// array second dimension represents list of disks used per set.
    		Sets [][]string `json:"sets"`
    		// Distribution algorithm represents the hashing algorithm
    		// to pick the right set index for an object.
    		DistributionAlgo string `json:"distributionAlgo"`
    	} `json:"xl"`
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  3. docs/debugging/xl-meta/main.go

    		}
    
    		toPrint := make([]string, 0, 16)
    		for _, file := range files {
    			var r io.Reader
    			var sz int64
    			switch file {
    			case "-":
    				r = os.Stdin
    			default:
    				f, err := os.Open(file)
    				if err != nil {
    					return err
    				}
    				if st, err := f.Stat(); err == nil {
    					sz = st.Size()
    				}
    				defer f.Close()
    				r = f
    			}
    			if strings.HasSuffix(file, ".zip") {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  4. src/main/webapp/WEB-INF/view/admin/storage/admin_storage.jsp

                                                        <td>
                                                            <em class="fa fa-folder-open" style="color:#F7C502;">
                                                                ${f:h(data.name)}
                                                        </td>
                                                        <td></td>
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu May 26 01:48:41 UTC 2022
    - 20.4K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/policy/v1/generated.proto

      // absence of the evicted pod.  So for example you can prevent all voluntary
      // evictions by specifying "100%".
      // +optional
      optional k8s.io.apimachinery.pkg.util.intstr.IntOrString minAvailable = 1;
    
      // Label query over pods whose evictions are managed by the disruption
      // budget.
      // A null selector will match no pods, while an empty ({}) selector will select
      // all pods within the namespace.
      // +patchStrategy=replace
      // +optional
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 8K bytes
    - Viewed (0)
  6. cmd/site-replication-utils.go

    		}
    	}
    	if cmpCount == totBuckets {
    		return ResyncCompleted
    	}
    	if cmpCount+failCount == totBuckets {
    		return ResyncFailed
    	}
    	return ResyncStarted
    }
    
    // update resync metrics per object
    func (sm *siteResyncMetrics) updateMetric(r TargetReplicationResyncStatus, resyncID string) {
    	if !globalSiteReplicationSys.isEnabled() {
    		return
    	}
    	sm.Lock()
    	defer sm.Unlock()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (1)
  7. cmd/erasure-metadata-utils.go

    			continue
    		}
    		errorCounts[err]++
    	}
    
    	max := 0
    	for err, count := range errorCounts {
    		switch {
    		case max < count:
    			max = count
    			maxErr = err
    
    		// Prefer `nil` over other error values with the same
    		// number of occurrences.
    		case max == count && err == nil:
    			maxErr = err
    		}
    	}
    	return max, maxErr
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  8. internal/event/target/amqp.go

    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-amqp-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of AMQP `%s`: %w", id, err)
    		}
    	}
    
    	target := &AMQPTarget{
    		id:         event.TargetID{ID: id, Name: "amqp"},
    		args:       args,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  9. misc/ios/go_ios_exec.go

    	}
    
    	return nil
    }
    
    func copyLocalDir(dst, src string) error {
    	if err := os.Mkdir(dst, 0755); err != nil {
    		return err
    	}
    
    	d, err := os.Open(src)
    	if err != nil {
    		return err
    	}
    	defer d.Close()
    	fi, err := d.Readdir(-1)
    	if err != nil {
    		return err
    	}
    
    	for _, f := range fi {
    		if f.IsDir() {
    			if f.Name() == "testdata" {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Jun 18 16:32:49 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  10. .github/CODEOWNERS

    ## GitHub docs: https://docs.github.com/en/repositories/managing-your-repositorys-settings-and-features/customizing-your-repository/about-code-owners
    ##
    ## CODEOWNERS style rules:
    ## 1. Prefer team ownership over individual user ownership.
    ## 2. GBT-related team should be listed first.
    ## 3. Try to keep paths alphabetically sorted within visual groups.
    ## 4. List individual owners last.
    ##
    
    # bt-unassigned-maintainers must be the first owner
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Thu Oct 24 14:46:27 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top