movement_window := ring.New(granularity+1)
events_chan := ps.Sub("movement")
myticker := time.NewTicker(time.Duration(gran_duration) * time.Second)
movement_window := ring.New(granularity+1)
events_chan := ps.Sub("movement")
myticker := time.NewTicker(time.Duration(gran_duration) * time.Second)