loglines

Documentation

Index

• func DedupAB(a, b []*ProcessedLine) ([]*ProcessedLine, []*ProcessedLine)
• func DedupLineSlices(lineSlices []*LineSlice) (*LineSlice, *LineSlice)
• func WriteOverlap(lines []*ProcessedLine, name string) error
• type Dump
• type GenerationDumper
  • func NewGenerationDumper(dir string, keepLogs bool) *GenerationDumper
  • func (dump *GenerationDumper) DumpLines(ls *LineSlice, numberInGen int)
  • func (dump *GenerationDumper) Start()
  • func (dump *GenerationDumper) Stop()
• type GenerationalLockedTime
  • func NewGenerationalLockedTime(initialTime time.Time) GenerationalLockedTime
  • func (lt *GenerationalLockedTime) Generation() uint32
  • func (lt *GenerationalLockedTime) Time() time.Time
  • func (lt *GenerationalLockedTime) Update(update time.Time)
• type Generations
  • func (gens *Generations) Add(lineSlice *LineSlice)
  • func (gens *Generations) Flush() *LineSlice
  • func (gens *Generations) FlushAll() *LineSlice
  • func (gens *Generations) ShouldFlush() bool
• type LineSlice
  • func MakeSliceFromLines(lines []*ProcessedLine, generation uint32) *LineSlice
• type ProcessedLine
  • func MakeNewCombinedSlice(x, y []*ProcessedLine) []*ProcessedLine
  • func ProcessLine(line string) (*ProcessedLine, error)

Functions

func DedupAB

func DedupAB(a, b []*ProcessedLine) ([]*ProcessedLine, []*ProcessedLine)

func DedupLineSlices

func DedupLineSlices(lineSlices []*LineSlice) (*LineSlice, *LineSlice)

func WriteOverlap

func WriteOverlap(lines []*ProcessedLine, name string) error

Types

type Dump

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

type GenerationDumper

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

func NewGenerationDumper

func NewGenerationDumper(dir string, keepLogs bool) *GenerationDumper

func (*GenerationDumper) DumpLines

func (dump *GenerationDumper) DumpLines(ls *LineSlice, numberInGen int)

func (*GenerationDumper) Start

func (dump *GenerationDumper) Start()

func (*GenerationDumper) Stop

func (dump *GenerationDumper) Stop()

type GenerationalLockedTime

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

func NewGenerationalLockedTime

func NewGenerationalLockedTime(initialTime time.Time) GenerationalLockedTime

func (*GenerationalLockedTime) Generation

func (lt *GenerationalLockedTime) Generation() uint32

func (*GenerationalLockedTime) Time

func (lt *GenerationalLockedTime) Time() time.Time

func (*GenerationalLockedTime) Update

func (lt *GenerationalLockedTime) Update(update time.Time)

type Generations

type Generations struct {
	Store  map[uint32][]*LineSlice
	Dumper *GenerationDumper
	Latest uint32
	Oldest uint32
}

func (*Generations) Add

func (gens *Generations) Add(lineSlice *LineSlice)

func (*Generations) Flush

func (gens *Generations) Flush() *LineSlice

func (*Generations) FlushAll

func (gens *Generations) FlushAll() *LineSlice

func (*Generations) ShouldFlush

func (gens *Generations) ShouldFlush() bool

type LineSlice

type LineSlice struct {
	Lines      []*ProcessedLine
	Generation uint32
	// contains filtered or unexported fields
}

func MakeSliceFromLines

func MakeSliceFromLines(lines []*ProcessedLine, generation uint32) *LineSlice

type ProcessedLine

type ProcessedLine struct {
	Timestamp  time.Time
	Full       string
	Content    string
	Generation uint32
}

func MakeNewCombinedSlice

func MakeNewCombinedSlice(x, y []*ProcessedLine) []*ProcessedLine

func ProcessLine

func ProcessLine(line string) (*ProcessedLine, error)