- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 125 for Kistner (0.21 sec)
-
cni/pkg/pluginlistener/listener.go
} var err error listener, err := net.Listen("unix", path) if err != nil { return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err) } // Update file permission so that cni plugin has permission to access it. if _, err := os.Stat(path); err != nil { return nil, fmt.Errorf("cni listener file %q doesn't exist", path) }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K bytes - Viewed (0) -
istioctl/pkg/authz/listener.go
filterChains []*filterChain } func getFilterConfig(filter *listener.Filter, out proto.Message) error { switch c := filter.ConfigType.(type) { case *listener.Filter_TypedConfig: if err := c.TypedConfig.UnmarshalTo(out); err != nil { return err } } return nil } func getHTTPConnectionManager(filter *listener.Filter) *hcm.HttpConnectionManager { cm := &hcm.HttpConnectionManager{}
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 6K bytes - Viewed (0) -
internal/http/listener.go
} case <-listener.ctx.Done(): } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.tcpListeners { listener.tcpListeners[i].Close() } return nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 5.8K bytes - Viewed (0) -
istioctl/pkg/util/configdump/listener.go
l := &listener.Listener{} err = dal[i].ActiveState.Listener.UnmarshalTo(l) if err != nil { return false } name := l.Name err = dal[j].ActiveState.Listener.UnmarshalTo(l) if err != nil { return false } return name < l.Name }) if stripVersions { for i := range dal { dal[i].ActiveState.VersionInfo = "" dal[i].ActiveState.LastUpdated = nil
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.5K bytes - Viewed (1) -
api/maven-api-core/src/main/java/org/apache/maven/api/Listener.java
import org.apache.maven.api.annotations.Experimental; import org.apache.maven.api.annotations.Nonnull; /** * A listener for session events. * TODO: open this to other events like similar to {@code org.apache.maven.eventspy.EventSpy} * * @since 4.0.0 */ @Experimental @FunctionalInterface @Consumer public interface Listener { void onEvent(@Nonnull Event event);
Java - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Thu Mar 23 05:29:39 GMT 2023 - 1.2K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener_test.go
Type: "TCP", }, inListener: &listener.Listener{ FilterChains: []*listener.FilterChain{{ Filters: []*listener.Filter{{ Name: wellknown.TCPProxy, }}, }}, }, expect: true, }, { desc: "unknown-type", inFilter: &ListenerFilter{ Type: "UNKNOWN", }, inListener: &listener.Listener{ FilterChains: []*listener.FilterChain{{
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 4.1K bytes - Viewed (0) -
istioctl/pkg/writer/compare/listener.go
Kuat <******@****.***> 1712262548 -0700
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
John Howard <******@****.***> 1707429512 -0800
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* after executing them. * * @param listener the listener to run when the computation is complete * @param executor the executor to run the listener in * @throws RejectedExecutionException if we tried to execute the listener immediately but the * executor rejected it. */ void addListener(Runnable listener, Executor executor);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
protected SettableFuture<Integer> inputFuture; protected ListenableFuture<T> resultFuture; protected MockFutureListener listener; @Override protected void setUp() throws Exception { super.setUp(); inputFuture = SettableFuture.create(); resultFuture = buildChainingFuture(inputFuture); listener = new MockFutureListener(resultFuture); } public void testFutureGetBeforeCallback() throws Exception {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.4K bytes - Viewed (0)