- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Flush (0.14 sec)
-
istioctl/pkg/writer/compare/sds/writer.go
if includeConfigType { s.Name = fmt.Sprintf("secret/%s", s.Name) } fmt.Fprintf(tw, "%s\t%s\t%s\t%t\t%s\t%s\t%s\n", s.Name, s.Type, s.State, s.Valid, s.SerialNumber, s.NotAfter, s.NotBefore) } return tw.Flush() } // printSecretItemsJSON prints secret in JSON format, and dumps the raw certificate data with the output func (w *sdsWriter) printSecretItemsJSON(secrets []SecretItem) error {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 21 14:17:23 GMT 2023 - 4.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
// // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps) if err != nil { return probeSet, err } probeSet.Flush() return probeSet, nil } func (s *Server) Start() {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_linux.go
if err != nil { return fmt.Errorf("failed to delete IP %s with and proto %d from ipset %s: %w", ip, ipProto, name, err) } return nil } func (m *realDeps) flush(name string) error { err := netlink.IpsetFlush(name) if err != nil { return fmt.Errorf("failed to flush ipset %s: %w", name, err) } return nil } // Alpine and some distros struggles with this - ipset CLI utilities support this, but
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_unspecified.go
return errors.New("not implemented on this platform") } func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error { return errors.New("not implemented on this platform") } func (m *realDeps) flush(name string) error { return errors.New("not implemented on this platform") } func (m *realDeps) clearEntriesWithComment(name, comment string) error { return errors.New("not implemented on this platform") }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 1.8K bytes - Viewed (0) -
bin/retry.sh
while true; do unset SHELL # Don't let environment control which shell to use if isatty; then if [ "$(uname)" == "Darwin" ]; then script -q -r "${tmpFile}" "${*}" else script --flush --quiet --return "${tmpFile}" --command "${*}" fi else # if we aren't a TTY, run directly as script will always run with a tty, which may output content that # we cannot display
Shell Script - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jun 11 16:08:08 GMT 2021 - 2K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/ecds.go
if err != nil { return err } for _, ecds := range dump { fmt.Fprintf(w, "%v\t%v\n", ecds.Name, strings.TrimPrefix(ecds.GetTypedConfig().GetTypeUrl(), typeURLPrefix), ) } return w.Flush() } func (c *ConfigWriter) retrieveSortedEcds() ([]*core.TypedExtensionConfig, error) { if c.configDump == nil { return nil, fmt.Errorf("config writer has not been primed") }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Jan 14 02:41:27 GMT 2023 - 2.6K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%x\t%v\t%v\n", secret.Identity, t, secret.State, certNotExpired(ca), n, valueOrNA(ca.ExpirationTime), valueOrNA(ca.ValidFrom)) } } } return w.Flush() } func valueOrNA(value string) string { if value == "" { return "NA" } return value } func certNotExpired(cert *Cert) bool {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/services.go
_, ip, _ = strings.Cut(svc.Addresses[0], "/") } waypoint := serviceWaypointName(svc, zDump.Services) fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", svc.Namespace, svc.Name, ip, waypoint) } return w.Flush() } // PrintServiceDump prints the relevant services in the config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintServiceDump(filter ServiceFilter, outputFormat string) error { zDump := c.ztunnelDump
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\n", wl.Namespace, wl.Name, ip, wl.Node, waypoint, wl.Protocol) } else { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", wl.Namespace, wl.Name, ip, wl.Node) } } return w.Flush() } // PrintWorkloadDump prints the relevant workloads in the config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintWorkloadDump(filter WorkloadFilter, outputFormat string) error { zDump := c.ztunnelDump
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 4K bytes - Viewed (0) -
istioctl/pkg/writer/table/writer.go
cells = append(cells, NewCell(name)) } c.header = Row{Cells: cells} } func (c *ColoredTableWriter) AddRow(obj interface{}) { c.rows = append(c.rows, c.addRowFunc(obj)) } func (c *ColoredTableWriter) Flush() { output := c.getTableOutput(c.rows) if len(output) == 0 { return } sep := getMaxWidths(output) for _, row := range output { for i, col := range row { _, _ = fmt.Fprint(c.writer, col.String())
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Oct 08 04:41:42 GMT 2022 - 2.8K bytes - Viewed (0)