Skip to main content
Version: 0.11.0

Function Mesh Worker service overview

This document gives a brief introduction into Function Mesh Worker service.

What is Function Mesh Worker service​

Function Mesh Worker service is a plug-in for Pulsar. It is similar to Pulsar Function Worker service but uses Function Mesh operators to schedule and run functions. Function Mesh Worker service enables you to use the pulsar-admin or pulsarctl CLI tools to manage Pulsar functions and connectors in Function Mesh.

How Function Mesh Worker service works​

The following figure illustrates how Function Mesh Worker service works with Pulsar proxy, converts and forwards function and / or connector admin requests to the Kubernetes cluster. The benefit of this approach is that you do not need to change the way you create and submit functions and / or connectors.

Function Mesh Workflow

Authentication​

In previous releases, Function Mesh Worker service used the super admin account to read the configuration file for Function Mesh operators, which is not secure. Therefore, starting from this release, Function Mesh Worker service supports setting a separate account for each user.

Note

Currently, only OAuth2 authentication is supported.

OAuth2 authentication​

For clients that use OAuth2 authentication, you need to create a Kubernetes Secret in advance in the same cluster where Function Mesh operators work. The Kubernetes Secret is something like the below:

apiVersion: v1
data:
  auth.json: |
    {
      "client_id": "xxxx",
      "client_secret": "xxxx",
      "issuer_url": "xxx"
    }
  clientAuthenticationParameters: {"privateKey":"file:///${SOME-PATH-OF-FILE}","issuerUrl":"${OAUTH-ISSUER-URL}","audience":"${OAUTH-AUDIENCE}","scope":"${OAUTH-SCOPE}"}
kind: Secret
metadata:
  name: ${OAUTH-CLIENT-NAME}
type: Opaque

Version matrix​

This table lists the version mapping relationships between Function Mesh and Function Mesh Worker service.

Function MeshFunction Mesh Worker service
v0.1.9
- v2.9.1.x (v2.9.1.1-v2.9.1.2)
- v2.8.2.x (v2.8.2.0-v2.8.2.2)
- v2.8.1 x (2.8.1.25-v2.8.1.26, v.2.8.1.28-v2.8.1.30)
v0.1.10
- v2.9.2.1+
- v2.8.2.3+
v0.1.11
- v2.10.0+
- v2.9.2.13+
- v2.8.2.14+
v0.2.0
- v2.10.0.5-v2.10.0.6
- v2.9.2.18-v2.9.2.22
- v2.8.3.4
v0.3.0
- v2.10.0.7
- v2.9.2.23+
- v2.8.3.5+
v0.4.0
- v2.10.1.4+
- v2.9.3.3+
- v2.8.3.6+
v0.5.0
- v2.10.1.7-v2.10.1.8
- v2.9.3.6-v2.9.3.8
- v2.8.4.1
v0.6.0
- v2.10.1.9+
- v2.9.3.9+
- v2.8.4.2+
v0.7.0
- v2.10.1.10+
- v2.9.3.14+
- v2.8.4.2+
v0.8.0
- v2.10.2.1+
- v2.9.3.16+
v0.9.0
- v2.10.2.5+
- v2.9.3.21+
v0.10.0
- v2.10.3.1+
- v2.9.4.2+
v0.11.0
- v2.10.3.5+
- v2.9.4.4+