Merge branch 'client-throttle'

Author: mustafaakin

config.example.yaml

@@ -1,14 +1,17 @@
 logLevel: debug
 logFormat: json
+throttlePeriod: 10
+kubeQPS: 60
+kubeBurst: 60
 # namespace: my-namespace-only # Omitting it defaults to all namespaces.
 route:
   # Main route
   routes:
     # This route allows dumping all events because it has no fields to match and no drop rules.
     - match:
         - receiver: "dump"
-    # This starts another route, drops all the events in *test* namespaces and Normal events 
-    # for capturing critical events 
+    # This starts another route, drops all the events in *test* namespaces and Normal events
+    # for capturing critical events
     - drop:
         - namespace: "*test*"
         - type: "Normal"
@@ -17,10 +20,10 @@ route:
         - receiver: "pipe"
     # This a final route for user messages
     - match:
-      - kind: "Pod|Deployment|ReplicaSet"
-        labels:
-          version: "dev"
-        receiver: "slack"
+        - kind: "Pod|Deployment|ReplicaSet"
+          labels:
+            version: "dev"
+          receiver: "slack"
 receivers:
   - name: "dump"
     elasticsearch:

main.go

@@ -66,6 +66,8 @@ func main() {
 	if err != nil {
 		log.Fatal().Err(err).Msg("cannot get kubeconfig")
 	}
+	kubeconfig.QPS = cfg.KubeQPS
+	kubeconfig.Burst = cfg.KubeBurst
 
 	engine := exporter.NewEngine(&cfg, &exporter.ChannelBasedReceiverRegistry{})
 	onEvent := engine.OnEvent

pkg/exporter/config.go

@@ -18,6 +18,8 @@ type Config struct {
 	LeaderElection kube.LeaderElectionConfig `yaml:"leaderElection"`
 	Route          Route                     `yaml:"route"`
 	Receivers      []sinks.ReceiverConfig    `yaml:"receivers"`
+	KubeQPS        float32                   `yaml:"kubeQPS,omitempty"`
+	KubeBurst      int                       `yaml:"kubeBurst,omitempty"`
 }
 
 func (c *Config) Validate() error {