Class: Avro::SchemaCompatibility::Checker

Inherits:
Object
  • Object
show all
Defined in:
lib/avro/schema_compatibility.rb

Constant Summary collapse

SIMPLE_CHECKS = 
Schema::PRIMITIVE_TYPES_SYM.dup.add(:fixed).freeze

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Checker

Returns a new instance of Checker.



80
81
82
 
# File 'lib/avro/schema_compatibility.rb', line 80

def initialize
  @recursion_set = Set.new
end

Instance Method Details

#can_read?(writers_schema, readers_schema) ⇒ Boolean

Returns:

  • (Boolean) 


84
85
86
 
# File 'lib/avro/schema_compatibility.rb', line 84

def can_read?(writers_schema, readers_schema)
  full_match_schemas(writers_schema, readers_schema)
end

#mutual_read?(writers_schema, readers_schema) ⇒ Boolean

Returns:

  • (Boolean) 


88
89
90
 
# File 'lib/avro/schema_compatibility.rb', line 88

def mutual_read?(writers_schema, readers_schema)
  can_read?(writers_schema, readers_schema) && can_read?(readers_schema, writers_schema)
end