querier

Documentation

Overview

Package querier contains library functions for MicroDB querier.

Index

• type Handler
  • func MySQLHandler(host, port, user, password, database, table string, sc stan.Conn) (Handler, error)
• type MySQLQuerier
  • func (m *MySQLQuerier) Close() error
  • func (m *MySQLQuerier) Handle() error

Types

type Handler

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

Handler represents a data origin querier.

func MySQLHandler

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

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

MySQLQuerier represents a MySQL-based data origin querier.

func (*MySQLQuerier) Close

func (m *MySQLQuerier) Close() error

Close closes all connections that the handler uses.

func (*MySQLQuerier) Handle

func (m *MySQLQuerier) Handle() error

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