# Functions
NewAccount creates a new account.
NewDBManager creates a new DBManager.
NewRetriever creates a new Retriever.
NewTimestamp creates a new Timestamp.
NewVaultsStreamer creates new streamer.
NewVaultsUploader creates new uploader.
ParseTimestamp parses a string and returns a time.Time object as UTC.
# Variables
ErrNotFoundInCache is an error when file is not found in cache.
# Structs
Account represents an account.
Column represents a column in a table being replicated.
CreateVaultParams ...
DBManager manages a duckdb database.
EventInfo represents information about a deal.
ListVaultEventsParams ...
ListVaultsParams ...
RetrieveEventParams ...
Retriever is responsible for retrieving file from the network.
TableSchema represents a table and its schema.
Timestamp represents a time a file was uploaded.
VaultsStreamer contains logic of streaming Postgres changes to Vaults Provider.
VaultsUploader contains logic of uploading Parquet files to Vaults Provider.
WriteVaultEventParams ...
# Interfaces
Replicator replicates Postgres txs into a channel.
VaultsProvider defines Vaults API.