Add migration tools for function (#80)

Fixed #77
* Add migration tools for function

Mapped field

```
puslar     function-mesh
tenant <=> tenant
namespace <=> namespace
name <=> name
className <=> className
autoAck <=> autoAck
processingGuarantees <=> ProcessingGuarantee
retainOrdering <=> retainOrdering
retainKeyOrdering <=> RetainKeyOrdering
deadLetterTopic <=> DeadLetterTopic
forwardSourceMessageProperty <=> ForwardSourceMessageProperty
maxMessageRetries <=> MaxMessageRetry
parallelism <=> replicas, MaxReplicas
inputs <=> topics list
topicsPattern <=> TopicPattern
customSerdeInputs <=> CustomSerdeSources
customSchemaInputs <=> CustomSchemaSources
inputSpecs <=> sourceSpecs
   schemaType <=> schemaType
   SerdeClassName <=> SerdeClassName
   isRegexPattern <=> isRegexPattern
   schemaProperties <=> SchemaProperties
   consumerProperties <=> ConsumerProperties
   receiverQueueSize <=> ReceiverQueueSize
   cryptoConfig <=> CryptoConfig
resources <=> resources(limits, requests)
   cpu <=> cpu
   ram <=> memory
cleanupSubscription <=> cleanupSubscription
Topic <=> topic
outputSerdeClassName <=> SinkSerdeClassName
outputSchemaType <=> SinkSchemaType
customSchemaOutputs <=> CustomSchemaSinks
producerConfig <=> ProducerConf
   maxPendingMessages <=> MaxPendingMessages
   maxPendingMessagesAcrossPartitions <=> MaxPendingMessagesAcrossPartitions
   useThreadLocalProducers <=> UseThreadLocalProducers
   cryptoConfig <=> CryptoConfig
subscriptionPosition <=> SubscriptionPosition
subName <=> SubscriptionName
userConfig  <=> funcConfig?
runtimeFlags <=> RuntimeFlags
runtime <=> Runtime
logTopic <=> LogTopic
? <=> SourceType
? <=> SinkType
```

.github/workflows/test-java-function.yml

@@ -37,8 +37,8 @@ jobs:
 
 #      - name: Add CRD, controller or webhooks
 #        run: |
-#          operator-sdk create api --group cloud --version v1alpha1 --kind Function --resource=true --controller=true
-#          operator-sdk create webhook --group cloud.streamnative.io --version v1alpha1 --kind Function --defaulting --programmatic-validation
+#          operator-sdk create api --group compute --version v1alpha1 --kind Function --resource=true --controller=true
+#          operator-sdk create webhook --group compute.functionmesh.io --version v1alpha1 --kind Function --defaulting --programmatic-validation
 
       - name: Deploy function mesh server
         run: |

go.mod

@@ -3,6 +3,7 @@ module github.com/streamnative/function-mesh
 go 1.13
 
 require (
+	github.com/ghodss/yaml v1.0.0
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/go-logr/logr v0.1.0
 	github.com/gogo/protobuf v1.3.1
@@ -12,10 +13,12 @@ require (
 	github.com/onsi/gomega v1.10.4
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/prometheus/client_golang v1.1.0 // indirect
+	github.com/streamnative/pulsarctl v0.5.0
 	github.com/stretchr/testify v1.6.1
 	golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d // indirect
 	google.golang.org/appengine v1.6.6 // indirect
 	google.golang.org/protobuf v1.25.0
+	gopkg.in/yaml.v2 v2.3.0
 	k8s.io/api v0.18.6
 	k8s.io/apimachinery v0.18.6
 	k8s.io/client-go v0.18.6