Sha256: 55f9e1ccfa589219bff1d18c419cf3472050af24e4d9ed2fa7a56323a5da3328
Contents?: true
Size: 615 Bytes
Versions: 29
Compression:
Stored size: 615 Bytes
Contents
module Kafka
module Protocol
# SaslHandshake Response (Version: 0) => error_code [enabled_mechanisms]
# error_code => int16
# enabled_mechanisms => array of strings
class SaslHandshakeResponse
attr_reader :error_code
attr_reader :enabled_mechanisms
def initialize(error_code:, enabled_mechanisms:)
@error_code = error_code
@enabled_mechanisms = enabled_mechanisms
end
def self.decode(decoder)
new(
error_code: decoder.int16,
enabled_mechanisms: decoder.array { decoder.string }
)
end
end
end
end
Version data entries
29 entries across 29 versions & 1 rubygems