Versions in this module Expand all Collapse all v0 v0.1.0 Jan 27, 2021 Changes in this version + func NewChannelEndpoints() (DriverEndpoint, EngineEndpoint) + func UnlimitedRowsChannel(bufferThis chan message, firstMessage message) chan []string + type ChannelDriverConn struct + func (cdc *ChannelDriverConn) Close() + func (cdc *ChannelDriverConn) ReadResult() (lastInsertedID int64, rowsAffected int64, err error) + func (cdc *ChannelDriverConn) ReadRows() (chan []string, error) + func (cdc *ChannelDriverConn) WriteExec(statement string) error + func (cdc *ChannelDriverConn) WriteQuery(query string) error + type ChannelDriverEndpoint struct + func (cde *ChannelDriverEndpoint) New(uri string) (DriverConn, error) + type ChannelEngineConn struct + func (cec *ChannelEngineConn) ReadStatement() (string, error) + func (cec *ChannelEngineConn) WriteError(err error) error + func (cec *ChannelEngineConn) WriteResult(lastInsertedID int64, rowsAffected int64) error + func (cec *ChannelEngineConn) WriteRow(row []string) error + func (cec *ChannelEngineConn) WriteRowEnd() error + func (cec *ChannelEngineConn) WriteRowHeader(header []string) error + type ChannelEngineEndpoint struct + func (cee *ChannelEngineEndpoint) Accept() (EngineConn, error) + func (cee *ChannelEngineEndpoint) Close() + type DriverConn interface + Close func() + ReadResult func() (lastInsertedID int64, rowsAffected int64, err error) + ReadRows func() (chan []string, error) + WriteExec func(stmt string) error + WriteQuery func(query string) error + type DriverEndpoint interface + New func(string) (DriverConn, error) + func NewChannelDriverEndpoint(channel chan<- chan message) DriverEndpoint + type EngineConn interface + ReadStatement func() (string, error) + WriteError func(err error) error + WriteResult func(lastInsertedID int64, rowsAffected int64) error + WriteRow func(row []string) error + WriteRowEnd func() error + WriteRowHeader func(header []string) error + func NewChannelEngineConn(newConn chan message) EngineConn + type EngineEndpoint interface + Accept func() (EngineConn, error) + Close func() + func NewChannelEngineEndpoint(channel <-chan chan message) EngineEndpoint