Support pulsar packages for functions create/update (streamnative#1022)

Author: jiangpengcheng

pkg/ctl/functions/update.go

@@ -364,8 +364,8 @@ func doUpdateFunctions(vc *cmdutils.VerbCmd, funcData *util.FunctionData) error
 	updateOptions := util.NewUpdateOptions()
 	updateOptions.UpdateAuthData = funcData.UpdateAuthData
 
-	if utils.IsPackageURLSupported(funcData.Jar) {
-		err = admin.Functions().UpdateFunctionWithURL(funcData.FuncConf, funcData.Jar, updateOptions)
+	if utils.IsPackageURLSupported(funcData.UserCodeFile) {
+		err = admin.Functions().UpdateFunctionWithURL(funcData.FuncConf, funcData.UserCodeFile, updateOptions)
 		if err != nil {
 			cmdutils.PrintError(vc.Command.OutOrStderr(), err)
 		} else {

pkg/ctl/utils/util.go

@@ -33,13 +33,20 @@ const (
 	FILE    = "file"
 	BUILTIN = "builtin"
 
+	FUNCTION = "function"
+	SINK     = "sink"
+	SOURCE   = "source"
+
 	PublicTenant     = "public"
 	DefaultNamespace = "default"
 )
 
 func IsPackageURLSupported(functionPkgURL string) bool {
-	return functionPkgURL != "" && strings.HasPrefix(functionPkgURL, HTTP) ||
-		strings.HasPrefix(functionPkgURL, FILE)
+	return functionPkgURL != "" && (strings.HasPrefix(functionPkgURL, HTTP) ||
+		strings.HasPrefix(functionPkgURL, FILE) ||
+		strings.HasPrefix(functionPkgURL, FUNCTION) ||
+		strings.HasPrefix(functionPkgURL, SINK) ||
+		strings.HasPrefix(functionPkgURL, SOURCE))
 }
 
 func InferMissingFunctionName(funcConf *utils.FunctionConfig) {