firewall

README

Firewall

Intro

files	how it works	Benchmark / 2.6 GHz Intel Core i7
Limiter	limiter interface
SleepLimiter	sleep process when tokens are run out	20M / qps 81.9 ns/op
MutexLimiter	use mutex counter and ticker to rate	100M / qps 14.2 ns/op
Semaphore	wraped chan struct{}	30M / qps 40.4 ns/op

How to use

// RateLimiter
limiter := New{XXX}Limiter(1*time.Second, 300)	// 300 tokens in one second
limiter.Acquire()	// return immediately or waiting useable token

// Semaphore
sema := NewChanSemaphore(cap)
sema.Acquire()
sema.Release()

Documentation

Index

• type ChanResourceLimiter
  • func NewChanResourcePool(cap int) *ChanResourceLimiter
  • func (this *ChanResourceLimiter) Acquire() interface{}
  • func (this *ChanResourceLimiter) Release(resource interface{})
• type ChanSemaphore
  • func NewChanSemaphore(cap int) *ChanSemaphore
  • func (this *ChanSemaphore) Acquire()
  • func (this *ChanSemaphore) Release()
• type Limiter
• type MutexLimiter
  • func NewMutexLimiter(ttl time.Duration, limit int) *MutexLimiter
  • func (l *MutexLimiter) Acquire()
• type ResourceLimiter
• type Semaphore
  • func NewSemaphore(cap int) Semaphore
• type SleepLimiter
  • func NewSleepLimiter(ttl time.Duration, limit int) *SleepLimiter
  • func (this *SleepLimiter) Acquire()

Types

type ChanResourceLimiter

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

func NewChanResourcePool

func NewChanResourcePool(cap int) *ChanResourceLimiter

NewChanResourcePool ...

func (*ChanResourceLimiter) Acquire

func (this *ChanResourceLimiter) Acquire() interface{}

func (*ChanResourceLimiter) Release

func (this *ChanResourceLimiter) Release(resource interface{})

type ChanSemaphore

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

Semaphore 限制同一时刻，最多可以发生的次数

func NewChanSemaphore

func NewChanSemaphore(cap int) *ChanSemaphore

NewChanSemaphore

func (*ChanSemaphore) Acquire

func (this *ChanSemaphore) Acquire()

func (*ChanSemaphore) Release

func (this *ChanSemaphore) Release()

type Limiter

type Limiter interface {
	Acquire()
}

type MutexLimiter

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

func NewMutexLimiter

func NewMutexLimiter(ttl time.Duration, limit int) *MutexLimiter

func (*MutexLimiter) Acquire

func (l *MutexLimiter) Acquire()

type ResourceLimiter

type ResourceLimiter interface {
	Acquire() interface{}
	Release(resource interface{})
}

type Semaphore

type Semaphore interface {
	// P wait()
	Acquire()

	// V signal()
	Release()
}

func NewSemaphore

func NewSemaphore(cap int) Semaphore

NewSemaphore

type SleepLimiter

type SleepLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

SleepLimiter 限制单位时间内的可执行次数

func NewSleepLimiter

func NewSleepLimiter(ttl time.Duration, limit int) *SleepLimiter

func (*SleepLimiter) Acquire

func (this *SleepLimiter) Acquire()