activity

Aug 24, 2026

Changes in this version

+ func ErrorRankKey(prefix, envUUID string, day time.Time) string

type EventType

+ const EventStatusError

+ type NodeErrorCount struct

+ Errors int64

+ NodeUUID string

type NodeTileSeries

+ StatusError []uint16

type RedisStore

+ func (s *RedisStore) TopErrorNodes(ctx context.Context, envUUID string, end time.Time, days, limit int) ([]NodeErrorCount, error)

Jul 6, 2026

Changes in this version

+ const BucketSeconds

+ const BucketsPerDay

+ const DefaultPrefix

+ const DefaultRetentionDays

+ const EventTypeCount

+ func DayKey(prefix, envUUID, nodeUUID string, day time.Time) string

+ func EnvDayKey(prefix, envUUID string, day time.Time) string

+ type EnvSeries = NodeTileSeries

+ type Event struct

+ At time.Time

+ Count uint16

+ EnvUUID string

+ NodeUUID string

+ Type EventType

+ type EventType uint8

+ const EventConfig

+ const EventEnroll

+ const EventQueryRead

+ const EventQueryWrite

+ const EventResult

+ const EventStatus

+ type NodeTileSeries struct

+ BucketSeconds int

+ Config []uint16

+ Enroll []uint16

+ QueryRead []uint16

+ QueryWrite []uint16

+ Result []uint16

+ Start time.Time

+ Status []uint16

+ Total []uint16

+ type RedisStore struct

+ func NewRedisStore(client *redis.Client, prefix string, retentionDays int, ...) *RedisStore

+ func (s *RedisStore) IncrementMany(ctx context.Context, events []Event) error

+ func (s *RedisStore) ReadEnvSeries(ctx context.Context, envUUID string, end time.Time, days int) (EnvSeries, error)

+ func (s *RedisStore) ReadSeries(ctx context.Context, envUUID string, nodeUUIDs []string, end time.Time, ...) (map[string]NodeTileSeries, error)