Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 529 for writers (0.12 sec)

  1. istioctl/pkg/util/common.go

    	Err error
    }
    
    func (c CommandParseError) Error() string {
    	return c.Err.Error()
    }
    
    // Confirm waits for a user to confirm with the supplied message.
    func Confirm(msg string, writer io.Writer) bool {
    	for {
    		_, _ = fmt.Fprintf(writer, "%s ", msg)
    		var response string
    		_, err := fmt.Scanln(&response)
    		if err != nil {
    			return false
    		}
    		switch strings.ToUpper(response) {
    		case "Y", "YES":
    			return true
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  2. istioctl/pkg/authz/listener.go

    		log.Errorf("failed to parse policy name: %s", name)
    		return "", ""
    	}
    	return fmt.Sprintf("%s.%s", parts[2], parts[1]), parts[3]
    }
    
    // Print prints the AuthorizationPolicy in the listener.
    func Print(writer io.Writer, listeners []*listener.Listener) {
    	parsedListeners := parse(listeners)
    	if parsedListeners == nil {
    		return
    	}
    
    	actionToPolicy := map[rbacpb.RBAC_Action]map[string]struct{}{}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  3. internal/ioutil/ioutil_test.go

    	}
    	writer.Write(nil)
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    	}
    
    	writer = WriteOnClose(io.Discard)
    	writer.Close()
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    	}
    }
    
    // Test for AppendFile.
    func TestAppendFile(t *testing.T) {
    	f, err := os.CreateTemp("", "")
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/io/CopyUtil.java

         *
         * @param writer
         *            ライター
         * @return ラップされたライター
         */
        protected static Writer wrap(final Writer writer) {
            if (writer instanceof BufferedWriter) {
                return writer;
            }
            if (writer instanceof StringWriter) {
                return writer;
            }
            return new BufferedWriter(writer, DEFAULT_BUF_SIZE);
        }
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/clusters/clusters.go

    )
    
    // EndpointFilter is used to pass filter information into route based config writer print functions
    type EndpointFilter struct {
    	Address string
    	Port    uint32
    	Cluster string
    	Status  string
    }
    
    // ConfigWriter is a writer for processing responses from the Envoy Admin config_dump endpoint
    type ConfigWriter struct {
    	Stdout   io.Writer
    	clusters *clusters.Wrapper
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  6. istioctl/pkg/util/formatting/formatter.go

    }
    
    func colorSuffix(colorize bool) string {
    	if !colorize {
    		return ""
    	}
    	return "\033[0m"
    }
    
    func IstioctlColorDefault(writer io.Writer) bool {
    	if strings.EqualFold(termEnvVar.Get(), "dumb") {
    		return false
    	}
    
    	file, ok := writer.(*os.File)
    	if ok {
    		if !isatty.IsTerminal(file.Fd()) {
    			return false
    		}
    	}
    
    	return true
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 11 02:41:45 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  7. compat/maven-model/src/test/java/org/apache/maven/model/v4/ModelXmlTest.java

        }
    
        String toXml(Model model) throws IOException, XMLStreamException {
            StringWriter sw = new StringWriter();
            MavenStaxWriter writer = new MavenStaxWriter();
            writer.setAddLocationInformation(false);
            writer.write(sw, model);
            return sw.toString();
        }
    
        Model fromXml(String xml) throws XMLStreamException {
            return new MavenStaxReader().read(new StringReader(xml));
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. internal/s3select/csv/record.go

    	return other
    }
    
    // WriteCSV - encodes to CSV data.
    func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error {
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.AlwaysQuote = opts.AlwaysQuote
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(r.csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  9. istioctl/pkg/config/config.go

    			return runList(c.OutOrStdout())
    		},
    	}
    	return listCmd
    }
    
    func runList(writer io.Writer) error {
    	// Sort flag names
    	keys := make([]string, len(settableFlags))
    	i := 0
    	for key := range settableFlags {
    		keys[i] = key
    		i++
    	}
    	sort.Strings(keys)
    	w := new(tabwriter.Writer).Init(writer, 0, 8, 5, ' ', 0)
    	fmt.Fprintf(w, "FLAG\tVALUE\tFROM\n")
    	for _, flag := range keys {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Jul 30 12:16:07 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/TikaExtractor.java

            try (DeferredFileOutputStream dfos = new DeferredFileOutputStream(memorySize, "tika", ".tmp", SystemUtils.getJavaIoTmpDir())) {
                final BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(dfos, enc));
                out.accept(writer);
                writer.flush();
    
                if (!dfos.isInMemory()) {
                    tempFile = dfos.getFile();
                }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 25K bytes
    - Viewed (0)
Back to top