repository

func (m *EventGroupRepo) Add(grp repository.EventGroup) (id primitive.ObjectID, err error)

func (m *EventGroupRepo) CollectingGroup(rule repository.EventGroupRule) (group repository.EventGroup, err error)

func (m *EventGroupRepo) Count(filter bson.M) (int64, error)

func (m *EventGroupRepo) Delete(filter bson.M) error

func (m *EventGroupRepo) DeleteID(id primitive.ObjectID) error

func (m *EventGroupRepo) Find(filter bson.M) (grps []repository.EventGroup, err error)

func (m *EventGroupRepo) Get(id primitive.ObjectID) (grp repository.EventGroup, err error)

func (m *EventGroupRepo) LastGroup(filter bson.M) (grp repository.EventGroup, err error)

func (m *EventGroupRepo) Paginate(filter bson.M, offset, limit int64, sortByCreatedAtDesc bool) (grps []repository.EventGroup, next int64, err error)

func (m *EventGroupRepo) StatByAggCount(ctx context.Context, ruleID primitive.ObjectID, startTime, endTime time.Time) ([]repository.EventGroupAggCount, error)

func (m *EventGroupRepo) StatByAggCountInPeriod(ctx context.Context, ruleID primitive.ObjectID, startTime, endTime time.Time, hour int64) ([]repository.EventGroupAggByDatetimeCount, error)

func (m *EventGroupRepo) StatByDatetimeCount(ctx context.Context, filter bson.M, startTime, endTime time.Time, hour int64) ([]repository.EventGroupByDatetimeCount, error)

func (m *EventGroupRepo) StatByRuleCount(ctx context.Context, startTime, endTime time.Time) ([]repository.EventGroupByRuleCount, error)

func (m *EventGroupRepo) StatByUserCount(ctx context.Context, startTime, endTime time.Time) ([]repository.EventGroupByUserCount, error)

func (m *EventGroupRepo) Traverse(filter bson.M, cb func(grp repository.EventGroup) error) error

func (m *EventGroupRepo) UpdateID(id primitive.ObjectID, grp repository.EventGroup) error

func (m *MessageRepo) Add(msg repository.Event) (id primitive.ObjectID, err error)

func (m *MessageRepo) AddWithContext(ctx context.Context, msg repository.Event) (id primitive.ObjectID, err error)

func (m *MessageRepo) Count(filter interface{}) (int64, error)

func (m *MessageRepo) CountByDatetime(ctx context.Context, filter bson.M, startTime, endTime time.Time, hour int64) ([]repository.EventByDatetimeCount, error)

func (m *MessageRepo) Delete(filter interface{}) error

func (m *MessageRepo) DeleteID(id primitive.ObjectID) error

func (m *MessageRepo) Find(filter interface{}) (messages []repository.Event, err error)

func (m *MessageRepo) FindIDs(ctx context.Context, filter interface{}, limit int64) ([]primitive.ObjectID, error)

func (m *MessageRepo) Get(id primitive.ObjectID) (msg repository.Event, err error)

func (m *MessageRepo) Has(filter interface{}) (bool, error)

func (m *MessageRepo) Paginate(filter interface{}, offset, limit int64) (messages []repository.Event, next int64, err error)

func (m *MessageRepo) Traverse(filter interface{}, cb func(msg repository.Event) error) error

func (m *MessageRepo) UpdateID(id primitive.ObjectID, update repository.Event) error

func (r *RuleRepo) Add(rule repository.Rule) (id primitive.ObjectID, err error)

func (r *RuleRepo) Count(filter bson.M) (int64, error)

func (r *RuleRepo) Delete(filter bson.M) error

func (r *RuleRepo) DeleteID(id primitive.ObjectID) error

func (r *RuleRepo) Find(filter bson.M) (rules []repository.Rule, err error)

func (r *RuleRepo) Get(id primitive.ObjectID) (rule repository.Rule, err error)

func (r *RuleRepo) Paginate(filter interface{}, offset, limit int64) (rules []repository.Rule, next int64, err error)

func (r *RuleRepo) Tags(ctx context.Context) ([]repository.Tag, error)

func (r *RuleRepo) Traverse(filter bson.M, cb func(rule repository.Rule) error) error

func (r *RuleRepo) UpdateID(id primitive.ObjectID, rule repository.Rule) error