service

type EventGroupService interface {
	// CutGroup 缩减分组中 event 的数量，只保留  keepCount 条（relation_ids 不为空的 events 不能删除）
	CutGroup(ctx context.Context, groupID primitive.ObjectID, keepCount int64) (int64, error)
	// EventShouldRealtime 检查事件是否应该即时发送，如果是，则执行 shouldFn 函数
	// 每次调用该函数，无论是否事件应该即时发送，都会更新时间静默周期，重新计算剩余时间
	EventShouldRealtime(ctx context.Context, evtKey string, silentPeriod time.Duration, shouldFn func())
}

type EventService interface {
	// Add add a new event to repository
	Add(ctx context.Context, msg extension.CommonEvent) (primitive.ObjectID, error)
}

type ServiceProvider struct{}