- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for CloseAll (0.13 sec)
-
pkg/proxy/healthcheck/service_health.go
for nsn, svc := range hcs.services { if port, found := newServices[nsn]; !found || port != svc.port { klog.V(2).InfoS("Closing healthcheck", "service", nsn, "port", svc.port) // errors are loged in closeAll() _ = svc.closeAll() delete(hcs.services, nsn) } } // Add any that are needed. for nsn, port := range newServices { if hcs.services[nsn] != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/kubelet/certificate/transport.go
if err := addCertRotation(stopCh, period, clientConfig, clientCertificateManager, exitAfter, d); err != nil { return nil, err } } else { clientConfig.Dial = d.DialContext } return d.CloseAll, nil } func addCertRotation(stopCh <-chan struct{}, period time.Duration, clientConfig *restclient.Config, clientCertificateManager certificate.Manager, exitAfter time.Duration, d *connrotation.Dialer) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 08 13:57:45 UTC 2022 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
// No need to do anything, it's already been removed from the list. return } delete(m.watchers, id) close(w.result) }) } // closeAll disconnects all watchers (presumably in response to a Shutdown call). func (m *Broadcaster) closeAll() { for _, w := range m.watchers { close(w.result) } // Delete everything from the map, since presence/absence in the map is used
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/ProjectBuildList.java
.findFirst() .orElse(null); } @Override public Iterator<ProjectSegment> iterator() { return items.iterator(); } public void closeAll() { for (ProjectSegment item : items) { MavenSession sessionForThisModule = item.getSession(); sessionForThisModule.setCurrentProject(null); } } public int size() {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Jan 10 12:55:54 UTC 2024 - 4.1K bytes - Viewed (0) -
guava/src/com/google/common/collect/Streams.java
return optional.isPresent() ? DoubleStream.of(optional.getAsDouble()) : DoubleStream.empty(); } @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private static void closeAll(BaseStream<?, ?>[] toClose) { // If one of the streams throws an exception, continue closing the others, then throw the // exception later. If more than one stream throws an exception, the later ones are added to the
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 36.5K bytes - Viewed (0) -
cmd/kubelet/app/server.go
} d := connrotation.NewDialer((&net.Dialer{Timeout: 30 * time.Second, KeepAlive: 30 * time.Second}).DialContext) clientConfig.Dial = d.DialContext return d.CloseAll, nil } // buildClientCertificateManager creates a certificate manager that will use certConfig to request a client certificate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/resources/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/report/uikit.min.js
t["href"===e?"source":e]=ht(i,e),t},{})}var Xr={},Gr={functional:!0,args:["message","status"],data:{message:"",status:"",timeout:5e3,group:null,pos:"top-center",clsClose:"uk-notification-close",clsMsg:"uk-notification-message"},install:function(r){r.notification.closeAll=function(i,n){_e(document.body,function(t){var e=r.getComponent(t,"notification");!e||i&&i!==e.group||e.close(n)})}},computed:{marginProp:function(t){return"margin"+(w(t.pos,"top")?"Top":"Bottom")},startProps:function(){var t;return(t={opacity:0...
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 130.5K bytes - Viewed (0)