Versions in this module Expand all Collapse all v0 v0.0.6 Jan 28, 2022 v0.0.5 Jan 28, 2022 v0.0.4 Jan 25, 2022 v0.0.3 Jan 24, 2022 Changes in this version + const MaxAllowedPacket + const SchemaDbSourceType + var DialectWriterCols = []string + var DialectWriters = []schema.DialectWriter + var ErrNotDate = errors.New("Unable to conver to time value") + var IntrospectCount = 20 + func IntrospectSchema(s *schema.Schema, name string, iter schema.Iterator) error + func IntrospectTable(tbl *schema.Table, iter schema.Iterator) error + func KeyFromWhere(wh interface{}) schema.Key + func MessageConversion(vals []interface{}) []schema.Message + func MysqlValueString(t value.ValueType) string + func NewMySqlSessionVars() expr.ContextReadWriter + func NewNamespacedContextReader(basereader expr.ContextReader, namespace string) expr.ContextReader + func NewNestedContextReadWriter(readers []expr.ContextReader, writer expr.ContextWriter, ts time.Time) expr.ContextReadWriter + func NewNestedContextReader(readers []expr.ContextReader, ts time.Time) expr.ContextReader + func RowsForSession(ctx *plan.Context) [][]driver.Value + func SchemaDBStoreProvider(s *schema.Schema) schema.Source + type ContextSimple struct + Data map[string]value.Value + func NewContextMap(data map[string]interface{}, namespacing bool) *ContextSimple + func NewContextMapTs(data map[string]interface{}, namespacing bool, ts time.Time) *ContextSimple + func NewContextSimple() *ContextSimple + func NewContextSimpleData(data map[string]value.Value) *ContextSimple + func NewContextSimpleNative(data map[string]interface{}) *ContextSimple + func NewContextSimpleTs(data map[string]value.Value, ts time.Time) *ContextSimple + func NewMySqlGlobalVars() *ContextSimple + func (m *ContextSimple) All() map[string]value.Value + func (m *ContextSimple) Body() interface{} + func (m *ContextSimple) Commit(rowInfo []expr.SchemaInfo, row expr.RowWriter) error + func (m *ContextSimple) Delete(row map[string]value.Value) error + func (m *ContextSimple) Id() uint64 + func (m *ContextSimple) Put(col expr.SchemaInfo, rctx expr.ContextReader, v value.Value) error + func (m *ContextSimple) Row() map[string]value.Value + func (m *ContextSimple) SupportNamespacing() + func (m *ContextSimple) Ts() time.Time + func (m ContextSimple) Get(key string) (value.Value, bool) + type ContextWrapper struct + func NewContextWrapper(val interface{}) *ContextWrapper + func (m *ContextWrapper) Get(key string) (value.Value, bool) + func (m *ContextWrapper) Row() map[string]value.Value + func (m *ContextWrapper) Ts() time.Time + type CsvDataSource struct + func NewCsvSource(table string, indexCol int, ior io.Reader, exit <-chan bool) (*CsvDataSource, error) + func (m *CsvDataSource) Close() error + func (m *CsvDataSource) Columns() []string + func (m *CsvDataSource) Init() + func (m *CsvDataSource) Next() schema.Message + func (m *CsvDataSource) Open(connInfo string) (schema.Conn, error) + func (m *CsvDataSource) Setup(*schema.Schema) error + func (m *CsvDataSource) Table(tableName string) (*schema.Table, error) + func (m *CsvDataSource) Tables() []string + type FileLineHandler func(line []byte) (schema.Message, error) + type JsonHelperScannable u.JsonHelper + func (m *JsonHelperScannable) MarshalJSON() ([]byte, error) + func (m *JsonHelperScannable) Scan(src interface{}) error + func (m *JsonHelperScannable) UnmarshalJSON(data []byte) error + func (m JsonHelperScannable) Value() (driver.Value, error) + type JsonSource struct + func NewJsonSource(table string, rc io.ReadCloser, exit <-chan bool, lh FileLineHandler) (*JsonSource, error) + func (m *JsonSource) Close() error + func (m *JsonSource) Columns() []string + func (m *JsonSource) CreateIterator() schema.Iterator + func (m *JsonSource) Init() + func (m *JsonSource) Next() schema.Message + func (m *JsonSource) Open(connInfo string) (schema.Conn, error) + func (m *JsonSource) Setup(*schema.Schema) error + func (m *JsonSource) Table(tableName string) (*schema.Table, error) + func (m *JsonSource) Tables() []string + type JsonWrapper json.RawMessage + func (m *JsonWrapper) MarshalJSON() ([]byte, error) + func (m *JsonWrapper) Scan(src interface{}) error + func (m *JsonWrapper) Unmarshal(v interface{}) error + func (m *JsonWrapper) UnmarshalJSON(data []byte) error + func (m JsonWrapper) Value() (driver.Value, error) + type KeyCol struct + Name string + Val driver.Value + func NewKeyCol(name string, val driver.Value) KeyCol + func (m KeyCol) Key() driver.Value + type KeyInt struct + Id int + func NewKeyInt(key int) KeyInt + func (m *KeyInt) Key() driver.Value + type KeyInt64 struct + Id int64 + func NewKeyInt64(key int64) KeyInt64 + func (m *KeyInt64) Key() driver.Value + type NamespacedContextReader struct + func (n *NamespacedContextReader) Get(key string) (value.Value, bool) + func (n *NamespacedContextReader) Row() map[string]value.Value + func (n *NamespacedContextReader) Ts() time.Time + type NestedContextReader struct + func (n *NestedContextReader) Delete(delRow map[string]value.Value) error + func (n *NestedContextReader) Get(key string) (value.Value, bool) + func (n *NestedContextReader) Put(col expr.SchemaInfo, readCtx expr.ContextReader, v value.Value) error + func (n *NestedContextReader) Row() map[string]value.Value + func (n *NestedContextReader) Ts() time.Time + type SchemaDb struct + func NewSchemaDb(s *schema.Schema) *SchemaDb + func (m *SchemaDb) Close() error + func (m *SchemaDb) DropTable(t string) error + func (m *SchemaDb) Init() + func (m *SchemaDb) Open(schemaObjectName string) (schema.Conn, error) + func (m *SchemaDb) Setup(*schema.Schema) error + func (m *SchemaDb) Table(table string) (*schema.Table, error) + func (m *SchemaDb) Tables() []string + type SchemaSource struct + func (m *SchemaSource) Close() error + func (m *SchemaSource) Columns() []string + func (m *SchemaSource) Get(key driver.Value) (schema.Message, error) + func (m *SchemaSource) Next() schema.Message + func (m *SchemaSource) SetContext(ctx *plan.Context) + func (m *SchemaSource) SetRows(rows [][]driver.Value) + type SqlDriverMessage struct + IdVal uint64 + Vals []driver.Value + func NewSqlDriverMessage(id uint64, row []driver.Value) *SqlDriverMessage + func (m *SqlDriverMessage) Body() interface{} + func (m *SqlDriverMessage) Id() uint64 + func (m *SqlDriverMessage) ToMsgMap(colidx map[string]int) *SqlDriverMessageMap + type SqlDriverMessageMap struct + ColIndex map[string]int + IdVal uint64 + Vals []driver.Value + func NewSqlDriverMessageMap(id uint64, row []driver.Value, colindex map[string]int) *SqlDriverMessageMap + func NewSqlDriverMessageMapCtx(id uint64, ctx expr.ContextReader, colindex map[string]int) *SqlDriverMessageMap + func NewSqlDriverMessageMapEmpty() *SqlDriverMessageMap + func NewSqlDriverMessageMapVals(id uint64, row []driver.Value, cols []string) *SqlDriverMessageMap + func (m *SqlDriverMessageMap) Body() interface{} + func (m *SqlDriverMessageMap) Copy() *SqlDriverMessageMap + func (m *SqlDriverMessageMap) Get(key string) (value.Value, bool) + func (m *SqlDriverMessageMap) Id() uint64 + func (m *SqlDriverMessageMap) Key() driver.Value + func (m *SqlDriverMessageMap) Row() map[string]value.Value + func (m *SqlDriverMessageMap) SetKey(key string) + func (m *SqlDriverMessageMap) SetKeyHashed(key string) + func (m *SqlDriverMessageMap) SetRow(row []driver.Value) + func (m *SqlDriverMessageMap) Ts() time.Time + func (m *SqlDriverMessageMap) Values() []driver.Value + type StringArray []string + func (m *StringArray) MarshalJSON() ([]byte, error) + func (m *StringArray) Scan(src interface{}) error + func (m *StringArray) UnmarshalJSON(data []byte) error + func (m StringArray) Value() (driver.Value, error) + type TimeValue time.Time + func (m *TimeValue) MarshalJSON() ([]byte, error) + func (m *TimeValue) Scan(src interface{}) error + func (m *TimeValue) Time() time.Time + func (m *TimeValue) UnmarshalJSON(data []byte) error + func (m TimeValue) Value() (driver.Value, error)