Class: Avrodrome::Adaptor

Inherits:
Object
  • Object
show all
Defined in:
lib/avrodrome/adaptor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(logger: Avrodrome.logger, registry: Avrodrome::Registry.new) ⇒ Adaptor

Returns a new instance of Adaptor.



5
6
7
8
 
# File 'lib/avrodrome/adaptor.rb', line 5

def initialize(logger: Avrodrome.logger, registry: Avrodrome::Registry.new)
  @logger   = logger
  @registry = registry
end

Instance Attribute Details

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



3
4
5
 
# File 'lib/avrodrome/adaptor.rb', line 3

def logger
  @logger
end

#registry ⇒ Object (readonly)

Returns the value of attribute registry.



3
4
5
 
# File 'lib/avrodrome/adaptor.rb', line 3

def registry
  @registry
end

Instance Method Details

#check(subject_name, schema) ⇒ Object

Check if a schema exists. Returns nil if not found.



42
43
44
45
46
 
# File 'lib/avrodrome/adaptor.rb', line 42

def check(subject_name, schema)
  subject = registry.subject(subject_name)
  return errors[:subject_not_found] unless subject
  subject.check(schema)&.to_hash
end

#compatible?(subject, schema, version = 'latest') ⇒ Boolean

AC: Assume short lived in memory store, no historic schemas for now

Check if a schema is compatible with the stored version. Returns:

  • true if compatible

  • nil if the subject or version does not exist

  • false if incompatible

docs.confluent.io/3.1.2/schema-registry/docs/api.html#compatibility

Returns:

  • (Boolean) 


56
57
58
59
60
61
62
 
# File 'lib/avrodrome/adaptor.rb', line 56

def compatible?(subject, schema, version = 'latest')
  true
  # data = post("/compatibility/subjects/#{subject}/versions/#{version}",
  #             expects: [200, 404],
  #             body: { schema: schema.to_s }.to_json)
  # data.fetch('is_compatible', false) unless data.has_key?('error_code')
end

#fetch(id) ⇒ Object 



10
11
12
13
 
# File 'lib/avrodrome/adaptor.rb', line 10

def fetch(id)
  logger.info "Fetching schema with id #{id}"
  registry.find(id)&.body&.to_s || errors[:not_found]
end

#global_config ⇒ Object

Get global config



65
66
67
 
# File 'lib/avrodrome/adaptor.rb', line 65

def global_config
  @gloabl_config ||= { "compatibilityLevel" => "BACKWARD" }
end

#register(subject, schema) ⇒ Object 



15
16
17
18
19
 
# File 'lib/avrodrome/adaptor.rb', line 15

def register(subject, schema)
  registered_schema = registry.register!(subject, schema)
  logger.info "Registered schema for subject `#{subject}`; id = #{registered_schema.id}"
  registered_schema.id
end

#subject_config(subject) ⇒ Object

Get config for subject



75
76
77
78
79
 
# File 'lib/avrodrome/adaptor.rb', line 75

def subject_config(subject)
  subject = registry.subject(subject)
  return errors[:subject_not_found] unless subject
  subject.config
end

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

Get a specific version for a subject



34
35
36
37
38
39
 
# File 'lib/avrodrome/adaptor.rb', line 34

def subject_version(subject_name, version = 'latest')
  subject = registry.subject(subject_name)
  return errors[:subject_not_found] unless subject
  version = nil if version == 'latest'
  subject.version(version) || errors[:version_not_found]
end

#subject_versions(subject_name) ⇒ Object

List all versions for a subject



27
28
29
30
31
 
# File 'lib/avrodrome/adaptor.rb', line 27

def subject_versions(subject_name)
  subject = registry.subject(subject_name)
  return errors[:subject_not_found] unless subject
  subject.schemas.map(&:version)
end

#subjects ⇒ Object

List all subjects



22
23
24
 
# File 'lib/avrodrome/adaptor.rb', line 22

def subjects
  registry.subjects.map(&:name)
end

#update_global_config(config) ⇒ Object

Update global config



70
71
72
 
# File 'lib/avrodrome/adaptor.rb', line 70

def update_global_config(config)
  global_config.merge!(config)
end

#update_subject_config(subject, config) ⇒ Object

Update config for subject



82
83
84
85
86
 
# File 'lib/avrodrome/adaptor.rb', line 82

def update_subject_config(subject, config)
  subject = registry.subject(subject)
  return errors[:subject_not_found] unless subject
  subject.config.merge!(config)
end