diff --git a/pgproto3/backend.go b/pgproto3/backend.go index 8f3c3478..ea44d1d1 100644 --- a/pgproto3/backend.go +++ b/pgproto3/backend.go @@ -15,6 +15,7 @@ type Backend struct { // Frontend message flyweights bind Bind _close Close + copyFail CopyFail describe Describe execute Execute flush Flush @@ -82,6 +83,8 @@ func (b *Backend) Receive() (FrontendMessage, error) { msg = &b.describe case 'E': msg = &b.execute + case 'f': + msg = &b.copyFail case 'H': msg = &b.flush case 'P': diff --git a/pgproto3/frontend.go b/pgproto3/frontend.go index d1541c74..31a955bc 100644 --- a/pgproto3/frontend.go +++ b/pgproto3/frontend.go @@ -23,6 +23,7 @@ type Frontend struct { copyInResponse CopyInResponse copyOutResponse CopyOutResponse copyDone CopyDone + copyFail CopyFail dataRow DataRow emptyQueryResponse EmptyQueryResponse errorResponse ErrorResponse @@ -83,6 +84,8 @@ func (b *Frontend) Receive() (BackendMessage, error) { msg = &b.dataRow case 'E': msg = &b.errorResponse + case 'f': + msg = &b.copyFail case 'G': msg = &b.copyInResponse case 'H':