View GitHub Repository kafka-influxdb

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

TestHeapsterEventJsonEncoder.testEncoder()   A

↳ Parent: TestHeapsterEventJsonEncoder

Complexity

Conditions 1

Size

Total Lines 5

Duplication

Lines 0
Ratio 0 %

Importance

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

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    3
                

                                    
                                                    
                
                
                
from kafka_influxdb.encoder import heapster_event_json_encoder

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    4
                

                                    
                                                    
                
                
                

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    5
                

                                    
                                                    
                
                
                
class TestHeapsterEventJsonEncoder(unittest.TestCase):

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    6
                

                                    
                                                    
                
                
                

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    7
                

                                    
                                                    
                
                
                
    def setUp(self):

            


            
                                                                                                            
                            
            
                                    
            
            

                
                    8
                

                                    
                                                    
                
                
                
        self.encoder = heapster_event_json_encoder.Encoder()

            


            
                                                                                                            
                                                                
            
                                    
            
            

                
                    9
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    10
                

                                    
                                                    
                
                
                
    def testEncoder(self):

            


            
                                                        
            
                                    
            
            

                
                    11
                

                                    
                                                    
                
                
                
        msg = b'{"EventValue":"{\\n \\"metadata\\": {\\n  \\"name\\": \\"etcd-operator-562633149-vvr85.149bd41846d603d4\\",\\n \\"namespace\\": \\"default\\",\\n  \\"selfLink\\":  \\"/api/v1/namespaces/default/events/etcd-operator-562633149-vvr85.149bd41846d603d4\\",\\n  \\"uid\\":   \\"09f904cd-dff1-11e6-bd3e-005056923a7e\\",\\n  \\"resourceVersion\\": \\"21782526\\",\\n  \\"creationTimestamp\\":     \\"2017-01-21T15:48:22Z\\"\\n },\\n \\"involvedObject\\": {\\n  \\"kind\\": \\"Pod\\",\\n  \\"namespace\\":\\"default\\",\\n  \\"name\\": \\"etcd-operator-562633149-vvr85\\",\\n \\"uid\\":\\"a5f12e21-de53-11e6-bd3e-005056923a7e\\",\\n  \\"apiVersion\\": \\"v1\\",\\n  \\"resourceVersion\\":\\"21339961\\",\\n  \\"fieldPath\\": \\"spec.containers{etcd-operator}\\"\\n },\\n \\"reason\\": \\"BackOff\\",\\n\\"message\\": \\"Back-off pulling image \\\\\\"10.58.9.201:5000/dc/etcd-operator:latest\\\\\\"\\",\\n \\"source\\":{\\n  \\"component\\": \\"kubelet\\",\\n  \\"host\\": \\"10.58.9.212\\"\\n },\\n \\"firstTimestamp\\":\\"2017-01-21T15:48:22Z\\",\\n \\"lastTimestamp\\": \\"2017-01-22T07:10:28Z\\",\\n \\"count\\": 3955,\\n \\"type\\": \\"Normal\\"\\n}","EventTimestamp":"2017-01-22T07:10:28Z","EventTags":{"eventID":"09f904cd-dff1-11e6-bd3e-005056923a7e","hostname":"10.58.9.212","pod_id":"a5f12e21-de53-11e6-bd3e-005056923a7e","pod_name":"etcd-operator-562633149-vvr85"}}'

            


            
                                                        
            
                                    
            
            

                
                    12
                

                                    
                                                    
                
                
                
        expected_msg = ['events,kind=Pod,namespace_name=default,object_name=etcd-operator-562633149-vvr85,reason=BackOff,hostname="10.58.9.212" message="Back-off pulling image \\"10.58.9.201:5000/dc/etcd-operator:latest\\"" 1485069028']

            


            
                                                        
            
                                    
            
            

                
                    13
                

                                    
                                                    
                
                
                
        encoded_message = self.encoder.encode(msg)

            


            
                                                        
            
                                    
            
            

                
                    14
                

                                    
                                                    
                
                
                
        self.assertEqual(encoded_message, expected_msg)