utils

Documentation

Index

• func IsReadLimitReached(bytesLoaded int64, linesLoaded int64, logFilePosition string) bool
• func MockProgress() (*Progress, *Bar)
• func MountPathClean(mountPath string) string
• func SplitLog(logContent string, startIndex, endIndex int, overFlag bool) string
• type Bar
  • func (b *Bar) Done()
  • func (b *Bar) IncrTotal(n int64)
  • func (b *Bar) SetTotal(total int64)
• type DoubleSpinner
  • func (s *DoubleSpinner) Current() (int64, int64)
  • func (s *DoubleSpinner) Done()
  • func (s *DoubleSpinner) IncrInt64(size int64)
• type LogPage
  • func (l *LogPage) Dividing(contentLineNum, contentByteLength int) (int, int)
  • func (l *LogPage) Paging(content string, logContentLineNum int) string
  • func (l *LogPage) SlicePaging(content []string) []string
• type Progress
  • func NewProgress(quiet, showSpeed bool) *Progress
  • func (p *Progress) AddByteSpinner(name string) *Bar
  • func (p *Progress) AddCountBar(name string, total int64) *Bar
  • func (p *Progress) AddCountSpinner(name string) *Bar
  • func (p *Progress) AddDoubleSpinner(name string) *DoubleSpinner
  • func (p *Progress) Done()

Functions

func IsReadLimitReached

func IsReadLimitReached(bytesLoaded int64, linesLoaded int64, logFilePosition string) bool

IsReadLimitReached checks logs if truncated by apiServer

func MockProgress

func MockProgress() (*Progress, *Bar)

func MountPathClean

func MountPathClean(mountPath string) string

MountPathClean cleans the path for mountPath

func SplitLog

func SplitLog(logContent string, startIndex, endIndex int, overFlag bool) string

Types

type Bar

type Bar struct {
	*mpb.Bar
	// contains filtered or unexported fields
}

func (*Bar) Done

func (b *Bar) Done()

func (*Bar) IncrTotal

func (b *Bar) IncrTotal(n int64)

func (*Bar) SetTotal

func (b *Bar) SetTotal(total int64)

type DoubleSpinner

type DoubleSpinner struct {
	// contains filtered or unexported fields
}

func (*DoubleSpinner) Current

func (s *DoubleSpinner) Current() (int64, int64)

func (*DoubleSpinner) Done

func (s *DoubleSpinner) Done()

func (*DoubleSpinner) IncrInt64

func (s *DoubleSpinner) IncrInt64(size int64)

type LogPage

type LogPage struct {
	LogFilePosition string
	LineLimit       int
	SizeLimit       int64
	HasNextPage     bool
	Truncated       bool
}

func (*LogPage) Dividing

func (l *LogPage) Dividing(contentLineNum, contentByteLength int) (int, int)

Dividing get startIndex and endIndex of contents, by

func (*LogPage) Paging

func (l *LogPage) Paging(content string, logContentLineNum int) string

Paging divided content into pages

func (*LogPage) SlicePaging

func (l *LogPage) SlicePaging(content []string) []string

SlicePaging divided slice into pages

type Progress

type Progress struct {
	*mpb.Progress
	Quiet bool
	// contains filtered or unexported fields
}

func NewProgress

func NewProgress(quiet, showSpeed bool) *Progress

func (*Progress) AddByteSpinner

func (p *Progress) AddByteSpinner(name string) *Bar

func (*Progress) AddCountBar

func (p *Progress) AddCountBar(name string, total int64) *Bar

func (*Progress) AddCountSpinner

func (p *Progress) AddCountSpinner(name string) *Bar

func (*Progress) AddDoubleSpinner

func (p *Progress) AddDoubleSpinner(name string) *DoubleSpinner

func (*Progress) Done

func (p *Progress) Done()