client

Documentation

Index

• func InitInstance(timeout time.Duration)
• type Client
  • func GetInstance() *Client
  • func New(timeout time.Duration) *Client
  • func (c *Client) CreateDataContainer(token string, baseUrl string, namespace string, dataSource string, name string, ...) error
  • func (c *Client) CreateDataSource(token string, baseUrl string, namespace string, name string, typeStr string, ...) error
  • func (c *Client) CreateNamespace(token string, baseUrl string, name string) error
  • func (c *Client) DeleteDataContainer(token string, baseUrl string, namespace string, dataSource string, name string) error
  • func (c *Client) DeleteDataSource(token string, baseUrl string, namespace string, name string) error
  • func (c *Client) DeleteNamespace(token string, baseUrl string, name string) error
  • func (c *Client) DeleteToken(token string, baseUrl string, name string) error
  • func (c *Client) ExecuteRawSql(token string, baseUrl string, namespace string, dataSource string, sql string, ...) ([]map[string]any, int64, error)
  • func (c *Client) GenerateToken(token string, baseUrl string, name string) (string, error)
  • func (c *Client) GetDataContainers(token string, baseUrl string, namespace string, dataSource string, name string, ...) ([]DataContainerInfo, error)
  • func (c *Client) GetDataSourceSpec(token string, baseUrl string, namespace string, name string) (string, error)
  • func (c *Client) GetDataSources(token string, baseUrl string, namespace string, name string, typeStr string, ...) ([]DataSourceInfo, error)
  • func (c *Client) GetExecuteSqlLogs(token string, baseUrl string, namespace string, dataSource string, ...) ([]ExecuteSqlLogInfo, error)
  • func (c *Client) GetNamespaces(token string, baseUrl string, name string, pageNo int, pageSize int) ([]NamespaceInfo, error)
  • func (c *Client) GetTokens(token string, baseUrl string, name string, pageNo int, pageSize int) ([]TokenInfo, error)
  • func (c *Client) Version(baseUrl string) error
• type DataContainerInfo
• type DataSourceInfo
• type ExecuteSqlLogInfo
• type InfosData
• type InfosResponse
• type MsgResponse
• type NamespaceInfo
• type TokenInfo

Functions

func InitInstance

func InitInstance(timeout time.Duration)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance() *Client

func New

func New(timeout time.Duration) *Client

func (*Client) CreateDataContainer

func (c *Client) CreateDataContainer(token string, baseUrl string, namespace string, dataSource string, name string, spec map[string]any) error

func (*Client) CreateDataSource

func (c *Client) CreateDataSource(token string, baseUrl string, namespace string, name string, typeStr string, spec map[string]any) error

func (*Client) CreateNamespace

func (c *Client) CreateNamespace(token string, baseUrl string, name string) error

func (*Client) DeleteDataContainer

func (c *Client) DeleteDataContainer(token string, baseUrl string, namespace string, dataSource string, name string) error

func (*Client) DeleteDataSource

func (c *Client) DeleteDataSource(token string, baseUrl string, namespace string, name string) error

func (*Client) DeleteNamespace

func (c *Client) DeleteNamespace(token string, baseUrl string, name string) error

func (*Client) DeleteToken

func (c *Client) DeleteToken(token string, baseUrl string, name string) error

func (*Client) ExecuteRawSql

func (c *Client) ExecuteRawSql(token string, baseUrl string,
	namespace string, dataSource string, sql string, values ...any) ([]map[string]any, int64, error)

func (*Client) GenerateToken

func (c *Client) GenerateToken(token string, baseUrl string, name string) (string, error)

func (*Client) GetDataContainers

func (c *Client) GetDataContainers(token string, baseUrl string, namespace string, dataSource string, name string, pageNo int, pageSize int) ([]DataContainerInfo, error)

func (*Client) GetDataSourceSpec

func (c *Client) GetDataSourceSpec(token string, baseUrl string, namespace string, name string) (string, error)

func (*Client) GetDataSources

func (c *Client) GetDataSources(token string, baseUrl string, namespace string, name string, typeStr string, pageNo int, pageSize int) ([]DataSourceInfo, error)

func (*Client) GetExecuteSqlLogs

func (c *Client) GetExecuteSqlLogs(token string, baseUrl string, namespace string, dataSource string,
	executor string, startExecuteTime string, endExecuteTime string, pageNo int, pageSize int) ([]ExecuteSqlLogInfo, error)

func (*Client) GetNamespaces

func (c *Client) GetNamespaces(token string, baseUrl string, name string, pageNo int, pageSize int) ([]NamespaceInfo, error)

func (*Client) GetTokens

func (c *Client) GetTokens(token string, baseUrl string, name string, pageNo int, pageSize int) ([]TokenInfo, error)

func (*Client) Version

func (c *Client) Version(baseUrl string) error

type DataContainerInfo

type DataContainerInfo struct {
	Namespace  string `json:"namespace"`
	DataSource string `json:"dataSource"`
	Name       string `json:"name"`
	Spec       string `json:"spec"`
}

type DataSourceInfo

type DataSourceInfo struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	Type      string `json:"type"`
	Spec      string `json:"spec"`
}

type ExecuteSqlLogInfo

type ExecuteSqlLogInfo struct {
	Namespace   string `json:"namespace"`
	DataSource  string `json:"dataSource"`
	SQL         string `json:"sql"`
	Executor    string `json:"executor"`
	ExecuteTime string `json:"executeTime"`
}

type InfosData

type InfosData[T any] struct {
	Infos      []T   `json:"infos"`
	TotalCount int64 `json:"totalCount"`
	PageNo     int   `json:"pageNo"`
}

type InfosResponse

type InfosResponse[T any] struct {
	MsgResponse
	InfosData[T]
}

type MsgResponse

type MsgResponse struct {
	Success bool   `json:"success"`
	ErrCode int    `json:"errCode"`
	Msg     string `json:"msg"`
}

type NamespaceInfo

type NamespaceInfo struct {
	Name string `json:"name"`
}

type TokenInfo

type TokenInfo struct {
	Name string `json:"name"`
}