Method: AvroTurf::CachedConfluentSchemaRegistry#subject_version

Defined in:
lib/avro_turf/cached_confluent_schema_registry.rb

#subject_version(subject, version = 'latest') ⇒ Object 



39
40
41
42
43
44
 
# File 'lib/avro_turf/cached_confluent_schema_registry.rb', line 39

def subject_version(subject, version = 'latest')
  return @upstream.subject_version(subject, version) if version == 'latest'

  @cache.lookup_by_version(subject, version) ||
    @cache.store_by_version(subject, version, @upstream.subject_version(subject, version))
end