Feature storeview (#283)

* feat: support storeView impl

* chore: add const storeType

* chore: use const in test

* feat: add interface for storeView

Author: crimson-gao

client_interface.go

@@ -170,6 +170,20 @@ type ClientInterface interface {
 	// ListEventStore returns all eventStore names of project p.
 	ListEventStore(project string, offset, size int) ([]string, error)
 
+	// #################### StoreView Operations #####################
+	// CreateStoreView creates a new storeView.
+	CreateStoreView(project string, storeView *StoreView) error
+	// UpdateStoreView updates a storeView.
+	UpdateStoreView(project string, storeView *StoreView) error
+	// DeleteStoreView deletes a storeView.
+	DeleteStoreView(project string, storeViewName string) error
+	// GetStoreView returns storeView.
+	GetStoreView(project string, storeViewName string) (*StoreView, error)
+	// ListStoreViews returns all storeView names of a project.
+	ListStoreViews(project string, req *ListStoreViewsRequest) (*ListStoreViewsResponse, error)
+	// GetStoreViewIndex returns all index config of logstores in the storeView, only support storeType logstore.
+	GetStoreViewIndex(project string, storeViewName string) (*GetStoreViewIndexResponse, error)
+
 	// #################### Logtail Operations #####################
 	// ListMachineGroup returns machine group name list and the total number of machine groups.
 	// The offset starts from 0 and the size is the max number of machine groups could be returned.

client_store_view.go

@@ -0,0 +1,124 @@
+package sls
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+)
+
+func (c *Client) CreateStoreView(project string, storeView *StoreView) error {
+	body, err := json.Marshal(storeView)
+	if err != nil {
+		return NewClientError(err)
+	}
+	h := map[string]string{
+		"Content-Type":      "application/json",
+		"x-log-bodyrawsize": fmt.Sprintf("%v", len(body)),
+	}
+	uri := "/storeviews"
+	r, err := c.request(project, "POST", uri, h, body)
+	if err != nil {
+		return err
+	}
+	r.Body.Close()
+	return nil
+}
+
+func (c *Client) UpdateStoreView(project string, storeView *StoreView) error {
+	body, err := json.Marshal(storeView)
+	if err != nil {
+		return NewClientError(err)
+	}
+	h := map[string]string{
+		"Content-Type":      "application/json",
+		"x-log-bodyrawsize": fmt.Sprintf("%v", len(body)),
+	}
+	uri := "/storeviews/" + storeView.Name
+	r, err := c.request(project, "PUT", uri, h, body)
+	if err != nil {
+		return err
+	}
+	r.Body.Close()
+	return nil
+}
+
+func (c *Client) DeleteStoreView(project string, storeViewName string) error {
+	h := map[string]string{
+		"Content-Type":      "application/json",
+		"x-log-bodyrawsize": "0",
+	}
+	uri := "/storeviews/" + storeViewName
+	r, err := c.request(project, "DELETE", uri, h, nil)
+	if err != nil {
+		return err
+	}
+	r.Body.Close()
+	return nil
+}
+
+func (c *Client) GetStoreView(project string, storeViewName string) (*StoreView, error) {
+	h := map[string]string{
+		"Content-Type":      "application/json",
+		"x-log-bodyrawsize": "0",
+	}
+	uri := "/storeviews/" + storeViewName
+	r, err := c.request(project, "GET", uri, h, nil)
+	if err != nil {
+		return nil, err
+	}
+	defer r.Body.Close()
+	buf, err := ioutil.ReadAll(r.Body)
+	if err != nil {
+		return nil, err
+	}
+	res := &StoreView{}
+	if err = json.Unmarshal(buf, res); err != nil {
+		return nil, NewClientError(err)
+	}
+	res.Name = storeViewName
+	return res, nil
+}
+
+func (c *Client) ListStoreViews(project string, req *ListStoreViewsRequest) (*ListStoreViewsResponse, error) {
+	h := map[string]string{
+		"Content-Type":      "application/json",
+		"x-log-bodyrawsize": "0",
+	}
+	uri := fmt.Sprintf("/storeviews?offset=%d&line=%d", req.Offset, req.Size)
+	r, err := c.request(project, "GET", uri, h, nil)
+	if err != nil {
+		return nil, err
+	}
+	defer r.Body.Close()
+	buf, err := ioutil.ReadAll(r.Body)
+	if err != nil {
+		return nil, err
+	}
+	res := &ListStoreViewsResponse{}
+	if err = json.Unmarshal(buf, res); err != nil {
+		return nil, NewClientError(err)
+	}
+	return res, nil
+}
+
+func (c *Client) GetStoreViewIndex(project string, storeViewName string) (*GetStoreViewIndexResponse, error) {
+	h := map[string]string{
+		"Content-Type":      "application/json",
+		"x-log-bodyrawsize": "0",
+	}
+	uri := fmt.Sprintf("/storeviews/%s/index", storeViewName)
+	r, err := c.request(project, "GET", uri, h, nil)
+	if err != nil {
+		return nil, err
+	}
+	defer r.Body.Close()
+	buf, err := ioutil.ReadAll(r.Body)
+	if err != nil {
+		return nil, err
+	}
+	res := &GetStoreViewIndexResponse{}
+	if err = json.Unmarshal(buf, res); err != nil {
+		return nil, NewClientError(err)
+	}
+	return res, nil
+}