trafficagg

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

type Deps struct {
	Store repository.Store
	Redis *redis.Client
	// TrafficReportThreshold reads the runtime-mutable minimum report size;
	// nil means no minimum.
	TrafficReportThreshold func() int64
	// Multiplier returns the node traffic multiplier in effect at the given
	// time; nil means no multiplier is configured.
	Multiplier func(at time.Time) float32
}

type UserTraffic struct {
	SID      int64
	Upload   int64
	Download int64
}