flowcount

Documentation

Index

• func RedisConfDo(commandName string, args ...interface{}) (interface{}, error)
• func RedisConfPipline(pip ...func(c redis.Conn)) error
• type FlowCounter
  • func NewFlowCounter() *FlowCounter
  • func (counter *FlowCounter) GetCounter(serviceName string) (*RedisFlowCountService, error)
• type RedisFlowCountService
  • func NewRedisFlowCountService(appID string, interval time.Duration) *RedisFlowCountService
  • func (o *RedisFlowCountService) GetDayData(t time.Time) (int64, error)
  • func (o *RedisFlowCountService) GetDayKey(t time.Time) string
  • func (o *RedisFlowCountService) GetHourData(t time.Time) (int64, error)
  • func (o *RedisFlowCountService) GetHourKey(t time.Time) string
  • func (o *RedisFlowCountService) Increase()

Functions

func RedisConfDo

func RedisConfDo(commandName string, args ...interface{}) (interface{}, error)

func RedisConfPipline

func RedisConfPipline(pip ...func(c redis.Conn)) error

Types

type FlowCounter

type FlowCounter struct {
	// 当服务多的时候使用map方便，但是需要加锁
	RedisFlowCountMap map[string]*RedisFlowCountService
	// 当服务比较少的时候使用 slice 便利，减少锁的开销
	RedisFlowCountSlice []*RedisFlowCountService
	Locker              sync.RWMutex
}

var FlowCounterHandler *FlowCounter

func NewFlowCounter

func NewFlowCounter() *FlowCounter

func (*FlowCounter) GetCounter

func (counter *FlowCounter) GetCounter(serviceName string) (*RedisFlowCountService, error)

type RedisFlowCountService

type RedisFlowCountService struct {
	AppID       string
	Interval    time.Duration
	QPS         int64
	Unix        int64
	TickerCount int64
	TotalCount  int64
}

func NewRedisFlowCountService

func NewRedisFlowCountService(appID string, interval time.Duration) *RedisFlowCountService

func (*RedisFlowCountService) GetDayData

func (o *RedisFlowCountService) GetDayData(t time.Time) (int64, error)

func (*RedisFlowCountService) GetDayKey

func (o *RedisFlowCountService) GetDayKey(t time.Time) string

func (*RedisFlowCountService) GetHourData

func (o *RedisFlowCountService) GetHourData(t time.Time) (int64, error)

func (*RedisFlowCountService) GetHourKey

func (o *RedisFlowCountService) GetHourKey(t time.Time) string

func (*RedisFlowCountService) Increase

func (o *RedisFlowCountService) Increase()

原子增加