You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by hg...@apache.org on 2025/07/05 09:11:28 UTC
(iggy) branch master updated: chore(sdk): delete `cli` folder in golang sdk. (#1961)
This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new ec58571b chore(sdk): delete `cli` folder in golang sdk. (#1961)
ec58571b is described below
commit ec58571bf702f9236fc03cbbe296811ea1c5e667
Author: Chengxi <ch...@gmail.com>
AuthorDate: Sat Jul 5 05:11:23 2025 -0400
chore(sdk): delete `cli` folder in golang sdk. (#1961)
Since iggy already has a rust client tool. I think this cli tool can be
deprecated.
---
foreign/go/cli/cli.go | 357 --------------------------------------------------
1 file changed, 357 deletions(-)
diff --git a/foreign/go/cli/cli.go b/foreign/go/cli/cli.go
deleted file mode 100644
index 289e5574..00000000
--- a/foreign/go/cli/cli.go
+++ /dev/null
@@ -1,357 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-package main
-
-import (
- "encoding/json"
- "flag"
- "fmt"
- "os"
-
- . "github.com/apache/iggy/foreign/go/contracts"
- "github.com/apache/iggy/foreign/go/iggycli"
- "github.com/apache/iggy/foreign/go/tcp"
-)
-
-// CLI commands
-var (
- createStreamCmd = flag.NewFlagSet("createstream", flag.ExitOnError)
- updateStreamCmd = flag.NewFlagSet("updatestream", flag.ExitOnError)
- getStreamCmd = flag.NewFlagSet("getstream", flag.ExitOnError)
- deleteStreamCmd = flag.NewFlagSet("deletestream", flag.ExitOnError)
-
- createTopicCmd = flag.NewFlagSet("createtopic", flag.ExitOnError)
- updateTopicCmd = flag.NewFlagSet("updatetopic", flag.ExitOnError)
- getTopicCmd = flag.NewFlagSet("gettopic", flag.ExitOnError)
- deleteTopicCmd = flag.NewFlagSet("deletetopic", flag.ExitOnError)
-
- getStatsCmd = flag.NewFlagSet("getstats", flag.ExitOnError)
-)
-
-// CLI flags
-var (
- url string
- port string
-
- //get stream
- gs_streamId int
-
- //create stream
- cs_streamId int
- cs_name string
-
- //update stream
- us_streamId int
- us_name string
-
- //delete stream
- ds_streamId int
-
- //get topic
- gt_streamId int
- gt_topicId int
-
- //create topic
- ct_streamId int
- ct_topicId int
- ct_name string
- ct_partitionsCount int
-
- //update topic
- ut_streamId int
- ut_topicId int
- ut_name string
-
- //delete topic
- dt_streamId int
- dt_topicId int
-)
-
-func getUsage() {
- fmt.Println("Usage:")
- fmt.Println(" getstream -url <url> -port <port> -streamId <streamId>")
- fmt.Println(" createstream -url <url> -port <port> -streamId <streamId> -name <name>")
- fmt.Println(" updatestream -url <url> -port <port> -streamId <streamId> -name <name>")
- fmt.Println(" deletestream -url <url> -port <port> -streamId <streamId>")
- fmt.Println(" gettopic -url <url> -port <port> -streamId <streamId> -topicId <topicId>")
- fmt.Println(" createtopic -url <url> -port <port> -streamId <streamId> -topicId <topicId> -name <name> -partitionsCount <partitionsCount>")
- fmt.Println(" deletetopic -url <url> -port <port> -streamId <streamId> -topicId <topicId>")
- fmt.Println(" getstats -url <url> -port <port>")
-}
-
-func init() {
- getStreamCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- getStreamCmd.StringVar(&port, "port", "8090", "Iggy server port")
- getStreamCmd.IntVar(&gs_streamId, "streamname", -1, "Stream Id. Returns all streams for default value.")
- getStreamCmd.IntVar(&gs_streamId, "sname", -1, "Alias for Stream Id")
- getStreamCmd.IntVar(&gs_streamId, "s", -1, "Alias for Stream Id")
-
- createStreamCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- createStreamCmd.StringVar(&port, "port", "8090", "Iggy server port")
- createStreamCmd.IntVar(&cs_streamId, "streamid", 1, "Stream Id")
- createStreamCmd.IntVar(&cs_streamId, "sid", 1, "Alias for Stream Id")
- createStreamCmd.IntVar(&cs_streamId, "s", 1, "Alias for Stream Id")
- createStreamCmd.StringVar(&cs_name, "name", "", "Stream name")
- createStreamCmd.StringVar(&cs_name, "n", "", "Stream name")
-
- updateStreamCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- updateStreamCmd.StringVar(&port, "port", "8090", "Iggy server port")
- updateStreamCmd.IntVar(&us_streamId, "streamid", 1, "Stream Id")
- updateStreamCmd.IntVar(&us_streamId, "sid", 1, "Alias for Stream Id")
- updateStreamCmd.IntVar(&us_streamId, "s", 1, "Alias for Stream Id")
- updateStreamCmd.StringVar(&us_name, "name", "", "Stream name")
- updateStreamCmd.StringVar(&us_name, "n", "", "Stream name")
-
- deleteStreamCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- deleteStreamCmd.StringVar(&port, "port", "8090", "Iggy server port")
- deleteStreamCmd.IntVar(&ds_streamId, "streamid", -1, "Stream Id")
- deleteStreamCmd.IntVar(&ds_streamId, "sid", -1, "Alias for Stream Id")
- deleteStreamCmd.IntVar(&ds_streamId, "s", -1, "Alias for Stream Id")
-
- getTopicCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- getTopicCmd.StringVar(&port, "port", "8090", "Iggy server port")
- getTopicCmd.IntVar(>_streamId, "streamid", 1, "Stream Id")
- getTopicCmd.IntVar(>_streamId, "sid", 1, "Alias for Stream Id")
- getTopicCmd.IntVar(>_streamId, "s", 1, "Alias for Stream Id")
- getTopicCmd.IntVar(>_topicId, "topicid", -1, "Topic Id. Returns all streams for default value.")
- getTopicCmd.IntVar(>_topicId, "tid", -1, "Alias for Topic Id")
- getTopicCmd.IntVar(>_topicId, "t", -1, "Alias for Topic Id")
-
- createTopicCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- createTopicCmd.StringVar(&port, "port", "8090", "Iggy server port")
- createTopicCmd.IntVar(&ct_streamId, "streamid", 1, "Stream Id")
- createTopicCmd.IntVar(&ct_streamId, "sid", 1, "Alias for Stream Id")
- createTopicCmd.IntVar(&ct_streamId, "s", 1, "Alias for Stream Id")
- createTopicCmd.IntVar(&ct_topicId, "topicid", 2, "Topic Id")
- createTopicCmd.IntVar(&ct_topicId, "tid", 1, "Alias for Topic Id")
- createTopicCmd.IntVar(&ct_topicId, "t", 1, "Alias for Topic Id")
- createTopicCmd.StringVar(&ct_name, "name", "", "Topic name")
- createTopicCmd.StringVar(&ct_name, "n", "", "Alias for Topic name")
- createTopicCmd.IntVar(&ct_partitionsCount, "partitionsCount", 1, "Number of partitions in topic")
- createTopicCmd.IntVar(&ct_partitionsCount, "pc", 1, "Alias for Number of partitions in topic")
-
- updateTopicCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- updateTopicCmd.StringVar(&port, "port", "8090", "Iggy server port")
- updateTopicCmd.IntVar(&ut_streamId, "streamid", 1, "Stream Id")
- updateTopicCmd.IntVar(&ut_streamId, "sid", 1, "Alias for Stream Id")
- updateTopicCmd.IntVar(&ut_streamId, "s", 1, "Alias for Stream Id")
- updateTopicCmd.IntVar(&ut_topicId, "topicid", 2, "Topic Id")
- updateTopicCmd.IntVar(&ut_topicId, "tid", 1, "Alias for Topic Id")
- updateTopicCmd.IntVar(&ut_topicId, "t", 1, "Alias for Topic Id")
- updateTopicCmd.StringVar(&ut_name, "name", "", "Topic name")
- updateTopicCmd.StringVar(&ut_name, "n", "", "Alias for Topic name")
-
- deleteTopicCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- deleteTopicCmd.StringVar(&port, "port", "8090", "Iggy server port")
- deleteTopicCmd.IntVar(&dt_streamId, "streamid", -1, "Stream Id")
- deleteTopicCmd.IntVar(&dt_streamId, "sid", -1, "Alias for Stream Id")
- deleteTopicCmd.IntVar(&dt_streamId, "s", -1, "Alias for Stream Id")
- deleteTopicCmd.IntVar(&dt_topicId, "topicid", -1, "Topic Id")
- deleteTopicCmd.IntVar(&dt_topicId, "tid", -1, "Alias for Topic Id")
- deleteTopicCmd.IntVar(&dt_topicId, "t", -1, "Alias for Topic Id")
-
- getStatsCmd.StringVar(&url, "url", "127.0.0.1", "Iggy server url")
- getStatsCmd.StringVar(&port, "port", "8090", "Iggy server port")
-}
-
-func main() {
- fmt.Println("THIS CLI IS NOT SUPPORTED, IT WILL BE REPLACED IN A CLOSE FUTURE.")
- if len(os.Args) < 2 {
- fmt.Println("No command provided.")
- os.Exit(1)
- }
-
- //this is very temporary
- cli := CreateClient()
- _, err := cli.LoginUser("iggy", "iggy")
- if err != nil {
- fmt.Println(err)
- os.Exit(1)
- }
-
- switch os.Args[1] {
- case "createstream":
- _ = createStreamCmd.Parse(os.Args[2:])
- if cs_name == "" {
- fmt.Println("Error: Name flag is required.")
- createStreamCmd.PrintDefaults()
- os.Exit(1)
- }
- uintStreamId := uint32(cs_streamId)
- _, err = cli.CreateStream(cs_name, &uintStreamId)
- if err != nil {
- HandleError(err)
- }
-
- case "updatestream":
- _ = updateStreamCmd.Parse(os.Args[2:])
- if us_name == "" {
- fmt.Println("Error: Name flag is required.")
- updateStreamCmd.PrintDefaults()
- os.Exit(1)
- }
-
- err := cli.UpdateStream(NewIdentifier(us_streamId), us_name)
- if err != nil {
- HandleError(err)
- }
-
- case "getstream":
- _ = getStreamCmd.Parse(os.Args[2:])
- if gs_streamId == -1 {
- streams, err := cli.GetStreams()
- if err != nil {
- HandleError(err)
- }
- SerializeAndPrint(streams)
- return
- }
-
- stream, err := cli.GetStream(NewIdentifier(gs_streamId))
- if err != nil {
- HandleError(err)
- }
- SerializeAndPrint(stream)
-
- case "deletestream":
- _ = deleteStreamCmd.Parse(os.Args[2:])
- if ds_streamId == -1 {
- fmt.Println("Error: Stream Id is required.")
- deleteStreamCmd.PrintDefaults()
- os.Exit(1)
- }
-
- err := cli.DeleteStream(NewIdentifier(ds_streamId))
- if err != nil {
- HandleError(err)
- }
-
- case "createtopic":
- _ = createTopicCmd.Parse(os.Args[2:])
- if ct_name == "" {
- fmt.Println("Error: Name flag is required.")
- createTopicCmd.PrintDefaults()
- os.Exit(1)
- }
-
- _, err := cli.CreateTopic(
- NewIdentifier(ct_streamId),
- ct_name,
- ct_partitionsCount,
- 0,
- 0,
- 0,
- nil,
- &ct_topicId)
- if err != nil {
- HandleError(err)
- }
- case "updatetopic":
- _ = updateTopicCmd.Parse(os.Args[2:])
- if ut_name == "" {
- fmt.Println("Error: Name flag is required.")
- updateTopicCmd.PrintDefaults()
- os.Exit(1)
- }
-
- err := cli.UpdateTopic(
- NewIdentifier(ut_streamId),
- NewIdentifier(ut_topicId),
- ut_name,
- 0,
- 0,
- 0,
- new(uint8),
- )
- if err != nil {
- HandleError(err)
- }
-
- case "gettopic":
- _ = getTopicCmd.Parse(os.Args[2:])
-
- if gt_topicId == -1 {
- topics, err := cli.GetTopics(NewIdentifier(gt_streamId))
- if err != nil {
- HandleError(err)
- }
- SerializeAndPrint(topics)
- return
- }
- topic, err := cli.GetTopic(NewIdentifier(gt_streamId), NewIdentifier(gt_topicId))
- if err != nil {
- HandleError(err)
- }
- SerializeAndPrint(topic)
-
- case "deletetopic":
- _ = deleteTopicCmd.Parse(os.Args[2:])
- if dt_streamId == -1 {
- fmt.Println("Error: Stream Id is required.")
- deleteStreamCmd.PrintDefaults()
- os.Exit(1)
- }
-
- if dt_topicId == -1 {
- fmt.Println("Error: Topic Id is required.")
- deleteStreamCmd.PrintDefaults()
- os.Exit(1)
- }
-
- err := cli.DeleteTopic(NewIdentifier(dt_streamId), NewIdentifier(dt_topicId))
- if err != nil {
- HandleError(err)
- }
-
- case "getstats":
- _ = getStatsCmd.Parse(os.Args[2:])
- stats, err := cli.GetStats()
- if err != nil {
- HandleError(err)
- }
- SerializeAndPrint(stats)
-
- case "help":
- getUsage()
- default:
- fmt.Println("Error: Unknown command.")
- getUsage()
- os.Exit(1)
- }
-}
-
-func CreateClient() iggycli.Client {
- cli, err := iggycli.NewIggyClient(iggycli.WithTcp(tcp.WithServerAddress(url + ":" + port)))
- if err != nil {
- panic(err)
- }
- return cli
-}
-
-func SerializeAndPrint(obj any) {
- jsonData, err := json.MarshalIndent(&obj, "", " ")
- if err != nil {
- HandleError(err)
- }
- fmt.Println(string(jsonData))
-}
-
-func HandleError(err error) {
- fmt.Println("Error:", err)
- os.Exit(1)
-}