- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 597 for serving (0.18 sec)
-
internal/grid/connection.go
type Subroute struct { *Connection trace *tracer route string subID subHandlerID } // String returns a string representation of the connection. func (c *Connection) String() string { return fmt.Sprintf("%s->%s", c.Local, c.Remote) } // StringReverse returns a string representation of the reverse connection. func (c *Connection) StringReverse() string { return fmt.Sprintf("%s->%s", c.Remote, c.Local) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
if (languages != null) { searchLog.setLanguages(StringUtils.join((String[]) languages, ",")); } else { searchLog.setLanguages(StringUtil.EMPTY); } @SuppressWarnings("unchecked") final Map<String, List<String>> fieldLogMap = (Map<String, List<String>>) req.getAttribute(Constants.FIELD_LOGS); if (fieldLogMap != null) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jul 22 02:07:37 UTC 2024 - 21.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlFilterServiceImpl.java
*/ @Override public void addIncludeUrlFilter(final String sessionId, final List<String> urlList) { for (final String url : urlList) { dataHelper.addIncludeUrlPattern(sessionId, url); } } /* * (non-Javadoc) * * @see * org.codelibs.fess.crawler.service.impl.UrlFilterService#addExcludeUrlFilter(java * .lang.String, java.lang.String)
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 3.6K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/FileToRawModelMerger.java
import org.apache.maven.api.model.ReportPlugin; import org.apache.maven.api.model.Reporting; import org.apache.maven.model.v4.MavenMerger; /** * As long as Maven controls the BuildPomXMLFilter, the entities that need merging are known. * All others can simply be copied from source to target to restore the locationTracker * * @since 4.0.0 * @deprecated use {@link org.apache.maven.api.services.ModelBuilder} instead */
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 7.5K bytes - Viewed (0) -
docs/en/docs/tutorial/header-params.md
/// tip Prefer to use the `Annotated` version if possible. /// ```Python hl_lines="10" {!> ../../docs_src/header_params/tutorial002.py!} ``` //// /// warning Before setting `convert_underscores` to `False`, bear in mind that some HTTP proxies and servers disallow the usage of headers with underscores. /// ## Duplicate headers
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 5.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceTest.java
import static com.google.common.util.concurrent.Service.State.FAILED; import static com.google.common.util.concurrent.Service.State.NEW; import static com.google.common.util.concurrent.Service.State.RUNNING; import static com.google.common.util.concurrent.Service.State.STARTING; import static com.google.common.util.concurrent.Service.State.STOPPING; import static com.google.common.util.concurrent.Service.State.TERMINATED; import java.util.Locale;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
public void testEnqueueAndDispatch_multithreaded() throws InterruptedException { Object listener = new Object(); ExecutorService service = Executors.newFixedThreadPool(4); ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); try { queue.addListener(listener, service); final CountDownLatch latch = new CountDownLatch(1); Multiset<Object> counters = ConcurrentHashMultiset.create();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
public void testEnqueueAndDispatch_multithreaded() throws InterruptedException { Object listener = new Object(); ExecutorService service = Executors.newFixedThreadPool(4); ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); try { queue.addListener(listener, service); final CountDownLatch latch = new CountDownLatch(1); Multiset<Object> counters = ConcurrentHashMultiset.create();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
cni/pkg/install/install.go
"istio.io/istio/pkg/util/sets" ) var installLog = scopes.CNIAgent type Installer struct { cfg *config.InstallConfig isReady *atomic.Value kubeconfigFilepath string cniConfigFilepath string } // NewInstaller returns an instance of Installer with the given config func NewInstaller(cfg *config.InstallConfig, isReady *atomic.Value) *Installer { return &Installer{ cfg: cfg,
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 09 21:33:51 UTC 2024 - 13.5K bytes - Viewed (0) -
helm/minio/templates/NOTES.txt
3. mc ls {{ template "minio.fullname" . }}-local {{- end }} {{- if eq .Values.service.type "LoadBalancer" }} MinIO can be accessed via port {{ .Values.service.port }} on an external IP address. Get the service external IP address by: kubectl get svc --namespace {{ .Release.Namespace }} -l app={{ template "minio.fullname" . }}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 15:48:31 UTC 2024 - 2.7K bytes - Viewed (0)