alihan/arkade-kubernetes
1
0
Fork 0
mirror of https://github.com/alexellis/arkade.git synced 2022-05-07 18:22:49 +03:00
Code Issues Projects Releases Wiki Activity

Add license flag for Kafka app

Browse Source 
Signed-off-by: Alex Ellis (OpenFaaS Ltd) <alexellis2@gmail.com>
This commit is contained in:
Alex Ellis (OpenFaaS Ltd)
2021-03-04 11:30:56 +00:00
parent d1d02d1329
commit 8281539e15
2 changed files with 26 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
cmd/apps/kafkaconnector_app.go
View File

@@ -7,7 +7,6 @@ import (
"fmt"
"github.com/alexellis/arkade/pkg/apps"
"github.com/alexellis/arkade/pkg/k8s"
"github.com/alexellis/arkade/pkg/types"
"github.com/alexellis/arkade/pkg"
@@ -16,9 +15,10 @@ import (
func MakeInstallKafkaConnector() *cobra.Command {
var command = &cobra.Command{
Use: "kafka-connector",
Short: "Install kafka-connector for OpenFaaS",
Long: `Install kafka-connector for OpenFaaS`,
Use: "kafka-connector",
Short: "Install kafka-connector for OpenFaaS",
Long: `Install OpenFaaS PRO kafka-connector for OpenFaaS so that you can invoke
functions when messages are received on a given topic on a Kafka broker.`,
Example: ` arkade install kafka-connector`,
SilenceUsage: true,
}
@@ -27,6 +27,7 @@ func MakeInstallKafkaConnector() *cobra.Command {
command.Flags().Bool("update-repo", true, "Update the helm repo")
command.Flags().StringP("topics", "t", "faas-request", "The topics for the connector to bind to")
command.Flags().String("broker-host", "kafka", "The host for the Kafka broker")
command.Flags().String("license-file", "", "The path to your license for OpenFaaS PRO")
command.Flags().StringArray("set", []string{},
"Use custom flags or override existing flags \n(example --set key=value)")
@@ -61,12 +62,6 @@ func MakeInstallKafkaConnector() *cobra.Command {
return err
}
arch := k8s.GetNodeArchitecture()
fmt.Printf("Node architecture: %q\n", arch)
if arch != IntelArch {
return fmt.Errorf(OnlyIntelArch)
}
kafkaConnectorAppOptions := types.DefaultInstallOptions().
WithNamespace(namespace).
WithHelmRepo("openfaas/kafka-connector").
@@ -75,6 +70,23 @@ func MakeInstallKafkaConnector() *cobra.Command {
WithHelmUpdateRepo(updateRepo).
WithKubeconfigPath(kubeConfigPath)
// If license file is sent, then we assume to set the --pro flag and create the secret
licenseFile, err := command.Flags().GetString("license-file")
if err != nil {
return err
}
if len(licenseFile) == 0 {
return fmt.Errorf("--license-file is required for OpenFaaS PRO")
}
overrides["openfaasPRO"] = "true"
secretData := []types.SecretsData{
{Type: types.FromFileSecret, Key: "license", Value: licenseFile},
}
proLicense := types.NewGenericSecret("openfaas-license", namespace, secretData)
kafkaConnectorAppOptions.WithSecret(proLicense)
_, err = apps.MakeInstallChart(kafkaConnectorAppOptions)
if err != nil {
return err

7
cmd/apps/mqttconnector_app.go
View File

@@ -16,9 +16,10 @@ import (
func MakeInstallMQTTConnector() *cobra.Command {
var command = &cobra.Command{
Use: "mqtt-connector",
Short: "Install mqtt-connector for OpenFaaS",
Long: `Install mqtt-connector for OpenFaaS`,
Use: "mqtt-connector",
Short: "Install mqtt-connector for OpenFaaS",
Long: `Install mqtt-connector for OpenFaaS so that you can invoke functions when
messages are received on a given topic on an MQTT broker.`,
Example: ` arkade install mqtt-connector`,
SilenceUsage: true,
}