Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,068 for statRps (0.11 sec)

  1. cmd/site-replication-utils.go

    		switch bktStatus {
    		case ResyncCompleted:
    			st.BucketStatuses[o.bucket] = ResyncCompleted
    			st.Status = siteResyncStatus(st.Status, st.BucketStatuses)
    			st.LastUpdate = UTCNow()
    			sm.resyncStatus[o.resyncID] = st
    		case ResyncFailed:
    			st.BucketStatuses[o.bucket] = ResyncFailed
    			st.Status = siteResyncStatus(st.Status, st.BucketStatuses)
    			st.LastUpdate = UTCNow()
    			sm.resyncStatus[o.resyncID] = st
    		}
    	}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	MaxLWorkers int
    }
    
    func initBackgroundReplication(ctx context.Context, objectAPI ObjectLayer) {
    	stats := NewReplicationStats(ctx, objectAPI)
    	globalReplicationPool.Set(NewReplicationPool(ctx, objectAPI, globalAPIConfig.getReplicationOpts(), stats))
    	globalReplicationStats.Store(stats)
    	go stats.trackEWMA()
    }
    
    type proxyResult struct {
    	Proxy bool
    	Err   error
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. istioctl/pkg/kubeinject/testdata/deployment/hello.yaml.injected

          app: hello
          tier: backend
          track: stable
      strategy: {}
      template:
        metadata:
          annotations:
            prometheus.io/path: /stats/prometheus
            prometheus.io/port: "15020"
            prometheus.io/scrape: "true"
            sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":null,"imagePullSecrets":null,"revision":"default"}'
          creationTimestamp: null
          labels:
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1K bytes
    - Viewed (0)
  4. istioctl/pkg/kubeinject/testdata/deployment/hello.yaml.iop.injected

          app: hello
          tier: backend
          track: stable
      strategy: {}
      template:
        metadata:
          annotations:
            prometheus.io/path: /stats/prometheus
            prometheus.io/port: "15020"
            prometheus.io/scrape: "true"
            sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":null,"imagePullSecrets":null,"revision":"default"}'
          creationTimestamp: null
          labels:
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  5. internal/disk/stat_solaris.go

    	"fmt"
    
    	"golang.org/x/sys/unix"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := unix.Statvfs_t{}
    	if err = unix.Statvfs(path, &s); err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail)
    	info = Info{
    		Total:  uint64(s.Frsize) * (uint64(s.Blocks) - reservedBlocks),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. cmd/metacache.go

    	}
    
    	if m.status == scanStateStarted && update.status != scanStateStarted {
    		m.status = update.status
    	}
    
    	if m.status == scanStateStarted && time.Since(m.lastHandout) > metacacheMaxClientWait {
    		// Drop if client hasn't been seen for 3 minutes.
    		m.status = scanStateError
    		m.error = "client not seen"
    	}
    
    	if m.error == "" && update.error != "" {
    		m.error = update.error
    		m.status = scanStateError
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/testdata/routes/istio-gateway-http-route-prefix/configdump.json

               "cluster": "outbound|8000||httpbin.default.svc.cluster.local",
               "timeout": "0s",
               "retry_policy": {
                "retry_on": "connect-failure,refused-stream,unavailable,cancelled,retriable-status-codes",
                "num_retries": 2,
                "retry_host_predicate": [
                 {
                  "name": "envoy.retry_host_predicates.previous_hosts",
                  "typed_config": {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 08 20:44:50 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. internal/logger/target/kafka/kafka.go

    	msg := sarama.ProducerMessage{
    		Topic: h.kconfig.Topic,
    		Value: sarama.ByteEncoder(logJSON),
    	}
    	_, _, err = h.producer.SendMessage(&msg)
    	if err != nil {
    		atomic.StoreInt32(&h.status, statusOffline)
    	} else {
    		atomic.StoreInt32(&h.status, statusOnline)
    	}
    	return err
    }
    
    // Init initialize kafka target
    func (h *Target) init() error {
    	if os.Getenv("_MINIO_KAFKA_DEBUG") != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. internal/disk/stat_netbsd.go

    	"fmt"
    
    	"golang.org/x/sys/unix"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := unix.Statvfs_t{}
    	if err = unix.Statvfs(path, &s); err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail)
    	info = Info{
    		Total:  uint64(s.Frsize) * (uint64(s.Blocks) - reservedBlocks),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  10. docs/bucket/replication/DESIGN.md

    replication also cycles through `PENDING` to `COMPLETED` or `FAILED` states for the `X-Amz-Replication-Status` on the source when a delete marker is set (i.e. performing `mc rm` on an object without specifying a version).After replication syncs the delete marker on the target, the DeleteMarker on the target shows `X-Amz-Replication-Status` of `REPLICA`. The status of DeleteMarker replication is returned by `X-Minio-Replication-DeleteMarker-Status` header on `HEAD/GET` calls for the delete marker version in...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
Back to top