diff options
| author | Felix Hanley <felix@userspace.com.au> | 2018-02-21 04:21:58 +0000 |
|---|---|---|
| committer | Felix Hanley <felix@userspace.com.au> | 2018-02-21 04:22:32 +0000 |
| commit | 734db776ce17a234825e83180a547cd3ad28f5e2 (patch) | |
| tree | d5c289056fb01dfc1f3f438dd4eec21a31a23166 /vendor/github.com/jackc/pgx/pgproto3/pgproto3.go | |
| parent | e9adf3a2bf8b81615275a6705b7957e43753f0ec (diff) | |
| download | dhtsearch-734db776ce17a234825e83180a547cd3ad28f5e2.tar.gz dhtsearch-734db776ce17a234825e83180a547cd3ad28f5e2.tar.bz2 | |
Update vendor deps
Diffstat (limited to 'vendor/github.com/jackc/pgx/pgproto3/pgproto3.go')
| -rw-r--r-- | vendor/github.com/jackc/pgx/pgproto3/pgproto3.go | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/vendor/github.com/jackc/pgx/pgproto3/pgproto3.go b/vendor/github.com/jackc/pgx/pgproto3/pgproto3.go new file mode 100644 index 0000000..fe7b085 --- /dev/null +++ b/vendor/github.com/jackc/pgx/pgproto3/pgproto3.go @@ -0,0 +1,42 @@ +package pgproto3 + +import "fmt" + +// Message is the interface implemented by an object that can decode and encode +// a particular PostgreSQL message. +type Message interface { + // Decode is allowed and expected to retain a reference to data after + // returning (unlike encoding.BinaryUnmarshaler). + Decode(data []byte) error + + // Encode appends itself to dst and returns the new buffer. + Encode(dst []byte) []byte +} + +type FrontendMessage interface { + Message + Frontend() // no-op method to distinguish frontend from backend methods +} + +type BackendMessage interface { + Message + Backend() // no-op method to distinguish frontend from backend methods +} + +type invalidMessageLenErr struct { + messageType string + expectedLen int + actualLen int +} + +func (e *invalidMessageLenErr) Error() string { + return fmt.Sprintf("%s body must have length of %d, but it is %d", e.messageType, e.expectedLen, e.actualLen) +} + +type invalidMessageFormatErr struct { + messageType string +} + +func (e *invalidMessageFormatErr) Error() string { + return fmt.Sprintf("%s body is invalid", e.messageType) +} |
