Documentation ¶ Index ¶ type DBConfig type Executor func NewExecutor(dbConfigs map[string]*config.DBConfig, dest *destination.Manager) *Executor func (e *Executor) Execute(ctx context.Context, t *task.Task) error func (e *Executor) Run(ctx context.Context, t *task.Task) error type QueryResult Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type DBConfig ¶ type DBConfig struct { Host string Port int User string Password string DBName string } type Executor ¶ type Executor struct { // contains filtered or unexported fields } func NewExecutor ¶ func NewExecutor(dbConfigs map[string]*config.DBConfig, dest *destination.Manager) *Executor func (*Executor) Execute ¶ func (e *Executor) Execute(ctx context.Context, t *task.Task) error func (*Executor) Run ¶ func (e *Executor) Run(ctx context.Context, t *task.Task) error type QueryResult ¶ type QueryResult struct { TaskID string `json:"task_id"` Timestamp time.Time `json:"timestamp"` QueryName string `json:"query_name"` ExecutionTime string `json:"execution_time"` RowCount int `json:"row_count"` Data []map[string]interface{} `json:"data"` } Source Files ¶ View all Source files executor.go Click to show internal directories. Click to hide internal directories.