stats

Documentation

Index

• Variables
• type BandwidthStat
• type BandwidthStatManager
  • func NewBandwidthStatManager() *BandwidthStatManager
  • func (this *BandwidthStatManager) Add(userId int64, serverId int64, bytes int64)
  • func (this *BandwidthStatManager) Inspect()
  • func (this *BandwidthStatManager) Loop() error
  • func (this *BandwidthStatManager) Start()
• type HTTPRequestStatManager
  • func NewHTTPRequestStatManager() *HTTPRequestStatManager
  • func (this *HTTPRequestStatManager) AddFirewallRuleGroupId(serverId int64, firewallRuleGroupId int64, actions []*waf.ActionConfig)
  • func (this *HTTPRequestStatManager) AddRemoteAddr(serverId int64, remoteAddr string, bytes int64, isAttack bool)
  • func (this *HTTPRequestStatManager) AddUserAgent(serverId int64, userAgent string)
  • func (this *HTTPRequestStatManager) Loop() error
  • func (this *HTTPRequestStatManager) Start()
  • func (this *HTTPRequestStatManager) Upload() error
• type StatItem
• type TrafficItem
• type TrafficStatManager
  • func NewTrafficStatManager() *TrafficStatManager
  • func (this *TrafficStatManager) Add(serverId int64, domain string, bytes int64, cachedBytes int64, ...)
  • func (this *TrafficStatManager) Start(configFunc func() *nodeconfigs.NodeConfig)
  • func (this *TrafficStatManager) Upload() error
• type UserAgentParser
  • func NewUserAgentParser() *UserAgentParser
  • func (this *UserAgentParser) Parse(userAgent string) (result UserAgentParserResult)
• type UserAgentParserResult

Variables

var SharedBandwidthStatManager = NewBandwidthStatManager()

var SharedHTTPRequestStatManager = NewHTTPRequestStatManager()

var SharedTrafficStatManager = NewTrafficStatManager()

var SharedUserAgentParser = NewUserAgentParser()

Types

type BandwidthStat

type BandwidthStat struct {
	Day      string
	TimeAt   string
	UserId   int64
	ServerId int64

	CurrentBytes     int64
	CurrentTimestamp int64
	MaxBytes         int64
}

type BandwidthStatManager

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

BandwidthStatManager 服务带宽统计

func NewBandwidthStatManager

func NewBandwidthStatManager() *BandwidthStatManager

func (*BandwidthStatManager) Add

func (this *BandwidthStatManager) Add(userId int64, serverId int64, bytes int64)

Add 添加带宽数据

func (*BandwidthStatManager) Inspect

func (this *BandwidthStatManager) Inspect()

func (*BandwidthStatManager) Loop

func (this *BandwidthStatManager) Loop() error

func (*BandwidthStatManager) Start

func (this *BandwidthStatManager) Start()

type HTTPRequestStatManager

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

HTTPRequestStatManager HTTP请求相关的统计 这里的统计是一个辅助统计，注意不要因为统计而影响服务工作性能

func NewHTTPRequestStatManager

func NewHTTPRequestStatManager() *HTTPRequestStatManager

NewHTTPRequestStatManager 获取新对象

func (*HTTPRequestStatManager) AddFirewallRuleGroupId

func (this *HTTPRequestStatManager) AddFirewallRuleGroupId(serverId int64, firewallRuleGroupId int64, actions []*waf.ActionConfig)

AddFirewallRuleGroupId 添加防火墙拦截动作

func (*HTTPRequestStatManager) AddRemoteAddr

func (this *HTTPRequestStatManager) AddRemoteAddr(serverId int64, remoteAddr string, bytes int64, isAttack bool)

AddRemoteAddr 添加客户端地址

func (*HTTPRequestStatManager) AddUserAgent

func (this *HTTPRequestStatManager) AddUserAgent(serverId int64, userAgent string)

AddUserAgent 添加UserAgent

func (*HTTPRequestStatManager) Loop

func (this *HTTPRequestStatManager) Loop() error

Loop 单个循环

func (*HTTPRequestStatManager) Start

func (this *HTTPRequestStatManager) Start()

Start 启动

func (*HTTPRequestStatManager) Upload

func (this *HTTPRequestStatManager) Upload() error

Upload 上传数据

type StatItem

type StatItem struct {
	Bytes               int64
	CountRequests       int64
	CountAttackRequests int64
	AttackBytes         int64
}

type TrafficItem

type TrafficItem struct {
	Bytes                int64
	CachedBytes          int64
	CountRequests        int64
	CountCachedRequests  int64
	CountAttackRequests  int64
	AttackBytes          int64
	PlanId               int64
	CheckingTrafficLimit bool
}

type TrafficStatManager

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

TrafficStatManager 区域流量统计

func NewTrafficStatManager

func NewTrafficStatManager() *TrafficStatManager

NewTrafficStatManager 获取新对象

func (*TrafficStatManager) Add

func (this *TrafficStatManager) Add(serverId int64, domain string, bytes int64, cachedBytes int64, countRequests int64, countCachedRequests int64, countAttacks int64, attackBytes int64, checkingTrafficLimit bool, planId int64)

Add 添加流量

func (*TrafficStatManager) Start

func (this *TrafficStatManager) Start(configFunc func() *nodeconfigs.NodeConfig)

Start 启动自动任务

func (*TrafficStatManager) Upload

func (this *TrafficStatManager) Upload() error

Upload 上传流量

type UserAgentParser

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

UserAgentParser UserAgent解析器

func NewUserAgentParser

func NewUserAgentParser() *UserAgentParser

func (*UserAgentParser) Parse

func (this *UserAgentParser) Parse(userAgent string) (result UserAgentParserResult)

type UserAgentParserResult

type UserAgentParserResult struct {
	OS             user_agent.OSInfo
	BrowserName    string
	BrowserVersion string
	IsMobile       bool
}