Sha256: 00ff6c3a63de2953e9dd075ac3edc9a552d3632c3c0bc639b8cb6a5794ed20c4
Contents?: true
Size: 1.68 KB
Versions: 19
Compression:
Stored size: 1.68 KB
Contents
# frozen_string_literal: true
require_relative 'base'
require 'json'
module Deimos
module SchemaClass
# Base Class of Record Classes generated from Avro.
class Record < Base
# Converts the object to a hash which can be used for debugging or comparing objects.
# @return [Hash] a hash representation of the payload
def as_json(_opts={})
super.except('payload_key')
end
# Element access method as if this Object were a hash
# @param key[String||Symbol]
# @return [Object] The value of the attribute if exists, nil otherwise
def [](key)
self.try(key.to_sym)
end
# :nodoc
def with_indifferent_access
self
end
# Returns the schema name of the inheriting class.
# @return [String]
def schema
raise NotImplementedError
end
# Returns the namespace for the schema of the inheriting class.
# @return [String]
def namespace
raise NotImplementedError
end
# Returns the full schema name of the inheriting class.
# @return [String]
def full_schema
"#{namespace}.#{schema}"
end
# Returns the schema validator from the schema backend
# @return [Deimos::SchemaBackends::Base]
def validator
Deimos.schema_backend(schema: schema, namespace: namespace)
end
# @return [Array<String>] an array of fields names in the schema.
def schema_fields
validator.schema_fields.map(&:name)
end
# :nodoc:
def self.initialize_from_value(value)
return nil if value.nil?
value.is_a?(self) ? value : self.new(**value.symbolize_keys)
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems