vreplication

type ColumnInfo struct {
	Name        string
	CharSet     string
	Collation   string
	DataType    string
	ColumnType  string
	IsPK        bool
	IsGenerated bool
}

type ControllerStatus struct {
	Index                 int32
	Source                string
	SourceShard           string
	StopPosition          string
	LastPosition          string
	Heartbeat             int64
	ReplicationLagSeconds int64
	Counts                map[string]int64
	Rates                 map[string][]float64
	State                 string
	SourceTablet          *topodatapb.TabletAlias
	Messages              []string
	QueryCounts           map[string]int64
	BulkQueryCounts       map[string]int64
	TrxQueryBatchCounts   map[string]int64
	PhaseTimings          map[string]int64
	CopyRowCount          int64
	CopyLoopCount         int64
	NoopQueryCounts       map[string]int64
	TableCopyTimings      map[string]int64
}

type Engine struct {
	// contains filtered or unexported fields
}

type EngineStatus struct {
	IsOpen      bool
	Controllers []*ControllerStatus
}

type HTTPStreamWriterMock struct {
	// contains filtered or unexported fields
}

type InsertGenerator struct {
	// contains filtered or unexported fields
}

type PostCopyAction struct {
	Type PostCopyActionType `json:"type"`
	Task string             `json:"task"`
}

type PostCopyActionType int

type ReplicaConnector struct {
	// contains filtered or unexported fields
}

type ReplicatorPlan struct {
	VStreamFilter *binlogdatapb.Filter
	TargetTables  map[string]*TablePlan
	TablePlans    map[string]*TablePlan
	ColInfoMap    map[string][]*ColumnInfo

	Source *binlogdatapb.BinlogSource
	// contains filtered or unexported fields
}

type ShardSorter []string

type TablePlan struct {
	// TargetName, SendRule will always be initialized.
	TargetName string
	SendRule   *binlogdatapb.Rule
	// Lastpk will be initialized if it was specified, and
	// will be used for building the final plan after field info
	// is received.
	Lastpk *sqltypes.Result
	// BulkInsertFront, BulkInsertValues and BulkInsertOnDup are used
	// by vcopier. These three parts are combined to build bulk insert
	// statements. This is functionally equivalent to generating
	// multiple statements using the "Insert" construct, but much more
	// efficient for the copy phase.
	BulkInsertFront  *sqlparser.ParsedQuery
	BulkInsertValues *sqlparser.ParsedQuery
	BulkInsertOnDup  *sqlparser.ParsedQuery
	// Insert, Update and Delete are used by vplayer.
	// If the plan is an insertIgnore type, then Insert
	// and Update contain 'insert ignore' statements and
	// Delete is nil.
	Insert           *sqlparser.ParsedQuery
	Update           *sqlparser.ParsedQuery
	Delete           *sqlparser.ParsedQuery
	MultiDelete      *sqlparser.ParsedQuery
	Fields           []*querypb.Field
	EnumValuesMap    map[string](map[string]string)
	ConvertIntToEnum map[string]bool
	// PKReferences is used to check if an event changed
	// a primary key column (row move).
	PKReferences []string
	// PKIndices is an array, length = #columns, true if column is part of the PK
	PKIndices               []bool
	Stats                   *binlogplayer.Stats
	FieldsToSkip            map[string]bool
	ConvertCharset          map[string](*binlogdatapb.CharsetConversion)
	HasExtraSourcePkColumns bool

	TablePlanBuilder *tablePlanBuilder
	// PartialInserts is a dynamically generated cache of insert ParsedQueries, which update only some columns.
	// This is when we use a binlog_row_image which is not "full". The key is a serialized bitmap of data columns
	// which are sent as part of the RowEvent.
	PartialInserts map[string]*sqlparser.ParsedQuery
	// PartialUpdates are same as PartialInserts, but for update statements
	PartialUpdates map[string]*sqlparser.ParsedQuery

	CollationEnv *collations.Environment
}

type VStreamerClient interface {
	Open(context.Context) error
	Close(context.Context) error

	// VStream streams VReplication events based on the specified filter.
	VStream(ctx context.Context, startPos string, tablePKs []*binlogdatapb.TableLastPK, filter *binlogdatapb.Filter, send func([]*binlogdatapb.VEvent) error) error

	// VStreamRows streams rows of a table from the specified starting point.
	VStreamRows(ctx context.Context, query string, lastpk *querypb.QueryResult, send func(*binlogdatapb.VStreamRowsResponse) error) error

	// VStreamTables streams rows of a table from the specified starting point.
	VStreamTables(ctx context.Context, send func(*binlogdatapb.VStreamTablesResponse) error) error
}

type VrLogStats struct {
	Type       string
	Detail     string
	StartTime  time.Time
	LogTime    string
	DurationNs int64
}