create

Documentation

Index

• Constants
• Variables

Constants

const (
	DatabaseAddress           = "address"
	DatabaseAddressShorthand  = "a"
	DatabaseUsername          = "username"
	DatabaseUsernameShorthand = "u"
	DatabasePassword          = "password"
	DatabasePasswordShorthand = "p"
	DatabaseType              = "type"
	DatabaseTypeShorthand     = "t"
)

const (
	NameKey       = "name"
	NameShorthand = "n"
)

const (
	EnvironmentIDKey         = "env-id"
	IntegrationNameKey       = "name"
	IntegrationNameShorthand = "n"
)

Variables

var CreateDatabaseIntegrationCmd = &cobra.Command{
	Use:          "database",
	Short:        "Create a database integration",
	Args:         cobra.NoArgs,
	SilenceUsage: true,
	RunE: func(_ *cobra.Command, args []string) error {
		ctxTimeout, cancel := context.WithTimeout(context.Background(), config.DefaultTimeout)
		defer cancel()

		c, err := cloudclient.NewClient(ctxTimeout)
		if err != nil {
			return err
		}

		r, err := c.CreateDatabaseIntegrationMutationWithResponse(ctxTimeout,
			cloudapi.CreateDatabaseIntegrationMutationJSONRequestBody{
				Name: viper.GetString(NameKey),
				DatabaseInfo: cloudapi.DatabaseInfoInput{
					Address: viper.GetString(DatabaseAddress),
					Credentials: map[string]interface{}{
						"username": viper.GetString(DatabaseUsername),
						"password": viper.GetString(DatabasePassword),
					},
					DatabaseType: cloudapi.DatabaseInfoInputDatabaseType(viper.GetString(DatabaseType)),
				},
			})
		if err != nil {
			return err
		}

		output.FormatIntegrations([]cloudapi.Integration{lo.FromPtr(r.JSON200)}, true)
		return nil
	},
}

var CreateGenericIntegrationCmd = &cobra.Command{
	Use:          "generic",
	Short:        "Create a generic integration",
	Args:         cobra.NoArgs,
	SilenceUsage: true,
	RunE: func(_ *cobra.Command, args []string) error {
		ctxTimeout, cancel := context.WithTimeout(context.Background(), config.DefaultTimeout)
		defer cancel()

		c, err := cloudclient.NewClient(ctxTimeout)
		if err != nil {
			return err
		}

		r, err := c.CreateGenericIntegrationMutationWithResponse(ctxTimeout,
			cloudapi.CreateGenericIntegrationMutationJSONRequestBody{
				Name: viper.GetString(NameKey),
			})
		if err != nil {
			return err
		}

		output.FormatIntegrations([]cloudapi.Integration{lo.FromPtr(r.JSON200)}, true)
		return nil
	},
}

var CreateGithubIntegrationCmd = &cobra.Command{
	Use:          "github",
	Short:        "Create a GitHub integration",
	Args:         cobra.NoArgs,
	SilenceUsage: true,
	RunE: func(_ *cobra.Command, args []string) error {
		output.PrintStdout("To create a GitHub integration, you need to authorize Otterize Cloud on your GitHub account. To do that, use Otterize Cloud at https://app.otterize.com/integrations")
		return nil
	},
}

var CreateIntegrationCmd = &cobra.Command{
	Use:   "create",
	Short: "Create an integration",
}

var CreateKubernetesIntegrationCmd = &cobra.Command{
	Use:          "kubernetes",
	Short:        "Create a Kubernetes integration",
	Args:         cobra.NoArgs,
	SilenceUsage: true,
	RunE: func(_ *cobra.Command, args []string) error {
		ctxTimeout, cancel := context.WithTimeout(context.Background(), config.DefaultTimeout)
		defer cancel()

		c, err := cloudclient.NewClient(ctxTimeout)
		if err != nil {
			return err
		}

		r, err := c.CreateKubernetesIntegrationMutationWithResponse(ctxTimeout,
			cloudapi.CreateKubernetesIntegrationMutationJSONRequestBody{
				EnvironmentId: lo.Ternary(viper.IsSet(EnvironmentIDKey), lo.ToPtr(viper.GetString(EnvironmentIDKey)), nil),
				Name:          viper.GetString(IntegrationNameKey),
			})
		if err != nil {
			return err
		}

		output.FormatIntegrations([]cloudapi.Integration{lo.FromPtr(r.JSON200)}, true)
		return nil
	},
}