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