kubernetes/pkg/proxy/util/linebuffer.go

type LineBuffer …

var _ …

type realLineBuffer …

// NewLineBuffer returns a new "real" LineBuffer
func NewLineBuffer() LineBuffer { … }

// Write is part of LineBuffer
func (buf *realLineBuffer) Write(args ...interface{ … }

// WriteBytes is part of LineBuffer
func (buf *realLineBuffer) WriteBytes(bytes []byte) { … }

// Reset is part of LineBuffer
func (buf *realLineBuffer) Reset() { … }

// Bytes is part of LineBuffer
func (buf *realLineBuffer) Bytes() []byte { … }

// String is part of LineBuffer
func (buf *realLineBuffer) String() string { … }

// Lines is part of LineBuffer
func (buf *realLineBuffer) Lines() int { … }

// Implements the logs.Marshaler interface
func (buf *realLineBuffer) MarshalLog() any { … }

type discardLineBuffer …

// NewDiscardLineBuffer returns a dummy LineBuffer that counts the number of writes but
// throws away the data. (This is used for iptables proxy partial syncs, to keep track of
// how many rules we managed to avoid having to sync.)
func NewDiscardLineBuffer() LineBuffer { … }

// Write is part of LineBuffer
func (buf *discardLineBuffer) Write(args ...interface{ … }

// WriteBytes is part of LineBuffer
func (buf *discardLineBuffer) WriteBytes(bytes []byte) { … }

// Reset is part of LineBuffer
func (buf *discardLineBuffer) Reset() { … }

// Bytes is part of LineBuffer
func (buf *discardLineBuffer) Bytes() []byte { … }

// String is part of LineBuffer
func (buf *discardLineBuffer) String() string { … }

// Lines is part of LineBuffer
func (buf *discardLineBuffer) Lines() int { … }