Documentation ¶
Index ¶
- func EncodeGroup(decodedGroup AlarmGroup) []string
- type AlarmGroup
- type GroupingStorage
- type RedisGroupingStorage
- func (s *RedisGroupingStorage) Clean(ctx context.Context, tx *redis.Tx, ruleID string) error
- func (s *RedisGroupingStorage) CleanPush(ctx context.Context, tx *redis.Tx, rule metaalarm.Rule, newAlarm types.Alarm, ...) error
- func (s *RedisGroupingStorage) Get(ctx context.Context, tx *redis.Tx, ruleID string) (AlarmGroup, error)
- func (s *RedisGroupingStorage) GetGroupLen(ctx context.Context, tx *redis.Tx, ruleID string) (int64, error)
- func (s *RedisGroupingStorage) Push(ctx context.Context, tx *redis.Tx, rule metaalarm.Rule, newAlarm types.Alarm, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EncodeGroup ¶
func EncodeGroup(decodedGroup AlarmGroup) []string
Types ¶
type AlarmGroup ¶
func DecodeGroup ¶
func DecodeGroup(encodedGroup []string) (AlarmGroup, error)
func (AlarmGroup) GetAlarmIds ¶
func (g AlarmGroup) GetAlarmIds() []string
type GroupingStorage ¶
type GroupingStorage interface { Push(context.Context, *redis.Tx, metaalarm.Rule, types.Alarm, string) error CleanPush(context.Context, *redis.Tx, metaalarm.Rule, types.Alarm, string) error Clean(context.Context, *redis.Tx, string) error Get(context.Context, *redis.Tx, string) (AlarmGroup, error) GetGroupLen(context.Context, *redis.Tx, string) (int64, error) }
type RedisGroupingStorage ¶
type RedisGroupingStorage struct{}
func NewRedisGroupingStorage ¶
func NewRedisGroupingStorage() *RedisGroupingStorage
func (*RedisGroupingStorage) Clean ¶
func (s *RedisGroupingStorage) Clean(ctx context.Context, tx *redis.Tx, ruleID string) error
func (*RedisGroupingStorage) Get ¶
func (s *RedisGroupingStorage) Get(ctx context.Context, tx *redis.Tx, ruleID string) (AlarmGroup, error)
func (*RedisGroupingStorage) GetGroupLen ¶
Click to show internal directories.
Click to hide internal directories.