time_series_index

Documentation

Index

• type Rows
• type TimeSeriesIndex
  • func New(collectorId, index, timeField, timeFormat string, keep int, ...) (*TimeSeriesIndex, error)
  • func (tsi TimeSeriesIndex) Get(t time.Time) string
  • func (tsi *TimeSeriesIndex) Group(rows []map[string]interface{}) (result []Rows)
  • func (tsi TimeSeriesIndex) Of(row map[string]interface{}) string
  • func (tsi TimeSeriesIndex) Prune(client *elastic.ES)

Types

type Rows

type Rows struct {
	Index string
	Rows  []map[string]interface{}
}

type TimeSeriesIndex

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

func New

func New(collectorId, index, timeField, timeFormat string, keep int, logger *loggerpkg.Logger) (
	*TimeSeriesIndex, error,
)

func (TimeSeriesIndex) Get

func (tsi TimeSeriesIndex) Get(t time.Time) string

func (*TimeSeriesIndex) Group

func (tsi *TimeSeriesIndex) Group(rows []map[string]interface{}) (result []Rows)

func (TimeSeriesIndex) Of

func (tsi TimeSeriesIndex) Of(row map[string]interface{}) string

func (TimeSeriesIndex) Prune

func (tsi TimeSeriesIndex) Prune(client *elastic.ES)