View GitHub Repository kafka-influxdb

Schedule Inspection
Subscribe
Completed
Push — master ( 528557...ccc821 )
by Matthias
11s
created

TestHeapsterJsonEncoder.testEncoder()   A

↳ Parent: TestHeapsterJsonEncoder

Complexity

Conditions 1

Size

Total Lines 5

Duplication

Lines 0
Ratio 0 %

Importance

Changes 2
Bugs 1 Features 1
Metric Value
cc 1
dl 0
loc 5
rs 9.4285
c 2
b 1
f 1
1 
import unittest
2 

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    3
                

                                    
                                                    
                
                
                
from kafka_influxdb.encoder import heapster_json_encoder

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    4
                

                                    
                                                    
                
                
                

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    5
                

                                    
                                                    
                
                
                
class TestHeapsterJsonEncoder(unittest.TestCase):

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    6
                

                                    
                                                    
                
                
                

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    7
                

                                    
                                                    
                
                
                
    def setUp(self):

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    8
                

                                    
                                                    
                
                
                
        self.encoder = heapster_json_encoder.Encoder()

            


            
                                                                                                            
                                                                
            
                                    
            
            

                
                    9
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    10
                

                                    
                                                    
                
                
                
    def testEncoder(self):

            


            
                                                        
            
                                    
            
            

                
                    11
                

                                    
                                                    
                
                
                
        msg = b'{ "MetricsName":"memory/major_page_faults","MetricsValue":{"value":56}, "MetricsTimestamp":"2017-01-19T17:26:00Z", "MetricsTags":{"container_name":"docker/9be430d3a1a28601292aebd76e15512d5471c630a7fa164d6a2a2fd9cbc19e3d"} } '

            


            
                                                        
            
                                    
            
            

                
                    12
                

                                    
                                                    
                
                
                
        encoded_message = self.encoder.encode(msg)        

            


            
                                                        
            
                                    
            
            

                
                    13
                

                                    
                                                    
                
                
                
        expected_msg = ['memory/major_page_faults,container_name=docker/9be430d3a1a28601292aebd76e15512d5471c630a7fa164d6a2a2fd9cbc19e3d value=56 1484846760']       

            


            
                                                        
            
                                    
            
            

                
                    14
                

                                    
                                                    
                
                
                
        self.assertEqual(encoded_message, expected_msg)