Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewDefaultManager (0.17 sec)

  1. staging/src/k8s.io/apiserver/pkg/storageversion/manager.go

    	managedStatus map[schema.GroupResource]*updateStatus
    }
    
    type updateStatus struct {
    	done    bool
    	lastErr error
    }
    
    // NewDefaultManager creates a new defaultManager.
    func NewDefaultManager() Manager {
    	s := &defaultManager{}
    	s.completed.Store(false)
    	s.managedResourceInfos = make(map[*ResourceInfo]struct{})
    	s.managedStatus = make(map[schema.GroupResource]*updateStatus)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:47:19 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go

    		TLS: transport.TLSConfig{
    			Insecure: false,
    		}}
    	proxyRoundTripper, err := transport.New(clientConfig)
    	if err != nil {
    		return nil, err
    	}
    	ppI := NewPeerProxyHandler(informerFactory, storageversion.NewDefaultManager(), proxyRoundTripper, id, reconciler, s)
    	if testDataExists(svdata.gvr) {
    		ppI.addToStorageVersionMap(svdata.gvr, svdata.serverId)
    	}
    	return ppI, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/config.go

    		StorageObjectCountTracker:           flowcontrolrequest.NewStorageObjectCountTracker(),
    		ShutdownWatchTerminationGracePeriod: time.Duration(0),
    
    		APIServerID:           id,
    		StorageVersionManager: storageversion.NewDefaultManager(),
    		TracerProvider:        tracing.NewNoopTracerProvider(),
    	}
    }
    
    // NewRecommendedConfig returns a RecommendedConfig struct with the default values
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
Back to top