Because now it became public for external 'epgsql_command' developers
@@ -17,7 +17,7 @@
| {error, epgsql:query_error()}].
-include("epgsql.hrl").
--include("../epgsql_binary.hrl").
+-include("protocol.hrl").
-record(batch,
{batch :: [{#statement{}, list()}],
@@ -8,7 +8,7 @@
-type response() :: ok | {error, epgsql:query_error()}.
-record(bind,
{stmt :: #statement{},
-record(close,
{type :: statement | portal,
@@ -14,7 +14,7 @@
| epgsql:query_error()}.
-record(connect,
{opts :: list(),
@@ -6,7 +6,7 @@
-export_type([response/0]).
-type response() :: {ok, [epgsql:column()]} | {error, epgsql:query_error()}.
-type response() :: {ok, #statement{}} | {error, epgsql:query_error()}.
@@ -18,7 +18,7 @@
| {error, epgsql:query_error()}.
-record(equery,
@@ -12,7 +12,7 @@
-record(execute,
@@ -9,7 +9,7 @@
-record(pquery,
@@ -20,7 +20,7 @@
-type response() :: response_single() | [response_single()].
-record(squery,
{query :: iodata(),
-include("../epgsql_replication.hrl").
-record(start_repl,
init(_) ->
oid2type = []
}).
--include("epgsql_binary.hrl").
-opaque codec() :: #codec{}.
@@ -4,7 +4,7 @@
-export([decode/2, encode/2]).
-define(postgres_epoc_jdate, 2451545).
-define(postgres_epoc_secs, 946684800).
-define(postgres_epoc_usecs, 946684800000000).
@@ -49,7 +49,7 @@
-export_type([transport/0, pg_sock/0]).
-include("epgsql_replication.hrl").
-type transport() :: {call, any()}
encode_standby_status_update/3]).
decode_message(<<Type:8, Len:?int32, Rest/binary>> = Bin) ->