vstreamer

Documentation

Index

• type ColExpr
• type Engine
  • func NewEngine(ts srvtopo.Server, se *schema.Engine) *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

Types

type ColExpr

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

ColExpr represents a column expression.

type Engine

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

Engine is the engine for handling vreplication streaming requests.

func NewEngine

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

func (vse *Engine) Close()

Close closes the Engine service.

func (*Engine) InitDBConfig

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

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

func (*Engine) Open

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

Open starts the Engine service.

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

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.