rhinof / limiter

A lock free implementation of the Token Bucket rate limiting algorithm.

limiter

A lock free implementation of the Token Bucket rate limiting algorithm.

Usage

    //max # of bytes/s to allow
	maxThroughput := 1000
	// wrapped io.Writer interface
	writer := getWriter()	
	limiter := limiter.NewLimiter(writer, maxThroughput)
	buffer := []byte{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
	n, err := limiter.Write(buffer)
	fmt.Printf("written %d bytes to wrapped stream - err: %v", n, err)

License

Licensed under the MIT License