- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for tale (0.15 sec)
-
cni/pkg/nodeagent/net.go
func (s *NetServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.Debugf("Pod is now opt out... cleaning up.") openNetns := s.currentPodSnapshot.Take(string(pod.UID)) if openNetns == nil { log.Warn("failed to find pod netns") return fmt.Errorf("failed to find pod netns") } // pod is removed from the mesh, but is still running. remove iptables rules
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) -
istioctl/pkg/checkinject/checkinject.go
return nil } w := table.NewStyleWriter(writer) w.SetAddRowFunc(func(obj interface{}) table.Row { wa := obj.(webhookAnalysis) row := table.Row{ Cells: make([]table.Cell, 0), } row.Cells = append(row.Cells, table.NewCell(wa.Name), table.NewCell(wa.Revision)) if wa.Injected { row.Cells = append(row.Cells, table.NewCell("✔", color.FgGreen)) } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
istioctl/pkg/writer/compare/sds/writer.go
secretDiffColumns = []string{"RESOURCE NAME", "TYPE", "VALID CERT", "NODE AGENT", "PROXY", "SERIAL NUMBER", "NOT AFTER", "NOT BEFORE"} ) // printSecretItemsTabular prints the secret in table format func (w *sdsWriter) printSecretItemsTabular(secrets []SecretItem) error { if len(secrets) == 0 { fmt.Fprintln(w.w, "No secret items to show.") return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 21 14:17:23 GMT 2023 - 4.1K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// No need to return NetnsCloser here it will be closed automatically on GC. // (it may be used in parallel by other parts of the code, so we want it to be used only when not used) func (p *podNetnsCache) Take(uid string) Netns { // lock current pod map p.mu.Lock() defer p.mu.Unlock() if ns, ok := p.currentPodCache[uid]; ok { delete(p.currentPodCache, uid) // already in cache return ns.Netns }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K 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) -
cni/pkg/nodeagent/ztunnelserver.go
PodDeleted(ctx context.Context, uid string) error PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error Close() error } /* To clean up stale ztunnels we may need to ztunnel to send its (uid, bootid / boot time) to us so that we can remove stale entries when the ztunnel pod is deleted or when the ztunnel pod is restarted in the same pod (remove old entries when the same uid connects again, but with different boot id?)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1) assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1) // make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns runtime.GC() assertNSClosed(t, closed) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status_test.go
clusterID: "cluster2", version: "1.19", cdsSyncStatus: status.ConfigStatus_STALE, ldsSyncStatus: status.ConfigStatus_SYNCED, rdsSyncStatus: status.ConfigStatus_SYNCED, edsSyncStatus: status.ConfigStatus_STALE, ecdsSyncStatus: status.ConfigStatus_STALE, }, }), "istiod3": xdsResponseInput("istiod3", []clientConfigInput{ { proxyID: "proxy3",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 6.5K bytes - Viewed (0) -
istioctl/pkg/writer/table/writer.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package table import ( "fmt" "io" "strings" "unicode/utf8" "github.com/fatih/color" ) type ColoredTableWriter struct { writer io.Writer header Row rows []Row
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Oct 08 04:41:42 GMT 2022 - 2.8K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
if orArgs.revision == "" && !orArgs.purge { return fmt.Errorf("at least one of the --revision or --purge flags must be set") } if len(args) > 0 { return fmt.Errorf("istioctl operator remove does not take arguments") } return nil }, RunE: func(cmd *cobra.Command, args []string) error { client, err := ctx.CLIClient() if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.4K bytes - Viewed (0)