PG

VERSION = "0.30.0"

connect(url)

connect_listen(url, channels : Enumerable(String), blocking : Bool = false, &blk : PQ::Notification -> ) : ListenConnection

connect_listen(url, *channels : String, blocking : Bool = false, &blk : PQ::Notification -> ) : ListenConnection

connect_replication(url, *, handler, publication_name, slot_name, keepalive_interval : Time::Span = 10.seconds)

array_type(t, oid)