statistic

Documentation

Index

• Constants
• type EventName
• type HandleData
• type Mongo
• type Statistic
  • func NewStatistic(collection string, database Mongo) *Statistic
  • func (s *Statistic) Get(name EventName, start, end time.Time, h handle, doc bool, filter *bson.D) ([]HandleData, error)
  • func (s *Statistic) Send(owner primitive.ObjectID, event EventName, data map[string]interface{}) error
  • func (s *Statistic) SendMany(count int, ...) error
• type SystemEvent

Constants

const (
	AutoHandle   handle = "auto"
	YearHandle   handle = "year"
	MonthHandle  handle = "month"
	DayHandle    handle = "day"
	HourHandle   handle = "hour"
	MinuteHandle handle = "minute"
)

Types

type EventName

type EventName string

Название события

type HandleData

type HandleData struct {
	Timestamp time.Time     `bson:"_id"`   // Идентификатор для свечки
	Count     int           `bson:"count"` // Кол-во документов в свече
	Documents []SystemEvent `bson:"doc"`   // Документы которые вошли в свечу
}

Структура для получения данных о свечке

type Mongo

type Mongo interface {
	Operation(op func(ctx context.Context, db *mongo.Database) error) error
}

type Statistic

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

func NewStatistic

func NewStatistic(collection string, database Mongo) *Statistic

func (*Statistic) Get

func (s *Statistic) Get(name EventName, start, end time.Time, h handle, doc bool, filter *bson.D) ([]HandleData, error)

Построение статистики

Параметры: name - название события start, end - период для выборки h - выбор типа свечи для отображения событий doc - параметр отвечает за необходимость возврата документов событий в группе filter - указатель на шаг фильтрации документов

func (*Statistic) Send

func (s *Statistic) Send(owner primitive.ObjectID, event EventName, data map[string]interface{}) error

Метод для сохранения одного события в коллекцию

func (*Statistic) SendMany

func (s *Statistic) SendMany(count int, builder func(i int) (owner primitive.ObjectID, event EventName, data map[string]interface{})) error

Метод для сохранения ряда событий в коллекцию

type SystemEvent

type SystemEvent struct {
	ID        primitive.ObjectID     `bson:"_id"`       // Идентификатор события
	Owner     primitive.ObjectID     `bson:"owner"`     // Владелец события (может быть NilObjectID)
	Name      EventName              `bson:"name"`      // Название события
	Timestamp time.Time              `bson:"timestamp"` // Временная метка
	Data      map[string]interface{} `bson:"data"`      // Сопутствующая информация
}