service

package

v0.0.0-...-737200f Latest Latest Go to latest Published: Jun 20, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/drkisler/dataPedestal

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AddJob(userID int32, params map[string]any) response.TResponse
func AddTable(userID int32, params map[string]any) response.TResponse
func AlterJob(userID int32, params map[string]any) response.TResponse
func AlterTable(userID int32, params map[string]any) response.TResponse
func CheckJob(userID int32, params map[string]any) response.TResponse
func CheckJobLoaded(userID int32, params map[string]any) response.TResponse
func CheckJobTable(userID int32, params map[string]any) response.TResponse
func CheckSQLValid(_ int32, params map[string]any) response.TResponse
func ClearJobLog(userID int32, params map[string]any) response.TResponse
func ClearTableLog(userID int32, params map[string]any) response.TResponse
func ConvertFromClickHouseDDL(userID int32, params map[string]any) response.TResponse
func CreateMyPushPlugin() plugins.IPlugin
func DeleteJob(userID int32, params map[string]any) response.TResponse
func DeleteJobLog(userID int32, params map[string]any) response.TResponse
func DeleteTable(userID int32, params map[string]any) response.TResponse
func DeleteTableLog(userID int32, params map[string]any) response.TResponse
func GenerateInsertFromClickHouseSQL(userID int32, params map[string]any) response.TResponse
func GetDestTableColumns(userID int32, params map[string]any) response.TResponse
func GetDestTables(userID int32, params map[string]any) response.TResponse
func GetJobs(userID int32, params map[string]any) response.TResponse
func GetPushTables(userID int32, params map[string]any) response.TResponse
func GetSourceConnOption(_ int32, _ map[string]any) response.TResponse
func GetSourceQuoteFlag(_ int32, _ map[string]any) response.TResponse
func GetSourceTableColumns(_ int32, params map[string]any) response.TResponse
func GetSourceTables(_ int32, _ map[string]any) response.TResponse
func InitPlugin()
func OffLineJob(userID int32, params map[string]any) response.TResponse
func OnLineJob(userID int32, params map[string]any) response.TResponse
func QueryJobLogs(userID int32, params map[string]any) response.TResponse
func QueryTableLogs(userID int32, params map[string]any) response.TResponse
func SetJobStatus(userID int32, params map[string]any) response.TResponse
func SetTableStatus(userID int32, params map[string]any) response.TResponse
type TBasePlugin
type TMyPlugin
- func (mp *TMyPlugin) CustomInterface(pluginOperate plugins.TPluginOperate) (resp response.TResponse)
- func (mp *TMyPlugin) GetConfigTemplate() response.TResponse
- func (mp *TMyPlugin) Load(config string) error
- func (mp *TMyPlugin) Run(config string) (resp response.TResponse)
- func (mp *TMyPlugin) Stop() response.TResponse
type TPluginFunc

Constants ¶

This section is empty.

Variables ¶

View Source

var PluginServ plugins.IPlugin

View Source

var SerialNumber string

Functions ¶

func AddJob ¶

func AddJob(userID int32, params map[string]any) response.TResponse

func AddTable ¶

func AddTable(userID int32, params map[string]any) response.TResponse

func AlterJob ¶

func AlterJob(userID int32, params map[string]any) response.TResponse

func AlterTable ¶

func AlterTable(userID int32, params map[string]any) response.TResponse

func CheckJob ¶

func CheckJob(userID int32, params map[string]any) response.TResponse

func CheckJobLoaded ¶

func CheckJobLoaded(userID int32, params map[string]any) response.TResponse

func CheckJobTable ¶

func CheckJobTable(userID int32, params map[string]any) response.TResponse

func CheckSQLValid ¶

func CheckSQLValid(_ int32, params map[string]any) response.TResponse

func ClearJobLog ¶

func ClearJobLog(userID int32, params map[string]any) response.TResponse

func ClearTableLog ¶

func ClearTableLog(userID int32, params map[string]any) response.TResponse

func ConvertFromClickHouseDDL ¶

func ConvertFromClickHouseDDL(userID int32, params map[string]any) response.TResponse

func CreateMyPushPlugin ¶

func CreateMyPushPlugin() plugins.IPlugin

func DeleteJob ¶

func DeleteJob(userID int32, params map[string]any) response.TResponse

func DeleteJobLog ¶

func DeleteJobLog(userID int32, params map[string]any) response.TResponse

func DeleteTable ¶

func DeleteTable(userID int32, params map[string]any) response.TResponse

func DeleteTableLog ¶

func DeleteTableLog(userID int32, params map[string]any) response.TResponse

func GenerateInsertFromClickHouseSQL ¶

func GenerateInsertFromClickHouseSQL(userID int32, params map[string]any) response.TResponse

func GetDestTableColumns ¶

func GetDestTableColumns(userID int32, params map[string]any) response.TResponse

func GetDestTables ¶

func GetDestTables(userID int32, params map[string]any) response.TResponse

func GetJobs ¶

func GetJobs(userID int32, params map[string]any) response.TResponse

func GetPushTables ¶

func GetPushTables(userID int32, params map[string]any) response.TResponse

func GetSourceConnOption ¶

func GetSourceConnOption(_ int32, _ map[string]any) response.TResponse

func GetSourceQuoteFlag ¶

func GetSourceQuoteFlag(_ int32, _ map[string]any) response.TResponse

func GetSourceTableColumns ¶

func GetSourceTableColumns(_ int32, params map[string]any) response.TResponse

func GetSourceTables ¶

func GetSourceTables(_ int32, _ map[string]any) response.TResponse

func InitPlugin ¶

func InitPlugin()

func OffLineJob ¶

func OffLineJob(userID int32, params map[string]any) response.TResponse

func OnLineJob ¶

func OnLineJob(userID int32, params map[string]any) response.TResponse

func QueryJobLogs ¶

func QueryJobLogs(userID int32, params map[string]any) response.TResponse

func QueryTableLogs ¶

func QueryTableLogs(userID int32, params map[string]any) response.TResponse

func SetJobStatus ¶

func SetJobStatus(userID int32, params map[string]any) response.TResponse

func SetTableStatus ¶

func SetTableStatus(userID int32, params map[string]any) response.TResponse

Types ¶

type TBasePlugin ¶

type TBasePlugin = pluginBase.TBasePlugin

type TMyPlugin ¶

type TMyPlugin struct {
	TBasePlugin
	HostPubUrl    string `json:"host_pub_url"`
	DbDriverDir   string `json:"db_driver_dir,omitempty"`
	ClickhouseCfg string `json:"clickhouse_cfg,omitempty"`
}

func (*TMyPlugin) CustomInterface ¶

func (mp *TMyPlugin) CustomInterface(pluginOperate plugins.TPluginOperate) (resp response.TResponse)

func (*TMyPlugin) GetConfigTemplate ¶

func (mp *TMyPlugin) GetConfigTemplate() response.TResponse

GetConfigTemplate 向客户端返回配置信息的样例

func (*TMyPlugin) Load ¶

func (mp *TMyPlugin) Load(config string) error

Load 根据配置信息设置属性，创建必要的变量

func (*TMyPlugin) Run ¶

func (mp *TMyPlugin) Run(config string) (resp response.TResponse)

func (*TMyPlugin) Stop ¶

func (mp *TMyPlugin) Stop() response.TResponse

Stop 停止程序，释放资源

type TPluginFunc ¶

type TPluginFunc func(userID int32, params map[string]any) response.TResponse

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL