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.



92
93
94
 
# File 'lib/avro/schema_compatibility.rb', line 92

def initialize
  @recursion_set = Set.new
end

Instance Method Details

#can_read?(writers_schema, readers_schema) ⇒ Boolean

Returns:

  • (Boolean) 


96
97
98
 
# File 'lib/avro/schema_compatibility.rb', line 96

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

#mutual_read?(writers_schema, readers_schema) ⇒ Boolean

Returns:

  • (Boolean) 


100
101
102
 
# File 'lib/avro/schema_compatibility.rb', line 100

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