Sha256: 968ff014f54b27719edad0dcad8caee659120420b71b246f5c7c80d1d5f7f50c
Contents?: true
Size: 646 Bytes
Versions: 49
Compression:
Stored size: 646 Bytes
Contents
# frozen_string_literal: true 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
49 entries across 49 versions & 4 rubygems