- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 68 for loggers (0.15 sec)
-
pkg/proxy/ipvs/proxier.go
logger.Error(err, "Failed to configure IPVS timeouts") } } if initOnly { logger.Info("System initialized and --init-only specified") return nil, nil } // Generate the masquerade mark to use for SNAT rules. masqueradeValue := 1 << uint(masqueradeBit) masqueradeMark := fmt.Sprintf("%#08x", masqueradeValue)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
func (jm *Controller) enqueueSyncJobWithDelay(logger klog.Logger, obj interface{}, delay time.Duration) { if delay < syncJobBatchPeriod { delay = syncJobBatchPeriod } jm.enqueueSyncJobInternal(logger, obj, delay) } func (jm *Controller) enqueueSyncJobInternal(logger klog.Logger, obj interface{}, delay time.Duration) { key, err := controller.KeyFunc(obj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
}, OptionalThing.empty()); response.flushBuffer(); if (logger.isDebugEnabled()) { logger.debug("Loaded {} docs", count); } } catch (final InvalidQueryException | ResultOffsetExceededException e) { if (logger.isDebugEnabled()) { logger.debug("Failed to process a scroll request.", e); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 02:17:23 UTC 2024 - 50.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
if (indexResponse.isAcknowledged()) { logger.info("Created {} index.", indexName); return true; } if (logger.isDebugEnabled()) { logger.debug("Failed to create {} index.", indexName); } } catch (final Exception e) { logger.warn("{} is not found.", indexConfigFile, e); } return false;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 84.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
if (!allowEmptyGroupAndRole(ldapUser)) { if (logger.isDebugEnabled()) { logger.debug("Login failed. No permissions. {}", context); } return OptionalEntity.empty(); } if (logger.isDebugEnabled()) { logger.debug("Logged in. {}", context); } return OptionalEntity.of(ldapUser);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 65.9K bytes - Viewed (0) -
integration-tests/gradle/gradle/wrapper/gradle-wrapper.jar
private static final int BUFFER_SIZE = 10240; private static final int PROGRESS_CHUNK = 1048576; private final Logger logger; private final String appName; private final String appVersion; private final DownloadProgressList progressListener; private final java.util.Map systemProperties; private final int networkTimeout; public void Download(Logger, String, String); public void Download(Logger, String, String, int); private static java.util.Map convertSystemPropert(java.util.Properties); public void...
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Oct 31 19:07:19 UTC 2023 - 62.2K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
networkInterfacer: proxyutil.RealNetwork{}, conntrackTCPLiberal: conntrackTCPLiberal, logger: logger, nfAcctCounters: map[string]bool{ metrics.IPTablesCTStateInvalidDroppedNFAcctCounter: false, metrics.LocalhostNodePortAcceptedNFAcctCounter: false, }, } burstSyncs := 2
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
initOnly bool, ) (*Proxier, error) { logger := klog.LoggerWithValues(klog.FromContext(ctx), "ipFamily", ipFamily) if initOnly { logger.Info("System initialized and --init-only specified") return nil, nil } // Generate the masquerade mark to use for SNAT rules. masqueradeValue := 1 << uint(masqueradeBit) masqueradeMark := fmt.Sprintf("%#08x", masqueradeValue)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
} for _, pod := range c.pods { informers.Core().V1().Pods().Informer().GetIndexer().Add(pod) manager.addPod(logger, pod) } actualPods, err := manager.getIndirectlyRelatedPods(logger, c.rs) if err != nil { t.Errorf("Unexpected error from getIndirectlyRelatedPods: %v", err) } var actualPodNames []string for _, pod := range actualPods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
ObjectMeta: metav1.ObjectMeta{Name: serviceName, Namespace: ns}, Spec: v1.ServiceSpec{ Ports: []v1.ServicePort{{TargetPort: intstr.FromInt32(80)}}, }, }) logger, _ := ktesting.NewTestContext(t) err := esController.syncService(logger, fmt.Sprintf("%s/%s", ns, serviceName)) assert.NoError(t, err) assert.Len(t, client.Actions(), 0) } func TestServiceExternalNameTypeSync(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0)