- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for clientTop (0.13 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactory.java
for (final CrawlerClient client : clientMap.values()) { client.setInitParameterMap(params); } } } public void setClientMap(final Map<Pattern, CrawlerClient> clientMap) { this.clientMap = clientMap; } @Override public void close() { clientMap.values().stream().distinct().forEach(client -> { try {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 4.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/bsentity/BsSearchLog.java
this.accessType = value; } public String getClientIp() { checkSpecifiedProperty("clientIp"); return convertEmptyToNull(clientIp); } public void setClientIp(String value) { registerModifiedProperty("clientIp"); this.clientIp = value; } public Long getHitCount() { checkSpecifiedProperty("hitCount"); return hitCount;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/cbean/cq/bs/BsSearchLogCQ.java
if (opLambda != null) { opLambda.callback(builder); } } public void setClientIp_SpanTerm(String clientIp) { setClientIp_SpanTerm("clientIp", null); } public void setClientIp_SpanTerm(String clientIp, ConditionOptionCall<SpanTermQueryBuilder> opLambda) { SpanTermQueryBuilder builder = regSpanTermQ("clientIp", clientIp);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 145.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientCreator.java
protected CrawlerContainer crawlerContainer; protected Map<String, String> clientMap = new LinkedHashMap<>(); protected List<CrawlerClientFactory> clientFactoryList = new LinkedList<>(); protected int maxClientFactorySize = 10000; public synchronized void register(final CrawlerClientFactory crawlerClientFactory) { clientMap.entrySet().stream().forEach(e -> load(crawlerClientFactory, e.getKey(), e.getValue()));
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.9K bytes - Viewed (0) -
security/pkg/k8s/configutil_test.go
} kc := kube.NewFakeClient(objs...) fake := kc.Kube().(*fake.Clientset) configmaps := kclient.New[*v1.ConfigMap](kc) if tc.clientMod != nil { tc.clientMod(fake) } kc.RunAndWait(test.NewStop(t)) fake.ClearActions() err := InsertDataToConfigMap(configmaps, tc.meta, tc.caBundle) if err != nil && err.Error() != tc.expectedErr {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 13K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryWrapper.java
@Override public CrawlerClient getClient(final String url) { return factory.getClient(url); } @Override public void setClientMap(final Map<Pattern, CrawlerClient> clientMap) { factory.setClientMap(clientMap); } @Override public boolean equals(final Object obj) { return factory.equals(obj); } @Override public String toString() {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.4K bytes - Viewed (0) -
src/net/splice_linux_test.go
size := tc.totalSize if tc.limitReadSize > 0 { if tc.limitReadSize < size { size = tc.limitReadSize } } clientUp, serverUp := spawnTestSocketPair(t, tc.upNet) defer serverUp.Close() cleanup, err := startTestSocketPeer(t, clientUp, "w", tc.chunkSize, size) if err != nil { t.Fatal(err) } defer cleanup(t) clientDown, serverDown := spawnTestSocketPair(t, tc.downNet)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 14.5K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Service.json
], "externalName": "externalNameValue", "externalTrafficPolicy": "externalTrafficPolicyValue", "healthCheckNodePort": 12, "publishNotReadyAddresses": true, "sessionAffinityConfig": { "clientIP": { "timeoutSeconds": 1 } }, "ipFamilies": [ "ipFamiliesValue" ], "ipFamilyPolicy": "ipFamilyPolicyValue", "allocateLoadBalancerNodePorts": true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 2.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/bsentity/dbmeta/SearchLogDbm.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.3K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.Service.yaml
protocol: protocolValue targetPort: targetPortValue publishNotReadyAddresses: true selector: selectorKey: selectorValue sessionAffinity: sessionAffinityValue sessionAffinityConfig: clientIP: timeoutSeconds: 1 trafficDistribution: trafficDistributionValue type: typeValue status: conditions: - lastTransitionTime: "2004-01-01T01:01:01Z" message: messageValue observedGeneration: 3
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 06:46:00 UTC 2024 - 2.1K bytes - Viewed (0)