1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495 |
- package client
- import (
- "encoding/json"
- "fmt"
- "git.sxidc.com/go-tools/api_binding/http_binding/response"
- "net/url"
- "strconv"
- )
- const (
- createDataContainerUrl = "/ds/api/v1/dataContainer/create"
- deleteDataContainerUrl = "/ds/api/v1/dataContainer/delete"
- getDataContainersUrl = "/ds/api/v1/dataContainer/query"
- )
- func (c *Client) CreateDataContainer(token string, baseUrl string, namespace string, dataSource string, name string, spec map[string]any) error {
- fullUrl, err := url.JoinPath(baseUrl, createDataContainerUrl)
- if err != nil {
- return err
- }
- resp := new(response.MsgResponse)
- specJsonBytes, err := json.Marshal(spec)
- if err != nil {
- return err
- }
- err = c.post(token, fullUrl, map[string]any{
- "namespace": namespace,
- "dataSource": dataSource,
- "name": name,
- "spec": string(specJsonBytes),
- }, resp)
- if err != nil {
- return err
- }
- if !resp.Success {
- return fmt.Errorf(resp.Msg)
- }
- return nil
- }
- func (c *Client) DeleteDataContainer(token string, baseUrl string, namespace string, dataSource string, name string) error {
- fullUrl, err := url.JoinPath(baseUrl, deleteDataContainerUrl)
- if err != nil {
- return err
- }
- resp := new(response.MsgResponse)
- err = c.post(token, fullUrl, map[string]any{
- "namespace": namespace,
- "dataSource": dataSource,
- "name": name,
- }, resp)
- if err != nil {
- return err
- }
- if !resp.Success {
- return fmt.Errorf(resp.Msg)
- }
- return nil
- }
- func (c *Client) GetDataContainers(token string, baseUrl string, namespace string, dataSource string, name string, pageNo int, pageSize int) ([]DataContainerInfo, error) {
- fullUrl, err := url.JoinPath(baseUrl, getDataContainersUrl)
- if err != nil {
- return nil, err
- }
- resp := new(response.InfosResponse[DataContainerInfo])
- err = c.get(token, fullUrl, map[string]string{
- "namespace": namespace,
- "dataSource": dataSource,
- "name": name,
- "pageNo": strconv.Itoa(pageNo),
- "pageSize": strconv.Itoa(pageSize),
- }, resp)
- if err != nil {
- return nil, err
- }
- if !resp.Success {
- return nil, fmt.Errorf(resp.Msg)
- }
- return resp.Infos, nil
- }
|