Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 887 for Initialize$ (0.14 sec)

  1. pkg/controlplane/apiserver/admission/initializer.go

    	}
    }
    
    // Initialize checks the initialization interfaces implemented by each plugin
    // and provide the appropriate initialization data
    func (i *PluginInitializer) Initialize(plugin admission.Interface) {
    	if wants, ok := plugin.(initializer.WantsQuotaConfiguration); ok {
    		wants.SetQuotaConfiguration(i.quotaConfiguration)
    	}
    
    	if wants, ok := plugin.(initializer.WantsExcludedAdmissionResources); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go

    		authorizer:        authz,
    		featureGates:      featureGates,
    		stopCh:            stopCh,
    		restMapper:        restMapper,
    	}
    }
    
    // Initialize checks the initialization interfaces implemented by a plugin
    // and provide the appropriate initialization data
    func (i pluginInitializer) Initialize(plugin admission.Interface) {
    	// First tell the plugin about drained notification, so it can pass it to further initializations.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 3K bytes
    - Viewed (0)
  3. platforms/core-runtime/native/src/main/java/org/gradle/internal/nativeintegration/services/NativeServices.java

            }
        }
    
        /**
         * Initializes the native services to use the given user home directory to store native libs and other resources. Does nothing if already initialized.
         *
         * Initializes all the services needed for the Gradle daemon.
         */
        public static void initializeOnDaemon(File userHomeDir, NativeServicesMode mode) {
            INSTANCE.initialize(userHomeDir, EnumSet.allOf(NativeFeatures.class), mode);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 06:47:39 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. pkg/kubeapiserver/admission/initializer.go

    func NewPluginInitializer(cloudConfig []byte) *PluginInitializer {
    	return &PluginInitializer{
    		cloudConfig: cloudConfig,
    	}
    }
    
    // Initialize checks the initialization interfaces implemented by each plugin
    // and provide the appropriate initialization data
    func (i *PluginInitializer) Initialize(plugin admission.Interface) {
    	if wants, ok := plugin.(WantsCloudConfig); ok {
    		wants.SetCloudConfig(i.cloudConfig)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go

    }
    
    func TestRESTMapperAdmissionPlugin(t *testing.T) {
    	initializer := initializer.New(nil, nil, nil, &TestAuthorizer{}, nil, nil, &doNothingRESTMapper{})
    	wantsRESTMapperAdmission := &WantsRESTMapperAdmissionPlugin{}
    	initializer.Initialize(wantsRESTMapperAdmission)
    
    	if wantsRESTMapperAdmission.mapper == nil {
    		t.Errorf("Expected REST mapper to be initialized but found nil")
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  6. cmd/server-main.go

    			globalActiveCred)
    		warnings = append(warnings, color.YellowBold(msg))
    	}
    
    	// Initialize users credentials and policies in background right after config has initialized.
    	go func() {
    		bootstrapTrace("globalIAMSys.Init", func() {
    			globalIAMSys.Init(GlobalContext, newObject, globalEtcdClient, globalRefreshIAMInterval)
    		})
    
    		// Initialize Console UI
    		if globalBrowserEnabled {
    			bootstrapTrace("initConsoleServer", func() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 04 15:12:57 UTC 2024
    - 34.5K bytes
    - Viewed (3)
  7. src/main/java/org/codelibs/core/beans/factory/BeanDescFactory.java

                if (!initialized) {
                    DisposableUtil.add(BeanDescFactory::clear);
                    initialized = true;
                }
            }
        }
    
        /**
         * キャッシュをクリアします。
         */
        public static void clear() {
            beanDescCache.clear();
            initialized = false;
        }
    
    Registered: Wed Jun 12 12:50:12 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. testing/internal-testing/src/main/groovy/org/gradle/testfixtures/internal/NativeServicesTestFixture.java

        static NativeServices nativeServices;
        static boolean initialized;
    
        public static synchronized void initialize() {
            if (!initialized) {
                System.setProperty("org.gradle.native", "true");
                File nativeDir = getNativeServicesDir();
                NativeServices.initializeOnDaemon(nativeDir, NativeServicesMode.fromSystemProperties());
                initialized = true;
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/walk/temp.go

    // allocated temporary variable of type [len]elem. This variable is
    // initialized, and elem must not contain pointers.
    func stackBufAddr(len int64, elem *types.Type) *ir.AddrExpr {
    	if elem.HasPointers() {
    		base.FatalfAt(base.Pos, "%v has pointers", elem)
    	}
    	tmp := typecheck.TempAt(base.Pos, ir.CurFunc, types.NewArray(elem, len))
    	return typecheck.Expr(typecheck.NodAddr(tmp)).(*ir.AddrExpr)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 09 16:41:23 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccessTest.groovy

            then:
            1 * initAction.requiresInitialization(lock) >> false
    
            then:
            1 * onOpenAction.accept(lock)
            0 * _
        }
    
        def "acquires lock then initializes cache and runs handler action on open"() {
            def initialLock = Mock(FileLock)
            def exclusiveLock = Mock(FileLock)
            def sharedLock = Mock(FileLock)
    
            when:
            cacheAccess.open()
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top