module CQL::Postgres::Wire::Frontend

Overview

Encoders for the messages a client sends. Each writes one complete frame to io, so several can be buffered and flushed together (pipelining).

Defined in:

postgres/wire/frontend.cr

Constant Summary

CANCEL_REQUEST = 80877102

SSL_REQUEST = 80877103

Class Method Summary

• .bind(io : IO, statement : String, params : Array(Types::Param), result_formats : Array(Int16)) : Nil
• .cancel_request(io : IO, process_id : Int32, secret_key : Bytes) : Nil

  The secret key runs to the end of the message (4 bytes before protocol 3.2).

• .close_portal(io : IO) : Nil
• .close_statement(io : IO, name : String) : Nil
• .copy_data(io : IO, chunk : Bytes) : Nil
• .copy_done(io : IO) : Nil
• .copy_fail(io : IO, reason : String) : Nil
• .describe_statement(io : IO, name : String) : Nil
• .execute(io : IO, max_rows : Int32 = 0) : Nil

  Runs the unnamed portal, returning at most max_rows rows (0: all of them).

• .flush(io : IO) : Nil
• .parse(io : IO, name : String, sql : String) : Nil
• .password(io : IO, password : String) : Nil
• .query(io : IO, sql : String) : Nil
• .sasl_initial_response(io : IO, mechanism : String, response : Bytes) : Nil
• .sasl_response(io : IO, response : Bytes) : Nil
• .ssl_request(io : IO) : Nil
• .startup(io : IO, parameters : Hash(String, String), version : ProtocolVersion = ProtocolVersion::V3_0) : Nil
• .sync(io : IO) : Nil
• .terminate(io : IO) : Nil

Class Method Detail