symphony.bdk.core.service.datafeed.on_disk_datafeed_id_repository.DatafeedIdRepository#

class symphony.bdk.core.service.datafeed.on_disk_datafeed_id_repository.DatafeedIdRepository#

Bases: abc.ABC

A repository interface for storing a datafeed id. By using the DatafeedLoopV1, the created datafeed id and agent base url has to be persisted on the BDK side.

__init__()#

Methods

__init__()

read()

Reads the persisted datafeed from storage.

write(datafeed_id, agent_base_path)

Persists the created datafeed id into the storage.
abstract read()#

Reads the persisted datafeed from storage.

:return the persisted datafeed id if present in storage, an empty string otherwise

abstract write(datafeed_id: str, agent_base_path: str)#

Persists the created datafeed id into the storage.

Parameters

  • datafeed_id – the datafeed id to be persisted

  • agent_base_path – the agent base path (i.e. scheme, host, port, context) to be persisted