- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for Start (0.15 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) -
cni/pkg/nodeagent/informers_test.go
"", ).Return(nil) server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } fs.Start(ctx) handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
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) -
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) -
common-protos/k8s.io/api/apps/v1beta2/generated.proto
message StatefulSetOrdinals { // start is the number representing the first replica's index. It may be used // to number replicas from an alternate index (eg: 1-indexed) over the default // 0-indexed names, or to orchestrate progressive movement of replicas from // one StatefulSet to another. // If set, replica indices will be in the range: // [.spec.ordinals.start, .spec.ordinals.start + .spec.replicas).
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 36.4K bytes - Viewed (0) -
common/scripts/tracing.sh
{ [[ $- = *x* ]] && was_execution_trace=1 || was_execution_trace=0; } 2>/dev/null { set +x; } 2>/dev/null # Throughout, "local" usage is critical to avoid nested calls overwriting things local start start="$(date -u +%s.%N)" # First, get a trace and span ID. We need to get one now so we can propagate it to the child # Get trace ID from TRACEPARENT, if present local tid tid="$(<<<"${TRACEPARENT:-}" cut -d- -f2)"
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jul 28 15:25:47 GMT 2023 - 4.1K 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) -
common/scripts/kind_provisioner.sh
net_bits = 128 if type(net) == IPv6Network else 32; net_len = pow(2, net_bits - net.prefixlen) start, end = int(net_len / 4 * 3), net_len if net_len > 2000: start, end = 1000, 2000 [print(str(ip) + "/" + str(ip.max_prefixlen)) for ip in islice(ip_network('$CIDR').hosts(), start, end)] EOF } function ips_to_cidrs() { IP_RANGE_START="$1" IP_RANGE_END="$2" python3 - <<EOF
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 08 19:12:55 GMT 2024 - 17.3K bytes - Viewed (1) -
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)