Documentation
¶
Index ¶
- type ColExpr
- type Engine
- func (vse *Engine) Close()
- func (vse *Engine) InitDBConfig(dbcfgs *dbconfigs.DBConfigs)
- func (vse *Engine) Open(keyspace, cell string) error
- func (vse *Engine) ServeHTTP(response http.ResponseWriter, request *http.Request)
- func (vse *Engine) Stream(ctx context.Context, startPos string, filter *binlogdatapb.Filter, ...) error
- func (vse *Engine) StreamRows(ctx context.Context, query string, lastpk []sqltypes.Value, ...) error
- type Plan
- type Table
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
Engine is the engine for handling vreplication streaming requests.
func NewEngine ¶
NewEngine creates a new Engine. Initialization sequence is: NewEngine->InitDBConfig->Open. Open and Close can be called multiple times and are idempotent.
func (*Engine) InitDBConfig ¶
InitDBConfig performs saves the required info from dbconfigs for future use.
func (*Engine) ServeHTTP ¶
func (vse *Engine) ServeHTTP(response http.ResponseWriter, request *http.Request)
ServeHTTP shows the current VSchema.
func (*Engine) Stream ¶
func (vse *Engine) Stream(ctx context.Context, startPos string, filter *binlogdatapb.Filter, send func([]*binlogdatapb.VEvent) error) error
Stream starts a new stream.
func (*Engine) StreamRows ¶ added in v1.6.0
func (vse *Engine) StreamRows(ctx context.Context, query string, lastpk []sqltypes.Value, send func(*binlogdatapb.VStreamRowsResponse) error) error
StreamRows streams rows.
type Plan ¶
type Plan struct {
Table *Table
ColExprs []ColExpr
VindexColumn int
Vindex vindexes.Vindex
KeyRange *topodatapb.KeyRange
}
Plan represents the plan for a table.
type Table ¶
type Table struct {
Name string
Columns []schema.TableColumn
}
Table contains the metadata for a table.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.