修改项目结构

instance.go → sdk/instance.go

@@ -1,4 +1,4 @@
-package ds_sdk
+package sdk
 
 import (
 	"git.sxidc.com/service-supports/ds-sdk/client"

options.go → sdk/options.go

@@ -1,4 +1,4 @@
-package ds_sdk
+package sdk
 
 import (
 	"time"

sdk.go → sdk/sdk.go

@@ -1,4 +1,4 @@
-package ds_sdk
+package sdk
 
 import (
 	"errors"
@@ -11,14 +11,14 @@ type SDK struct {
 	client  *client.Client
 }
 
-func (sdk *SDK) CreateDataContainer(name string, spec map[string]any) error {
+func (s *SDK) CreateDataContainer(name string, spec map[string]any) error {
 	if strutils.IsStringEmpty(name) {
 		return errors.New("没有传递数据容器名称")
 	}
 
-	options := sdk.options
+	options := s.options
 
-	err := sdk.client.CreateDataContainer(options.token, options.baseUrl,
+	err := s.client.CreateDataContainer(options.token, options.baseUrl,
 		options.namespace, options.dataSource.Name, name, spec)
 	if err != nil {
 		return err
@@ -27,14 +27,14 @@ func (sdk *SDK) CreateDataContainer(name string, spec map[string]any) error {
 	return nil
 }
 
-func (sdk *SDK) DeleteDataContainer(name string) error {
+func (s *SDK) DeleteDataContainer(name string) error {
 	if strutils.IsStringEmpty(name) {
 		return errors.New("没有传递数据容器名称")
 	}
 
-	options := sdk.options
+	options := s.options
 
-	err := sdk.client.DeleteDataContainer(options.token, options.baseUrl,
+	err := s.client.DeleteDataContainer(options.token, options.baseUrl,
 		options.namespace, options.dataSource.Name, name)
 	if err != nil {
 		return err
@@ -43,21 +43,21 @@ func (sdk *SDK) DeleteDataContainer(name string) error {
 	return nil
 }
 
-func (sdk *SDK) GetDataContainers(name string, pageNo int, pageSize int) ([]client.DataContainerInfo, error) {
-	options := sdk.options
+func (s *SDK) GetDataContainers(name string, pageNo int, pageSize int) ([]client.DataContainerInfo, error) {
+	options := s.options
 
-	return sdk.client.GetDataContainers(options.token, options.baseUrl,
+	return s.client.GetDataContainers(options.token, options.baseUrl,
 		options.namespace, options.dataSource.Name, name, pageNo, pageSize)
 }
 
-func (sdk *SDK) ExecuteRawSql(sql string) ([]map[string]any, error) {
+func (s *SDK) ExecuteRawSql(sql string) ([]map[string]any, error) {
 	if strutils.IsStringEmpty(sql) {
 		return make([]map[string]any, 0), nil
 	}
 
-	options := sdk.options
+	options := s.options
 
-	results, err := sdk.client.ExecuteRawSql(options.token, options.baseUrl,
+	results, err := s.client.ExecuteRawSql(options.token, options.baseUrl,
 		options.namespace, options.dataSource.Name, sql)
 	if err != nil {
 		return nil, err
@@ -66,14 +66,14 @@ func (sdk *SDK) ExecuteRawSql(sql string) ([]map[string]any, error) {
 	return results, nil
 }
 
-func (sdk *SDK) ExecuteSql(name string, executeParams map[string]any) ([]map[string]any, error) {
+func (s *SDK) ExecuteSql(name string, executeParams map[string]any) ([]map[string]any, error) {
 	if strutils.IsStringEmpty(name) {
 		return nil, errors.New("没有传递SQL资源名称")
 	}
 
-	options := sdk.options
+	options := s.options
 
-	results, err := sdk.client.ExecuteSql(options.token, options.baseUrl,
+	results, err := s.client.ExecuteSql(options.token, options.baseUrl,
 		options.namespace, options.dataSource.Name, name, executeParams)
 	if err != nil {
 		return nil, err