- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 760 for Initialize (1.35 sec)
-
pkg/kubelet/certificate/kubelet.go
certificateStore, err := certificate.NewFileStore( "kubelet-server", certDirectory, certDirectory, kubeCfg.TLSCertFile, kubeCfg.TLSPrivateKeyFile) if err != nil { return nil, fmt.Errorf("failed to initialize server certificate store: %v", err) } var certificateRenewFailure = compbasemetrics.NewCounter( &compbasemetrics.CounterOpts{ Subsystem: metrics.KubeletSubsystem,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
}, } // Iterating over the test cases, calling the function under test and asserting the response. for i, testCase := range testCases { // obtain the put bucket policy request body. // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. recV4 := httptest.NewRecorder() // construct HTTP request for PUT bucket policy endpoint.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
cmd/auth-handler_test.go
func mustNewRequest(method string, urlStr string, contentLength int64, body io.ReadSeeker, t *testing.T) *http.Request { req, err := newTestRequest(method, urlStr, contentLength, body) if err != nil { t.Fatalf("Unable to initialize new http request %s", err) } return req } // This is similar to mustNewRequest but additionally the request // is signed with AWS Signature V4, fails if not able to do so.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultExclusiveCacheAccessCoordinatorTest.groovy
1 * initializationAction.initialize(exclusiveLock) 1 * exclusiveLock.close() then: 1 * lockManager.lock(lockFile, mode(Shared), "<display-name>") >> sharedLock 1 * initializationAction.requiresInitialization(sharedLock) >> false _ * sharedLock.state 0 * _._ } def "initializes cache on open when lock mode is exclusive"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 24K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
// if object upload fails stop the test. if err != nil { t.Fatalf("Error uploading object: <ERROR> %v", err) } // initialize httptest Recorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request for DELETE bucket.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 39.8K bytes - Viewed (0) -
tensorflow/cc/framework/gradients.cc
TF_RETURN_IF_ERROR(BackpropAlongEdge(dx[i], {e->src(), e->src_output()})); } } return absl::OkStatus(); } Status SymbolicGradientBuilder::AddGradients() { // Initialize backprops. TF_RETURN_IF_ERROR(Initialize()); // Backward propagation. std::vector<Output> dy; while (!ready_.empty()) { // n has collected all gradients. Node* n = ready_.front(); ready_.pop_front();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 05:57:22 UTC 2024 - 22K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
return types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages), FailedMessages: atomic.LoadInt64(&h.failedMessages), QueueLength: queueLength, } } // Init initialize kafka target func (h *Target) Init(ctx context.Context) error { if !h.kconfig.Enabled { return nil } if err := h.validate(); err != nil { return err } if h.kconfig.QueueDir != "" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/registry/rbac/rest/storage_rbac.go
// starts, the roles don't initialize, and nothing works. err := wait.Poll(1*time.Second, 30*time.Second, func() (done bool, err error) { client, err := clientset.NewForConfig(hookContext.LoopbackClientConfig) if err != nil { utilruntime.HandleError(fmt.Errorf("unable to initialize client set: %v", err)) return false, nil } return ensureRBACPolicy(p, client)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java
CliRequest request = new CliRequest(new String[0], null); // read .mvn/maven.config cli.initialize(request); cli.cli(request); assertEquals("multithreaded", request.commandLine.getOptionValue(CLIManager.BUILDER)); assertEquals("8", request.commandLine.getOptionValue(CLIManager.THREADS));
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 28.3K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/TestUtil.groovy
} private TestUtil(File rootDir, File userHomeDir) { NativeServicesTestFixture.initialize() this.rootDir = rootDir this.userHomeDir = userHomeDir } static InstantiatorFactory instantiatorFactory() { if (instantiatorFactory == null) { NativeServicesTestFixture.initialize()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 13.2K bytes - Viewed (0)