mysqldriver

package
v0.0.0-...-726f7ef Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 12, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 ...

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.