- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 249 for uds (0.12 sec)
-
pkg/log/uds.go
msg, err := json.Marshal(logs) if err != nil { return fmt.Errorf("failed to sync uds log: %v", err) } resp, err := u.client.Post(u.url, "application/json", bytes.NewReader(msg)) if err != nil { return fmt.Errorf("failed to send logs to uds server %v: %v", u.url, err) } if resp.StatusCode != http.StatusOK { return fmt.Errorf("uds server returns non-ok status %v: %v", u.url, resp.Status) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 16 00:20:01 UTC 2024 - 3.4K bytes - Viewed (0) -
cni/pkg/log/uds.go
} // StartUDSLogServer starts up a UDS server which receives log reported from CNI network plugin. func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error { if sockAddress == "" { return nil } log.Info("Start a UDS server for CNI plugin logs") unixListener, err := uds.NewListener(sockAddress) if err != nil { return fmt.Errorf("failed to create UDS listener: %v", err) } go func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.7K bytes - Viewed (0) -
releasenotes/notes/cni-uds-log.yaml
Pengyuan Bian <******@****.***> 1626308505 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 15 00:21:45 UTC 2021 - 264 bytes - Viewed (0) -
cni/pkg/log/uds_test.go
) func TestUDSLog(t *testing.T) { // Start UDS log server udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger(istiolog.DebugLevel) stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.1K bytes - Viewed (0) -
security/pkg/nodeagent/sds/server.go
"time" "go.uber.org/atomic" "google.golang.org/grpc" mesh "istio.io/api/mesh/v1alpha1" "istio.io/istio/pkg/security" "istio.io/istio/pkg/uds" ) const ( maxStreams = 100000 maxRetryTimes = 5 ) // Server is the gPRC server that exposes SDS through UDS. type Server struct { workloadSds *sdsservice grpcWorkloadListener net.Listener grpcWorkloadServer *grpc.Server
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 17:44:41 UTC 2024 - 3.3K bytes - Viewed (0) -
samples/security/spire/istio-spire-config.yaml
readOnly: true - path: spec.template.spec.initContainers value: - name: wait-for-spire-socket image: busybox:1.28 volumeMounts: - name: workload-socket mountPath: /run/secrets/workload-spiffe-uds readOnly: true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 24 22:08:56 UTC 2023 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/config.go
return allErrs } if transport.TCP != nil && transport.UDS != nil { allErrs = append(allErrs, field.Invalid( fldPath.Child("tcp"), transport.TCP, "TCP and UDS cannot both be set")) } else if transport.TCP == nil && transport.UDS == nil { allErrs = append(allErrs, field.Required( fldPath.Child("tcp"), "One of TCP or UDS must be set")) } else if transport.TCP != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/util.go
if err != nil { return nil, 0, err } port = ln.Addr().(*net.TCPAddr).Port return ln, port, nil } func listenOnUDS(uds string) (net.Listener, error) { _ = os.Remove(uds) ln, err := net.Listen("unix", uds) if err != nil { return nil, err } return ln, nil } func listenUDPAddress(ip string, port int) (net.PacketConn, int, error) { parsedIP := net.ParseIP(ip)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/metrics/metrics.go
// ProtocolGRPC means that the proxy protocol is the GRPC protocol. ProtocolGRPC = "grpc" // TransportTCP means that the transport is TCP. TransportTCP = "tcp" // TransportUDS means that the transport is UDS. TransportUDS = "uds" // StageConnect indicates that the dial failed at establishing connection to the proxy server. StageConnect = "connect" // StageProxy indicates that the dial failed at requesting the proxy server to proxy.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 01 23:36:51 UTC 2022 - 4.3K bytes - Viewed (0) -
cluster/gce/manifests/konnectivity-server.yaml
readOnly: true - name: konnectivity-uds mountPath: /etc/srv/kubernetes/konnectivity-server readOnly: false volumes: - name: varlogkonnectivityserver hostPath: path: /var/log/konnectivity-server.log type: FileOrCreate - name: pki hostPath: path: /etc/srv/kubernetes/pki - name: konnectivity-uds hostPath: path: /etc/srv/kubernetes/konnectivity-server
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 10:31:11 UTC 2024 - 1.8K bytes - Viewed (0)