func (c *RateRedisCounter) IncrBy(val int64) error {
	curTimeShard := c.timer.UnixNano() / int64(c.resolution)
	key := c.makeKey(curTimeShard)

	c.conn.Send("MULTI")
	c.conn.Send("INCRBY", key, val)
	c.conn.Send("EXPIRE", key, int(c.period/time.Second)+1) // give 1 secs more than the resolution

	_, err := c.conn.Do("EXEC")
	return err
}
// IncrBy adds the given value to this counter
IncrBy adds the given value to this counter
// IncrBy adds the given value to this counter
func (c *RateRedisCounter) IncrBy(val int64) error {
	curTimeShard := c.timer.UnixNano() / int64(c.resolution)
	key := c.makeKey(curTimeShard)
	c.conn.Send("MULTI")
	c.conn.Send("INCRBY", key, val)
	c.conn.Send("EXPIRE", key, int(c.period/time.Second)+1) 
	_, err := c.conn.Do("EXEC")
	return err
}
func ( c * RateRedisCounter ) IncrBy ( val int64 ) error { curTimeShard := c . timer . UnixNano ( ) / int64 ( c . resolution ) key := c . makeKey ( curTimeShard ) c . conn . Send ( " " ) c . conn . Send ( " " , key , val ) c . conn . Send ( " " , key , int ( c . period / time . Second ) + 1 ) _ , err := c . conn . Do ( " " ) return err }
IncrBy adds the given value to this counter
IncrBy adds the given value to this counter
// give 1 secs more than the resolution