Make indexID configurable (#2)

* Make indexID configurable

* Fix sprintf parameter order

* Make indexID a mandatory parameter instead of having a default value

---------

Co-authored-by: Lukas Knienieder <[email protected]>

client.go

@@ -26,6 +26,10 @@ func New(cfg Config) *Client {
 		panic("missing Quickwit URL")
 	}
 
+	if cfg.IndexID == "" {
+		panic("missing Quickwit Index ID")
+	}
+
 	if cfg.BatchWait < 0 {
 		panic("wrong BatchWait option")
 	}
@@ -56,8 +60,8 @@ func New(cfg Config) *Client {
 }
 
 // NewWithDefault creates a new client with default configuration.
-func NewWithDefault(url string) *Client {
-	return New(NewDefaultConfig(url))
+func NewWithDefault(url string, indexID string) *Client {
+	return New(NewDefaultConfig(url, indexID))
 }
 
 func (c *Client) run() {
@@ -130,7 +134,7 @@ func (c *Client) send(buf *bytes.Buffer) (int, error) {
 	ctx, cancel := context.WithTimeout(context.Background(), c.cfg.Timeout)
 	defer cancel()
 
-	url := c.cfg.URL + "/api/v1/test/ingest?commit=" + string(c.cfg.Commit)
+	url := fmt.Sprintf("%s/api/v1/%s/ingest?commit=%s", c.cfg.URL, c.cfg.IndexID, string(c.cfg.Commit))
 
 	req, err := http.NewRequestWithContext(ctx, "POST", url, buf)
 	if err != nil {

config.go

@@ -30,6 +30,8 @@ type Config struct {
 	URL    string
 	Client http.Client
 
+	IndexID string
+
 	BatchWait  time.Duration
 	BatchBytes int
 	Commit     CommitMode
@@ -39,11 +41,13 @@ type Config struct {
 }
 
 // NewDefaultConfig creates a default configuration for a given Quickwit cluster.
-func NewDefaultConfig(url string) Config {
+func NewDefaultConfig(url string, indexID string) Config {
 	return Config{
 		URL:    url,
 		Client: http.Client{},
 
+		IndexID: indexID,
+
 		BatchWait:  DefaultBatchWait,
 		BatchBytes: DefaultBatchBytes,
 		Commit:     DefautCommitMode,

example/example.go

@@ -14,7 +14,7 @@ func main() {
 	//     -H 'Content-Type: application/yaml' \
 	//     --data-binary @test-config.yaml
 
-	client := quickwit.NewWithDefault("http://localhost:7280")
+	client := quickwit.NewWithDefault("http://localhost:7280", "test")
 	defer client.Stop() // flush and stop
 
 	for i := 0; i < 10; i++ {