node

type Bucket struct {
	Key      string `json:"key"`
	DocCount int    `json:"doc_count"`
}

type ESConf i2es.ESConf

type ESDoc struct {
	Echo    string `json:"echo"`
	Subg    string `json:"subg"`
	To      string `json:"to"`
	Author  string `json:"author"`
	Message string `json:"message"`
	Date    string `json:"date"`
	MsgID   string `json:"msgid"`
	Tags    string `json:"tags"`
	Repto   string `json:"repto"`
	Address string `json:"address"`
	TopicID string `json:"topicid"`
}

type ESSearchResp struct {
	Took           int64 `json:"took"`
	TimedOut       bool  `json:"timed_out"`
	ESSearchShards `json:"_shards"`
	Hits           `json:"hits"`
}

type ESSearchShards struct {
	Total      int64 `json:"total"`
	Successful int64 `json:"successful"`
	Skipped    int64 `json:"skipped"`
	Failed     int64 `json:"failed"`
}

type EchoAgg struct {
	DocCountErrorUpperBound int64    `json:"doc_count_error_upper_bound"`
	SumOtherDocCount        int64    `json:"sum_other_doc_count"`
	Buckets                 []Bucket `json:"buckets"`
}

type EchoAggregations struct {
	EchoAgg  map[string]EchoAgg `json:"aggregations"`
	UniqEcho map[string]Uniq    `json:"uniqueEcho"`
}

type EchoBucket struct {
	Key   string `json:"key"`
	Count int64  `json:"doc_count"`
}

type Hit struct {
	Index  string     `json:"_index"`
	Type   string     `json:"_type"`
	ID     string     `json:"_id"`
	Source i2es.ESDoc `json:"_source"`
}

type Hits struct {
	Total    int64   `json:"total"`
	MaxScore float64 `json:"max_score"`
	Hits     []Hit   `json:"hits"`
}

type MaxIdAggregation struct {
	Hits  UserHits        `json:"hits"`
	MaxID map[string]Uniq `json:"aggregations"`
}

type PointRequest struct {
	Pauth string `json:"pauth"`
	Tmsg  string `json:"tmsg"`
}

type Uniq struct {
	Value float64 `json:"value"`
}

type User struct {
	// Will be added to the address:
	// i.e. dynamic,1
	UserID int64 `json:"user_id"`
	// Will be added to the bundled message
	Name string `json:"name"`
	// Email address needs for password restore
	Email      string `json:"email"`
	AuthString string `json:"auth_string"`
	Address    string `json:"address"`
	// Created time
	Created int64 `json:"created"`
}

type UserHit struct {
	Index  string  `json:"_index"`
	Type   string  `json:"_type"`
	ID     string  `json:"_id"`
	Score  float64 `json:"_score"`
	Source User    `json:"_source"`
}

type UserHits struct {
	Total    int64     `json:"total"`
	MaxScore float64   `json:"max_score"`
	Hits     []UserHit `json:"hits"`
}