Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + const ExcludeStr + func AddStatusPart() + func InitVStreamerClient(cfg *dbconfigs.DBConfigs) + func MatchTable(tableName string, filter *binlogdatapb.Filter) (*binlogdatapb.Rule, error) + func StatusSummary() (maxSecondsBehindMaster int64, binlogPlayersCount int32) + type ControllerStatus struct + Counts map[string]int64 + Index uint32 + LastPosition string + Messages []string + Rates map[string][]float64 + SecondsBehindMaster int64 + Source string + SourceShard string + SourceTablet string + State string + StopPosition string + type Engine struct + func NewEngine(ts *topo.Server, cell string, mysqld mysqlctl.MysqlDaemon, ...) *Engine + func (vre *Engine) Close() + func (vre *Engine) Exec(query string) (*sqltypes.Result, error) + func (vre *Engine) IsOpen() bool + func (vre *Engine) Open(ctx context.Context) error + func (vre *Engine) WaitForPos(ctx context.Context, id int, pos string) error + type EngineStatus struct + Controllers []*ControllerStatus + IsOpen bool + type HTTPStreamWriterMock struct + func NewHTTPStreamWriterMock() *HTTPStreamWriterMock + func (w *HTTPStreamWriterMock) Flush() + func (w *HTTPStreamWriterMock) Header() http.Header + func (w *HTTPStreamWriterMock) Write(data []byte) (int, error) + func (w *HTTPStreamWriterMock) WriteHeader(statuscode int) + type InsertGenerator struct + func NewInsertGenerator(state, dbname string) *InsertGenerator + func (ig *InsertGenerator) AddRow(workflow string, bls *binlogdatapb.BinlogSource, pos, cell, tabletTypes string) + func (ig *InsertGenerator) String() string + type MySQLVStreamerClient struct + func NewMySQLVStreamerClient() *MySQLVStreamerClient + func (vsClient *MySQLVStreamerClient) Close(ctx context.Context) (err error) + func (vsClient *MySQLVStreamerClient) Open(ctx context.Context) (err error) + func (vsClient *MySQLVStreamerClient) VStream(ctx context.Context, startPos string, filter *binlogdatapb.Filter, ...) error + func (vsClient *MySQLVStreamerClient) VStreamRows(ctx context.Context, query string, lastpk *querypb.QueryResult, ...) error + type ReplicatorPlan struct + TablePlans map[string]*TablePlan + TargetTables map[string]*TablePlan + VStreamFilter *binlogdatapb.Filter + func (rp *ReplicatorPlan) MarshalJSON() ([]byte, error) + type ShardSorter []string + func (s ShardSorter) Key(ind int) string + func (s ShardSorter) Len() int + func (s ShardSorter) Less(i, j int) bool + func (s ShardSorter) Swap(i, j int) + type TablePlan struct + BulkInsertFront *sqlparser.ParsedQuery + BulkInsertOnDup *sqlparser.ParsedQuery + BulkInsertValues *sqlparser.ParsedQuery + Delete *sqlparser.ParsedQuery + Fields []*querypb.Field + Insert *sqlparser.ParsedQuery + Lastpk *sqltypes.Result + PKReferences []string + SendRule *binlogdatapb.Rule + TargetName string + Update *sqlparser.ParsedQuery + func (tp *TablePlan) MarshalJSON() ([]byte, error) + type TabletVStreamerClient struct + func NewTabletVStreamerClient(tablet *topodatapb.Tablet) *TabletVStreamerClient + func (vsClient *TabletVStreamerClient) Close(ctx context.Context) (err error) + func (vsClient *TabletVStreamerClient) Open(ctx context.Context) (err error) + func (vsClient *TabletVStreamerClient) VStream(ctx context.Context, startPos string, filter *binlogdatapb.Filter, ...) error + func (vsClient *TabletVStreamerClient) VStreamRows(ctx context.Context, query string, lastpk *querypb.QueryResult, ...) error + type VStreamerClient interface + Close func(ctx context.Context) error + Open func(ctx context.Context) error + VStream func(ctx context.Context, startPos string, filter *binlogdatapb.Filter, ...) error + VStreamRows func(ctx context.Context, query string, lastpk *querypb.QueryResult, ...) error + type VrLogStats struct + Detail string + DurationNs int64 + LogTime string + StartTime time.Time + Type string + func NewVrLogStats(eventType string) *VrLogStats + func (stats *VrLogStats) Send(detail string)
Go to main page