worker

package

Go to main page

Versions in this module

v1

v1.8.0

Jun 2, 2019

v1.7.0

May 23, 2019

v1.6.0

Apr 24, 2019

v1.5.0

Feb 12, 2019

Changes in this version

+ func CheckValidTypesForResultMerger(fields []*querypb.Field, pkFieldCount int) error

+ func CreateConsistentTransactions(ctx context.Context, tablet *topo.TabletInfo, wr *wrangler.Wrangler, ...) ([]int64, string, error)

+ func CreateTargetFrom(tablet *topodatapb.Tablet) *query.Target

+ func RollbackTransaction(ctx context.Context, ts *topo.Server, tabletAlias *topodatapb.TabletAlias, ...) error

+ type MultiSplitDiffWorker struct

+ func (msdw *MultiSplitDiffWorker) Run(ctx context.Context) error

+ func (msdw *MultiSplitDiffWorker) StatusAsHTML() template.HTML

+ func (msdw *MultiSplitDiffWorker) StatusAsText() string

+ type NonTransactionalTableScanner struct

+ func (ntts NonTransactionalTableScanner) ScanTable(ctx context.Context, td *tabletmanagerdatapb.TableDefinition) (*QueryResultReader, error)

type QueryResultReader

+ func NewTransactionalQueryResultReaderForTablet(ctx context.Context, ts *topo.Server, tabletAlias *topodatapb.TabletAlias, ...) (*QueryResultReader, error)

+ func TransactionalTableScan(ctx context.Context, log logutil.Logger, ts *topo.Server, ...) (*QueryResultReader, error)

type RestartableResultReader

+ func NewTransactionalRestartableResultReader(ctx context.Context, logger logutil.Logger, tp tabletProvider, ...) (*RestartableResultReader, error)

type ResultMerger

+ func (rm *ResultMerger) Close(ctx context.Context)

type ResultReader

+ Close func(ctx context.Context)

+ type Scanners struct

+ type TableScanner interface

+ ScanTable func(ctx context.Context, td *tabletmanagerdatapb.TableDefinition) (*QueryResultReader, error)

+ func CreateConsistentTableScanners(ctx context.Context, tablet *topo.TabletInfo, wr *wrangler.Wrangler, ...) ([]TableScanner, string, error)

+ type TransactionalTableScanner struct

+ func (tt TransactionalTableScanner) ScanTable(ctx context.Context, td *tabletmanagerdatapb.TableDefinition) (*QueryResultReader, error)

type Worker

+ func NewMultiSplitDiffWorker(wr *wrangler.Wrangler, cell, keyspace, shard string, excludeTables []string, ...) Worker

v1.4.0

Nov 13, 2018

Changes in this version

type StatusWorkerState

+ const WorkerStateDiffWillFail

v1.3.0

Oct 31, 2018

Changes in this version

+ const ResultSizeRows

+ var DiffFoundTypes = []DiffType

+ var DiffTypes = []DiffType

+ var ErrStoppedRowReader = errors.New(...)

+ func AddCommand(groupName string, c Command)

+ func CompareRows(fields []*querypb.Field, compareCount int, left, right []sqltypes.Value) (int, error)

+ func FindHealthyTablet(ctx context.Context, wr *wrangler.Wrangler, tsc *discovery.TabletStatsCache, ...) (*topodatapb.TabletAlias, error)

+ func FindWorkerTablet(ctx context.Context, wr *wrangler.Wrangler, cleaner *wrangler.Cleaner, ...) (*topodatapb.TabletAlias, error)

+ func PrintAllCommands(logger logutil.Logger)

+ func RowsEqual(left, right []sqltypes.Value) int

+ type BaseQueryBuilder struct

+ func (b *BaseQueryBuilder) WriteHead(buffer *bytes.Buffer)

+ func (b *BaseQueryBuilder) WriteSeparator(buffer *bytes.Buffer)

+ func (b *BaseQueryBuilder) WriteTail(buffer *bytes.Buffer)

+ type BlockWorker struct

+ func (bw *BlockWorker) Run(ctx context.Context) error

+ func (bw *BlockWorker) StatusAsHTML() template.HTML

+ func (bw *BlockWorker) StatusAsText() string

+ type Command struct

+ Help string

+ Interactive func(ctx context.Context, wi *Instance, wr *wrangler.Wrangler, ...) (Worker, *template.Template, map[string]interface{}, error)

+ Method func(wi *Instance, wr *wrangler.Wrangler, subFlags *flag.FlagSet, args []string) (Worker, error)

+ Name string

+ Params string

+ type DeletesQueryBuilder struct

+ func NewDeletesQueryBuilder(dbName string, td *tabletmanagerdatapb.TableDefinition) *DeletesQueryBuilder

+ func (b *DeletesQueryBuilder) WriteRow(buffer *bytes.Buffer, row []sqltypes.Value)

+ type DiffReport struct

+ func (dr *DiffReport) ComputeQPS()

+ func (dr *DiffReport) HasDifferences() bool

+ func (dr *DiffReport) String() string

+ type DiffType int

+ const DiffEqual

+ const DiffExtraneous

+ const DiffMissing

+ const DiffNotEqual

+ type InsertsQueryBuilder struct

+ func NewInsertsQueryBuilder(dbName string, td *tabletmanagerdatapb.TableDefinition) *InsertsQueryBuilder

+ func (*InsertsQueryBuilder) WriteRow(buffer *bytes.Buffer, row []sqltypes.Value)

+ type Instance struct

+ func NewInstance(ts *topo.Server, cell string, commandDisplayInterval time.Duration) *Instance

+ func (wi *Instance) Cancel() bool

+ func (wi *Instance) CreateWrangler(logger logutil.Logger) *wrangler.Wrangler

+ func (wi *Instance) InitInteractiveMode()

+ func (wi *Instance) InitStatusHandling()

+ func (wi *Instance) InstallSignalHandlers()

+ func (wi *Instance) Reset() error

+ func (wi *Instance) RunCommand(ctx context.Context, args []string, wr *wrangler.Wrangler, runFromCli bool) (Worker, chan struct{}, error)

+ func (wi *Instance) WaitForCommand(wrk Worker, done chan struct{}) error

+ type LegacySplitCloneWorker struct

+ func (scw *LegacySplitCloneWorker) Run(ctx context.Context) error

+ func (scw *LegacySplitCloneWorker) StatusAsHTML() template.HTML

+ func (scw *LegacySplitCloneWorker) StatusAsText() string

+ type Pair struct

+ Key string

+ Value int

+ type PairList []Pair

+ func (p PairList) Len() int

+ func (p PairList) Less(i, j int) bool

+ func (p PairList) Swap(i, j int)

+ type PanicWorker struct

+ func (pw *PanicWorker) Run(ctx context.Context) error

+ func (pw *PanicWorker) StatusAsHTML() template.HTML

+ func (pw *PanicWorker) StatusAsText() string

+ type PingWorker struct

+ func (pw *PingWorker) Run(ctx context.Context) error

+ func (pw *PingWorker) StatusAsHTML() template.HTML

+ func (pw *PingWorker) StatusAsText() string

+ type QueryBuilder interface

+ WriteHead func(*bytes.Buffer)

+ WriteRow func(*bytes.Buffer, []sqltypes.Value)

+ WriteSeparator func(*bytes.Buffer)

+ WriteTail func(*bytes.Buffer)

+ type QueryResultReader struct

+ func NewQueryResultReaderForTablet(ctx context.Context, ts *topo.Server, tabletAlias *topodatapb.TabletAlias, ...) (*QueryResultReader, error)

+ func TableScan(ctx context.Context, log logutil.Logger, ts *topo.Server, ...) (*QueryResultReader, error)

+ func TableScanByKeyRange(ctx context.Context, log logutil.Logger, ts *topo.Server, ...) (*QueryResultReader, error)

+ func (qrr *QueryResultReader) Close(ctx context.Context) error

+ func (qrr *QueryResultReader) Fields() []*querypb.Field

+ func (qrr *QueryResultReader) Next() (*sqltypes.Result, error)

+ type RestartableResultReader struct

+ func NewRestartableResultReader(ctx context.Context, logger logutil.Logger, tp tabletProvider, ...) (*RestartableResultReader, error)

+ func (r *RestartableResultReader) Close(ctx context.Context)

+ func (r *RestartableResultReader) Fields() []*querypb.Field

+ func (r *RestartableResultReader) Next() (*sqltypes.Result, error)

+ type ResultMerger struct

+ func NewResultMerger(inputs []ResultReader, pkFieldCount int) (*ResultMerger, error)

+ func (rm *ResultMerger) Fields() []*querypb.Field

+ func (rm *ResultMerger) Next() (*sqltypes.Result, error)

+ type ResultReader interface

+ Fields func() []*querypb.Field

+ Next func() (*sqltypes.Result, error)

+ type RowAggregator struct

+ func NewRowAggregator(ctx context.Context, maxRows, maxSize int, insertChannel chan string, ...) *RowAggregator

+ func (ra *RowAggregator) Add(row []sqltypes.Value) error

+ func (ra *RowAggregator) Flush() error

+ type RowDiffer struct

+ func NewRowDiffer(left, right *QueryResultReader, ...) (*RowDiffer, error)

+ func (rd *RowDiffer) Go(log logutil.Logger) (dr DiffReport, err error)

+ type RowDiffer2 struct

+ func NewRowDiffer2(ctx context.Context, left, right ResultReader, ...) (*RowDiffer2, error)

+ func (rd *RowDiffer2) Diff() (DiffReport, error)

+ type RowReader struct

+ func NewRowReader(resultReader ResultReader) *RowReader

+ func (rr *RowReader) Drain() (int, error)

+ func (rr *RowReader) Fields() []*querypb.Field

+ func (rr *RowReader) Next() ([]sqltypes.Value, error)

+ func (rr *RowReader) StopAfterCurrentResult()

+ type RowRouter struct

+ func NewRowRouter(shardInfos []*topo.ShardInfo, keyResolver keyspaceIDResolver) RowRouter

+ func (rr *RowRouter) Route(row []sqltypes.Value) (int, error)

+ type RowSplitter struct

+ KeyRanges []*topodatapb.KeyRange

+ KeyResolver keyspaceIDResolver

+ func NewRowSplitter(shardInfos []*topo.ShardInfo, keyResolver keyspaceIDResolver) *RowSplitter

+ func (rs *RowSplitter) Send(fields []*querypb.Field, result [][][]sqltypes.Value, baseCmds []string, ...) bool

+ func (rs *RowSplitter) Split(result [][][]sqltypes.Value, rows [][]sqltypes.Value) error

+ func (rs *RowSplitter) StartSplit() [][][]sqltypes.Value

+ type SplitCloneWorker struct

+ func (scw *SplitCloneWorker) FormattedOfflineSources() string

+ func (scw *SplitCloneWorker) Run(ctx context.Context) error

+ func (scw *SplitCloneWorker) StatsUpdate(ts *discovery.TabletStats)

+ func (scw *SplitCloneWorker) StatusAsHTML() template.HTML

+ func (scw *SplitCloneWorker) StatusAsText() string

+ type SplitDiffWorker struct

+ func (sdw *SplitDiffWorker) Run(ctx context.Context) error

+ func (sdw *SplitDiffWorker) StatusAsHTML() template.HTML

+ func (sdw *SplitDiffWorker) StatusAsText() string

+ type StatusWorker struct

+ func NewStatusWorker() StatusWorker

+ func (w *StatusWorker) SetState(state StatusWorkerState)

+ func (w *StatusWorker) State() StatusWorkerState

+ func (w *StatusWorker) StatusAsHTML() template.HTML

+ func (w *StatusWorker) StatusAsText() string

+ type StatusWorkerState string

+ const WorkerStateCleanUp

+ const WorkerStateCloneOffline

+ const WorkerStateCloneOnline

+ const WorkerStateDebugRunning

+ const WorkerStateDiff

+ const WorkerStateDone

+ const WorkerStateError

+ const WorkerStateFindTargets

+ const WorkerStateInit

+ const WorkerStateNotStarted

+ const WorkerStateSyncReplication

+ func (state StatusWorkerState) String() string

+ type TabletTracker struct

+ func NewTabletTracker() *TabletTracker

+ func (t *TabletTracker) TabletsInUse() string

+ func (t *TabletTracker) Track(stats []discovery.TabletStats) *topodatapb.Tablet

+ func (t *TabletTracker) Untrack(alias *topodatapb.TabletAlias)

+ type UpdatesQueryBuilder struct

+ func NewUpdatesQueryBuilder(dbName string, td *tabletmanagerdatapb.TableDefinition) *UpdatesQueryBuilder

+ func (b *UpdatesQueryBuilder) WriteRow(buffer *bytes.Buffer, row []sqltypes.Value)

+ func (b *UpdatesQueryBuilder) WriteSeparator(buffer *bytes.Buffer)

+ type VerticalSplitDiffWorker struct

+ func (vsdw *VerticalSplitDiffWorker) Run(ctx context.Context) error

+ func (vsdw *VerticalSplitDiffWorker) StatusAsHTML() template.HTML

+ func (vsdw *VerticalSplitDiffWorker) StatusAsText() string

+ type Worker interface

+ Run func(context.Context) error

+ State func() StatusWorkerState

+ StatusAsHTML func() template.HTML

+ StatusAsText func() string

+ func NewBlockWorker(wr *wrangler.Wrangler) (Worker, error)

+ func NewLegacySplitCloneWorker(wr *wrangler.Wrangler, cell, keyspace, shard string, excludeTables []string, ...) (Worker, error)

+ func NewPanicWorker(wr *wrangler.Wrangler) (Worker, error)

+ func NewPingWorker(wr *wrangler.Wrangler, message string) (Worker, error)

+ func NewSplitDiffWorker(wr *wrangler.Wrangler, cell, keyspace, shard string, sourceUID uint32, ...) Worker

+ func NewVerticalSplitDiffWorker(wr *wrangler.Wrangler, cell, keyspace, shard string, ...) Worker

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