Documentation
¶
Index ¶
- type MultiReaderLineBuffer
- func (mrlb *MultiReaderLineBuffer) AddLine(line string)
- func (mrlb *MultiReaderLineBuffer) GetLineCount() int
- func (mrlb *MultiReaderLineBuffer) GetLines() []string
- func (mrlb *MultiReaderLineBuffer) GetTotalLineCount() int
- func (mrlb *MultiReaderLineBuffer) ReadAll(r io.Reader)
- func (mrlb *MultiReaderLineBuffer) SetLineCallback(callback func(string))
- type ReaderLineBuffer
- func (rlb *ReaderLineBuffer) GetLineCount() int
- func (rlb *ReaderLineBuffer) GetLines() []string
- func (rlb *ReaderLineBuffer) GetTotalLineCount() int
- func (rlb *ReaderLineBuffer) IsDone() bool
- func (rlb *ReaderLineBuffer) ReadAll()
- func (rlb *ReaderLineBuffer) ReadLine() (string, error)
- func (rlb *ReaderLineBuffer) SetLineCallback(callback func(string))
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MultiReaderLineBuffer ¶ added in v0.12.2
type MultiReaderLineBuffer struct {
// contains filtered or unexported fields
}
func MakeMultiReaderLineBuffer ¶ added in v0.12.2
func MakeMultiReaderLineBuffer(maxLines int) *MultiReaderLineBuffer
func (*MultiReaderLineBuffer) AddLine ¶ added in v0.12.2
func (mrlb *MultiReaderLineBuffer) AddLine(line string)
func (*MultiReaderLineBuffer) GetLineCount ¶ added in v0.12.2
func (mrlb *MultiReaderLineBuffer) GetLineCount() int
func (*MultiReaderLineBuffer) GetLines ¶ added in v0.12.2
func (mrlb *MultiReaderLineBuffer) GetLines() []string
func (*MultiReaderLineBuffer) GetTotalLineCount ¶ added in v0.12.2
func (mrlb *MultiReaderLineBuffer) GetTotalLineCount() int
func (*MultiReaderLineBuffer) ReadAll ¶ added in v0.12.2
func (mrlb *MultiReaderLineBuffer) ReadAll(r io.Reader)
func (*MultiReaderLineBuffer) SetLineCallback ¶ added in v0.12.2
func (mrlb *MultiReaderLineBuffer) SetLineCallback(callback func(string))
callback is synchronous. will block the consuming of lines and guaranteed to run in order. it is also guaranteed only one callback will be running at a time (protected by the internal line lock)
type ReaderLineBuffer ¶
type ReaderLineBuffer struct {
// contains filtered or unexported fields
}
func MakeReaderLineBuffer ¶
func MakeReaderLineBuffer(reader io.Reader, maxLines int) *ReaderLineBuffer
func (*ReaderLineBuffer) GetLineCount ¶
func (rlb *ReaderLineBuffer) GetLineCount() int
func (*ReaderLineBuffer) GetLines ¶
func (rlb *ReaderLineBuffer) GetLines() []string
func (*ReaderLineBuffer) GetTotalLineCount ¶
func (rlb *ReaderLineBuffer) GetTotalLineCount() int
func (*ReaderLineBuffer) IsDone ¶
func (rlb *ReaderLineBuffer) IsDone() bool
func (*ReaderLineBuffer) ReadAll ¶
func (rlb *ReaderLineBuffer) ReadAll()
func (*ReaderLineBuffer) ReadLine ¶
func (rlb *ReaderLineBuffer) ReadLine() (string, error)
func (*ReaderLineBuffer) SetLineCallback ¶
func (rlb *ReaderLineBuffer) SetLineCallback(callback func(string))
Click to show internal directories.
Click to hide internal directories.