evutil

type AutoStore ¶

type AutoStore struct {
	New func(event string) db.Storer
	// contains filtered or unexported fields
}

AutoStore is a Store that creates a new Storer if it is not Registered

func (a *AutoStore) Storer(event string) (w db.Storer)

type EventSummaries ¶

type EventSummaries struct {
	Labels []string
	Events []string
	Data   []EventSummary
}

EventSummaries is a result summary format

func NewEventSummaries(empty string, results db.Results) *EventSummaries

func (s *EventSummaries) Table() Table

type EventSummary ¶

type EventSummary struct {
	Values []string
	Totals map[string]float64
}

EventSummary groups values with totals

func (r *EventSummary) TableRow(events []string) []interface{}

type FieldCache ¶

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

FieldCache is an in memory cache of field ids

func (c *FieldCache) BlobID(blob []byte) (id uint64, ok bool)

func (c *FieldCache) Fields(id uint64) (fields db.Fields)

func (c *FieldCache) ID(fields db.Fields) (uint64, bool)

func (c *FieldCache) Labels() (labels []string)

func (c *FieldCache) Set(id uint64, fields db.Fields) db.Fields

func (c *FieldCache) SetBlob(id uint64, blob []byte) db.Fields

type FieldSummaries ¶

type FieldSummaries []FieldSummary

FieldSummaries is a slice of FieldSummary results

func NewFieldSummaries(results db.Results) (s FieldSummaries)

type FieldSummary ¶

type FieldSummary struct {
	Event  string             `json:"event"`
	Label  string             `json:"label"`
	Values map[string]float64 `json:"values"`
}

FieldSummary is a query result presented as a summary of field values

func (s *FieldSummary) Add(value string, n float64)

type MemoryStore ¶

type MemoryStore map[string]*MemoryStorer

MemoryStore is a Store collecting snapshots in memory

func NewMemoryStore(events ...string) MemoryStore

func (m MemoryStore) Scan(ctx context.Context, queries ...db.ScanQuery) (db.Results, error)

func (m MemoryStore) Storer(event string) db.Storer

type MemoryStorer ¶

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

MemoryStorer is an in-memory EventStore for debugging

func (m *MemoryStorer) Last() *db.Snapshot

func (m *MemoryStorer) Len() int

func (m *MemoryStorer) Store(s *db.Snapshot) error

type MuxScanner ¶

type MuxScanner map[string]db.ScanQuerier

MuxScanner multiplexes ScanQuerier instances into a Scanner

func (m MuxScanner) Scan(ctx context.Context, queries ...db.ScanQuery) (db.Results, error)

func (m MuxScanner) Set(s db.ScanQuerier, events ...string) MuxScanner

type MuxStore ¶

type MuxStore map[string]db.Storer

MuxStore maps event names to Storers

func (m MuxStore) Add(event string, s db.Storer) (MuxStore, db.Storer)

func (m MuxStore) Set(event string, s db.Storer) MuxStore

func (m MuxStore) Storer(event string) db.Storer

type StorerFunc ¶

type StorerFunc func(s *db.Snapshot) error

StorerFunc is a function that implements Storer interface

func (fn StorerFunc) Store(s *db.Snapshot) error

type SyncStore ¶

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

SyncStore provides a mutable Store safe for concurrent use

func (s *SyncStore) Add(event string, w db.Storer) db.Storer

func (s *SyncStore) Register(event string, w db.Storer) bool

func (s *SyncStore) Set(event string, w db.Storer)

func (s *SyncStore) Storer(event string) (w db.Storer)

type Table ¶

type Table struct {
	Columns []interface{}   `json:"cols"`
	Data    [][]interface{} `json:"data"`
}

Table holds generic tabular data

type Total ¶

type Total struct {
	Event  string    `json:"event"`
	Fields db.Fields `json:"fields,omitempty"`
	Total  float64   `json:"total"`
}

type Totals ¶

type Totals []Total

func NewTotals(results db.Results) (totals Totals)