store

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

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

type Candle struct {
	Nodes       map[string]Info
	StartMinute time.Time
}

type Engine interface {
	Save(candle Candle) (err error)
	Load(ctx context.Context, periodStart, periodEnd time.Time) (result []Candle, err error)
}

type Info struct {
	Volume int
	Files  map[string]int
}

type LogRecord struct {
	FromIP   string    `json:"from_ip"`
	FileName string    `json:"file_name"`
	DestHost string    `json:"dest"`
	Date     time.Time `json:"ts"`
}