service

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(userID int32, params map[string]any) response.TResponse
• func CheckSourceConnect(_ 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 CreateMyPullPlugin() 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 GetDestTables(_ int32, _ map[string]any) response.TResponse
• func GetJobs(userID int32, params map[string]any) response.TResponse
• func GetPullTables(userID int32, params map[string]any) response.TResponse
• func GetSourceQuoteFlag(userID int32, params map[string]any) response.TResponse
• func GetSourceTables(userID int32, params map[string]any) response.TResponse
• func GetTableColumns(userID int32, params map[string]any) response.TResponse
• func GetTableScript(userID int32, params 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() (resp response.TResponse)
• type TPluginFunc

Variables

var PluginServ plugins.IPlugin

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(userID int32, params map[string]any) response.TResponse

func CheckSourceConnect

func CheckSourceConnect(_ 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 CreateMyPullPlugin

func CreateMyPullPlugin() 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 GetDestTables

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

func GetJobs

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

func GetPullTables

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

func GetSourceQuoteFlag

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

func GetSourceTables

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

func GetTableColumns

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

func GetTableScript

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

func InitPlugin

func InitPlugin()

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
	HostReplyUrl  string `json:"host_reply_url,omitempty"`
	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)

CustomInterface 提供接口以外的自定义功能，由用户实现

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)

Run 启动程序

func (*TMyPlugin) Stop

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

Stop 停止程序，释放资源

type TPluginFunc

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