timebased

Documentation

Index

• func AddEntryToTable(cEntry *TableEntry, tableList *list.List)
• func AddEntryToTables(indexKeyStructs map[string]*IndexKeyTable, entry config.GenericMap, ...)
• func DeleteOldEntriesFromTables(indexKeyStructs map[string]*IndexKeyTable, nowInSecs time.Time)
• func PrintTable(l *list.List)
• type DataTableMap
• type FilterStruct
  • func CreateIndexKeysAndFilters(rules []api.TimebasedFilterRule) (map[string]*IndexKeyTable, []FilterStruct)
  • func (fs *FilterStruct) CalculateResults(nowInSecs time.Time)
  • func (fs *FilterStruct) CalculateValue(l *list.List, oldestValidTime time.Time) float64
  • func (fs *FilterStruct) ComputeTopkBotk()
  • func (fs *FilterStruct) CreateGenericMap() []config.GenericMap
• type IndexKeyTable
• type TableEntry

Functions

func AddEntryToTable

func AddEntryToTable(cEntry *TableEntry, tableList *list.List)

func AddEntryToTables

func AddEntryToTables(indexKeyStructs map[string]*IndexKeyTable, entry config.GenericMap, nowInSecs time.Time)

func DeleteOldEntriesFromTables

func DeleteOldEntriesFromTables(indexKeyStructs map[string]*IndexKeyTable, nowInSecs time.Time)

func PrintTable

func PrintTable(l *list.List)

Types

type DataTableMap

type DataTableMap map[string]*list.List

type FilterStruct

type FilterStruct struct {
	Rule              api.TimebasedFilterRule
	IndexKeyDataTable *IndexKeyTable
	Results           filterOperationResults
	Output            []filterOperationResult
}

func CreateIndexKeysAndFilters

func CreateIndexKeysAndFilters(rules []api.TimebasedFilterRule) (map[string]*IndexKeyTable, []FilterStruct)

CreateIndexKeysAndFilters creates structures for each IndexKey that appears in the rules. Note that the same IndexKey might appear in more than one Rule. Connect IndexKey structure to its filters. For each IndexKey, we need a table of history to handle the largest TimeInterval.

func (*FilterStruct) CalculateResults

func (fs *FilterStruct) CalculateResults(nowInSecs time.Time)

func (*FilterStruct) CalculateValue

func (fs *FilterStruct) CalculateValue(l *list.List, oldestValidTime time.Time) float64

func (*FilterStruct) ComputeTopkBotk

func (fs *FilterStruct) ComputeTopkBotk()

func (*FilterStruct) CreateGenericMap

func (fs *FilterStruct) CreateGenericMap() []config.GenericMap

type IndexKeyTable

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

type TableEntry

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