cache

Documentation

Index

• type DropCounter
• type DropDetection
  • func (d *DropDetection) Detect(id uint32, seq uint64, timestamp uint32)
  • func (d *DropDetection) GetCounter() interface{}
  • func (d *DropDetection) Init(name string, windowSize uint64)
• type Instance

Types

type DropCounter

type DropCounter struct {
	Dropped      uint64 `statsd:"dropped"`  // 当前SEQ减去上次的SEQ
	Disorder     uint64 `statsd:"disorder"` // 当前SEQ小于上次的SEQ时+1，包乱序并且超出了CACHE_SIZE
	DisorderSize uint64 `statsd:"disorder_size"`
}

type DropDetection

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

func (*DropDetection) Detect

func (d *DropDetection) Detect(id uint32, seq uint64, timestamp uint32)

func (*DropDetection) GetCounter

func (d *DropDetection) GetCounter() interface{}

func (*DropDetection) Init

func (d *DropDetection) Init(name string, windowSize uint64)

type Instance

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