Documentation
¶
Index ¶
- Constants
- func ImplicitlyCommits(statement string) bool
- func NewLimitedListener(listenerCfg mysql.ListenerConfig) (server.ProtocolListener, error)
- func NewListener(listenerCfg mysql.ListenerConfig) (server.ProtocolListener, error)
- func RunInMemory(args []string) (*int, *sync.WaitGroup)
- func RunOnDisk(args []string) (*int, *sync.WaitGroup)
- type LimitedListener
- type Listener
- type ParsedQuery
Constants ¶
const (
Version = "0.1.0"
)
Variables ¶
This section is empty.
Functions ¶
func ImplicitlyCommits ¶
ImplicitlyCommits returns whether the given statement implicitly commits. Case-insensitive.
func NewLimitedListener ¶
func NewLimitedListener(listenerCfg mysql.ListenerConfig) (server.ProtocolListener, error)
NewLimitedListener creates a new LimitedListener.
func NewListener ¶
func NewListener(listenerCfg mysql.ListenerConfig) (server.ProtocolListener, error)
NewListener creates a new Listener.
func RunInMemory ¶
RunInMemory starts the server based on the given args, while also using RAM as the backing store. The returned WaitGroup may be used to wait for the server to close.
Types ¶
type LimitedListener ¶
type LimitedListener struct {
// contains filtered or unexported fields
}
LimitedListener automatically shuts down the listener after two connections close. This is intended only for testing. Tests will always make use of two connections, and they are as follows: 1. Establish a connection, and create the database. Disconnect afterward (Postgres enforces one connection per database). 2. Establish a connection, and run all of the queries relevant to the database. Tests that do not use the framework provided may not adhere to the above rules, and therefore must find another way to properly close their servers.
func (*LimitedListener) Accept ¶
func (l *LimitedListener) Accept()
Accept implements the interface server.ProtocolListener.
func (*LimitedListener) Addr ¶
func (l *LimitedListener) Addr() net.Addr
Addr implements the interface server.ProtocolListener.
func (*LimitedListener) Close ¶
func (l *LimitedListener) Close()
Close implements the interface server.ProtocolListener.
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
Listener listens for connections to process PostgreSQL requests into Dolt requests.
func (*Listener) Close ¶
func (l *Listener) Close()
Close stops the handling of incoming connections.
func (*Listener) HandleConnection ¶
HandleConnection handles a connection's session.
type ParsedQuery ¶
ParsedQuery represents a query that may have been parsed. If Parsed is nil, then the Query should be parsed by the listener, otherwise the Parsed statement should be used.
Source Files