Function exec

cmd/client/create/cmd.go:62–98

(_ *cobra.Command, _ []string)

}

func exec(_ *cobra.Command, _ []string) {
	cfg := adminclient.NewConfiguration()
	cfg.Servers = []adminclient.ServerConfiguration{{
		URL: common.Config.ServiceAddr,
	}}
	cli := adminclient.NewAPIClient(cfg)
	f := adminclient.ModelFunction{
		Name: config.name,
		Runtime: adminclient.ModelRuntimeConfig{
			Type: fs_cmmon.WASMRuntime,
			Config: map[string]interface{}{
				fs_cmmon.RuntimeArchiveConfigKey: config.archive,
			}},
		Source:   utils.MakeMemorySourceTubeConfig(config.inputs...),
		Sink:     *utils.MakeMemorySinkTubeConfig(config.output),
		Replicas: config.replica,
	}

	res, err := cli.FunctionAPI.CreateFunction(context.Background()).Body(f).Execute()
	if err != nil {
		if res != nil {
			body, e := io.ReadAll(res.Body)
			if e != nil {
				fmt.Printf("Failed to create function: %v\n", err)
			} else {
				fmt.Printf("Failed to create function: %v, %s\n", err, string(body))
			}
		} else {
			fmt.Printf("Failed to create function: %v\n", err)
		}
		os.Exit(1)
	}
	if res.StatusCode != 200 {
		fmt.Printf("Failed to create function with status code: %d\n", res.StatusCode)
		os.Exit(1)
	}
}