rpcutils

type Addresses struct {
	Address []string `json:"address"` // 地址列表
}

type BaseStatsItem struct {
	ChildStatsItems []StatsItem // 子统计项组件列表
	MaxStatsItems   int
	sync.RWMutex
}

type CallBackFunc func(req interface{}) (interface{}, error)

type ClientRequest struct {
	Method string              `json:"method"` // 请求方法
	Params [1]*json.RawMessage `json:"params"` // 请求参数
	ID     uint64              `json:"id"`     // 请求标识
}

type CountByTime struct {
	Match  []*QMatch `json:"match"`  // 匹配条件
	Ranges *QRanges  `json:"ranges"` // 范围
}

type DBRead struct {
	Title    string
	Prefix   string
	Host     string
	Symbol   string
	Version  int32
	ID       string
	Username string
	Password string
}

type DonateStatsItem struct {
	PrintJSON string
	StatsComm
}

type DonationStats struct {
	Match     []*QMatch  `json:"match"`     // 匹配条件
	TermsAgg  *QMatchKey `json:"termsAgg"`  // 聚合字段
	SubSumAgg *QMatchKey `json:"subSumAgg"` // 子聚合字段
}

type Hashes struct {
	Hash []string `json:"hash"` // 哈希列表
}

type Organizations struct {
	Organization []string `json:"organization"` // 组织列表
}

type QMatch struct {
	Key   string      `json:"key"`   // 字段名
	Value interface{} `json:"value"` // 值
}

type QMatchKey struct {
	Key string `json:"key"` // 字段名
}

type QPage struct {
	Size   int `json:"size"`   // 大小
	Number int `json:"number"` // 当前页数
}

type QRange struct {
	Key    string      `json:"key"`   // 字段名
	RStart interface{} `json:"start"` // 开始位置（大于等于）
	REnd   interface{} `json:"end"`   // 结束位置（小于等于）
	GT     interface{} `json:"gt"`    // 大于
	LT     interface{} `json:"lt"`    // 小于
}

type QRanges struct {
	Key    string   `json:"key"`    // 字段名
	Ranges []*Range `json:"ranges"` // 范围
}

type QSort struct {
	Key       string `json:"key"`       // 字段名
	Ascending bool   `json:"ascending"` // 是否升序
}

type Range struct {
	RStart interface{} `json:"start"` // 开始位置（大于等于）
	REnd   interface{} `json:"end"`   // 结束位置（小于等于）
}

type RepDonationStat struct {
	Name  string  `json:"name"`  // 名字
	Total float64 `json:"total"` // 总和
	Count int64   `json:"count"` // 个数
}

type RepDonationStates struct {
	Itemes []*RepDonationStat `json:"itemes"` // 项
}

type RepLastSeq struct {
	LastSyncSeq    int64 `json:"lastSyncSeq"`    // 最新同步区块高度
	LastConvertSeq int64 `json:"lastConvertSeq"` // 最新解析区块高度
}

type RepSubTermsAgg struct {
	SubTermsAggKey string `json:"subTermsAggKey"` // 子聚合字段
	Count          int64  `json:"count"`          // 计数
}

type RepTermsAgg struct {
	Count         int64             `json:"count"`         // 计数
	TermsAggKey   string            `json:"termsAggKey"`   // 聚合字段
	SubTermsAgges []*RepSubTermsAgg `json:"subTermsAgges"` // 子聚合字段
}

type RepVolunteerStat struct {
	TermsAgges []*RepTermsAgg `json:"termsAgges"` // 聚合信息
	Count      int64          `json:"count"`      // 计数
}

type ServerResponse struct {
	ID     uint64      `json:"id"`     // 请求标识
	Result interface{} `json:"result"` // 返回结果
	Error  interface{} `json:"error"`  // 错误描述
}

type SpecifiedFields struct {
	Match  []*QMatch `json:"match"`  // 匹配条件
	Sort   []*QSort  `json:"sort"`   // 排序
	Count  int       `json:"count"`  // 总量
	Fields []string  `json:"fields"` // 字段列表
}

type StatsComm interface {
	SetLastSeq(lastseq int64)
	GetLastSeq() int64
	SetTimeout(timeout *time.Timer)
	GetTimeout() *time.Timer
	StopTimeOut()
	SetIsRefreshing(IsRefreshing bool)
	GetIsRefreshing() bool
	GetInterval() int64
	GetLastCallTime() int64
	Update(rep interface{})
	GetRep() interface{}
	GetReq() interface{}
	PrintStatusJSON() string
	StatsHandle(req interface{}) (interface{}, error)
}

type StatsCommInfo struct {
	Req          interface{}
	Rep          interface{}
	Interval     int64
	LastSeq      int64
	LastCallTime int64
	IsRefreshing bool

	sync.RWMutex
	CallBack CallBackFunc
	// contains filtered or unexported fields
}

type StatsItem interface {
	IsMatch(falgType int, req interface{}) bool
	PrintStatsItemJSON() string
	StatsComm
}

type StatsItemStatus struct {
	Interval     int64 `json:"interval"`
	LastSeq      int64 `json:"lastSeq"`
	LastCallTime int64 `json:"lastCallTime"`
	IsRefreshing bool  `json:"isRefreshing"`
}

type TotalStats struct {
	Match  []*QMatch  `json:"match"`  // 匹配条件
	SumAgg *QMatchKey `json:"sumAgg"` // 聚合字段
}

type VolunteerStats struct {
	Match       []*QMatch  `json:"match"`       // 匹配条件
	TermsAgg    *QMatchKey `json:"termsAgg"`    // 聚合字段
	SubTermsAgg *QMatchKey `json:"subTermsAgg"` // 子组合字段
	SubSumAgg   *QMatchKey `json:"subSumAgg"`   // 子统计字段
}

type VolunteerStatsItem struct {
	PrintJSON string
	StatsComm
}