Storage Driver Support
Opened this issue · 0 comments
dixonwhitmire commented
This epic supports storing input messages outside of LinuxForHealth Connect's kafka topics within a storage system. Storage systems include:
- Object Storage (using minio)
- IPFS
- RDBMS
Storage systems are supported through the use of a storage driver "interface" which defines the basic operations requires to store and fetch a message from a system.
def store(input_message: Any) -> str:
# input_message is an EDI Model
# return type is the URI to the message within the storage system
pass
def fetch(uri: str) -> Any:
# uri is the storage system uri
# returns the input message as an EDI model
pass