teastats

package
v0.0.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 4, 2019 License: MIT Imports: 19 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	ValuePeriodSecond = "second"
	ValuePeriodMinute = "minute"
	ValuePeriodHour   = "hour"
	ValuePeriodDay    = "day"
	ValuePeriodWeek   = "week"
	ValuePeriodMonth  = "month"
	ValuePeriodYear   = "year"
)

Variables

View Source 
var AllStartedServers = maps.Map{} // serverId => *ServerQueue
View Source 
var AllStatFilters = []maps.Map{}

Functions

func FindAllStatFilters 

func FindAllStatFilters() []maps.Map

获取所有的filter

func RegisterFilter 

func RegisterFilter(filters ...FilterInterface)

注册一个或多个筛选器

func RestartServerFilters 

func RestartServerFilters(serverId string, codes []string)

启动一个服务的筛选器

Types

type BackendAllPeriodFilter 

type BackendAllPeriodFilter struct {
	CounterFilter
}

后端统计

func (*BackendAllPeriodFilter) Codes 

func (this *BackendAllPeriodFilter) Codes() []string

func (*BackendAllPeriodFilter) Filter 

func (this *BackendAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*BackendAllPeriodFilter) Indexes 

func (this *BackendAllPeriodFilter) Indexes() []string

func (*BackendAllPeriodFilter) Name 

func (this *BackendAllPeriodFilter) Name() string

func (*BackendAllPeriodFilter) Start 

func (this *BackendAllPeriodFilter) Start(queue *Queue, code string)

func (*BackendAllPeriodFilter) Stop 

func (this *BackendAllPeriodFilter) Stop()

type BrowserAllPeriodFilter 

type BrowserAllPeriodFilter struct {
	CounterFilter
}

浏览器统计

func (*BrowserAllPeriodFilter) Codes 

func (this *BrowserAllPeriodFilter) Codes() []string

func (*BrowserAllPeriodFilter) Filter 

func (this *BrowserAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*BrowserAllPeriodFilter) Indexes 

func (this *BrowserAllPeriodFilter) Indexes() []string

func (*BrowserAllPeriodFilter) Name 

func (this *BrowserAllPeriodFilter) Name() string

func (*BrowserAllPeriodFilter) Start 

func (this *BrowserAllPeriodFilter) Start(queue *Queue, code string)

func (*BrowserAllPeriodFilter) Stop 

func (this *BrowserAllPeriodFilter) Stop()

type CityAllPeriodFilter 

type CityAllPeriodFilter struct {
	CounterFilter
}

城市统计

func (*CityAllPeriodFilter) Codes 

func (this *CityAllPeriodFilter) Codes() []string

func (*CityAllPeriodFilter) Filter 

func (this *CityAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*CityAllPeriodFilter) Indexes 

func (this *CityAllPeriodFilter) Indexes() []string

func (*CityAllPeriodFilter) Name 

func (this *CityAllPeriodFilter) Name() string

func (*CityAllPeriodFilter) Start 

func (this *CityAllPeriodFilter) Start(queue *Queue, code string)

func (*CityAllPeriodFilter) Stop 

func (this *CityAllPeriodFilter) Stop()

type CostAllPeriodFilter 

type CostAllPeriodFilter struct {
	CounterFilter
}

耗时统计

func (*CostAllPeriodFilter) Codes 

func (this *CostAllPeriodFilter) Codes() []string

func (*CostAllPeriodFilter) Filter 

func (this *CostAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*CostAllPeriodFilter) Indexes 

func (this *CostAllPeriodFilter) Indexes() []string

func (*CostAllPeriodFilter) Name 

func (this *CostAllPeriodFilter) Name() string

func (*CostAllPeriodFilter) Start 

func (this *CostAllPeriodFilter) Start(queue *Queue, code string)

func (*CostAllPeriodFilter) Stop 

func (this *CostAllPeriodFilter) Stop()

type CostPagePeriodFilter 

type CostPagePeriodFilter struct {
	CounterFilter
}

耗时统计

func (*CostPagePeriodFilter) Codes 

func (this *CostPagePeriodFilter) Codes() []string

func (*CostPagePeriodFilter) Filter 

func (this *CostPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*CostPagePeriodFilter) Indexes 

func (this *CostPagePeriodFilter) Indexes() []string

func (*CostPagePeriodFilter) Name 

func (this *CostPagePeriodFilter) Name() string

func (*CostPagePeriodFilter) Start 

func (this *CostPagePeriodFilter) Start(queue *Queue, code string)

func (*CostPagePeriodFilter) Stop 

func (this *CostPagePeriodFilter) Stop()

type CounterFilter 

type CounterFilter struct {
	Period ValuePeriod

	IncreaseFunc func(value maps.Map, inc maps.Map) maps.Map
	// contains filtered or unexported fields
}

数值增长型的

func (*CounterFilter) ApplyFilter 

func (this *CounterFilter) ApplyFilter(accessLog *tealogs.AccessLog, params map[string]string, value map[string]interface{})

应用筛选器

func (*CounterFilter) CheckNewIP 

func (this *CounterFilter) CheckNewIP(accessLog *tealogs.AccessLog, attachKey string) bool

检查新IP

func (*CounterFilter) CheckNewUV 

func (this *CounterFilter) CheckNewUV(accessLog *tealogs.AccessLog, attachKey string) bool

检查新UV

func (*CounterFilter) StartFilter 

func (this *CounterFilter) StartFilter(code string, period ValuePeriod)

启动筛选器

func (*CounterFilter) StopFilter 

func (this *CounterFilter) StopFilter()

停止筛选器

type DeviceAllPeriodFilter 

type DeviceAllPeriodFilter struct {
	CounterFilter
}

设备统计

func (*DeviceAllPeriodFilter) Codes 

func (this *DeviceAllPeriodFilter) Codes() []string

func (*DeviceAllPeriodFilter) Filter 

func (this *DeviceAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*DeviceAllPeriodFilter) Indexes 

func (this *DeviceAllPeriodFilter) Indexes() []string

func (*DeviceAllPeriodFilter) Name 

func (this *DeviceAllPeriodFilter) Name() string

func (*DeviceAllPeriodFilter) Start 

func (this *DeviceAllPeriodFilter) Start(queue *Queue, code string)

func (*DeviceAllPeriodFilter) Stop 

func (this *DeviceAllPeriodFilter) Stop()

type FastcgiAllPeriodFilter 

type FastcgiAllPeriodFilter struct {
	CounterFilter
}

Fastcgi请求统计

func (*FastcgiAllPeriodFilter) Codes 

func (this *FastcgiAllPeriodFilter) Codes() []string

func (*FastcgiAllPeriodFilter) Filter 

func (this *FastcgiAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*FastcgiAllPeriodFilter) Indexes 

func (this *FastcgiAllPeriodFilter) Indexes() []string

func (*FastcgiAllPeriodFilter) Name 

func (this *FastcgiAllPeriodFilter) Name() string

func (*FastcgiAllPeriodFilter) Start 

func (this *FastcgiAllPeriodFilter) Start(queue *Queue, code string)

func (*FastcgiAllPeriodFilter) Stop 

func (this *FastcgiAllPeriodFilter) Stop()

type FilterInterface 

type FilterInterface interface {
	// 名称
	Name() string

	// 代号
	Codes() []string

	// 索引参数
	Indexes() []string

	// 启动
	Start(queue *Queue, code string)

	// 筛选某个访问日志
	Filter(accessLog *tealogs.AccessLog)

	// 停止
	Stop()
}

筛选器接口

func FindFilter 

func FindFilter(code string) FilterInterface

查找单个Filter

type IPAllPeriodFilter 

type IPAllPeriodFilter struct {
	CounterFilter
}

IP统计

func (*IPAllPeriodFilter) Codes 

func (this *IPAllPeriodFilter) Codes() []string

func (*IPAllPeriodFilter) Filter 

func (this *IPAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*IPAllPeriodFilter) Indexes 

func (this *IPAllPeriodFilter) Indexes() []string

func (*IPAllPeriodFilter) Name 

func (this *IPAllPeriodFilter) Name() string

func (*IPAllPeriodFilter) Start 

func (this *IPAllPeriodFilter) Start(queue *Queue, code string)

func (*IPAllPeriodFilter) Stop 

func (this *IPAllPeriodFilter) Stop()

type IPPagePeriodFilter 

type IPPagePeriodFilter struct {
	CounterFilter
}

IP统计

func (*IPPagePeriodFilter) Codes 

func (this *IPPagePeriodFilter) Codes() []string

func (*IPPagePeriodFilter) Filter 

func (this *IPPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*IPPagePeriodFilter) Indexes 

func (this *IPPagePeriodFilter) Indexes() []string

func (*IPPagePeriodFilter) Name 

func (this *IPPagePeriodFilter) Name() string

func (*IPPagePeriodFilter) Start 

func (this *IPPagePeriodFilter) Start(queue *Queue, code string)

func (*IPPagePeriodFilter) Stop 

func (this *IPPagePeriodFilter) Stop()

type KVStorage 

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

KV存储引擎

func NewKVStorage 

func NewKVStorage(filename string) *KVStorage

获取新对象

func (*KVStorage) Close 

func (this *KVStorage) Close() error

关闭

func (*KVStorage) Get 

func (this *KVStorage) Get(key string) (string, error)

获取键对应的值

func (*KVStorage) Has 

func (this *KVStorage) Has(key string) (bool, error)

检查key是否存在，并不检查是否过期

func (*KVStorage) Set 

func (this *KVStorage) Set(key string, value string, life time.Duration) error

设置键值对

type LandingPagePeriodFilter 

type LandingPagePeriodFilter struct {
	CounterFilter
}

登陆页统计

func (*LandingPagePeriodFilter) Codes 

func (this *LandingPagePeriodFilter) Codes() []string

func (*LandingPagePeriodFilter) Filter 

func (this *LandingPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*LandingPagePeriodFilter) Indexes 

func (this *LandingPagePeriodFilter) Indexes() []string

func (*LandingPagePeriodFilter) Name 

func (this *LandingPagePeriodFilter) Name() string

func (*LandingPagePeriodFilter) Start 

func (this *LandingPagePeriodFilter) Start(queue *Queue, code string)

func (*LandingPagePeriodFilter) Stop 

func (this *LandingPagePeriodFilter) Stop()

type LocationAllPeriodFilter 

type LocationAllPeriodFilter struct {
	CounterFilter
}

路径规则请求统计

func (*LocationAllPeriodFilter) Codes 

func (this *LocationAllPeriodFilter) Codes() []string

func (*LocationAllPeriodFilter) Filter 

func (this *LocationAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*LocationAllPeriodFilter) Indexes 

func (this *LocationAllPeriodFilter) Indexes() []string

func (*LocationAllPeriodFilter) Name 

func (this *LocationAllPeriodFilter) Name() string

func (*LocationAllPeriodFilter) Start 

func (this *LocationAllPeriodFilter) Start(queue *Queue, code string)

func (*LocationAllPeriodFilter) Stop 

func (this *LocationAllPeriodFilter) Stop()

type MethodAllPeriodFilter 

type MethodAllPeriodFilter struct {
	CounterFilter
}

请求方法统计

func (*MethodAllPeriodFilter) Codes 

func (this *MethodAllPeriodFilter) Codes() []string

func (*MethodAllPeriodFilter) Filter 

func (this *MethodAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*MethodAllPeriodFilter) Indexes 

func (this *MethodAllPeriodFilter) Indexes() []string

func (*MethodAllPeriodFilter) Name 

func (this *MethodAllPeriodFilter) Name() string

func (*MethodAllPeriodFilter) Start 

func (this *MethodAllPeriodFilter) Start(queue *Queue, code string)

func (*MethodAllPeriodFilter) Stop 

func (this *MethodAllPeriodFilter) Stop()

type MethodPagePeriodFilter 

type MethodPagePeriodFilter struct {
	CounterFilter
}

请求方法统计

func (*MethodPagePeriodFilter) Codes 

func (this *MethodPagePeriodFilter) Codes() []string

func (*MethodPagePeriodFilter) Filter 

func (this *MethodPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*MethodPagePeriodFilter) Indexes 

func (this *MethodPagePeriodFilter) Indexes() []string

func (*MethodPagePeriodFilter) Name 

func (this *MethodPagePeriodFilter) Name() string

func (*MethodPagePeriodFilter) Start 

func (this *MethodPagePeriodFilter) Start(queue *Queue, code string)

func (*MethodPagePeriodFilter) Stop 

func (this *MethodPagePeriodFilter) Stop()

type OSAllPeriodFilter 

type OSAllPeriodFilter struct {
	CounterFilter
}

操作系统统计

func (*OSAllPeriodFilter) Codes 

func (this *OSAllPeriodFilter) Codes() []string

func (*OSAllPeriodFilter) Filter 

func (this *OSAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*OSAllPeriodFilter) Indexes 

func (this *OSAllPeriodFilter) Indexes() []string

func (*OSAllPeriodFilter) Name 

func (this *OSAllPeriodFilter) Name() string

func (*OSAllPeriodFilter) Start 

func (this *OSAllPeriodFilter) Start(queue *Queue, code string)

func (*OSAllPeriodFilter) Stop 

func (this *OSAllPeriodFilter) Stop()

type PVAllPeriodFilter 

type PVAllPeriodFilter struct {
	CounterFilter
}

PV统计

func (*PVAllPeriodFilter) Codes 

func (this *PVAllPeriodFilter) Codes() []string

func (*PVAllPeriodFilter) Filter 

func (this *PVAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*PVAllPeriodFilter) Indexes 

func (this *PVAllPeriodFilter) Indexes() []string

func (*PVAllPeriodFilter) Name 

func (this *PVAllPeriodFilter) Name() string

func (*PVAllPeriodFilter) Start 

func (this *PVAllPeriodFilter) Start(queue *Queue, code string)

func (*PVAllPeriodFilter) Stop 

func (this *PVAllPeriodFilter) Stop()

type PVPagePeriodFilter 

type PVPagePeriodFilter struct {
	CounterFilter
}

PV统计

func (*PVPagePeriodFilter) Codes 

func (this *PVPagePeriodFilter) Codes() []string

func (*PVPagePeriodFilter) Filter 

func (this *PVPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*PVPagePeriodFilter) Indexes 

func (this *PVPagePeriodFilter) Indexes() []string

func (*PVPagePeriodFilter) Name 

func (this *PVPagePeriodFilter) Name() string

func (*PVPagePeriodFilter) Start 

func (this *PVPagePeriodFilter) Start(queue *Queue, code string)

func (*PVPagePeriodFilter) Stop 

func (this *PVPagePeriodFilter) Stop()

type ProvinceAllPeriodFilter 

type ProvinceAllPeriodFilter struct {
	CounterFilter
}

省份统计

func (*ProvinceAllPeriodFilter) Codes 

func (this *ProvinceAllPeriodFilter) Codes() []string

func (*ProvinceAllPeriodFilter) Filter 

func (this *ProvinceAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*ProvinceAllPeriodFilter) Indexes 

func (this *ProvinceAllPeriodFilter) Indexes() []string

func (*ProvinceAllPeriodFilter) Name 

func (this *ProvinceAllPeriodFilter) Name() string

func (*ProvinceAllPeriodFilter) Start 

func (this *ProvinceAllPeriodFilter) Start(queue *Queue, code string)

func (*ProvinceAllPeriodFilter) Stop 

func (this *ProvinceAllPeriodFilter) Stop()

type Queue 

type Queue struct {
	ServerId string
	// contains filtered or unexported fields
}

入库队列

func NewQueue 

func NewQueue() *Queue

获取新对象

func (*Queue) Add 

func (this *Queue) Add(itemCode string, t time.Time, period ValuePeriod, params map[string]string, value maps.Map)

添加指标值

func (*Queue) Index 

func (this *Queue) Index(index []string)

添加索引

func (*Queue) Start 

func (this *Queue) Start(serverId string)

队列单例

func (*Queue) Stop 

func (this *Queue) Stop()

停止

type RefererDomainPeriodFilter 

type RefererDomainPeriodFilter struct {
	CounterFilter
}

来源域名统计

func (*RefererDomainPeriodFilter) Codes 

func (this *RefererDomainPeriodFilter) Codes() []string

func (*RefererDomainPeriodFilter) Filter 

func (this *RefererDomainPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*RefererDomainPeriodFilter) Indexes 

func (this *RefererDomainPeriodFilter) Indexes() []string

func (*RefererDomainPeriodFilter) Name 

func (this *RefererDomainPeriodFilter) Name() string

func (*RefererDomainPeriodFilter) Start 

func (this *RefererDomainPeriodFilter) Start(queue *Queue, code string)

func (*RefererDomainPeriodFilter) Stop 

func (this *RefererDomainPeriodFilter) Stop()

type RefererURLPeriodFilter 

type RefererURLPeriodFilter struct {
	CounterFilter
}

来源URL统计

func (*RefererURLPeriodFilter) Codes 

func (this *RefererURLPeriodFilter) Codes() []string

func (*RefererURLPeriodFilter) Filter 

func (this *RefererURLPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*RefererURLPeriodFilter) Indexes 

func (this *RefererURLPeriodFilter) Indexes() []string

func (*RefererURLPeriodFilter) Name 

func (this *RefererURLPeriodFilter) Name() string

func (*RefererURLPeriodFilter) Start 

func (this *RefererURLPeriodFilter) Start(queue *Queue, code string)

func (*RefererURLPeriodFilter) Stop 

func (this *RefererURLPeriodFilter) Stop()

type RegionAllPeriodFilter 

type RegionAllPeriodFilter struct {
	CounterFilter
}

区域统计

func (*RegionAllPeriodFilter) Codes 

func (this *RegionAllPeriodFilter) Codes() []string

func (*RegionAllPeriodFilter) Filter 

func (this *RegionAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*RegionAllPeriodFilter) Indexes 

func (this *RegionAllPeriodFilter) Indexes() []string

func (*RegionAllPeriodFilter) Name 

func (this *RegionAllPeriodFilter) Name() string

func (*RegionAllPeriodFilter) Start 

func (this *RegionAllPeriodFilter) Start(queue *Queue, code string)

func (*RegionAllPeriodFilter) Stop 

func (this *RegionAllPeriodFilter) Stop()

type RequestAllPeriodFilter 

type RequestAllPeriodFilter struct {
	CounterFilter
}

请求数统计

func (*RequestAllPeriodFilter) Codes 

func (this *RequestAllPeriodFilter) Codes() []string

func (*RequestAllPeriodFilter) Filter 

func (this *RequestAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*RequestAllPeriodFilter) Indexes 

func (this *RequestAllPeriodFilter) Indexes() []string

func (*RequestAllPeriodFilter) Name 

func (this *RequestAllPeriodFilter) Name() string

func (*RequestAllPeriodFilter) Start 

func (this *RequestAllPeriodFilter) Start(queue *Queue, code string)

func (*RequestAllPeriodFilter) Stop 

func (this *RequestAllPeriodFilter) Stop()

type RequestPagePeriodFilter 

type RequestPagePeriodFilter struct {
	CounterFilter
}

请求数统计

func (*RequestPagePeriodFilter) Codes 

func (this *RequestPagePeriodFilter) Codes() []string

func (*RequestPagePeriodFilter) Filter 

func (this *RequestPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*RequestPagePeriodFilter) Indexes 

func (this *RequestPagePeriodFilter) Indexes() []string

func (*RequestPagePeriodFilter) Name 

func (this *RequestPagePeriodFilter) Name() string

func (*RequestPagePeriodFilter) Start 

func (this *RequestPagePeriodFilter) Start(queue *Queue, code string)

func (*RequestPagePeriodFilter) Stop 

func (this *RequestPagePeriodFilter) Stop()

type RewriteAllPeriodFilter 

type RewriteAllPeriodFilter struct {
	CounterFilter
}

重写规则请求统计

func (*RewriteAllPeriodFilter) Codes 

func (this *RewriteAllPeriodFilter) Codes() []string

func (*RewriteAllPeriodFilter) Filter 

func (this *RewriteAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*RewriteAllPeriodFilter) Indexes 

func (this *RewriteAllPeriodFilter) Indexes() []string

func (*RewriteAllPeriodFilter) Name 

func (this *RewriteAllPeriodFilter) Name() string

func (*RewriteAllPeriodFilter) Start 

func (this *RewriteAllPeriodFilter) Start(queue *Queue, code string)

func (*RewriteAllPeriodFilter) Stop 

func (this *RewriteAllPeriodFilter) Stop()

type ServerQueue 

type ServerQueue struct {
	Queue   *Queue
	Filters map[string]FilterInterface // code => instance
}

服务队列配置

func FindServerQueue 

func FindServerQueue(serverId string) *ServerQueue

查找ServerQueue

func (*ServerQueue) Filter 

func (this *ServerQueue) Filter(accessLog *tealogs.AccessLog)

func (*ServerQueue) StartFilter 

func (this *ServerQueue) StartFilter(code string)

func (*ServerQueue) Stop 

func (this *ServerQueue) Stop()

type StatusAllPeriodFilter 

type StatusAllPeriodFilter struct {
	CounterFilter
}

状态码统计

func (*StatusAllPeriodFilter) Codes 

func (this *StatusAllPeriodFilter) Codes() []string

func (*StatusAllPeriodFilter) Filter 

func (this *StatusAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*StatusAllPeriodFilter) Indexes 

func (this *StatusAllPeriodFilter) Indexes() []string

func (*StatusAllPeriodFilter) Name 

func (this *StatusAllPeriodFilter) Name() string

func (*StatusAllPeriodFilter) Start 

func (this *StatusAllPeriodFilter) Start(queue *Queue, code string)

func (*StatusAllPeriodFilter) Stop 

func (this *StatusAllPeriodFilter) Stop()

type StatusPagePeriodFilter 

type StatusPagePeriodFilter struct {
	CounterFilter
}

状态码统计

func (*StatusPagePeriodFilter) Codes 

func (this *StatusPagePeriodFilter) Codes() []string

提供的代码

func (*StatusPagePeriodFilter) Filter 

func (this *StatusPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

筛选

func (*StatusPagePeriodFilter) Indexes 

func (this *StatusPagePeriodFilter) Indexes() []string

func (*StatusPagePeriodFilter) Name 

func (this *StatusPagePeriodFilter) Name() string

func (*StatusPagePeriodFilter) Start 

func (this *StatusPagePeriodFilter) Start(queue *Queue, code string)

启动

func (*StatusPagePeriodFilter) Stop 

func (this *StatusPagePeriodFilter) Stop()

停止

type TrafficAllPeriodFilter 

type TrafficAllPeriodFilter struct {
	CounterFilter
}

流量统计

func (*TrafficAllPeriodFilter) Codes 

func (this *TrafficAllPeriodFilter) Codes() []string

func (*TrafficAllPeriodFilter) Filter 

func (this *TrafficAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*TrafficAllPeriodFilter) Indexes 

func (this *TrafficAllPeriodFilter) Indexes() []string

func (*TrafficAllPeriodFilter) Name 

func (this *TrafficAllPeriodFilter) Name() string

func (*TrafficAllPeriodFilter) Start 

func (this *TrafficAllPeriodFilter) Start(queue *Queue, code string)

func (*TrafficAllPeriodFilter) Stop 

func (this *TrafficAllPeriodFilter) Stop()

type TrafficPagePeriodFilter 

type TrafficPagePeriodFilter struct {
	CounterFilter
}

流量统计

func (*TrafficPagePeriodFilter) Codes 

func (this *TrafficPagePeriodFilter) Codes() []string

func (*TrafficPagePeriodFilter) Filter 

func (this *TrafficPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*TrafficPagePeriodFilter) Indexes 

func (this *TrafficPagePeriodFilter) Indexes() []string

func (*TrafficPagePeriodFilter) Name 

func (this *TrafficPagePeriodFilter) Name() string

func (*TrafficPagePeriodFilter) Start 

func (this *TrafficPagePeriodFilter) Start(queue *Queue, code string)

func (*TrafficPagePeriodFilter) Stop 

func (this *TrafficPagePeriodFilter) Stop()

type UVAllPeriodFilter 

type UVAllPeriodFilter struct {
	CounterFilter
}

UV统计

func (*UVAllPeriodFilter) Codes 

func (this *UVAllPeriodFilter) Codes() []string

func (*UVAllPeriodFilter) Filter 

func (this *UVAllPeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*UVAllPeriodFilter) Indexes 

func (this *UVAllPeriodFilter) Indexes() []string

func (*UVAllPeriodFilter) Name 

func (this *UVAllPeriodFilter) Name() string

func (*UVAllPeriodFilter) Start 

func (this *UVAllPeriodFilter) Start(queue *Queue, code string)

func (*UVAllPeriodFilter) Stop 

func (this *UVAllPeriodFilter) Stop()

type UVPagePeriodFilter 

type UVPagePeriodFilter struct {
	CounterFilter
}

UV统计

func (*UVPagePeriodFilter) Codes 

func (this *UVPagePeriodFilter) Codes() []string

func (*UVPagePeriodFilter) Filter 

func (this *UVPagePeriodFilter) Filter(accessLog *tealogs.AccessLog)

func (*UVPagePeriodFilter) Indexes 

func (this *UVPagePeriodFilter) Indexes() []string

func (*UVPagePeriodFilter) Name 

func (this *UVPagePeriodFilter) Name() string

func (*UVPagePeriodFilter) Start 

func (this *UVPagePeriodFilter) Start(queue *Queue, code string)

func (*UVPagePeriodFilter) Stop 

func (this *UVPagePeriodFilter) Stop()

type Value 

type Value struct {
	Id         primitive.ObjectID     `bson:"_id" json:"id"`              // 数据库存储的ID
	Item       string                 `bson:"item" json:"item"`           // 指标代号
	Period     ValuePeriod            `bson:"period" json:"period"`       // 周期
	Value      map[string]interface{} `bson:"value" json:"value"`         // 数据内容
	Params     map[string]string      `bson:"params" json:"params"`       // 参数
	Timestamp  int64                  `bson:"timestamp" json:"timestamp"` // 时间戳
	TimeFormat struct {
		Year   string `bson:"year" json:"year"`
		Month  string `bson:"month" json:"month"`
		Week   string `bson:"week" json:"week"`
		Day    string `bson:"day" json:"day"`
		Hour   string `bson:"hour" json:"hour"`
		Minute string `bson:"minute" json:"minute"`
		Second string `bson:"second" json:"second"`
	} `bson:"timeFormat" json:"timeFormat"` // 时间信息
}

统计指标值定义

func NewItemValue 

func NewItemValue() *Value

获取新对象

func (*Value) SetTime 

func (this *Value) SetTime(t time.Time)

type ValuePeriod 

type ValuePeriod = string

值周期

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.