mysqldriver

Documentation

Index

• type MySQLDataStore
  • func NewDatastore(conf *libqpu.QPUConfig, inputSchema libqpu.Schema) (MySQLDataStore, error)
  • func (ds MySQLDataStore) GetNotificationLanency() (float64, float64, float64, float64)
  • func (ds MySQLDataStore) GetSnapshot(table string, projection, isNull, isNotNull []string) (<-chan libqpu.LogOperation, <-chan error)
  • func (ds MySQLDataStore) SubscribeOps(table string) (<-chan libqpu.LogOperation, context.CancelFunc, <-chan error)
• type MySQLUpdate

Types

type MySQLDataStore

type MySQLDataStore struct {
	// contains filtered or unexported fields
}

MySQLDataStore ...

func NewDatastore

func NewDatastore(conf *libqpu.QPUConfig, inputSchema libqpu.Schema) (MySQLDataStore, error)

NewDatastore ...

func (MySQLDataStore) GetNotificationLanency

func (ds MySQLDataStore) GetNotificationLanency() (float64, float64, float64, float64)

GetNotificationLanency ...

func (MySQLDataStore) GetSnapshot

func (ds MySQLDataStore) GetSnapshot(table string, projection, isNull, isNotNull []string) (<-chan libqpu.LogOperation, <-chan error)

GetSnapshot ...

func (MySQLDataStore) SubscribeOps

func (ds MySQLDataStore) SubscribeOps(table string) (<-chan libqpu.LogOperation, context.CancelFunc, <-chan error)

SubscribeOps ...

type MySQLUpdate

type MySQLUpdate struct {
	RecordID   string
	Table      string
	Timestamp  string
	Attributes []struct {
		Key      string
		ValueOld string
		ValueNew string
	}
}

MySQLUpdate ...