Ansu Varghese aavarghese
aavarghese
/ policy.rego
Created
April 15, 2021 05:02
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package policy | |
| import data.acl | |
| default allow = false | |
| # METADATA | |
| # scope: rule | |
| # schemas: | |
| # - input: schema["input"] |
aavarghese
/ policy.rego
Last active
April 21, 2021 19:55
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package kubernetes.admission | |
| # METADATA | |
| # scope: rule | |
| # schemas: | |
| # - input: schema["input"] | |
| # - input.request.object: schema.kubernetes["pod"] | |
| deny[msg] { | |
| input.request.kind.kinds == "Pod" # This line has a typo, should be input.request.kind.kind | |
| image := input.request.object.spec.containers[_].images # This line has a typo, should be input.request.object.spec.containers[_].image |
aavarghese
/ policy.rego
Last active
April 21, 2021 19:55
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package kubernetes.admission | |
| deny[msg] { | |
| input.request.kind.kinds == "Pod" # This line has a typo, should be input.request.kind.kind | |
| image := input.request.object.spec.containers[_].image | |
| not startswith(image, "hooli.com/") | |
| msg := sprintf("image '%v' comes from untrusted registry", [image]) | |
| } |
aavarghese
/ task-rego.yaml
Last active
October 26, 2021 16:17
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| --- | |
| apiVersion: tekton.dev/v1beta1 | |
| kind: Task | |
| metadata: | |
| name: da-rego-analysis | |
| spec: | |
| params: | |
| - name: repository | |
| description: the git repo | |
| - name: policy-dir |
aavarghese
/ base_tfplan.rego
Created
October 26, 2021 16:02
Example Rego file with typo for Newstack blog
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package ibmcloud.tfplan | |
| import data as tfplan | |
| # lists all the variables from variable section | |
| # METADATA | |
| # schemas: | |
| # - data: schema.plan-schema | |
| variables = vars{ | |
| some k |
aavarghese
/ scaling_ekb.diff
Last active
March 21, 2022 20:27
Changes needed to activate new scaling & scheduling kafka source consumers code in eventing-kafka-broker
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| diff --git a/control-plane/cmd/kafka-controller/main.go b/control-plane/cmd/kafka-controller/main.go | |
| index 5447ae63..13b8c84c 100644 | |
| --- a/control-plane/cmd/kafka-controller/main.go | |
| +++ b/control-plane/cmd/kafka-controller/main.go | |
| @@ -29,10 +29,12 @@ import ( | |
| "knative.dev/eventing-kafka-broker/control-plane/pkg/config" | |
| "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/broker" | |
| "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/channel" | |
| + "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/consumer" |
aavarghese
/ ha.diff
Last active
March 21, 2022 20:26
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| diff --git a/control-plane/cmd/kafka-controller/main.go b/control-plane/cmd/kafka-controller/main.go | |
| index 5447ae63..13b8c84c 100644 | |
| --- a/control-plane/cmd/kafka-controller/main.go | |
| +++ b/control-plane/cmd/kafka-controller/main.go | |
| @@ -29,10 +29,12 @@ import ( | |
| "knative.dev/eventing-kafka-broker/control-plane/pkg/config" | |
| "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/broker" | |
| - "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/channel" | |
| + channelv2 "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/channel/v2" |
aavarghese
/ disp0.log
Created
June 9, 2022 19:03
This file has been truncated, but you can view the full file.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| {"@timestamp":"2022-06-09T18:20:29.424Z","@version":"1","message":"Consumer closed or poll is in-flight","logger_name":"dev.knative.eventing.kafka.broker.dispatcher.impl.consumer.OrderedConsumerVerticle","thread_name":"vert.x-eventloop-thread-2","level":"DEBUG","level_value":10000} | |
| {"@timestamp":"2022-06-09T18:20:29.624Z","@version":"1","message":"Consumer closed or poll is in-flight","logger_name":"dev.knative.eventing.kafka.broker.dispatcher.impl.consumer.OrderedConsumerVerticle","thread_name":"vert.x-eventloop-thread-2","level":"DEBUG","level_value":10000} | |
| {"@timestamp":"2022-06-09T18:20:29.824Z","@version":"1","message":"Consumer closed or poll is in-flight","logger_name":"dev.knative.eventing.kafka.broker.dispatcher.impl.consumer.OrderedConsumerVerticle","thread_name":"vert.x-eventloop-thread-2","level":"DEBUG","level_value":10000} | |
| {"@timestamp":"2022-06-09T18:20:29.926Z","@version":"1","message":"[Consumer clientId=consumer-kafka-src50c-1, groupId=kafka-src50c] Received FETCH response from node 1 for re |
aavarghese
/ controller.log
Created
June 9, 2022 19:08
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2022/06/09 17:14:27 Registering 6 clients | |
| 2022/06/09 17:14:27 Registering 6 informer factories | |
| 2022/06/09 17:14:27 Registering 13 informers | |
| 2022/06/09 17:14:27 Registering 7 controllers | |
| {"level":"info","ts":"2022-06-09T17:14:27.719Z","caller":"logging/config.go:117","msg":"Successfully created the logger."} | |
| {"level":"info","ts":"2022-06-09T17:14:27.719Z","caller":"logging/config.go:118","msg":"Logging level set to: debug"} | |
| {"level":"info","ts":"2022-06-09T17:14:27.719Z","caller":"logging/config.go:80","msg":"Fetch GitHub commit ID from kodata failed","error":"open /var/run/ko/HEAD: no such file or directory"} | |
| {"level":"info","ts":"2022-06-09T17:14:27.719Z","logger":"kafka-broker-controller","caller":"profiling/server.go:64","msg":"Profiling enabled: false","knative.dev/pod":"kafka-controller-6fbb58486c-kltql"} | |
| {"level":"info","ts":"2022-06-09T17:14:27.749Z","logger":"kafka-broker-controller","caller":"leaderelection/context.go:47","msg":"Running with Standard leader election","knative.dev/pod":"kafka-controll |
aavarghese
/ eventdisplay.log
Created
June 9, 2022 19:08
This file has been truncated, but you can view the full file.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| {"level":"info","ts":1654795166.560904,"logger":"fallback","caller":"customizeEventDisplay/evendisplay.go:103","msg":"Env vars: displayConcurrentConnection: true delay: 10 cloudevent: true forward: true scraper: http://kafkascraper print true \n"} | |
| {"level":"info","ts":1654795166.5610971,"logger":"fallback","caller":"customizeEventDisplay/evendisplay.go:114","msg":"Receiving events as cloudevents"} | |
| {"level":"info","ts":1654795167.5617049,"logger":"fallback","caller":"customizeEventDisplay/evendisplay.go:171","msg":"Host: eventdisplay-7c8868fbb6-pm2nh: we have 0 concurrent connections\n"} | |
| {"level":"info","ts":1654795168.5622337,"logger":"fallback","caller":"customizeEventDisplay/evendisplay.go:171","msg":"Host: eventdisplay-7c8868fbb6-pm2nh: we have 0 concurrent connections\n"} | |
| {"level":"info","ts":1654795169.562961,"logger":"fallback","caller":"customizeEventDisplay/evendisplay.go:171","msg":"Host: eventdisplay-7c8868fbb6-pm2nh: we have 0 concurrent connections\n"} | |
| {"level":"info","ts":1654795170.563463,"logge |
OlderNewer