microdb

Apr 23, 2021

Changes in this version

+ func AddDataOriginFromCfg(name string) error

+ type ConnectionCfg struct

+ Dsn string

+ OriginType DataOriginType

type DataOrigin

+ Connection *ConnectionCfg

+ Schema *Schema

+ type DataOriginCfg struct

+ Origins map[string]*DataOrigin

type Schema

+ Table string

Apr 22, 2021

Changes in this version

type DataOrigin

+ func (d *DataOrigin) ReadTopic() string

+ func (d *DataOrigin) WriteTopic() string

type Schema

+ InsertQuery string

+ LocalTableQuery string

+ OriginTableQuery string

+ type SchemaOption func() (*Schema, error)

+ func WithSchemaBuilder(originType DataOriginType, table string, ...) SchemaOption

+ func WithSchemaStrings(originType DataOriginType, ...) SchemaOption

Apr 16, 2021

Changes in this version

+ const DataOriginTypeMySQL

+ const DataOriginTypeSQLite3

+ func AddDataOrigin(table string, opt DataOriginOption) error

+ func InsertQuery(table string) (string, error)

+ func LocalTableQuery(table string) (string, error)

+ func NATSConn(host, port, clusterID, clientID string, opt ...stan.Option) (stan.Conn, error)

+ func NATSConnFromEnv() (stan.Conn, error)

+ func OriginTableQuery(table string) (string, error)

+ type DataOrigin struct

+ func GetDataOrigin(table string) (*DataOrigin, error)

+ func (d *DataOrigin) GetDB() (*sql.DB, error)

+ type DataOriginOption func() (*DataOrigin, error)

+ func WithMySQLDataOrigin(host, port, user, password, database string, schema *Schema) DataOriginOption

+ type DataOriginType string

+ type Schema struct