livesql

Jan 10, 2019

Changes in this version

+ func FieldToValue(field *thunderpb.Field) (driver.Value, error)

+ func FilterFromProto(schema *sqlgen.Schema, proto *thunderpb.SQLFilter) (string, sqlgen.Filter, error)

+ func FilterToProto(schema *sqlgen.Schema, tableName string, filter sqlgen.Filter) (*thunderpb.SQLFilter, error)

type Binlog

+ func (b *Binlog) SetLogger(l logger.Logger)

type LiveDB

+ func (ldb *LiveDB) AddDependency(ctx context.Context, dep QueryDependency) error

+ type QueryDependency struct

+ Filter sqlgen.Filter

+ Table string

Aug 22, 2018

Changes in this version

+ type Binlog struct

+ func NewBinlog(ldb *LiveDB, host string, port uint16, username, password, database string) (*Binlog, error)

+ func NewBinlogWithSource(ldb *LiveDB, sourceDB *sql.DB, host string, port uint16, ...) (*Binlog, error)

+ func (b *Binlog) Close() error

+ func (b *Binlog) RunPollLoop() error

+ func (b *Binlog) SetUpdateDelay(d time.Duration)

+ type LiveDB struct

+ func NewLiveDB(db *sqlgen.DB) *LiveDB

+ func Open(hostname string, port uint16, username, password, database string, ...) (*LiveDB, error)

+ func (ldb *LiveDB) Close() error

+ func (ldb *LiveDB) Query(ctx context.Context, result interface{}, filter sqlgen.Filter, ...) error

+ func (ldb *LiveDB) QueryRow(ctx context.Context, result interface{}, filter sqlgen.Filter, ...) error