class Cassandra::Protocol::StartupRequest

Constants

COMPRESSION

@private

CQL_VERSION

@private

Attributes

options[R]

Public Class Methods

new(cql_version, compression = nil) click to toggle source
Calls superclass method Cassandra::Protocol::Request::new
   # File lib/cassandra/protocol/requests/startup_request.rb
29 def initialize(cql_version, compression = nil)
30   super(1)
31   raise ArgumentError, "Invalid CQL version: #{cql_version.inspect}" unless cql_version
32   @options = {CQL_VERSION => cql_version}
33   @options[COMPRESSION] = compression if compression
34 end

Public Instance Methods

compressable?() click to toggle source
   # File lib/cassandra/protocol/requests/startup_request.rb
36 def compressable?
37   false
38 end
to_s() click to toggle source
   # File lib/cassandra/protocol/requests/startup_request.rb
44 def to_s
45   %(STARTUP #{@options})
46 end
write(buffer, protocol_version, encoder) click to toggle source
   # File lib/cassandra/protocol/requests/startup_request.rb
40 def write(buffer, protocol_version, encoder)
41   buffer.append_string_map(@options)
42 end