Version: Next

Run Go Functions

After packaging your Pulsar Go function, you can submit your Go function to a Pulsar cluster. This section describes how to submit a Go function through a function CRD. You can use the image field to specify the runner image for creating the Go function. You can also specify the location where the package or the image is stored.

Define a Go function by using a YAML file and save the YAML file.

This example shows how to publish a go-function-sample function to a Pulsar cluster by using a JAR package called function://my-tenant/my-ns/my-function@0.1.

apiVersion: compute.functionmesh.io/v1alpha1
kind: Function
metadata:
  name: go-function-sample
  namespace: default
spec:
  image: streamnative/pulsar-functions-go-runner:2.7.1 # using go function runner
  className: exclamation_function.ExclamationFunction
  forwardSourceMessageProperty: true
  maxPendingAsyncRequests: 1000
  replicas: 1
  maxReplicas: 5
  logTopic: persistent://public/default/logging-function-logs
  input:
    topics:
    - persistent://public/default/go-function-input-topic
    typeClassName: java.lang.String
  output:
    topic: persistent://public/default/go-function-output-topic
    typeClassName: java.lang.String
  pulsar:
    pulsarConfig: "test-pulsar"
  golang:
    go: go_func_all
    goLocation: ""
    # use package name:
    # goLocation: function://public/default/nul-test-go-function@v1
    # to be delete & use admission hook

This example shows how to publish a go-function-sample function to a Pulsar cluster by using a Docker image.

apiVersion: compute.functionmesh.io/v1alpha1
kind: Function
metadata:
  name: go-function-sample
  namespace: default
spec:
  image: streamnative/example-function-image:latest # using function image here
  className: exclamation_function.ExclamationFunction
  forwardSourceMessageProperty: true
  maxPendingAsyncRequests: 1000
  replicas: 1
  maxReplicas: 5
  logTopic: persistent://public/default/logging-function-logs
  input:
    topics:
    - persistent://public/default/go-function-input-topic
    typeClassName: java.lang.String
  output:
    topic: persistent://public/default/go-function-output-topic
    typeClassName: java.lang.String
  pulsar:
    pulsarConfig: "test-pulsar"
  golang:
    go: go_func_all
    goLocation: ""
    # use package name:
    # goLocation: function://public/default/nul-test-go-function@v1
    # to be delete & use admission hook

This example shows how to publish a golang-exclamation-function function to a Pulsar cluster by using the self-built image golang-exclamation-function:v1.

apiVersion: compute.functionmesh.io/v1alpha1
kind: Function
metadata:
  name: golang-exclamation-function
  namespace: default
spec:
  image: golang-exclamation-function:v1
  forwardSourceMessageProperty: true
  maxPendingAsyncRequests: 1000
  replicas: 1
  maxReplicas: 5
  logTopic: persistent://public/default/logging-function-logs
  input:
    topics:
    - persistent://public/default/input-golang-topic
  output:
    topic: persistent://public/default/output-golang-topic
  resources:
    requests:
      cpu: "0.1"
      memory: 1G
    limits:
      cpu: "0.2"
      memory: 1.1G
  secretsMap:
    "name":
        path: "test-secret"
        key: "username"
    "pwd":
        path: "test-secret"
        key: "password"
  pulsar:
    pulsarConfig: "test-pulsar"
  golang:
    go: /pulsar/go_function
  clusterName: test
  autoAck: true
---
apiVersion: v1
kind: ConfigMap
metadata:
  name: test-pulsar
data:
  webServiceURL: http://sn-platform-pulsar-broker.default.svc.cluster.local:8080
  brokerServiceURL: pulsar://sn-platform-pulsar-broker.default.svc.cluster.local:6650
---
apiVersion: v1
data:
  username: YWRtaW4=
  password: MWYyZDFlMmU2N2Rm
kind: Secret
metadata:
  name: test-secret
type: Opaque

Apply the YAML file to create the Go function.
```
kubectl apply -f /path/to/YAML/file
```
Check whether the Go function is created successfully.
```
kubectl get all
```