go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/vttablet/tabletserver/vstreamer Index | Files | Directories

package vstreamer

import "gopkg.in/src-d/go-vitess.v1/vt/vttablet/tabletserver/vstreamer"

Index

Package Files

engine.go planbuilder.go rowstreamer.go vstreamer.go

type ColExpr Uses

type ColExpr struct {
    ColNum int
    Alias  sqlparser.ColIdent
    Type   querypb.Type
}

ColExpr represents a column expression.

type Engine Uses

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

Engine is the engine for handling vreplication streaming requests.

func NewEngine Uses

func NewEngine(ts srvtopo.Server, se *schema.Engine) *Engine

NewEngine creates a new Engine. Initialization sequence is: NewEngine->InitDBConfig->Open. Open and Close can be called multiple times and are idempotent.

func (*Engine) Close Uses

func (vse *Engine) Close()

Close closes the Engine service.

func (*Engine) InitDBConfig Uses

func (vse *Engine) InitDBConfig(dbcfgs *dbconfigs.DBConfigs)

InitDBConfig performs saves the required info from dbconfigs for future use.

func (*Engine) Open Uses

func (vse *Engine) Open(keyspace, cell string) error

Open starts the Engine service.

func (*Engine) ServeHTTP Uses

func (vse *Engine) ServeHTTP(response http.ResponseWriter, request *http.Request)

ServeHTTP shows the current VSchema.

func (*Engine) Stream Uses

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 Uses

func (vse *Engine) StreamRows(ctx context.Context, query string, lastpk []sqltypes.Value, send func(*binlogdatapb.VStreamRowsResponse) error) error

StreamRows streams rows.

type Plan Uses

type Plan struct {
    Table        *Table
    ColExprs     []ColExpr
    VindexColumn int
    Vindex       vindexes.Vindex
    KeyRange     *topodatapb.KeyRange
}

Plan represents the plan for a table.

type Table Uses

type Table struct {
    Name    string
    Columns []schema.TableColumn
}

Table contains the metadata for a table.

Directories

PathSynopsis
testenvPackage testenv supplies test functions for testing vstreamer.

Package vstreamer imports 29 packages (graph) and is imported by 1 packages. Updated 2019-06-13. Refresh now. Tools for package owners.