- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for Listeners (0.11 sec)
-
internal/grid/debug.go
} } addr := l.Addr() hosts = append(hosts, "http://"+addr.String()) listeners = append(listeners, l) } return } func startHTTPServer(listener net.Listener, handler http.Handler) (server *httptest.Server) { server = httptest.NewUnstartedServer(handler) server.Config.Addr = listener.Addr().String() server.Listener = listener server.Start() return server
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 4.2K bytes - Viewed (0) -
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/service/scopes/EventScope.java
import java.lang.annotation.Target; /** * Attached to a listener interface to indicate which scope its events are generated in. * * <p>Events generated in a particular scope are visible to listeners in the same scope and ancestor scopes. * Events are not visible to listeners in descendent scopes. * * <p>This annotation is used primarily to indicate to developers the scopes where this listener are available. There is also
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 1.5K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/test/groovy/org/gradle/api/tasks/testing/testng/TestNGOptionsTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 22:42:49 UTC 2024 - 4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/scope/internal/MojoExecutionScope.java
IdentityHashMap<WeakMojoExecutionListener, Object> listeners = new IdentityHashMap<>(); for (Object provided : getScopeState().provided.values()) { if (provided instanceof WeakMojoExecutionListener) { listeners.put((WeakMojoExecutionListener) provided, null); } } return listeners.keySet(); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listenertest/match.go
"istio.io/istio/pkg/util/sets" ) type ListenersTest struct { // Match listener by name Name string // Match listener by port Port uint32 // Listener assertions Listener ListenerTest } // ListenerTest provides a struct for defining expectations for a listener type ListenerTest struct { // Assert the listener contains these filter chains (in order, if TotalMatch) FilterChains []FilterChainTest
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 6.4K bytes - Viewed (0) -
analysis/analysis-api-standalone/analysis-api-standalone-base/src/org/jetbrains/kotlin/analysis/api/standalone/base/project/structure/PluginStructureProvider.kt
@Suppress("UnstableApiUsage") @KaAnalysisNonPublicApi object PluginStructureProvider { /** * This fake plugin is required to provide it as a required parameter. * Effectively, it is only used to group project listeners. */ private val fakePluginDescriptor = DefaultPluginDescriptor("analysis-api-standalone-base-loader") private object ReadContext : ReadModuleContext { override val interner get() = NoOpXmlInterner
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 04 22:09:27 UTC 2024 - 7.3K bytes - Viewed (0) -
platforms/software/testing-base/build.gradle.kts
and setup basic testing-related features like a testSuites container and the testing extension. It provides most of the testing-related abstract base types and interfaces for things like Test tasks, listeners and filters. This project is a implementation dependency of many other testing-related subprojects in the Gradle build. """ errorprone { disabledChecks.addAll( "EmptyBlockTag", // 3 occurrences
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 2.9K bytes - Viewed (0) -
manifests/addons/dashboards/lib/panels.libsonnet
self.bars(title, targets, desc='') + timeSeries.standardOptions.withOverrides([ overrideSeries('cds', 'Clusters'), overrideSeries('eds', 'Endpoints'), overrideSeries('lds', 'Listeners'), overrideSeries('rds', 'Routes'), overrideSeries('istio.io/debug', 'Debug'), overrideSeries('wads', 'Authorization'), overrideSeries('wds', 'Workloads'), ]), },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
} if !find { return false } } if wf.Node != "" && !strings.EqualFold(workload.Node, wf.Node) { return false } return true } // PrintWorkloadSummary prints a summary of the relevant listeners in the config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintWorkloadSummary(filter WorkloadFilter) error { w := c.tabwriter() zDump := c.ztunnelDump
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/ctrlz/ctrlz.go
} // Canonicalize the address and resolve a dynamic port if necessary listener, err := net.Listen("tcp", fmt.Sprintf("%s:%d", addr, o.Port)) if err != nil { log.Errorf("Unable to start ControlZ: %v", err) return nil, err } s := &Server{ listener: listener, httpServer: http.Server{ Addr: listener.Addr().(*net.TCPAddr).String(), ReadTimeout: 10 * time.Second,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 21:22:53 UTC 2024 - 5.9K bytes - Viewed (0)