Index

_

_abc_impl (app.models.asset.Asset attribute) (app.models.connector.Connector attribute) (app.models.connector.Endpoints attribute) (app.models.connector.PortConfig attribute) (app.models.contract.Contract attribute) (app.models.policy.Constraint attribute) (app.models.policy.Operator attribute) (app.models.policy.Policy attribute) (app.models.policy.PolicyDefinition attribute) (app.models.policy.Rule attribute) (app.models.transfer.Transfer attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) (app.schemas.transfer.CheckTransfer attribute) (app.schemas.transfer.ContractAgreement attribute) (app.schemas.transfer.NegotitateContract attribute) (app.schemas.transfer.RequestCatalog attribute) (app.schemas.transfer.StartTransfer attribute) (app.schemas.transfer.TransferResponse attribute)

_convert_contract_to_edc_format() (in module app.services.contracts_service) _convert_rules() (in module app.services.policies_service) _create_docker_network_if_not_exists() (in module app.services.edc_launcher_service) _generate_files() (in module app.services.edc_launcher_service) _get_connector() (in module app.services.contracts_service) _parse_contract_item() (in module app.services.contracts_service) _register_contract_with_edc() (in module app.services.contracts_service) _run_docker_compose() (in module app.services.edc_launcher_service) _run_docker_compose_down() (in module app.services.edc_launcher_service) _wait_for_postgres() (in module app.services.edc_launcher_service)

A

accessPolicyId (app.models.contract.Contract attribute) action (app.models.policy.Rule attribute) api_key (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) app module app.db module app.db.client module app.main module app.models module app.models.asset module app.models.connector module app.models.contract module app.models.policy module app.models.transfer module app.routes module app.routes.assets_routes module app.routes.connectors_routes module app.routes.contracts_routes module app.routes.policies_routes module

app.routes.transfers_routes module app.schemas module app.schemas.connector module app.schemas.transfer module app.services module app.services.assets_service module app.services.connectors_service module app.services.contracts_service module app.services.edc_launcher_service module app.services.policies_service module app.services.transfers_service module app.util module app.util.edc_helpers module asset (app.models.transfer.Transfer attribute) (app.schemas.transfer.NegotitateContract attribute) (app.schemas.transfer.TransferResponse attribute) Asset (class in app.models.asset) asset_id (app.models.asset.Asset attribute) assetsSelector (app.models.contract.Contract attribute) authorization (app.models.transfer.Transfer attribute) (app.schemas.transfer.TransferResponse attribute)

B

base_url (app.models.asset.Asset attribute)

C

catalog_request() (in module app.routes.transfers_routes) catalog_request_curl() (in module app.services.transfers_service) catalog_request_service() (in module app.services.transfers_service) check_data_pull() (in module app.routes.transfers_routes) check_ports_unique() (in module app.services.connectors_service) check_transfer() (in module app.routes.transfers_routes) check_transfer_curl() (in module app.services.transfers_service) check_transfer_data_curl_pull() (in module app.services.transfers_service) check_transfer_data_pull_service() (in module app.services.transfers_service) check_transfer_service() (in module app.services.transfers_service) CheckTransfer (class in app.schemas.transfer) Connector (class in app.models.connector) ConnectorResponse (class in app.schemas.connector) ConnectorUpdate (class in app.schemas.connector) constraint (app.models.policy.Rule attribute) Constraint (class in app.models.policy) consumer (app.models.transfer.Transfer attribute) (app.schemas.transfer.CheckTransfer attribute) (app.schemas.transfer.ContractAgreement attribute) (app.schemas.transfer.NegotitateContract attribute) (app.schemas.transfer.RequestCatalog attribute) (app.schemas.transfer.StartTransfer attribute) (app.schemas.transfer.TransferResponse attribute) content_type (app.models.asset.Asset attribute)

context (app.models.contract.Contract attribute) (app.models.policy.Policy attribute) (app.models.policy.PolicyDefinition attribute) Contract (class in app.models.contract) contract_agreement() (in module app.routes.transfers_routes) contract_agreement_id (app.models.transfer.Transfer attribute) (app.schemas.transfer.StartTransfer attribute) (app.schemas.transfer.TransferResponse attribute) contract_id (app.models.contract.Contract attribute) contract_offer_id (app.schemas.transfer.NegotitateContract attribute) ContractAgreement (class in app.schemas.transfer) contractPolicyId (app.models.contract.Contract attribute) control (app.models.connector.PortConfig attribute) convert_objectids() (in module app.services.transfers_service) convert_policy_to_edc_format() (in module app.services.policies_service) convert_rules_get() (in module app.services.policies_service) create_asset() (in module app.services.assets_service) create_asset_route() (in module app.routes.assets_routes) create_connector() (in module app.services.connectors_service) create_connector_route() (in module app.routes.connectors_routes) create_contract() (in module app.services.contracts_service) create_contract_route() (in module app.routes.contracts_routes) create_policy() (in module app.services.policies_service) create_policy_route() (in module app.routes.policies_routes) create_transfer_service() (in module app.services.transfers_service)

D

data_address_name (app.models.asset.Asset attribute) data_address_proxy (app.models.asset.Asset attribute) data_address_type (app.models.asset.Asset attribute) delete_asset() (in module app.services.assets_service) delete_asset_route() (in module app.routes.assets_routes) (in module app.routes.policies_routes) delete_connector() (in module app.services.connectors_service) delete_connector_route() (in module app.routes.connectors_routes)

delete_contract() (in module app.services.contracts_service) delete_contract_route() (in module app.routes.contracts_routes) delete_policy() (in module app.services.policies_service) description (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) domain (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute)

E

edc (app.models.asset.Asset attribute) (app.models.contract.Contract attribute) (app.models.policy.Policy attribute) endpoint (app.models.transfer.Transfer attribute) (app.schemas.transfer.TransferResponse attribute)

Endpoints (class in app.models.connector) endpoints_url (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute)

G

get_all_connectors() (in module app.services.connectors_service) get_all_transfers() (in module app.routes.transfers_routes) get_all_transfers_service() (in module app.services.transfers_service) get_api_key() (in module app.util.edc_helpers) get_asset_by_asset_id() (in module app.routes.assets_routes) get_asset_by_asset_id_service() (in module app.services.assets_service) get_assets_by_edc_id() (in module app.services.assets_service) get_base_url() (in module app.util.edc_helpers) get_connector() (in module app.routes.connectors_routes)

get_connector_by_id() (in module app.services.connectors_service) get_contract_agreement_curl() (in module app.services.transfers_service) get_contract_agreement_service() (in module app.services.transfers_service) get_contract_by_contract_id() (in module app.routes.contracts_routes) get_contract_by_contract_id_service() (in module app.services.contracts_service) get_contracts_by_edc_id() (in module app.services.contracts_service) get_db() (in module app.db.client) get_policies_by_edc_id() (in module app.services.policies_service) get_policy_by_policy_id() (in module app.routes.policies_routes) get_policy_by_policy_id_service() (in module app.services.policies_service)

H

has_policy_id (app.models.transfer.Transfer attribute) (app.schemas.transfer.TransferResponse attribute)

http (app.models.connector.PortConfig attribute)

I

id (app.models.policy.Operator attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.transfer.TransferResponse attribute)

id_contract_negotiation (app.schemas.transfer.ContractAgreement attribute) init_mongo() (in module app.db.client) is_port_in_use() (in module app.services.connectors_service)

K

keystore_password (in module app.services.edc_launcher_service)

L

leftOperand (app.models.policy.Constraint attribute) list_assets_by_edc() (in module app.routes.assets_routes)

list_connectors() (in module app.routes.connectors_routes) list_contracts_by_edc() (in module app.routes.contracts_routes) list_policies_by_edc() (in module app.routes.policies_routes)

M

management (app.models.connector.Endpoints attribute) (app.models.connector.PortConfig attribute) mode (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) model_config (app.models.asset.Asset attribute) (app.models.connector.Connector attribute) (app.models.connector.Endpoints attribute) (app.models.connector.PortConfig attribute) (app.models.contract.Contract attribute) (app.models.policy.Constraint attribute) (app.models.policy.Operator attribute) (app.models.policy.Policy attribute) (app.models.policy.PolicyDefinition attribute) (app.models.policy.Rule attribute) (app.models.transfer.Transfer attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) (app.schemas.transfer.CheckTransfer attribute) (app.schemas.transfer.ContractAgreement attribute) (app.schemas.transfer.NegotitateContract attribute) (app.schemas.transfer.RequestCatalog attribute) (app.schemas.transfer.StartTransfer attribute) (app.schemas.transfer.TransferResponse attribute) module app app.db app.db.client app.main app.models app.models.asset app.models.connector app.models.contract app.models.policy app.models.transfer app.routes app.routes.assets_routes app.routes.connectors_routes app.routes.contracts_routes app.routes.policies_routes app.routes.transfers_routes app.schemas app.schemas.connector app.schemas.transfer app.services app.services.assets_service app.services.connectors_service app.services.contracts_service app.services.edc_launcher_service app.services.policies_service app.services.transfers_service app.util app.util.edc_helpers

N

name (app.models.asset.Asset attribute) (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) negotiate_contract() (in module app.routes.transfers_routes) negotiate_contract_curl() (in module app.services.transfers_service)

negotiate_contract_id (app.models.transfer.Transfer attribute) (app.schemas.transfer.TransferResponse attribute) negotiate_contract_service() (in module app.services.transfers_service) NegotitateContract (class in app.schemas.transfer) new_transfer() (in module app.routes.transfers_routes) normalize_odrl_list() (in module app.services.policies_service)

O

obligation (app.models.policy.PolicyDefinition attribute)

operator (app.models.policy.Constraint attribute) Operator (class in app.models.policy)

P

permission (app.models.policy.PolicyDefinition attribute) policy (app.models.policy.Policy attribute) Policy (class in app.models.policy) policy_id (app.models.policy.Policy attribute) PolicyDefinition (class in app.models.policy) PortConfig (class in app.models.connector) ports (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) prohibition (app.models.policy.PolicyDefinition attribute)

protocol (app.models.connector.Endpoints attribute) (app.models.connector.PortConfig attribute) provider (app.models.transfer.Transfer attribute) (app.schemas.transfer.NegotitateContract attribute) (app.schemas.transfer.RequestCatalog attribute) (app.schemas.transfer.StartTransfer attribute) (app.schemas.transfer.TransferResponse attribute) proxy_http_logger() (in module app.routes.transfers_routes) proxy_pull() (in module app.routes.transfers_routes) public (app.models.connector.PortConfig attribute)

R

register_asset_with_edc() (in module app.services.assets_service) register_policy_with_edc() (in module app.services.policies_service)

RequestCatalog (class in app.schemas.transfer) rightOperand (app.models.policy.Constraint attribute) Rule (class in app.models.policy)

S

start_edc() (in module app.routes.connectors_routes) start_edc_service() (in module app.services.connectors_service) start_http_server() (in module app.routes.transfers_routes) start_http_server_service() (in module app.services.transfers_service) start_transfer() (in module app.routes.transfers_routes) start_transfer_curl() (in module app.services.transfers_service) start_transfer_curl_pull() (in module app.services.transfers_service) start_transfer_pull() (in module app.routes.transfers_routes) start_transfer_service() (in module app.services.transfers_service)

start_transfer_service_pull() (in module app.services.transfers_service) StartTransfer (class in app.schemas.transfer) startup_db() (in module app.main) state (app.models.connector.Connector attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute) stop_edc() (in module app.routes.connectors_routes) stop_edc_service() (in module app.services.connectors_service) stop_http_server() (in module app.routes.transfers_routes) stop_http_server_service() (in module app.services.transfers_service)

T

Transfer (class in app.models.transfer) transfer_flow (app.models.transfer.Transfer attribute) (app.schemas.transfer.TransferResponse attribute) transfer_process_id (app.models.transfer.Transfer attribute) (app.schemas.transfer.CheckTransfer attribute) (app.schemas.transfer.TransferResponse attribute)

TransferResponse (class in app.schemas.transfer) type (app.models.connector.Connector attribute) (app.models.policy.PolicyDefinition attribute) (app.schemas.connector.ConnectorResponse attribute) (app.schemas.connector.ConnectorUpdate attribute)

U

update_asset() (in module app.services.assets_service) update_asset_route() (in module app.routes.assets_routes) update_connector() (in module app.services.connectors_service)

update_connector_route() (in module app.routes.connectors_routes) update_contract() (in module app.services.contracts_service) update_contract_route() (in module app.routes.contracts_routes)

V

version (app.models.connector.PortConfig attribute)