Skip to content

Instantly share code, notes, and snippets.

[jim@localhost displayer]$ func deploy
Building function image
Trying to pull quay.io/boson/faas-nodejs-builder:latest...
Getting image source signatures
Copying blob af4e116295dd [--------------------------------------] 0.0b / 0.0b
Copying blob af4e116295dd skipped: already exists
Copying blob af4e116295dd skipped: already exists
Copying blob 66510ec4cc80 [--------------------------------------] 0.0b / 0.0b
Copying blob af4e116295dd skipped: already exists
Copying blob 66510ec4cc80 skipped: already exists
[jim@localhost drogue-cloud]$ k logs -l eventing.knative.dev/sourceName=kafka-source
{"level":"info","ts":"2021-05-12T20:54:44.980Z","caller":"metrics/metrics_worker.go:91","msg":"Successfully updated the metrics exporter; old config: <nil>; new config &{knative.dev/sources kafkasource prometheus 5000000000 <nil> <nil> false 9090 0.0.0.0 false { false}}"}
{"level":"info","ts":"2021-05-12T20:54:44.980Z","caller":"adapter/adapter.go:90","msg":"Starting with config: ","Topics":"knative-messaging-kafka.drogue-iot.iot-channel","ConsumerGroup":"eds","SinkURI":"http://event-display.default.svc.cluster.local","Name":"kafka-source","Namespace":"default"}
{"level":"info","ts":"2021-05-12T20:54:48.000Z","caller":"consumer/consumer_handler.go:57","msg":"setting up handler"}
{"level":"info","ts":"2021-05-12T20:54:48.011Z","caller":"consumer/consumer_handler.go:76","msg":"Starting partition consumer, topic: knative-messaging-kafka.drogue-iot.iot-channel, partition: 0, initialOffset: -1","ConsumeGroup":"eds"}
{"level"
let mut event = EventBuilderV10::new()
.id(uuid::Uuid::new_v4().to_string())
.ty(DEFAULT_TYPE_EVENT)
// we need an "absolute" URL for the moment: until 0.4 is released
// see: https://github.com/cloudevents/sdk-rust/issues/106
.source(format!("drogue://{}", source))
.inject(Id::new(publish.app_id, publish.device_id))
.subject(&publish.channel)
.time(Utc::now());
[jim@localhost drogue-cloud]$ k logs -l eventing.knative.dev/sourceName=kafka-source
{"level":"info","ts":"2021-05-11T21:17:13.008Z","caller":"metrics/metrics_worker.go:91","msg":"Successfully updated the metrics exporter; old config: <nil>; new config &{knative.dev/sources kafkasource prometheus 5000000000 <nil> <nil> false 9090 0.0.0.0 false { false}}"}
{"level":"info","ts":"2021-05-11T21:17:13.008Z","caller":"adapter/adapter.go:90","msg":"Starting with config: ","Topics":"knative-messaging-kafka.drogue-iot.iot-channel","ConsumerGroup":"jim","SinkURI":"http://event-display.default.svc.cluster.local","Name":"kafka-source","Namespace":"default"}
{"level":"info","ts":"2021-05-11T21:17:16.025Z","caller":"consumer/consumer_handler.go:57","msg":"setting up handler"}
{"level":"info","ts":"2021-05-11T21:17:16.027Z","caller":"consumer/consumer_handler.go:76","msg":"Starting partition consumer, topic: knative-messaging-kafka.drogue-iot.iot-channel, partition: 1, initialOffset: -1","ConsumeGroup":"jim"}
{"level"
[jim@localhost drogue-cloud]$ drg create app app_id -vvvv
2021-05-10 08:36:36,152 INFO [drg::config] Loading configuration file: /home/jim/.config/drg_config.yaml
2021-05-10 08:36:36,153 DEBUG [drg::openid] Token expires at : 2021-05-09 21:17:32.265511414 UTC
2021-05-10 08:36:36,153 INFO [drg::openid] Token is expired or will be soon, refreshing...
2021-05-10 08:36:36,153 DEBUG [drg::openid] Refreshing token using url : http://192.168.39.91/auth/realms/drogue/protocol/openid-connect/token
2021-05-10 08:36:36,160 DEBUG [hyper::client::connect::http] connecting to 192.168.39.91:80
2021-05-10 08:36:36,160 DEBUG [tokio_reactor] adding I/O source: 0
2021-05-10 08:36:36,160 DEBUG [tokio_reactor::registration] scheduling Write for: 0
2021-05-10 08:36:36,160 DEBUG [hyper::client::connect::http] connected to Some(192.168.39.91:80)
2021-05-10 08:36:36,160 DEBUG [tokio_reactor::registration] scheduling Read for: 0
[jim@localhost drogue-cloud]$ drg login http://192.168.39.91:30390
Opening in existing browser session.
Context name: minikube
Successfully authenticated to drogue cloud : http://192.168.39.91:30390/
Error: Context minikube already exist in config!
[jim@localhost drogue-cloud]$ drg create app app_id -vvvv
2021-05-08 12:49:44,553 INFO [drg::config] Loading configuration file: /home/jim/.config/drg_config.yaml
2021-05-08 12:49:44,554 DEBUG [drg::openid] Token expires at : 2021-05-08 16:53:13.378585391 UTC
2021-05-08 12:49:44,568 DEBUG [reqwest::connect] starting new connection: http://192.168.39.91:31330/
diff --git a/rt/Cargo.toml b/rt/Cargo.toml
index 151f9f0..bc4d268 100644
--- a/rt/Cargo.toml
+++ b/rt/Cargo.toml
@@ -38,14 +38,14 @@ features = ["unproven"]
[dependencies.lorawan-device]
git = "https://github.com/ivajloip/rust-lorawan.git"
-branch = "master"
+rev = "4241d0b4c82f"
[jim@localhost drogue-install-minikube-0.4.0]$ minikube start --cpus 4 --memory 16384 --disk-size 20gb --addons ingress
* minikube v1.13.1 on Fedora 33
* minikube 1.18.1 is available! Download it: https://github.com/kubernetes/minikube/releases/tag/v1.18.1
* To disable this notice, run: 'minikube config set WantUpdateNotification false'
* Using the kvm2 driver based on existing profile
* Starting control plane node minikube in cluster minikube
* Restarting existing kvm2 VM for "minikube" ...
* Preparing Kubernetes v1.19.2 on Docker 19.03.12 ...
* Verifying Kubernetes components...
+ drg get app app_id
{
"metadata": {
"creationTimestamp": "2021-03-30T16:31:43.949894Z",
"generation": 0,
"name": "app_id",
"resourceVersion": "1cf61c52-3644-46f1-a61e-a60e2592e9b5",
"uid": "cd3d73f9-3b0e-4a92-8ed8-2dc8be82d773"
},
"spec": {
16:25:52.374 INFO - adapter is ready
16:25:52.374 INFO - Echo disabled
16:25:52.374 INFO - Mux enabled
16:25:52.374 INFO - Recv mode configured
16:25:52.374 INFO - adapter configured
16:25:52.374 INFO - Starting ESP8266 Modem
16:26:00.120 INFO - Joining network
16:26:03.873 INFO - wifi connected
16:26:06.889 INFO - wifi got ip
16:26:06.889 INFO - Joined wifi network with IP: 192.168.0.104