- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for Dost (0.17 sec)
-
cni/pkg/nodeagent/net.go
go s.ztunnelServer.Run(ctx) } func (s *NetServer) Stop() { log.Debug("removing host iptables rules") s.iptablesConfigurator.DeleteHostRules() log.Debug("destroying host ipset") s.hostsideProbeIPSet.Flush() if err := s.hostsideProbeIPSet.DestroySet(); err != nil { log.Warnf("could not destroy host ipset on shutdown") } log.Debug("stopping ztunnel server") s.ztunnelServer.Close() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/metrics-resource.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/sftp-server.go
tokens := strings.SplitN(arg, "=", 2) if len(tokens) != 2 { logger.Fatal(fmt.Errorf("invalid arguments passed to --sftp=%s", arg), "unable to start SFTP server") } switch tokens[0] { case "address": host, portStr, err := net.SplitHostPort(tokens[1]) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed to --sftp=%s (%v)", arg, err), "unable to start SFTP server") } port, err = strconv.Atoi(portStr)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
if err != nil { return err } found := false list := *el for i := range list { if list[i].nodeName == u.Host { list[i].disks = append(list[i].disks, u.String()) found = true break } } if !found { list = append(list, node{nodeName: u.Host, disks: []string{u.String()}}) } *el = list return nil } type poolArgs struct { args []string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/storage-rest-client.go
// Returns a storage rest client. func newStorageRESTClient(endpoint Endpoint, healthCheck bool, gm *grid.Manager) (*storageRESTClient, error) { serverURL := &url.URL{ Scheme: endpoint.Scheme, Host: endpoint.Host, Path: path.Join(storageRESTPrefix, endpoint.Path, storageRESTVersion), } restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken()) if healthCheck {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
internal/rest/client.go
} // Given a string of the form "host", "host:port", or "[ipv6::address]:port", // return true if the string includes a port. func hasPort(s string) bool { return strings.LastIndex(s, ":") > strings.LastIndex(s, "]") } // removeEmptyPort strips the empty port in ":port" to "" // as mandated by RFC 3986 Section 6.2.3. func removeEmptyPort(host string) string { if hasPort(host) { return strings.TrimSuffix(host, ":") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to // redetect for each pod anyway. // // Extreme corner case: // If for some reason your host had both binaries, and you were injecting out-of-band
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/event/target/postgresql.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
}, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "", ).Return(nil)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/format-erasure.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0)