querier

package

v0.1.7 Latest Latest Go to latest Published: Apr 29, 2021 License: Unlicense Imports: 10 Imported by: 0

Details

Package querier contains library functions for MicroDB querier.

This section is empty.

This section is empty.

This section is empty.

type Handler interface {
	Handle() error
	Close() error
}

Handler represents a data origin querier.

func MySQLHandler(host, port, user, password, database, table string, sc stan.Conn) (Handler, error)

MySQLHandler returns a new instance of querier for MySQL-based data origin.

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

MySQLQuerier represents a MySQL-based data origin querier.

func (m *MySQLQuerier) Close() error

Close closes all connections that the handler uses.

func (m *MySQLQuerier) Handle() error

Handle starts the subscriber for handling write and direct read queries.