module IProto::ConnectionAPI

Constants

BINARY
DEFAULT_RECONNECT
EMPTY_STR
HEADER_SIZE
PING
PING_ID

Public Instance Methods

next_request_id() click to toggle source
# File lib/iproto/connection_api.rb, line 10
def next_request_id
  @next_request_id = ((@next_request_id ||= 0) + 1) & 0x7fffffff
end
pack_request(request_type, request_id, body) click to toggle source
# File lib/iproto/connection_api.rb, line 19
def pack_request(request_type, request_id, body)
  data = ::BinUtils.append_int32_le!(nil, request_type, body.bytesize, request_id)
  ::BinUtils.append_string!(data, body)
end
send_request(request_id, data) click to toggle source
# File lib/iproto/connection_api.rb, line 14
def send_request(request_id, data)
  # for override
end