feat: support package loader (#186)

Author: RobertIndie

.github/workflows/license.yaml

@@ -27,4 +27,4 @@ jobs:
     steps:
       - uses: actions/checkout@v3
       - name: Run license check
-        run: ./license-checker/license-checker.sh
+        run: make license

admin/client/README.md

@@ -7,6 +7,7 @@ This API client was generated by the [OpenAPI Generator](https://openapi-generat
 
 - API version: 1.0.0
 - Package version: 1.0.0
+- Generator version: 7.6.0
 - Build package: org.openapitools.codegen.languages.GoClientCodegen
 For more information, please visit [https://github.com/FunctionStream](https://github.com/FunctionStream)
 
@@ -22,7 +23,7 @@ go get golang.org/x/net/context
 Put the package under your project folder and add the following in import:
 
 ```go
-import adminclient "github.com/functionstream/functionstream/admin/client"
+import adminclient "github.com/functionstream/function-stream/admin/client"
 ```
 
 To use a proxy, set the environment variable `HTTP_PROXY`:

admin/client/client.go

@@ -7,6 +7,7 @@ Name | Type | Description | Notes
 **Config** | Pointer to **map[string]string** |  | [optional] 
 **Name** | **string** |  | 
 **Namespace** | Pointer to **string** |  | [optional] 
+**Package** | **string** |  | 
 **Replicas** | **int32** |  | 
 **Runtime** | [**ModelRuntimeConfig**](ModelRuntimeConfig.md) |  | 
 **Sink** | [**ModelTubeConfig**](ModelTubeConfig.md) |  | 
@@ -16,7 +17,7 @@ Name | Type | Description | Notes
 
 ### NewModelFunction
 
-`func NewModelFunction(name string, replicas int32, runtime ModelRuntimeConfig, sink ModelTubeConfig, source []ModelTubeConfig, ) *ModelFunction`
+`func NewModelFunction(name string, package_ string, replicas int32, runtime ModelRuntimeConfig, sink ModelTubeConfig, source []ModelTubeConfig, ) *ModelFunction`
 
 NewModelFunction instantiates a new ModelFunction object
 This constructor will assign default values to properties that have it defined,
@@ -101,6 +102,26 @@ SetNamespace sets Namespace field to given value.
 
 HasNamespace returns a boolean if a field has been set.
 
+### GetPackage
+
+`func (o *ModelFunction) GetPackage() string`
+
+GetPackage returns the Package field if non-nil, zero value otherwise.
+
+### GetPackageOk
+
+`func (o *ModelFunction) GetPackageOk() (*string, bool)`
+
+GetPackageOk returns a tuple with the Package field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetPackage
+
+`func (o *ModelFunction) SetPackage(v string)`
+
+SetPackage sets Package field to given value.
+
+
 ### GetReplicas
 
 `func (o *ModelFunction) GetReplicas() int32`

admin/client/docs/ModelFunction.md

@@ -336,6 +336,7 @@
   "model.Function": {
    "required": [
     "name",
+    "package",
     "runtime",
     "source",
     "sink",
@@ -354,6 +355,9 @@
     "namespace": {
      "type": "string"
     },
+    "package": {
+     "type": "string"
+    },
     "replicas": {
      "type": "integer",
      "format": "int32"

admin/client/model_model_function.go

@@ -25,6 +25,8 @@ import (
 	"testing"
 	"time"
 
+	"github.com/functionstream/function-stream/common/config"
+
 	"github.com/functionstream/function-stream/fs/api"
 	"github.com/functionstream/function-stream/fs/runtime/wazero"
 
@@ -117,11 +119,11 @@ func BenchmarkStressForBasicFuncWithMemoryQueue(b *testing.B) {
 
 	s, err := server.NewServer(
 		server.WithRuntimeFactoryBuilder(common.WASMRuntime,
-			func(configMap common.ConfigMap) (api.FunctionRuntimeFactory, error) {
+			func(configMap config.ConfigMap) (api.FunctionRuntimeFactory, error) {
 				return wazero.NewWazeroFunctionRuntimeFactory(), nil
 			}),
 		server.WithTubeFactoryBuilder(common.MemoryTubeType,
-			func(configMap common.ConfigMap) (contube.TubeFactory, error) {
+			func(configMap config.ConfigMap) (contube.TubeFactory, error) {
 				return memoryQueueFactory, nil
 			}),
 	)

admin/client/utils.go

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package common
+package config
 
 // ConfigMap is a custom type that represents a map where keys are strings and values are of any type.
 // Since Viper is not case-sensitive, we use '-' to separate words in all field names in the config map.
@@ -24,3 +24,14 @@ package common
 //   - `socket-path` refers to the path of the socket.
 //   - `pulsar-url` refers to the URL of the Pulsar service.
 type ConfigMap map[string]interface{}
+
+// MergeConfig merges multiple ConfigMap into one
+func MergeConfig(configs ...ConfigMap) ConfigMap {
+	result := ConfigMap{}
+	for _, config := range configs {
+		for k, v := range config {
+			result[k] = v
+		}
+	}
+	return result
+}

apidocs.json

@@ -19,8 +19,10 @@ package common
 import "fmt"
 
 var (
-	ErrorFunctionNotFound       = fmt.Errorf("function not found")
-	ErrorFunctionExists         = fmt.Errorf("function already exists")
-	ErrorRuntimeFactoryNotFound = fmt.Errorf("runtime factory not found")
-	ErrorTubeFactoryNotFound    = fmt.Errorf("tube factory not found")
+	ErrorFunctionNotFound           = fmt.Errorf("function not found")
+	ErrorFunctionExists             = fmt.Errorf("function already exists")
+	ErrorFunctionUnsupportedRuntime = fmt.Errorf("function does not support runtime")
+	ErrorRuntimeFactoryNotFound     = fmt.Errorf("runtime factory not found")
+	ErrorTubeFactoryNotFound        = fmt.Errorf("tube factory not found")
+	ErrorPackageNoSupportedRuntime  = fmt.Errorf("package does not support any runtime")
 )