Scalable and distributed custom feed generator, ott - on that topic

Hook up custom smartmodules

+12
+5
connectors/posts-config.yaml
··· 8 8 batch-size: "4 MB" 9 9 http: 10 10 endpoint: "wss://jetstream2.us-east.bsky.network/subscribe?wantedCollections=app.bsky.feed.post" 11 + transforms: 12 + - uses: aleeve/contruct-post-uri@0.1.0 13 + - uses: aleeve/assign-record-key@0.1.0 14 + with: 15 + key: uri
+4
hooks.sh
··· 1 1 fluvio cluster status || fluvio cluster start --k8 2 + cd ./smart-modules/assign-record-key/ && smdk build && smdk load 3 + cd - 4 + cd ./smart-modules/contruct-post-uri/ && smdk build && smdk load 5 + cd - 2 6 kind load docker-image loaded-pg:$POSTGRES_VERSION
+3
smart-modules/contruct-post-uri/SmartModule.toml
··· 6 6 description = "" 7 7 license = "Apache-2.0" 8 8 visibility = "private" 9 + [[params]] 10 + name = "key" 11 + description = "Dummy param to fix smdk load"