Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + var HeartbeatTime = 900 * time.Millisecond + var PacketSize = flag.Int("vstream_packet_size", 30000, ...) + type ColExpr struct + Alias sqlparser.ColIdent + ColNum int + Type querypb.Type + Vindex vindexes.Vindex + VindexColumns []int + type Engine struct + func NewEngine(ts srvtopo.Server, se *schema.Engine) *Engine + func (vse *Engine) Close() + func (vse *Engine) InitDBConfig(cp dbconfigs.Connector) + func (vse *Engine) IsOpen() bool + 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) StreamResults(ctx context.Context, query string, ...) error + func (vse *Engine) StreamRows(ctx context.Context, query string, lastpk []sqltypes.Value, ...) error + type Plan struct + ColExprs []ColExpr + KeyRange *topodatapb.KeyRange + Table *Table + Vindex vindexes.Vindex + VindexColumns []int + type RowStreamer interface + Cancel func() + Stream func() error + func NewRowStreamer(ctx context.Context, cp dbconfigs.Connector, se *schema.Engine, query string, ...) RowStreamer + type Table struct + Fields []*querypb.Field + Name string + type VStreamer interface + Cancel func() + Stream func() error + func NewVStreamer(ctx context.Context, cp dbconfigs.Connector, se *schema.Engine, ...) VStreamer
Go to main page