Package vbase-py
class vbase.AggregateIndexingService(services: list[IndexingService])
find_last_object(object_cid: str, return_set_cid=False) → dict | None
find_last_user_set_object(user: str, set_cid: str) → dict | None
find_object(object_cid: str, return_set_cids=False) → list[dict]
find_objects(object_cids: list[str], return_set_cids=False) → list[dict]
find_user_objects(user: str, return_set_cids=False) → list[dict]
find_user_set_objects(user: str, set_cid: str) → list[dict]
find_user_sets(user: str) → list[dict]
class vbase.BaseSetMatchingService
abstractmethod find_matching_sets(criteria: SetMatchingCriteria) → list[SetMatch]
class vbase.ChainSetMatchingService(matching_services: list[BaseSetMatchingService])
find_matching_sets(criteria: SetMatchingCriteria) → list[SetMatch]
class vbase.FailoverIndexingService(services: list[IndexingService])
find_last_object(object_cid: str, return_set_cid=False) → dict
find_last_user_set_object(user: str, set_cid: str) → dict
find_object(object_cid: str, return_set_cids=False) → dict
find_objects(object_cids: list[str], return_set_cids=False) → list[dict]
find_user_objects(user: str, return_set_cids=False) → list[dict]
find_user_set_objects(user: str, set_cid: str) → dict
find_user_sets(user: str) → list[dict]
class vbase.ForwarderCommitmentService(forwarder_url: str, api_key: str, private_key: str | None = None, commitment_service_json_file_name: str | None = 'CommitmentService.json')
add_object(object_cid: str) → dict
add_set(set_cid: str) → dict
add_set_object(set_cid: str, object_cid: str) → dict
add_set_objects_batch(set_cid: str, object_cids: List[str]) → List[dict]
add_sets_objects_batch(set_cids: List[str], object_cids: List[str]) → List[dict]
static create_instance_from_env(dotenv_path: str | None = None) → ForwarderCommitmentService
get_commitment_service_data() → dict
static get_init_args_from_env(dotenv_path: str | None = None) → dict
user_set_exists(user: str, set_cid: str) → bool
verify_user_object(user: str, object_cid: str, timestamp: str) → bool
verify_user_set_objects(user: str, set_cid: str, user_set_object_cid_sum: str) → bool
verify_user_sets(user: str, user_set_cid_sum: str) → bool
class vbase.ForwarderCommitmentServiceTest(forwarder_url: str, api_key: str, private_key: str | None = None, commitment_service_json_file_name: str | None = 'CommitmentServiceTest.json')
add_object_with_timestamp(object_cid: str, timestamp: str) → dict
add_set_object_with_timestamp(set_cid: str, object_cid: str, timestamp: str) → dict
add_set_objects_with_timestamps_batch(set_cid: str, object_cids: List[str], timestamps: List[str]) → List[dict]
add_sets_objects_with_timestamps_batch(set_cids: List[str], object_cids: List[str], timestamps: List[str]) → List[dict]
clear_set_objects(set_cid: str)
clear_sets()
static create_instance_from_env(dotenv_path: str | None = None) → ForwarderCommitmentServiceTest
class vbase.FuzzySetMatchingService(db_url: str, tolerance: float = 0.2)
MIN_CRITERIA_SIZE_FOR_TOLERANCE = 5
find_matching_sets(criteria: SetMatchingCriteria) → list[SetMatch]
class vbase.HeadBasedSetMatchingService(db_url: str)
find_matching_sets(criteria: SetMatchingCriteria) → list[SetMatch]
class vbase.IndexingService
static create_instance_from_commitment_service(commitment_service: CommitmentService) → IndexingService
static create_instance_from_env_json_descriptor(dotenv_path: str | None = None) → IndexingService
static create_instance_from_json_descriptor(is_json: str) → IndexingService
find_last_object(object_cid: str, return_set_cid=False) → dict | None
find_last_user_set_object(user: str, set_cid: str) → dict | None
find_object(object_cid: str, return_set_cids=False) → List[dict]
find_objects(object_cids: List[str], return_set_cids=False) → List[dict]
find_user_objects(user: str, return_set_cids=False) → List[dict]
find_user_set_objects(user: str, set_cid: str) → List[dict]
find_user_sets(user: str) → List[dict]
class vbase.SQLIndexingService(db_url: str, indexing_stale_threshold_seconds: int = 60)
find_last_object(object_cid: str, return_set_cid=False) → dict | None
find_last_user_set_object(user: str, set_cid: str) → dict | None
find_object(object_cid: str, return_set_cids=False) → List[dict]
find_objects(object_cids: List[str], return_set_cids=False) → List[dict]
find_user_objects(user: str, return_set_cids=False) → List[dict]
find_user_set_objects(user: str, set_cid: str) → List[dict]
find_user_sets(user: str) → List[dict]
class vbase.SetMatch(rank: float, set_cid: str, user: str, last_matching_element_timestamp: int, is_full_match: bool, data_freshness_timestamp: int | None = None)
data_freshness_timestamp: int | None = None
is_full_match: bool
last_matching_element_timestamp: int
rank: float
set_cid: str
user: str
class vbase.SetMatchingCriteria(objects: list[TimestampedCid])
objects: list[TimestampedCid]
class vbase.TimestampedCid(object_cid: str, timestamp: int)
object_cid: str
timestamp: int
class vbase.VBaseBytesObject(init_data: bytes | None = None, init_dict: Dict[str, str] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: bytes) → str
class vbase.VBaseClient(commitment_service: CommitmentService)
add_named_set(name: str) → dict
add_object(object_cid: str) → dict
add_set(set_cid: str) → dict
add_set_object(set_cid: str, object_cid: str) → dict
add_set_objects_batch(set_cid: str, object_cids: List[str]) → List[dict]
add_sets_objects_batch(set_cids: List[str], object_cids: List[str]) → List[dict]
static create_instance_from_env(dotenv_path: str | None = None) → VBaseClient
get_default_user() → str
get_named_set_cid(name: str) → str
get_sim_t() → Timestamp | None
in_sim() → bool
run_pit_sim(ts: DatetimeIndex, callback: Callable[[], int | float | dict | DataFrame]) → Series | DataFrame
user_named_set_exists(user: str, name: str) → bool
user_set_exists(user: str, set_cid: str) → bool
verify_user_named_sets(user: str, names: List[str]) → bool
verify_user_object(user: str, object_cid: str, timestamp: Timestamp | str) → bool
verify_user_set_objects(user: str, set_cid: str, user_set_objects_cid_sum: str) → bool
verify_user_sets(user: str, user_sets_cid_sum: str) → bool
class vbase.VBaseClientTest(commitment_service: CommitmentServiceTest)
add_object_with_timestamp(object_cid: str, timestamp: Timestamp | str) → dict
add_set_object_with_timestamp(set_cid: str, object_cid: str, timestamp: Timestamp | str) → dict
add_set_objects_with_timestamps_batch(set_cid: str, object_cids: List[str], timestamps: List[Timestamp]) → List[dict]
add_sets_objects_with_timestamps_batch(set_cids: List[str], object_cids: List[str], timestamps: List[Timestamp]) → List[dict]
clear_named_set_objects(name: str)
clear_set_objects(set_cid: str)
clear_sets()
static create_instance_from_env(dotenv_path: str | None = None) → VBaseClientTest
static normalize_pd_timestamp(timestamp: Timestamp | str)
class vbase.VBaseDataset(vbc: VBaseClient | VBaseClientTest, name: str | None = None, record_type: Type[VBaseObject] | None = None, init_dict: dict | None = None, init_json: str | None = None)
add_record(record_data: any) → dict
add_record_with_timestamp(record_data: any, timestamp: Timestamp | str) → dict
add_records_batch(record_data_list: List[any]) → List[dict]
add_records_with_timestamps_batch(record_data_list: List[any], timestamps: List[Timestamp | str]) → List[dict]
get_commitment_receipts() → List[dict]
get_last_record() → Any | None
get_last_record_data() → Any | None
get_pd_data_frame() → DataFrame | None
get_records() → List[any] | None
static get_set_cid_for_dataset(dataset_name: str) → str
get_timestamps() → DatetimeIndex
to_dict() → dict
to_json() → str
try_restore_timestamps_from_index() -> (<class 'bool'>, typing.List[str])
verify_commitments() -> (<class 'bool'>, typing.List[str])
class vbase.VBaseDatasetAsync(vbc: VBaseClient | VBaseClientTest, name: str | None = None, record_type: Type[VBaseObject] | None = None, init_dict: dict | None = None, init_json: str | None = None)
async add_record_async(record_data: any) → dict
async add_record_with_timestamp_async(record_data: any, timestamp: Timestamp | str) → dict
async add_records_batch_async(record_data_list: List[any]) → List[dict]
async add_records_with_timestamps_batch_async(record_data_list: List[any], timestamps: List[Timestamp | str]) → List[dict]
async classmethod create(*args, **kwargs) → VBaseDatasetAsync
async verify_commitments_async() -> (<class 'bool'>, typing.List[str])
class vbase.VBaseFloatObject(init_data: float | None = None, init_dict: Dict[str, float] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: float) → str
class vbase.VBaseIntObject(init_data: int | None = None, init_dict: Dict[str, int] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: int) → str
class vbase.VBaseJsonObject(init_data: str | None = None, init_dict: Dict[str, str] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: str) → str
get_dict() → dict
class vbase.VBaseObject(init_data: Any | None = None, init_dict: Dict | None = None, init_json: str | None = None)
cid: str | None
data: Any
get_cid() → str
abstractmethod static get_cid_for_data(record_data: Any) → str
get_dict() → dict
class vbase.VBasePortfolioObject(init_data: Dict[str, int | float] | None = None, init_dict: Dict[str, Dict[str, int | float]] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: dict) → str
class vbase.VBasePrivateFloatObject(init_data: float | str | None = None, init_dict: Dict[str, float | str] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: Tuple[int, str]) → str
class vbase.VBasePrivateIntObject(init_data: int | str | None = None, init_dict: Dict[str, int | str] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: Tuple[int, str]) → str
class vbase.VBaseStringObject(init_data: str | None = None, init_dict: Dict[str, str] | None = None, init_json: str | None = None)
static get_cid_for_data(record_data: str) → str
class vbase.Web3HTTPCommitmentService(node_rpc_url: str, commitment_service_address: str, private_key: str | None = None, commitment_service_json_file_name: str | None = 'CommitmentService.json', inject_geth_poa_middleware: bool = False)
add_object(object_cid: str) → dict
add_set(set_cid: str) → dict
add_set_object(set_cid: str, object_cid: str) → dict
add_set_objects_batch(set_cid: str, object_cids: List[str]) → List[dict]
add_sets_objects_batch(set_cids: List[str], object_cids: List[str]) → List[dict]
static create_instance_from_env(dotenv_path: str | None = None) → Web3HTTPCommitmentService
static get_init_args_from_env(dotenv_path: str | None = None) → dict
user_set_exists(user: str, set_cid: str) → bool
verify_user_object(user: str, object_cid: str, timestamp: str) → bool
verify_user_set_objects(user: str, set_cid: str, user_set_object_cid_sum: str) → bool
verify_user_sets(user: str, user_set_cid_sum: str) → bool
class vbase.Web3HTTPCommitmentServiceTest(node_rpc_url: str = None, commitment_service_address: str = None, private_key: str | None = None, commitment_service_json_file_name: str | None = 'CommitmentServiceTest.json', inject_geth_poa_middleware: bool = False)
add_object_with_timestamp(object_cid: str, timestamp: str) → dict
add_set_object_with_timestamp(set_cid: str, object_cid: str, timestamp: str) → dict
add_set_objects_with_timestamps_batch(set_cid: str, object_cids: List[str], timestamps: List[str]) → List[dict]
add_sets_objects_with_timestamps_batch(set_cids: List[str], object_cids: List[str], timestamps: List[str]) → List[dict]
clear_set_objects(set_cid: str)
clear_sets()
static create_instance_from_env(dotenv_path: str | None = None) → Web3HTTPCommitmentServiceTest
class vbase.Web3HTTPIndexingService(commitment_services: List[Web3HTTPCommitmentService])
RETRY_BACKOFF = 2
RETRY_DELAY = 2
RETRY_TRIES = 5
static create_instance_from_env_json_descriptor(dotenv_path: str | None = None) → Web3HTTPIndexingService
static create_instance_from_json_descriptor(is_json: str) → Web3HTTPIndexingService
find_last_object(object_cid: str, return_set_cid=False) → dict | None
find_last_user_set_object(user: str, set_cid: str) → dict | None
find_object(object_cid: str, return_set_cids=False) → List[dict]
find_objects(object_cids: List[str], return_set_cids=False) → List[dict]
find_user_objects(user: str, return_set_cids=False) → List[dict]
find_user_set_objects(user: str, set_cid: str) → List[dict]
find_user_sets(user: str) → List[dict]
vbase.get_default_logger(name: str) → Logger
Last updated

