Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 232 for Writer (0.2 sec)

  1. internal/bucket/replication/datatypes_gen.go

    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = StatusType(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z StatusType) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteString(string(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  2. logger/logger.go

    const (
    	// Silent silent log level
    	Silent LogLevel = iota + 1
    	// Error error log level
    	Error
    	// Warn warn log level
    	Warn
    	// Info info log level
    	Info
    )
    
    // Writer log writer interface
    type Writer interface {
    	Printf(string, ...interface{})
    }
    
    // Config logger config
    type Config struct {
    	SlowThreshold             time.Duration
    	Colorful                  bool
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Nov 07 02:19:41 GMT 2023
    - 5.8K bytes
    - Viewed (0)
  3. istioctl/pkg/injector/injector-list.go

    		return filtered[i].Name < filtered[j].Name
    	})
    	return filtered, nil
    }
    
    func printNS(writer io.Writer, namespaces []corev1.Namespace, hooks []admitv1.MutatingWebhookConfiguration,
    	allPods map[resource.Namespace][]corev1.Pod,
    ) error {
    	outputCount := 0
    
    	w := new(tabwriter.Writer).Init(writer, 0, 8, 1, ' ', 0)
    	for _, namespace := range namespaces {
    		revision := getInjectedRevision(&namespace, hooks)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jan 04 03:08:06 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  4. istioctl/pkg/proxystatus/proxystatus.go

    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/completion"
    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/istioctl/pkg/util/ambient"
    	"istio.io/istio/istioctl/pkg/writer/compare"
    	"istio.io/istio/istioctl/pkg/writer/pilot"
    	pilotxds "istio.io/istio/pilot/pkg/xds"
    	"istio.io/istio/pkg/log"
    )
    
    var configDumpFile string
    
    func readConfigFile(filename string) ([]byte, error) {
    	file := os.Stdin
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  5. istioctl/pkg/proxyconfig/clusters.go

    		},
    	}
    	opts.AttachControlPlaneFlags(cmd)
    	return cmd
    }
    
    func writeMulticlusterStatus(out io.Writer, input map[string][]byte) error {
    	statuses, err := parseClusterStatuses(input)
    	if err != nil {
    		return err
    	}
    	w := new(tabwriter.Writer).Init(out, 0, 8, 5, ' ', 0)
    	_, _ = fmt.Fprintln(w, "NAME\tSECRET\tSTATUS\tISTIOD")
    	for istiod, clusters := range statuses {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  6. internal/s3select/simdj/record.go

    	return sql.SelectFmtSIMDJSON, r.object
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	o := r.object
    	elems, err := o.Parse(nil)
    	if err != nil {
    		return err
    	}
    	b, err := elems.MarshalJSON()
    	if err != nil {
    		return err
    	}
    	n, err := writer.Write(b)
    	if err != nil {
    		return err
    	}
    	if n != len(b) {
    		return io.ErrShortWrite
    	}
    	return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  7. src/archive/zip/zip_test.go

    	}
    	for i := 0; i < chunks; i++ {
    		_, err := f.Write(chunk)
    		if err != nil {
    			t.Fatal("write chunk:", err)
    		}
    	}
    	if frag := int(size % chunkSize); frag > 0 {
    		_, err := f.Write(chunk[:frag])
    		if err != nil {
    			t.Fatal("write chunk:", err)
    		}
    	}
    	end := []byte("END\n")
    	_, err = f.Write(end)
    	if err != nil {
    		t.Fatal("write end:", err)
    	}
    	if err := w.Close(); err != nil {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  8. clause/clause.go

    // ClauseBuilder clause builder, allows to customize how to build clause
    type ClauseBuilder func(Clause, Builder)
    
    type Writer interface {
    	WriteByte(byte) error
    	WriteString(string) (int, error)
    }
    
    // Builder builder interface
    type Builder interface {
    	Writer
    	WriteQuoted(field interface{})
    	AddVar(Writer, ...interface{})
    	AddError(error) error
    }
    
    // Clause
    type Clause struct {
    	Name                string // WHERE
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Thu Feb 02 09:15:08 GMT 2023
    - 1.7K 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 {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Jul 30 12:16:07 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  10. cmd/bitrot.go

    				br.Close()
    			}
    		}
    	}
    }
    
    // Close all the writers.
    func closeBitrotWriters(ws []io.Writer) {
    	for _, w := range ws {
    		if w != nil {
    			if bw, ok := w.(io.Closer); ok {
    				bw.Close()
    			}
    		}
    	}
    }
    
    // Returns hash sum for whole-bitrot, nil for streaming-bitrot.
    func bitrotWriterSum(w io.Writer) []byte {
    	if bw, ok := w.(*wholeBitrotWriter); ok {
    		return bw.Sum(nil)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.6K bytes
    - Viewed (0)
Back to top