Versions in this module Expand all Collapse all v0 v0.1.4 Jan 27, 2022 v0.1.3 Nov 2, 2021 v0.1.2 May 4, 2021 v0.1.1 May 3, 2021 v0.1.0 May 3, 2021 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)