- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for Stuart (0.24 sec)
-
cni/pkg/nodeagent/server.go
s.Ready() s.dataplane.Start(s.ctx) s.handlers.Start() } func (s *Server) Stop() { log.Info("CNI ambient server terminating, cleaning up node net rules") s.cniServerStopFunc() s.dataplane.Stop() } type meshDataplane struct { kubeClient kubernetes.Interface netServer MeshDataplane } func (s *meshDataplane) Start(ctx context.Context) { s.netServer.Start(ctx) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
podIP := netip.MustParseAddr("99.9.9.1") podIPs := []netip.Addr{podIP} server := &fakeServer{} server.On("AddPodToMesh", fakeCtx, pod, podIPs, "", ).Return(nil) server.Start(fakeCtx) m := meshDataplane{ kubeClient: fakeClientSet, netServer: server, } err := m.AddPodToMesh(fakeCtx, pod, podIPs, "") assert.NoError(t, err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
manifests/addons/values-kiali.yaml
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 09 21:40:53 GMT 2024 - 385 bytes - Viewed (0) -
manifests/charts/gateway/templates/deployment.yaml
{{- toYaml .Values.securityContext | nindent 8 }} {{- else }} # Safe since 1.22: https://github.com/kubernetes/kubernetes/pull/103326 sysctls: - name: net.ipv4.ip_unprivileged_port_start value: "0" {{- end }} {{- with .Values.volumes }} volumes: {{ toYaml . | nindent 8 }} {{- end }} containers: - name: istio-proxy
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 3.5K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
netNs, err := getNs(netns) if err != nil { err = fmt.Errorf("failed to open netns %q: %s", netns, err) return err } defer netNs.Close() return netNs.Do(func(_ ns.NetNS) error { log.Infof("============= Start iptables configuration for %v =============", podName) defer log.Infof("============= End iptables configuration for %v =============", podName) return cmd.ProgramIptables(cfg) })
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 17:36:41 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/repair/repair.go
func StartRepair(ctx context.Context, cfg config.RepairConfig) { if !cfg.Enabled { repairLog.Info("CNI repair is disable.") return } repairLog.Info("Start CNI race condition repair.") client, err := clientSetup() if err != nil { repairLog.Fatalf("CNI repair could not construct clientSet: %s", err) } rc, err := NewRepairController(client, cfg) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
import ( "io" "os" "path/filepath" "strings" "testing" "istio.io/istio/cni/pkg/constants" "istio.io/istio/pkg/log" "istio.io/istio/pkg/test/util/assert" ) func TestUDSLog(t *testing.T) { // Start UDS log server udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
manifests/charts/gateway/values.yaml
# Define the security context for the pod. # If unset, this will be automatically set to the minimum privileges required to bind to port 80 and 443. # On Kubernetes 1.22+, this only requires the `net.ipv4.ip_unprivileged_port_start` sysctl. securityContext: ~ containerSecurityContext: ~ service: # Type of service. Set to "None" to disable the service entirely type: LoadBalancer ports: - name: status-port
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 11 16:55:28 GMT 2024 - 4.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
"The total number of node agent reconcile events.", ) ) type K8sHandlers interface { GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) GetAmbientPods() []*corev1.Pod Start() } type InformerHandlers struct { ctx context.Context dataplane MeshDataplane systemNamespace string queue controllers.Queue pods kclient.Client[*corev1.Pod]
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/nodeagent/netns_linux.go
// not as optimal but at least always safe to do. runtime.UnlockOSThread() } }() return toRun() } var wg sync.WaitGroup wg.Add(1) // Start the callback in a new green thread so that if we later fail // to switch the namespace back to the original one, we can safely // leave the thread locked to die without a risk of the current thread
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 31 10:05:36 GMT 2024 - 2.7K bytes - Viewed (0)