class Deimos::SchemaBackends::AvroLocal
Encode / decode using local Avro encoding.
Public Instance Methods
decode_payload(payload, schema:)
click to toggle source
@override
# File lib/deimos/schema_backends/avro_local.rb, line 10 def decode_payload(payload, schema:) avro_turf.decode(payload, schema_name: schema, namespace: @namespace) end
encode_payload(payload, schema: nil, topic: nil)
click to toggle source
@override
# File lib/deimos/schema_backends/avro_local.rb, line 15 def encode_payload(payload, schema: nil, topic: nil) avro_turf.encode(payload, schema_name: schema, namespace: @namespace) end
Private Instance Methods
avro_turf()
click to toggle source
@return [AvroTurf]
# File lib/deimos/schema_backends/avro_local.rb, line 22 def avro_turf @avro_turf ||= AvroTurf.new( schemas_path: Deimos.config.schema.path, schema_store: @schema_store ) end