Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
57 changes: 57 additions & 0 deletions functions/knative/with-output-binding-node/http-trigger.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,57 @@
apiVersion: core.openfunction.io/v1beta1
kind: Function
metadata:
name: sample-node-http-trigger
spec:
version: v2.0.0
image: your-docker-registry/image:tag
# imageCredentials:
# name: your-docker-registry-secret
# build:
# builder: openfunction/builder-node:v2-16.13
# env:
# FUNC_NAME: tryKnative
# srcRepo:
# url: https://github.com/OpenFunction/samples.git
# sourceSubPath: functions/async/mqtt-io-node
# revision: main
# app port default to "8080"
# port: 8080
serving:
# default to knative
runtime: knative
scaleOptions:
minReplicas: 0
maxReplicas: 2
annotations:
# Dapr annotations: https://docs.dapr.io/reference/arguments-annotations-overview/
# default to "info"
dapr.io/log-level: debug
# default to "true"
dapr.io/log-as-json: 'false'
template:
containers:
- name: function
imagePullPolicy: Always
params:
# default to FUNC_NAME value
FUNCTION_TARGET: tryKnativeAsync
# default to http
FUNCTION_SIGNATURE_TYPE: openfunction
DEBUG: common:*,ofn:*
outputs:
- name: mqtt-output
component: mqtt-out
operation: create
bindings:
# Dapr MQTT Binding: https://docs.dapr.io/reference/components-reference/supported-bindings/mqtt/
mqtt-out:
type: bindings.mqtt
version: v1
metadata:
- name: consumerID
value: '{uuid}'
- name: url
value: tcp://admin:public@emqx:1883
- name: topic
value: out
12 changes: 12 additions & 0 deletions functions/knative/with-output-binding-node/index.mjs
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
export const tryKnative = (req, res) => {
res.send(`Hello, ${req.query.u || 'World'}!`);
};

export const tryKnativeAsync = async (ctx, data) => {
console.log('Data received: %o', data);
await ctx.send(data);

// Optional to send ANY data back as HTTP response
// Request data is also accessible via "ctx.req"
// ctx.res.send(ctx.req.query);
};
9 changes: 9 additions & 0 deletions functions/knative/with-output-binding-node/package.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
{
"main": "index.mjs",
"scripts": {
"start": "functions-framework --target=tryKnative"
},
"dependencies": {
"@openfunction/functions-framework": "^0.5.0"
}
}