package ioutils

import "k8s.io/kubernetes/pkg/kubelet/util/ioutils"

Index ¶

• func LimitWriter(w io.Writer, n int64) io.Writer
• func WriteCloserWrapper(w io.Writer) io.WriteCloser
• type LimitedWriter
• func (l *LimitedWriter) Write(p []byte) (n int, err error)

Functions ¶

func LimitWriter ¶

func LimitWriter(w io.Writer, n int64) io.Writer

LimitWriter is a copy of the standard library ioutils.LimitReader, applied to the writer interface. LimitWriter returns a Writer that writes to w but stops with EOF after n bytes. The underlying implementation is a *LimitedWriter.

func WriteCloserWrapper ¶

func WriteCloserWrapper(w io.Writer) io.WriteCloser

WriteCloserWrapper returns a writeCloserWrapper.

Types ¶

type LimitedWriter ¶

type LimitedWriter struct {
	W io.Writer // underlying writer
	N int64     // max bytes remaining
}

A LimitedWriter writes to W but limits the amount of data returned to just N bytes. Each call to Write updates N to reflect the new amount remaining. Write returns EOF when N <= 0 or when the underlying W returns EOF.

func (*LimitedWriter) Write ¶

func (l *LimitedWriter) Write(p []byte) (n int, err error)

Source Files ¶

ioutils.go