Versions in this module Expand all Collapse all v0 v0.0.2 May 3, 2021 v0.0.1 May 3, 2021 Changes in this version + const ItemDefaultChannelSize + const MaxAllowedPacket + const MysqlTimeFormat + var ErrInternalError = fmt.Errorf("QLBridge: Internal Error") + var ErrNoSchemaSelected = fmt.Errorf("No Schema Selected") + var ErrNotImplemented = fmt.Errorf("QLBridge: Not implemented") + var ErrNotSupported = fmt.Errorf("QLBridge: Not supported") + var ErrShuttingDown = fmt.Errorf("Received Shutdown Signal") + var ErrUnknownCommand = fmt.Errorf("QLBridge: Unknown Command") + func DisableRecover() + func RegisterSqlDriver() + type AggFunc func(v value.Value) + type AggPartial struct + Ct int64 + N float64 + type Aggregator interface + Do func(v value.Value) + Merge func(*AggPartial) + Reset func() + Result func() interface{} + func NewAvg(col *rel.Column, partial bool) Aggregator + func NewCount(col *rel.Column) Aggregator + func NewGroupByValue(col *rel.Column) Aggregator + func NewSum(col *rel.Column, partial bool) Aggregator + type Alter struct + func NewAlter(ctx *plan.Context, p *plan.Alter) *Alter + func (m *Alter) Close() error + func (m *Alter) Run() error + type Command struct + func NewCommand(ctx *plan.Context, p *plan.Command) *Command + func (m *Command) Close() error + func (m *Command) Run() error + type Create struct + func NewCreate(ctx *plan.Context, p *plan.Create) *Create + func (m *Create) Close() error + func (m *Create) Run() error + type DeletionScanner struct + func (m *DeletionScanner) Run() error + type DeletionTask struct + func NewDelete(ctx *plan.Context, p *plan.Delete) *DeletionTask + func (m *DeletionTask) Close() error + func (m *DeletionTask) Run() error + type Drop struct + func NewDrop(ctx *plan.Context, p *plan.Drop) *Drop + func (m *Drop) Close() error + func (m *Drop) Run() error + type ErrChan chan error + type Executor interface + NewTask func(p plan.Task) Task + WalkAlter func(p *plan.Alter) (Task, error) + WalkCommand func(p *plan.Command) (Task, error) + WalkCreate func(p *plan.Create) (Task, error) + WalkDelete func(p *plan.Delete) (Task, error) + WalkDrop func(p *plan.Drop) (Task, error) + WalkGroupBy func(p *plan.GroupBy) (Task, error) + WalkHaving func(p *plan.Having) (Task, error) + WalkInsert func(p *plan.Insert) (Task, error) + WalkJoin func(p *plan.JoinMerge) (Task, error) + WalkJoinKey func(p *plan.JoinKey) (Task, error) + WalkOrder func(p *plan.Order) (Task, error) + WalkPlan func(p plan.Task) (Task, error) + WalkPreparedStatement func(p *plan.PreparedStatement) (Task, error) + WalkProjection func(p *plan.Projection) (Task, error) + WalkSelect func(p *plan.Select) (Task, error) + WalkSource func(p *plan.Source) (Task, error) + WalkUpdate func(p *plan.Update) (Task, error) + WalkUpsert func(p *plan.Upsert) (Task, error) + WalkWhere func(p *plan.Where) (Task, error) + type ExecutorSource interface + WalkExecSource func(p *plan.Source) (Task, error) + type GroupBy struct + func NewGroupBy(ctx *plan.Context, p *plan.GroupBy) *GroupBy + func (m *GroupBy) Close() error + func (m *GroupBy) Run() error + type GroupByFinal struct + func NewGroupByFinal(ctx *plan.Context, p *plan.GroupBy) *GroupByFinal + func (m *GroupByFinal) Close() error + func (m *GroupByFinal) Run() error + type JobExecutor struct + Ctx *plan.Context + Executor Executor + Planner plan.Planner + RootTask TaskRunner + func BuildSqlJob(ctx *plan.Context) (*JobExecutor, error) + func NewExecutor(ctx *plan.Context, planner plan.Planner) *JobExecutor + func (m *JobExecutor) Close() error + func (m *JobExecutor) DrainChan() MessageChan + func (m *JobExecutor) NewTask(p plan.Task) Task + func (m *JobExecutor) Run() error + func (m *JobExecutor) Setup() error + func (m *JobExecutor) WalkAlter(p *plan.Alter) (Task, error) + func (m *JobExecutor) WalkChildren(p plan.Task, root Task) error + func (m *JobExecutor) WalkCommand(p *plan.Command) (Task, error) + func (m *JobExecutor) WalkCreate(p *plan.Create) (Task, error) + func (m *JobExecutor) WalkDelete(p *plan.Delete) (Task, error) + func (m *JobExecutor) WalkDrop(p *plan.Drop) (Task, error) + func (m *JobExecutor) WalkGroupBy(p *plan.GroupBy) (Task, error) + func (m *JobExecutor) WalkHaving(p *plan.Having) (Task, error) + func (m *JobExecutor) WalkInsert(p *plan.Insert) (Task, error) + func (m *JobExecutor) WalkJoin(p *plan.JoinMerge) (Task, error) + func (m *JobExecutor) WalkJoinKey(p *plan.JoinKey) (Task, error) + func (m *JobExecutor) WalkOrder(p *plan.Order) (Task, error) + func (m *JobExecutor) WalkPlan(p plan.Task) (Task, error) + func (m *JobExecutor) WalkPlanAll(p plan.Task) (Task, error) + func (m *JobExecutor) WalkPlanTask(p plan.Task) (Task, error) + func (m *JobExecutor) WalkPreparedStatement(p *plan.PreparedStatement) (Task, error) + func (m *JobExecutor) WalkProjection(p *plan.Projection) (Task, error) + func (m *JobExecutor) WalkSelect(p *plan.Select) (Task, error) + func (m *JobExecutor) WalkSource(p *plan.Source) (Task, error) + func (m *JobExecutor) WalkSourceExec(p *plan.Source) (Task, error) + func (m *JobExecutor) WalkUpdate(p *plan.Update) (Task, error) + func (m *JobExecutor) WalkUpsert(p *plan.Upsert) (Task, error) + func (m *JobExecutor) WalkWhere(p *plan.Where) (Task, error) + type JobMaker func(ctx *plan.Context) (Executor, error) + type JobRunner interface + Close func() error + Run func() error + Setup func() error + type JoinKey struct + func NewJoinKey(ctx *plan.Context, p *plan.JoinKey) *JoinKey + func (m *JoinKey) Run() error + type JoinMerge struct + func NewJoinNaiveMerge(ctx *plan.Context, l, r TaskRunner, p *plan.JoinMerge) *JoinMerge + func (m *JoinMerge) Run() error + type KeyEvaluator func(msg schema.Message) driver.Value + type MessageChan chan schema.Message + type MessageHandler func(ctx *plan.Context, msg schema.Message) bool + func MakeHandler(task TaskRunner) MessageHandler + type Order struct + func NewOrder(ctx *plan.Context, p *plan.Order) *Order + func (m *Order) Close() error + func (m *Order) Run() error + type OrderMessages struct + func NewOrderMessages(p *plan.Order) *OrderMessages + func (m *OrderMessages) Len() int + func (m *OrderMessages) Less(i, j int) bool + func (m *OrderMessages) Swap(i, j int) + type Projection struct + func NewProjection(ctx *plan.Context, p *plan.Projection) *Projection + func NewProjectionFinal(ctx *plan.Context, p *plan.Projection) *Projection + func NewProjectionInProcess(ctx *plan.Context, p *plan.Projection) *Projection + func NewProjectionLimit(ctx *plan.Context, p *plan.Projection) *Projection + func (m *Projection) Close() error + func (m *Projection) CloseFinal() error + type RequiresContext interface + SetContext func(ctx *plan.Context) + type ResultBuffer struct + func NewResultBuffer(ctx *plan.Context, writeTo *[]schema.Message) *ResultBuffer + func (m *ResultBuffer) Close() error + func (m *ResultBuffer) Copy() *ResultBuffer + type ResultExecWriter struct + func NewResultExecWriter(ctx *plan.Context) *ResultExecWriter + func (m *ResultExecWriter) Close() error + func (m *ResultExecWriter) Copy() *ResultExecWriter + func (m *ResultExecWriter) Result() driver.Result + type ResultWriter struct + func NewResultRows(ctx *plan.Context, cols []string) *ResultWriter + func NewResultWriter(ctx *plan.Context) *ResultWriter + func (m *ResultWriter) Close() error + func (m *ResultWriter) Columns() []string + func (m *ResultWriter) Copy() *ResultWriter + func (m *ResultWriter) Next(dest []driver.Value) error + func (m *ResultWriter) Run() error + type SigChan chan bool + type Source struct + ExecSource ExecutorSource + JoinKey KeyEvaluator + Scanner schema.ConnScanner + func NewSource(ctx *plan.Context, p *plan.Source) (*Source, error) + func NewSourceScanner(ctx *plan.Context, p *plan.Source, scanner schema.ConnScanner) *Source + func (m *Source) Close() error + func (m *Source) Copy() *Source + func (m *Source) Run() error + type Task interface + Add func(Task) error + Children func() []Task + Close func() error + CloseFinal func() error + Run func() error + func BuildSqlJobPlanned(planner plan.Planner, executor Executor, ctx *plan.Context) (Task, error) + type TaskBase struct + Ctx *plan.Context + Handler MessageHandler + Name string + func NewTaskBase(ctx *plan.Context) *TaskBase + func (m *TaskBase) Add(task Task) error + func (m *TaskBase) AddPlan(task plan.Task) error + func (m *TaskBase) Children() []Task + func (m *TaskBase) Close() error + func (m *TaskBase) CloseFinal() error + func (m *TaskBase) ErrChan() ErrChan + func (m *TaskBase) MessageIn() MessageChan + func (m *TaskBase) MessageInSet(ch MessageChan) + func (m *TaskBase) MessageOut() MessageChan + func (m *TaskBase) MessageOutSet(ch MessageChan) + func (m *TaskBase) Quit() + func (m *TaskBase) Run() error + func (m *TaskBase) Setup(depth int) error + func (m *TaskBase) SigChan() SigChan + type TaskParallel struct + func NewTaskParallel(ctx *plan.Context) *TaskParallel + func (m *TaskParallel) Add(task Task) error + func (m *TaskParallel) Children() []Task + func (m *TaskParallel) Close() error + func (m *TaskParallel) PrintDag(depth int) + func (m *TaskParallel) Run() error + func (m *TaskParallel) Setup(depth int) error + type TaskPrinter interface + PrintDag func(depth int) + type TaskRunner interface + ErrChan func() ErrChan + MessageIn func() MessageChan + MessageInSet func(MessageChan) + MessageOut func() MessageChan + MessageOutSet func(MessageChan) + Quit func() + Setup func(depth int) error + SigChan func() SigChan + type TaskSequential struct + func NewTaskSequential(ctx *plan.Context) *TaskSequential + func (m *TaskSequential) Add(task Task) error + func (m *TaskSequential) Children() []Task + func (m *TaskSequential) Close() error + func (m *TaskSequential) PrintDag(depth int) + func (m *TaskSequential) Run() (err error) + func (m *TaskSequential) Setup(depth int) error + type TaskStepper struct + func NewTaskStepper(ctx *plan.Context) *TaskStepper + func (m *TaskStepper) Run() error + type Upsert struct + func NewInsert(ctx *plan.Context, p *plan.Insert) *Upsert + func NewUpdate(ctx *plan.Context, p *plan.Update) *Upsert + func NewUpsert(ctx *plan.Context, p *plan.Upsert) *Upsert + func (m *Upsert) Close() error + func (m *Upsert) Run() error + type Where struct + func NewHaving(ctx *plan.Context, p *plan.Having) *Where + func NewWhere(ctx *plan.Context, p *plan.Where) *Where + func NewWhereFilter(ctx *plan.Context, sql *rel.SqlSelect) *Where + func NewWhereFinal(ctx *plan.Context, p *plan.Where) *Where