01i LSrSSKJr SSKrSSKrSSKrSSKrSSKrSSK r SSK J r J r J r SSKJrJrJrJrJrJrJrJrJrJrJr SSKJrJrJrJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5 SSK6J7r7J8r8 SSK J9r9 \Rt\;\<\Rz\;\R|\R~\<\Rt\;\<\Rz\;44\R|\R~\<\Rt\;\<\Rz\;4\R~\<44r@\Rt\R\<\@4\R\R|\<\@44rC1S krD"S S 5rE"S S 5rF"SS\ RRRR5rJ"SS\ RRRR5rK"SS5rL"SS5rM"SS5rN"SS5rO"SS5rP"SS\95rQg)zGraphDB client module.) annotationsN)GraphLiteralURIRef) BadRequestError ConflictErrorForbiddenErrorInternalServerError NotFoundErrorPreconditionFailedErrorRepositoryNotFoundErrorRepositoryNotHealthyErrorResponseFormatErrorServiceUnavailableErrorUnauthorisedError)AccessControlEntryAuthenticatedUserBackupOperationBeanClearGraphAccessControlEntryClusterRequestFreeAccessSettingsGraphDBRepositoryImportSettingsInfrastructureStatistics NodeStatusParserSettingsPluginAccessControlEntryRepositoryConfigBeanRepositoryConfigBeanCreateRepositorySizeInfoRepositoryStatisticsServerImportBodyStatementAccessControlEntryStructuresStatisticsSystemAccessControlEntryUser UserCreate UserUpdate_parse_operation _parse_plugin _parse_policy _parse_role))extract_filename_from_content_dispositioninfer_filename_from_fileobj) RDF4JClient>pluginsystem statement clear_graphc\rSrSrSrS Sjr\S5r\S5rS SSjjr SSjr SSS jjr SS jr S r g)AccessControlListManagementNzBManage fine-grained access control lists for GraphDB repositories.cXlX lgN) _identifier _http_client)self identifier http_clients W/home/james-whalen/.local/lib/python3.13/site-packages/rdflib/contrib/graphdb/client.py__init__$AccessControlListManagement.__init__Qs%'cUR$r8r:r;s r>r='AccessControlListManagement.http_clientU   rAcUR$)zRepository identifier.)r9rDs r>r<&AccessControlListManagement.identifierYsrANc 0n UbU[;a[SU<35eXS'Ub[U5U S'UbR[U[5(aUR 5U S'O)[U[ 5(aX:S'O[SU<35eUbR[U[5(aUR 5U S'O)[U[ 5(aXJS'O[SU<35eUbX[U[[45(aUR 5U S 'O)[U[ 5(aXZS 'O[S U<35eUb[U[5(aUR 5U S 'O\[U[5(aURR 5U S 'O)[U[ 5(aXjS 'O[S U<35eUb[U5U S 'Ub[U5U S'U b[U 5U S'URRSURS3U S9n U R5 U R!5n [U [&5(d [%S5eU Vs/sHn[(R*"U5PM sn$![["4an [%SU 35U eSn A ff=fs snf![["4an [%SU 35U eSn A ff=f![,R.an U R0R2nUS:Xa#[5SU R0R635U eUS:Xa#[9SU R0R635U eUS:Xa#[;SU R0R635U eeSn A ff=f)a List ACL rules for the repository. Parameters: scope: The scope of the FGAC rule (`statement`, `clear_graph`, `plugin`, `system`). operation: The operation of the FGAC rule (`read`, `write`, `*`). subject: The subject of the FGAC rule in Turtle format (for example, ``). predicate: The predicate of the FGAC rule in Turtle format (for example, ``). obj: The object of the FGAC rule in Turtle format (for example, `"Mary"@en`). graph: The graph of the FGAC rule in Turtle format (for example, ``). plugin: The plugin name for the FGAC rule with plugin scope (for example, `elasticsearch-connector`). role: The role associated with the FGAC rule. policy: The policy for the FGAC rule (`allow`, `deny`, `abstain`). Returns: A list of FGAC rules. Raises: ValueError: If the parameters are invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. ResponseFormatError: If the response cannot be parsed. NzInvalid FGAC scope filter: scope operationsubjectzInvalid FGAC subject filter: predicatezInvalid FGAC predicate filter: objectzInvalid FGAC object filter: contextzInvalid FGAC graph filter: r0rolepolicy/rest/repositories//aclparams"Failed to parse GraphDB response: zAFailed to parse GraphDB response: expected a list of ACL entries.Request is unauthorised: Request is forbidden: Internal server error: )_ALLOWED_FGAC_SCOPES ValueErrorr) isinstancern3strrrr<r*r,r+r:getraise_for_statusjson TypeErrorrlistr from_dicthttpxHTTPStatusErrorresponse status_codertextr r )r;rJrKrLrMobjgraphr0rPrQrUrjpayloaderraclstatuss r>rf AccessControlListManagement.list^sR"$  00 #>ui!HII#7O  "29"=F;   '6**$+JJLy!GS))$+y! #@ !LMM  )V,,&/lln{#Is++&/{# #B9-!PQQ ?#011#&668x C%%#&x  #?w!GHH  %(($)HHJy!E5))$)$4$4$7$7$9y!E3''$)y! #>ui!HII  ,V4F8   (.F6N  ,V4F8 % ((,,%doo%6d;F-H  % % ' "--/ gt,,)W ELMWc*44S9WMM * )8> N * )8> $$ \\--F}'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A  sm58K.J> KJ2# J-J2J*J%%J**K-J22KKKKN-BM??Nc[U5n[SU55(a [S5eUVs/sHo3R5PM nnSS0nURR SUR S3UUS9nUR5 gs snf![RanURRnUS:Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS:Xa#[!SURR35UeeSnAff=f)a Set ACL rules for the repository. !!! Note This method overwrites existing ACL rules in the repository. If you want to add new rules without overwriting existing ones, use the [`add`][rdflib.contrib.graphdb.client.AccessControlListManagement.add] method. Parameters: acl_rules: The list of ACL rules to set. Raises: BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. ValueError: If the ACL rules are not provided as a sequence or are not AccessControlEntry instances. c3L# UHn[U[5(+v M g7fr8r_r.0rules r> 2AccessControlListManagement.set..SND:d$6777N"$3All ACL rules must be AccessControlEntry instances. Content-Typeapplication/jsonrRrSheadersrdInvalid request: rWrXrYrZr[r\N)rfanyr^as_dictr:putr<rcrhrirjrkrrlrr r r; acl_rulesacl_rules_listryrorrjrprrs r>setAccessControlListManagement.setss&i SNS S SRS S.<=nd<<>n=!#56 ((,,%doo%6d;-H  % % '>$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A ! sB 9BE%%B;E  E%cZ[U5n[SU55(a [S5eUVs/sHoDR5PM nnSS0n0nUb?[ U[ 5(d [S5eUS:a [S5e[ U5US 'URRS URS 3UUUS 9nUR5 gs snf![Ran U RRn U S :Xa#[SU RR 35U eU S:Xa#[#SU RR 35U eU S:Xa#[%SU RR 35U eU S:Xa#['SU RR 35U eeSn A ff=f)a3 Add ACL rules to the repository. You can also provide an optional URL request parameter position that specifies the position of the rules to be added. The position is zero-based (0 is the first position). If the position parameter is not provided, the rules are added at the end of the list. Parameters: acl_rules: The list of ACL rules to add. position: The zero-based position to add the rules at. Raises: BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. ValueError: If the position is not an integer or is a negative integer. ValueError: If the ACL rules are not provided as a sequence or are not AccessControlEntry instances. c3L# UHn[U[5(+v M g7fr8rvrws r>rz2AccessControlListManagement.add..#r|r}r~rrNzPosition must be an integer.rz$Position must be a positive integer.positionrRrSrrdrUrrrWrXrYrZr[r\)rfrr^rr_intrar:postr<rcrhrirjrkrrlrr r ) r;rrrryrorrUrjrprrs r>addAccessControlListManagement.add s,i SNS S SRS S.<=nd<<>n=!#56  h,, !?@@!| !GHH!$XF:  ((--%doo%6d; .H  % % '!>"$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A ! sC:CF**B;F%%F*c[U5n[SU55(a [S5eUVs/sHo3R5PM nnSS0nURR SSUR S3UUS9nUR5 gs snf![RanURRnUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[SURR35UeUS:Xa#[!SURR35UeeSnAff=f)a Delete ACL rules from the repository. The provided FGAC rules are removed from the list regardless of their position. Parameters: acl_rules: The list of ACL rules to delete. Raises: BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. ValueError: If the ACL rules are not provided as a sequence or are not AccessControlEntry instances. c3L# UHn[U[5(+v M g7fr8rvrws r>rz5AccessControlListManagement.delete..Zr|r}r~rrDELETErRrSmethodurlrrdrrrWrXrYrZr[r\N)rfrr^rr:requestr<rcrhrirjrkrrlrr r rs r>delete"AccessControlListManagement.deleteIsv i SNS S SRS S.<=nd<<>n=!#56 ((00)$//):$? 1H  % % '>$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A ! sB :BE&&B;E!!E&)r:r9r<rar= httpx.Client) NNNNNNNNN)rJz@t.Literal['statement', 'clear_graph', 'plugin', 'system'] | NonerKz&t.Literal['read', 'write', '*'] | NonerLstr | URIRef | NonerMrrmzstr | URIRef | Literal | Nonernz:t.Literal['*', 'named', 'default'] | URIRef | Graph | Noner0 str | NonerPrrQz,t.Literal['allow', 'deny', 'abstain'] | Nonereturnzxt.List[SystemAccessControlEntry | StatementAccessControlEntry | PluginAccessControlEntry | ClearGraphAccessControlEntry])rt.Sequence[AccessControlEntry]r8)rrr int | None)__name__ __module__ __qualname____firstlineno____doc__r?propertyr=r<rfrrr__static_attributes__rAr>r5r5NsL(!!  SW<@'+)--1LP!?CzOz:z% z ' z + zJzzz=z zx0fQU;7;CM;z.rAr5c&\rSrSrSrSSjr\S5rSSjrSSjr SSSjjr SSS jjr SSS jjr SS jr SS jrSS jrSSjrSSjrSSjrS SjrS!SjrS"SjrSrg)#ClusterGroupManagementizz2Manage and monitor GraphDB cluster configurations.cXlgr8rCr;r=s r>r?ClusterGroupManagement.__init__}'rAcUR$r8rCrDs r>r="ClusterGroupManagement.http_clientrFrAcURRS5nUR5 g![RanUR R nUS:Xa#[SUR R35UeUS:Xa#[SUR R35UeUS:Xa#[SUR R35UeeSnAff=f) aTruncate the GraphDB cluster log. The truncate log operation is used to free up storage space on all cluster nodes by clearing the current transaction log and removing cached recovery snapshots. Raises: ResponseFormatError: If the response is not in the expected format. BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. z/rest/cluster/truncate-logrrrWrXrYrZN r=rrcrhrirjrkrrlrr r;rjrprrs r> truncate_log#ClusterGroupManagement.truncate_logs '',,-IJH  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@  s+.CBCCc^SS0nURRSUS9nUR5 [R"UR 55$![ [[4an[SU35UeSnAff=f![RanURRnUS:Xa#[SURR35UeUS :Xa#[!S URR35UeUS :Xa#[#S URR35UeeSnAff=f) aTGet the GraphDB cluster configuration. Returns: Cluster configuration. Raises: ResponseFormatError: If the response is not in the expected format. UnauthorisedError: If the request is unauthorised. NotFoundError: If the cluster configuration is not found. InternalServerError: If the server returns an internal error. Acceptr/rest/cluster/configrz'Failed to parse cluster configuration: NrWrXz!Cluster configuration not found: r[r\)r=rbrcrrgrdKeyErrorrer^rrhrirjrkrrlr r r;rrjrprrs r> get_config!ClusterGroupManagement.get_configs: !34G''++,BG+TH  % % ' %// @@i4 )=cUC $$ \\--F}'/ 0A0A/BC3#7 8I8I7JK3)-cll.?.?-@A  5.B#AA>*A99A>>BD,BD''D,Nc [U[5(a[SU55(a [S5eSU4SU4SU4SU4SU4SU4S U4/n U H*upU cM [ U 5[ LdM[U S 35e S U0n UbX,S 'UbXrz7ClusterGroupManagement.create_config..s 26;dJtS)))er}nodes must be a list[str].election_min_timeoutelection_range_timeoutheartbeat_intervalmessage_size_kbverification_timeouttransaction_log_maximum_size_gbbatch_update_intervalN must be an int if provided.nodeselectionMinTimeoutelectionRangeTimeoutheartbeatInterval messageSizeKBverificationTimeouttransactionLogMaximumSizeGBbatchUpdateIntervalrrrrrrrWrXrYrZiz&Cluster configuration already exists: Precondition failed: )r_rfrretyperr=rrcrhrirjrkrrlrr rr )r;rrrrrrrr _int_fields field_namevaluerorrjrprrs r> create_config$ClusterGroupManagement.create_configskD< eT**c26;2// <==()=>)+AB%'9:"O4')=>24ST(*?@9K&1! $eC)?#zl2N$OPP&1*1%(8G#/0D,-%12H./!-/A+,*+:(#/1E-..:9X56$01F-.%'9:G'',,&-H  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3#? ) s&AC$C$0A3C$$G!8C$GG!cSnUbS[U5R50nSS0nUcURRSUS9nOURRSX2S9nUR 5 UR 5n[U[5(d [S 5e[S UR555(d [S 5e[R"[[[4U5$![ [4an[SU35UeSnAff=f![R anUR"R$nUS :Xa#['S UR"R(35UeUS:Xa#[+SUR"R(35UeUS:Xa#[-SUR"R(35UeeSnAff=f)aDelete the GraphDB cluster. By default, the cluster group cannot be deleted if one or more nodes are unreachable. Reachable here means that the nodes are not in status `NO_CONNECTION`, therefore there is an RPC connection to them. Parameter: force: When set to `True`, the cluster configuration will be deleted only on the reachable nodes and the response will always succeed. Returns: A dictionary where the node address is the key and the deletion status message is the value. Raises: ResponseFormatError: If the response is not in the expected format. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If one or more nodes in the group are not reachable and force is not set to `True`. NforcerrrrrrUz+Failed to parse cluster deletion response: zBFailed to parse cluster deletion response: expected a JSON object.c3t# UH.up[U[5=(a [U[5v M0 g7fr8r)rxkeyrs r>rz7ClusterGroupManagement.delete_config..Ss/"1JC3$?E3)??"1s68zKFailed to parse cluster deletion response: expected string keys and values.rWrXrYrZrr)ralowerr=rrcrdr^rerr_dictallitemstcastrhrirjrkrrlr r )r;rrUrrjrorprrs r> delete_config$ClusterGroupManagement.delete_config's()-  s5z//12F+ !34G~++22*G3 ++22*G3  % % ' "--/ gt,,)X")--/*a66$sCx.'2 2 * )A#G  $$ \\--F}'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>?  s>A D/C7?A7D7DDDDG 2BGG cSU4SU4SU4SU4SU4SU4SU4/nUH*upU cM [U 5[LdM[U S 35e 0n UbXS 'UbX+S 'UbX;S 'UbXKS 'UbX[S'UbXkS'UbX{S'SS0n URR SXS9n U R 5 [ R"U R55$![[[4an[SU35UeSnAff=f![RanURRnUS:Xa#[!SURR"35UeUS:Xa#[%SURR"35UeUS:Xa#['SURR"35UeUS:Xa#[)SURR"35UeeSnAff=f)aUpdate the GraphDB cluster configuration. If one of the cluster nodes is down or was not able to accept the new configuration, the operation will not be successful. A total consensus between the nodes is required. In case one or more of them cannot append the new configuration, it will be rejected by all of the nodes. Parameters: election_min_timeout: The minimum wait time in milliseconds for a heartbeat from a leader. election_range_timeout: The variable portion of each waiting period in milliseconds for a heartbeat. heartbeat_interval: The interval in milliseconds between each heartbeat that is sent to follower nodes by the leader. message_size_kb: The size of the data blocks, in kilobytes, transferred during data replication streaming through the RPC protocol. verification_timeout: The amount of time in milliseconds that a follower node would wait before attempting to verify the last committed entry when the first verification is unsuccessful. transaction_log_maximum_size_gb: Maximum size of the transaction log in GBs. The transaction log will be automatically truncated if it becomes bigger than this value. The minimum transaction log size is 1 GB. Setting it to a negative value will disable automatic transaction log truncation. batch_update_interval: The interval in milliseconds between requesting updates from the primary cluster. Used only when the cluster is in secondary mode. Returns: The updated cluster configuration. Raises: BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If one or more nodes in the group are not reachable. rrrrrrrNrrrrrrrrrrrrz/Failed to parse updated cluster configuration: rrrWrXrYrZrr)rrrer=patchrcrrgrdrr^rrhrirjrkrrlrr r )r;rrrrrrrrrrrorrjrprrs r> update_config$ClusterGroupManagement.update_configksRP$%9 : %'= > !#5 6  0 #%9 : .0O P $&; <5 "- J T%[%;:,.J KLL"-%'  +,@( ) ! -.D* +  )+=' (  &'6O $  +-A) * * 65T1 2 ,-B) */0 ''--&.H  % % ' %// @@i4 )EcUK $$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s7*C;+#CC8$C33C88C;;GB;G  Gcp[U[5(d [S5eU(d [S5eURR SSU0S9nUR 5 g![RanURRnUS:Xa#[SURR35UeUS:Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[S URR35UeeSnAff=f)aAdd primary cluster tag. Parameters: tag: The identifier tag to add to the primary cluster. Raises: TypeError: If tag is not a string. ValueError: If tag is an empty string. BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the cluster is not in a state to add a tag. tag must be a stringtag must be a non-empty string/rest/cluster/config/tagtagrdrrrWrXrYrZrrNr_rarer^r=rrcrhrirjrkrrlrr r )r;rrjrprrs r>add_tagClusterGroupManagement.add_tags=#s##23 3=> > '',,*%-H  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s,A!!D55B;D00D5c|[U[5(d [S5eU(d [S5eSS0nURR SSUSU0S9nUR 5 g![RanURRnUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[SURR35UeUS:Xa#[SURR35UeeSnAff=f)aRemove primary cluster tag. Parameters: tag: The identifier tag to remove from the primary cluster. Raises: TypeError: If tag is not a string. ValueError: If tag is an empty string. BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the cluster is not in a state to delete a tag. rrrrrrrrrrrWrXrYrZrrN)r_rarer^r=rrcrhrirjrkrrlrr r )r;rrrjrprrs r> delete_tag!ClusterGroupManagement.delete_tagsO#s##23 3=> >!#56 ''//.S\ 0H  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s.A''D;;B;D66D;c[U[5(d [S5eU(d [S5e[U[5(d [S5eU(d [S5eXS.nURR SUS9nUR 5 g![RanURRnUS:Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS:Xa#[SURR35UeeSnAff=f)aEnable cluster secondary mode. You can switch any healthy primary cluster to secondary mode by providing the RPC address of the primary cluster node that it will replicate and then declaring the tag used to identify it. Once you have switched a cluster to secondary mode, all of its current repositories and data will be removed and replaced with the data and state of the primary cluster. !!! Note You can enable the secondary cluster mode from any of the nodes of a cluster, not just the leader node. You can also use any of the healthy nodes of the primary cluster to connect to that cluster. !!! Warning Enabling the secondary mode will delete all data on the secondary cluster and replicate the state of the primary cluster. Parameters: primary_node: The RPC address of one of the healthy nodes of the primary cluster. tag: The identifier tag of the primary cluster. Raises: TypeError: If primary_node or tag is not a string. ValueError: If primary_node or tag is an empty string. BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the cluster is not in a state to enable secondary mode. zprimary_node must be a stringz'primary_node must be a non-empty stringrr) primaryNoder#/rest/cluster/config/secondary-moderrrrWrXrYrZrrNr)r; primary_noderrorjrprrs r>enable_secondary_mode,ClusterGroupManagement.enable_secondary_mode%si:,,,;< <FG G#s##23 3=> >".; '',,5G-H  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s**BE))B;E$$E)c URRS5nUR5 g ![RanUR R nUS:Xa#[SUR R35UeUS:Xa#[SUR R35UeUS:Xa#[SUR R35UeUS:Xa#[S UR R35UeeS nAff=f) aDisable cluster secondary mode. Once in secondary mode, you can disable secondary mode and then you will no longer be in that mode. Doing this will stop the pulling of updates from the primary cluster. Raises: BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the cluster is not in a state to disable secondary mode. rrrrWrXrYrZrrN) r=rrcrhrirjrkrrlrr r rs r>disable_secondary_mode-ClusterGroupManagement.disable_secondary_modecs ''../TUH  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s+.DB;C==Dc[U[5(a[SU55(a [S5eSU0nSS0nURR SX2S9nUR 5 g![RanURRnUS:Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS:Xa#[SURR35UeeSnAff=f)aAdd nodes to the GraphDB cluster. Parameters: nodes: List of node addresses to add to the cluster. Raises: TypeError: If nodes is not a list of strings. BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If one or more nodes in the group are not reachable. c3L# UHn[U[5(+v M g7fr8rrs r>rz3ClusterGroupManagement.add_nodes.. . 27$ 4% % %%r}rrrr/rest/cluster/config/noderrrrWrXrYrZrrN)r_rfrrer=rrcrhrirjrkrrlrr r )r;rrorrjrprrs r> add_nodes ClusterGroupManagement.add_nodessZ%&&#. 27. + + 89 9E"!#56 '',,+W-H  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s*A,,EB;D;;Ec[U[5(a[SU55(a [S5eSU0nURR SSUS9nUR 5 g![RanURRnUS:Xa#[SURR35UeUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[SURR35UeeSnAff=f)aRemove nodes from the GraphDB cluster. Parameters: nodes: List of node addresses to remove from the cluster. Raises: TypeError: If nodes is not a list of strings. BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If one or more nodes in the group are not reachable. c3L# UHn[U[5(+v M g7fr8rrs r>rz6ClusterGroupManagement.remove_nodes..rr}rrrr)rrrdrrrWrXrYrZrrN)r_rfrrer=rrcrhrirjrkrrlrr r )r;rrorjrprrs r> remove_nodes#ClusterGroupManagement.remove_nodessS%&&#. 27. + + 89 9E" ''///0H  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s+A))D==B;D88D=c[U[5(a[SU55(a [S5e[U[5(a[SU55(a [S5eX!S.nURR SUS9nUR 5 g![RanURRnUS:Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS:Xa#[SURR35UeeSnAff=f)aReplace nodes in the GraphDB cluster. Parameters: add_nodes: List of node addresses to add to the cluster. remove_nodes: List of node addresses to remove from the cluster. Raises: TypeError: If add_nodes or remove_nodes is not a list of strings. BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If one or more nodes in the group are not reachable. c3L# UHn[U[5(+v M g7fr8rrs r>rz7ClusterGroupManagement.replace_nodes..s 2 2;$ 4% % %)r}zadd_nodes must be a list[str].c3L# UHn[U[5(+v M g7fr8rrs r>rzrs 5 2>$ 4% % %,r}z!remove_nodes must be a list[str].) removeNodesaddNodesrrrrrWrXrYrZrrN)r_rfrrer=rrcrhrirjrkrrlrr r )r;rrrorjrprrs r> replace_nodes$ClusterGroupManagement.replace_nodess|)T**c2 2;2 / / <= =,--5 2>5 2 2 ?@ @".F ''--.IPW-XH  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3-+CLL,=,=+>? ! s4*BE33B;E..E3c^SS0nURRSUS9nUR5 [R"UR 55$![ [[4an[SU35UeSnAff=f![RanURRnUS:Xa#[SURR35UeUS :Xa#[!S URR35UeUS :Xa#[#S URR35UeeSnAff=f) aOGet the status of this GraphDB cluster node. Returns: NodeStatus: The status of this GraphDB cluster node. Raises: ResponseFormatError: If the response cannot be parsed. BadRequestError: If the request is invalid. NotFoundError: If the node status is not found. InternalServerError: If the internal server error. rrz/rest/cluster/node/statusrzFailed to parse node status: NrrrzNode status not found: r[r\)r=rbrcrrgrdrrer^rrhrirjrkrrlr r rs r> node_status"ClusterGroupManagement.node_statuss: !34G''+++W,H  % % ' !++HMMO<<i4 )3C59 $$ \\--F}%(9#,,:K:K9L&MNTWW3#-cll.?.?-@A3)-cll.?.?-@A  rcSS0nURRSUS9nUR5 UR5nUVs/sHn[R "U5PM sn$s snf![ [[4an[SU35UeSnAff=f![RanURRnUS:Xa#[SURR35UeUS :Xa#[!S URR35UeUS :Xa#[#S URR35UeeSnAff=f) aDGet the status of the GraphDB cluster. Returns: A list of node statuses for the cluster group. Raises: ResponseFormatError: If the response cannot be parsed. BadRequestError: If the request is invalid. NotFoundError: If the group status is not found. InternalServerError: If the internal server error. rrz/rest/cluster/group/statusrzFailed to parse group status: NrrrzGroup status not found: r[r\)r=rbrcrdrrgrrer^rrhrirjrkrrlr r )r;rrjdataitemrprrs r> group_status#ClusterGroupManagement.group_status.sQ !34G''++,g,H  % % ' }}?CDtt ,,T2tDDDi4 )4SE: $$ \\--F}%(9#,,:K:K9L&MNTWW3#.s||/@/@.AB3)-cll.?.?-@A  sG.BA- A(%A-(A--BBBBE-BD??ErCr=r)rNone)rr)NNNNNNN)r list[str]rrrrrrrrrrrrrrrr)r8)r bool | Nonerzdict[str, str])rrrrrrrrrrrrrrrr)rrarr))rrarrarr))rr*rr))rr*rr*rr))rr)rzlist[NodeStatus])rrrrrr?rr=rrrrrrrrr rrrr!r&rrrAr>rrzsX<(!!:$R,0-1)-&*+/6:,0^^)^!+ ^ ' ^ $ ^)^*4^ *^ ^@BL,0-1)-&*+/6:,0`(`!+`' ` $ ` ) `*4` *` `D(T,\<|B)V*X+Z$L%rArcp^\rSrSrSrS U4Sjjr\S Sj5rS S SjjrSSjr SSjr SSjr S r U=r $) RepositoryiVa8GraphDB Repository client. Overrides specific methods of the RDF4J Repository class and also provides GraphDB-only functionality (such as FGAC ACL management) made available through the GraphDB REST API. Parameters: identifier: The identifier of the repository. http_client: The httpx.Client instance. cn>[TU]X5 [URUR5Ulgr8)superr?r5r<r=_access_control_list_management)r;r<r= __class__s r>r?Repository.__init__as, 1/J OOT--0 ,rAcUR$r8r0rDs r>rqRepository.aclgs333rAc S[U50nURRSURS3US9nUR 5 g![ R a~nURRS:Xa[SURS35e[SURS URRS URR35eS nAff=f) aRepository health check. Parameters: timeout: A timeout parameter in seconds. If provided, the endpoint attempts to retrieve the repository within this timeout. If not, the passive check is performed. Returns: bool: True if the repository is healthy, otherwise an error is raised. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryNotHealthyError: If the repository is not healthy. passivez/repositories/z/healthrTTr Repository not found.z is not healthy. z - N) rar=rbr<rcrhrirjrkr r9rrl)r;timeoutrUrjrps r>healthRepository.healthks W.F''++  19&,H  % % '$$ ||''3.-!$"2"2!3;?,d..//@AYAY@ZZ]^a^j^j^o^o]pq   sAACA9CCc<SS0nURRSURS3US9nUR5 /nUR 5HLnSU;a)[ US[ 5(a[S0USD6US'UR[S0UD65 MN U$![[4an[SU35UeSnAff=f![RanURR S :Xa#[#S URR$35UeURR S :Xa#['S URR$35UeURR S :Xa#[)SURR$35UeeSnAff=f)aJGet server files available for import. Returns: A list of files available for import. Raises: ResponseFormatError: If the response format is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. rrrR/import/serverrparserSettingsFailed to parse response: NrWrXrYrZr[r\r)r=rbr<rcrdr_rrappendrr^rerrhrirjrkrrlr r )r;rrjresultr%rps r>get_server_import_files"Repository.get_server_import_filess" !34G''++%doo%6nE,H  % % ' W$MMOD'4/J-.552@2"#342-.MM."84"89,  * W),Fse*LMSVV W$$ ||''3.'/ 0A0A/BC))S0$,S\\->->,?@))S0)-cll.?.?-@A  s6rr Bad request: rWrXrYrZrzRequest is not found: N)r=rr<rrcrhrirjrkrrlrr r )r;server_import_bodyrrjrprrs r>import_server_import_file$Repository.import_server_import_files4 %'9:G'',,%doo%6nE'//1-H  % % '$$ \\--F}% cll6G6G5H&IJPSS3'/ 0A0A/BC3$,S\\->->,?@3#,S\\->->,?@ ! sA AD""B;DD"cSU0nURRSURS3US9nUR5 g ![R anUR RnUS:Xa#[SUR R35UeUS:Xa#[SUR R35UeUS :Xa#[S UR R35UeeS nAff=f) aCancel server file import operation. Parameters: name: The name of the file import to interrupt. Raises: BadRequestError: If the request is bad. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. namerRr>rTrrFrWrXrYrZN) r=rr<rcrhrirjrkrrlrr )r;rKrUrjrprrs r>cancel_server_import_file$Repository.cancel_server_import_files d^F''..%doo%6nE/H  % % '$$ \\--F}% cll6G6G5H&IJPSS3'/ 0A0A/BC3$,S\\->->,?@  sr-r-Vs< 44>.`$LrAr-c0^\rSrSrSrSU4SjjrSrU=r$)RepositoryManagerizGraphDB Repository Manager. This manager client overrides specific RDF4J RepositoryManager class methods to provide GraphDB-specific implementations. cb>[TU]U5n[URUR5$)agGet a repository by ID. !!! Note This performs a health check before returning the repository object. Parameters: repository_id: The identifier of the repository. Returns: Repository: The repository instance. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryNotHealthyError: If the repository is not healthy. )r/rbr-r<r=)r; repository_id_repor1s r>rbRepositoryManager.gets,  M*%**E,=,=>>rAr)rUrarr-)rrrrrrbrrPrQs@r>rSrSs ??rArScx\rSrSrSrS Sjr\S5r\S Sj5rSSjr \SSj5r SSjr SS jr S r g )MonitoringManagementiz& Monitor different GraphDB processes. cXlgr8rCrs r>r?MonitoringManagement.__init__ rrAcUR$r8rCrDs r>r= MonitoringManagement.http_client#rFrAcSS0nURRSUS9nUR5 [S0UR 5D6$![ [ 4an[SU35UeSnAff=f![RanURRnUS:Xa#[SURR35UeUS :Xa#[S URR35UeUS :Xa#[S URR35UeUS :Xa#[!SURR35UeeSnAff=f)anGet structures statistics. Returns: The structures statistics. Raises: ResponseFormatError: If the response format is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. ServiceUnavailableError: If the server is unavailable. rrz/rest/monitor/structuresrr@NrWrXrYrZr[r\Service is unavailable: r)r=rbrcr$rdr^rerrhrirjrkrrlr r rrs r> structuresMonitoringManagement.structures'sa !34G''++,FPW+XH  % % ' W+>hmmo>> * W),Fse*LMSVV W$$ \\--F}'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A3-.s||/@/@.AB % s5.A1A A.A))A..A11EB;EEcdSS0nURRSU3US9nUR5 [R"UR 55$![ [[4an[SU35UeSnAff=f![RanURRnUS:Xa#[SURR35UeUS :Xa#[!S URR35UeUS :Xa#[#S URR35UeeSnAff=f) aGet repository statistics. Parameters: repository_id: The identifier of the repository. Returns: RepositoryStatistics: The repository statistics. Raises: ResponseFormatError: If the response cannot be parsed. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. rrz/rest/monitor/repository/rr@NrWrXrYrZr[r\)r=rbrcr!rgrdr^rerrrhrirjrkrrlr r )r;rUrrjrprrs r>get_repo_stats#MonitoringManagement.get_repo_statsQsD !34G''+++M?;W,H  % % ' W+55hmmoFF 84 W),Fse*LMSVV W$$ \\--F}'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A  s51B#AB-A<<BBD/BD**D/c^SS0nURRSUS9nUR5 [R"UR 55$![ [[4an[SU35UeSnAff=f![RanURRnUS:Xa#[SURR35UeUS :Xa#[!S URR35UeUS :Xa#[#S URR35UeeSnAff=f) aXGet all infrastructure statistics. Returns: InfrastructureStatistics: The infrastructure statistics. Raises: ResponseFormatError: If the response cannot be parsed. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. rrz/rest/monitor/infrastructurerr@NrWrXrYrZr[r\)r=rbrcrrgrdr^rerrrhrirjrkrrlr r rs r>infrastructure#MonitoringManagement.infrastructurezs= !34G''++.,H  % % ' W/99(--/JJ 84 W),Fse*LMSVV W$$ \\--F}'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A  rc&SS0nURRSUS9nUR5 UR$![R anUR RnUS:Xa#[SUR R35UeUS:Xa#[SUR R35UeUS :Xa#[S UR R35UeUS :Xa#[S UR R35UeeS nAff=f)akGet cluster statistics. !!! Note This endpoint is only available in GraphDB EE. Returns: Prometheus-style metrics. Raises: UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. ServiceUnavailableError: If the server is unavailable. rz text/plainz/rest/monitor/clusterrrWrXrYrZr[r\r_r`N) r=rbrcrlrhrirjrkrr r rrs r>clusterMonitoringManagement.clusters# .G''++,CW+UH  % % '== $$ \\--F}'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A3-.s||/@/@.AB % s9<DB;D  DcSS0nURRSUS9nUR5 UR5nU(dg[R "U5$![ [[4an[SU35UeSnAff=f![RanURRnUS:Xa#[SURR35UeUS :Xa#[!S URR35UeUS :Xa#[#S URR35UeUS :Xa#[%SURR35UeeSnAff=f)aTrack backup operations. Returns: On-going backup operations or `None` if no backup is in progress. Raises: ResponseFormatError: If the response cannot be parsed. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. ServiceUnavailableError: If the server is unavailable. rrz/rest/monitor/backuprNr@rWrXrYrZr[r\r_r`)r=rbrcrdrrgr^rerrrhrirjrkrrlr r r)r;rrjr$rprrs r>backupMonitoringManagement.backupsp !34G''++,BG+TH  % % ' W}}*44T:: 84 W),Fse*LMSVV W$$ \\--F}'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A3-.s||/@/@.AB % s;.B A AB4BBB EB;EErCNr()rr$)rUra)rr)rra)rzBackupOperationBean | None)rrrrrr?rr=rardrgrjrmrrrAr>rYrYs[(!!''R'R$$L&P*rArYcV\rSrSrSrSSjr\S5rSSSjjrSSSjjr \ RSSS.SS jjj5r \ RSSS jj5r SSS.SS jjjr SSS jjr S rg)RecoveryManagementiz% GraphDB Recovery Management client. cXlgr8rCrs r>r?RecoveryManagement.__init__rrAcUR$r8rCrDs r>r=RecoveryManagement.http_clientrFrANc6^^ UbB[U[5(d [S5e[SU55(d [S5e[U[5(dUb [S5e[U[5(dUb [S5e0nUbX%S'UbX5S'UbXES 'S[ R "U5S 4m SU U4S jjn[U[[[45(a[U5nU"S US 45 g[US5(ah[U[[R45(dC[R"[R [U5n[#US 5n U"XS 45 g[U[[R45(ac[$R&"U5R)5n [+U S5n U R,=(d [#U S 5n U"XS 45 SSS5 g[S5e!,(df  g=f)aRestore GraphDB instance from a backup archive. Parameters: backup: Backup archive content as bytes/bytes-like, a binary file-like object, or a filesystem path to a `.tar` produced by [`backup`][rdflib.contrib.graphdb.client.RecoveryManagement.backup]. repositories: List of repositories to restore. If `None` (default), the parameter is omitted and all repositories found in the backup are restored. If an empty list (`[]`) is provided, no repositories from the backup are restored. restore_system_data: Whether to restore system data (users, saved queries, visual graphs, etc.). If omitted, GraphDB defaults to `false`. If `true` and no system data exists in the backup, GraphDB returns an error. remove_stale_repositories: Whether to remove repositories on the target instance that are not restored from the backup. If omitted, GraphDB defaults to `false`. Raises: ValueError: If parameters are invalid, or if backup is not a supported type. BadRequestError: If the request is bad. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. N#repositories must be a list or Nonec3B# UHn[U[5v M g7fr8rrxrs r>rz-RecoveryManagement.restore..$@TRRSST4SU4/S9nUR5 g![RanUR R nUS:Xa#[SUR R35UeUS:Xa#[SUR R35UeUS :Xa#[S UR R35UeUeSnAff=f) Nz/rest/recovery/restorerUfile)filesrrFrWrXrYrZr) file_partrjrprr params_partr;s r>_post)RecoveryManagement.restore.._post;s ++00,$k2VY4GH1))+(( 11S=)M#,,:K:K9L*MNTWWs]+3CLL4E4E3FGs](01B1B0CD  s04C BCC graphdb-backup.tarzapplication/x-tarreadrbzPbackup must be bytes/bytes-like, a binary file-like object, or a filesystem path)r FileContentrr))r_rfr^rrOrddumpsbytes bytearray memoryviewhasattrraosPathLikerrIOr.pathlibPath expanduseropenrK) r;rmrrestore_system_dataremove_stale_repositoriesrorcontentfile_objfilename backup_pathfrs ` @r>restoreRecoveryManagement.restores>  #lD11 !FGG@<@@@ !IJJ.55#/IJ J4d;;)5OP P$&  #&2N #  *+>' ( $ 01J- .$($**W*=?Q#R   * fui< = =FmG '2EF G  66 " ":fsBKK>P+Q+Qvvadd5k62H28=QRH 8':; <  fsBKK0 1 1!,,v.99;Kk4(A&++/J+0x$789 )  ^  )( s *H  Hc^^ [U[5(aU(d [S5eUbB[U[5(d [S5e[ SU55(d [S5e[U[ 5(dUb [S5e[U[ 5(dUb [S5e0nUbX&S'UbX6S 'UbXFS 'XS 'S[ R"U5S 4m SU U4S jjnUc U"S5 g[U[[[45(a[U5nU"SUS45 g[US5(ah[U[[R45(dC[R"[R [U5n [#U S5n U"XS45 g[U[[R45(ac[$R&"U5R)5n [+U S5n U R,=(d [#U S5n U"XS45 SSS5 g[S5e!,(df  g=f)aRestore GraphDB instance from a cloud backup archive. Parameters: bucket_uri: Cloud bucket URI including provider-specific parameters (required). repositories: List of repositories to restore. If `None` (default), the parameter is omitted and all repositories found in the backup are restored. If an empty list (`[]`) is provided, no repositories from the backup are restored. restore_system_data: Whether to restore system data (users, saved queries, visual graphs, etc.). If omitted, GraphDB defaults to `false`. If `true` and no system data exists in the backup, GraphDB returns an error. remove_stale_repositories: Whether to remove repositories on the target instance that are not restored from the backup. If omitted, GraphDB defaults to `false`. authentication_file: Optional credential file content as bytes/bytes-like, a binary file-like object, or a filesystem path. Raises: ValueError: If parameters are invalid, or authentication_file is not a supported type. BadRequestError: If the request is bad. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. %bucket_uri must be a non-empty stringNrvc3B# UHn[U[5v M g7fr8rrxs r>rz3RecoveryManagement.cloud_restore..r{r|r}r~rrrr bucketUrirc>ST4/nUbURSU45 TRRSSS0US9nUR5 g![R anUR RnUS:Xa#[SUR R35UeUS :Xa#[S UR R35UeUS :Xa#[S UR R35UeUeSnAff=f) NrUauthenticationFilez/rest/recovery/cloud-restorerrrrrrFrWrXrYrZ rAr=rrcrhrirjrkrrlrr authentication_partrrjrprrrr;s r>r/RecoveryManagement.cloud_restore.._posts5={4K3LE". 24GHI ++002%'9:1 ))+(( 11S=)M#,,:K:K9L*MNTWWs]+3CLL4E4E3FGs](01B1B0CD  -A C8 BC33C8authentication-fileapplication/octet-streamrr]authentication_file must be bytes/bytes-like, a binary file-like object, or a filesystem pathrzFileContent | Nonerr)r_rar^rfrrOrdrrrrrrrrrrr.rrrrrK)r; bucket_urirrrauthentication_filerorrrr auth_pathrrs` @r> cloud_restore RecoveryManagement.cloud_restorehs,D*c***DE E  #lD11 !FGG@<@@@ !IJJ.55#/IJ J4d;;)5OP P$&  #&2N #  *+>' ( $ 01J- .) $($**W*=?Q#R   2  & $K  )E9j+I J J/0G ('3MN O  & / / #r{{!39 9 vvadd5k+>?H28=RSH 8'AB C  )C+= > > %89DDFIi&!$>>-H,.x$>?@ '  k  '& s *I I)destcgr8rr;rbackup_system_datars r>rmRecoveryManagement.backupsrAcgr8rrs r>rmrsrAcUbB[U[5(d [S5e[SU55(d [S5e[U[5(dUb [S5e0nUbXS'UbX$S'SSjnUc7UR R S US 9nUR5 UR$[R"U5R5R5nUR RS S US 9nUR5 UR!5(a8UR"R%S S 5n ['U 5n U (aX- nOUS- nUR)UR*S-5n [-U S5n UR/5Hn U R1U 5 M SSS5 U R3U5 SSS5 U$![RanU"U5 SnAgSnAff=f!,(df  NR=f!,(df  U$=f![RanU"U5 SnAgSnAff=f)aCreate a new backup of GraphDB instance. The backup is returned as a tar archive containing repository data and optionally system data (user accounts, saved queries, visual graphs, etc.). Parameters: repositories: List of repositories to be backed up, specified by their repository identifiers. If `None`, all repositories will be included in the backup. backup_system_data: Determines whether user account data such as user accounts, saved queries, or visual graphs, among others, should be included in the backup. dest: Destination path to save the backup archive. If `None`, the backup content is returned as bytes (suitable for small backups). If a directory path is provided, the filename from the response Content-Disposition header is used (e.g., backup-2026-01-16-10-30-00.tar). If a file path is provided, that exact path is used. The response is streamed directly to disk (recommended for large backups). Returns: bytes: If `dest` is `None`, returns the backup archive as bytes. Path: If `dest` is provided, returns the resolved `pathlib.Path` where the backup was saved. Raises: ValueError: If repositories is not a list or None, or if backup_system_data is not a bool or None. BadRequestError: If the request is bad. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. OSError: If the destination path cannot be written to. Nrvc3B# UHn[U[5v M g7fr8rrxs r>rz,RecoveryManagement.backup..r{r|r}!backup_system_data must be a boolrbackupSystemDatac(URRnUS:Xa#[SURR35UeUS:Xa#[ SURR35UeUS:Xa#[ SURR35UeUe)NrrFrWrXrYrZ)rjrkrrlrr )rprrs r>_handle_http_error5RecoveryManagement.backup.._handle_http_error"s\\--F}% cll6G6G5H&IJPSS3'/ 0A0A/BC3$,S\\->->,?@IrAz/rest/recovery/backuprPOSTzContent-Dispositionrz.partialwb)rpzhttpx.HTTPStatusErrorrz t.NoReturn)r_rfr^rrOr=rrcrrhrirrrresolvestreamis_dirrrbr- with_suffixsuffixr iter_byteswritereplace)r;rrrrorrjrp dest_pathcontent_dispositionrtmp_pathrchunks r>rmrs?F  #lD11 !FGG@<@@@ !IJJ,d338J8V@A A$&  #&2N #  )*<& '  < (++001Hw0W))+'''  T*557??AI (%%,,3'---/!'')).6.>.>.B.B12/+$M/$$(1(rz2RecoveryManagement.cloud_backup..|r{r|r}rrrrrc>ST4/nUbURSU45 TRRSSS0US9nUR5 g![R anUR RnUS:Xa#[SUR R35UeUS :Xa#[S UR R35UeUS :Xa#[S UR R35UeUeSnAff=f) NrUrz/rest/recovery/cloud-backuprrrrrFrWrXrYrZrrs r>r.RecoveryManagement.cloud_backup.._posts5={4K3LE". 24GHI ++001%'9:1 ))+(( 11S=)M#,,:K:K9L*MNTWWs]+3CLL4E4E3FGs](01B1B0CD  rrrrrrrr) r;rrrrrorrrrrrrs ` @r> cloud_backupRecoveryManagement.cloud_backup[s6*c***DE E  #lD11 !FGG@<@@@ !IJJ,d338J8V@A A$&  #&2N #  )*<& ') $($**W*=?Q#R   2  & $K  )E9j+I J J/0G ('3MN O  & / / #r{{!39 9 vvadd5k+>?H28=RSH 8'AB C  )C+= > > %89DDFIi&!$>>-H,.x$>?@ '  k  '& s *H H%rCr()NNN) rmzEbytes | bytearray | memoryview | t.IO[bytes] | str | os.PathLike[str]rlist[str] | Nonerr+rr+rr))NNNN) rrarrrr+rr+rLbytes | bytearray | memoryview | t.IO[bytes] | str | os.PathLike[str] | Nonerr)NN)rrrr+rr)rr)rrrr+rzstr | os.PathLike[str]rz pathlib.Path)rrrr+rzstr | os.PathLike[str] | Nonerzbytes | pathlib.Path) rrarrrr+rrrr))rrrrrr?rr=rrroverloadrmrrrrAr>rprps(!! *.+/15 d Ud 'd ) d $/ d  d R*.+/15 u u 'u ) u $/ u  Yu  u nZZ*.*.  &(    ZZ*.*.&( %   *.*.h( /3 h(&h((h( , h(  h(Z*.*. e e 'e ( e Y e  e e rArpc\rSrSrSrSSjrSSSjjrSSSjjr\S5r \ RSSSjj5r \ RSS S jj5r \ RSS!S jj5r \ RSS"S jj5r SS#S jjr S$S jr SS%SjjrSS&SjjrSS'Sjjr\ RSSS.S(Sjj5r\ RSSSS.S)Sjj5r\ RSS.S*Sjj5rSSSSS.S+SjjrSrg),RepositoryManagementizGraphDB Repository Management client. The functionality provided by this management client accepts an optional location parameter to operate on external GraphDB locations. cXlgr8rCrs r>r?RepositoryManagement.__init__rrANc0nUbXS'URRSUS9nUR5 UR5Vs/sHn[R "U5PM sn$s snf![ [4an[SU35UeSnAff=f![RaCnURRS:Xa#[SURR35UeeSnAff=f)aList all repositories. Parameters: location: The location of the repositories. Returns: list[GraphDBRepository]: List of GraphDB repositories. Raises: InternalServerError: If the server returns an internal error. ResponseFormatError: If the response cannot be parsed. Nlocation/rest/repositoriesrTrVr[r\)r=rbrcrdrrgr^rerrhrirjrkr rl)r;rrUrjreporps r>rfRepositoryManagement.lists  !):  ''++,@+PH  % % ' FNmmoVod)33D9oVVV * )8> $$ ||''3.)-cll.?.?-@A   sF*BA0 A+(A0+A00BBBBC.+>C))C.c0nUbX$S'SSjn[U[5(a/nUbf[U[R5(a[ UR 55nO [ U5n[ SU55(a [S5eSSUS44/nUHupURX"X545 M URRS UUS 9n O:Ub [S 5eURRS S S 0UR5US9n U R5 g![Ran U RR n U S:Xa#[#SU RR$35U eU S:Xa#['SU RR$35U eU S:Xa#[)SU RR$35U eU S:Xa#[+SU RR$35U eeSn A ff=f)aCreate a new repository. Parameters: config: Repository configuration. When a `RepositoryConfigBeanCreate` is provided, the request is sent as JSON. When a string is provided, it is treated as Turtle content and sent as multipart/form-data part `config` (required by GraphDB) with the content type `text/turtle`. location: Optional repository location (query param `location`). files: Optional extra multipart parts for GraphDB-specific files (e.g. `obdaFile`, `owlFile`, `propertiesFile`, `constraintFile`, `dbMetadataFile`, `lensesFile`). Keys must be the form part names; values may be file content or httpx-style file tuples. Ignored when `config` is a dataclass (JSON payload). Raises: BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. Nrc[U[5(a2[U5S:XaUup#U=(d UU4$Uup#nU=(d UX44$X4$)N)r_tuplelen)fieldrrr content_types r>_normalize_file_content._normalize_file_content sT%''u:?(-%H$-w7727/< )E7AA> !rAc30# UH upUS:Hv M g7f)configNr)rxr_s r>rz.RepositoryManagement.create..sI[5H,[szQDo not pass a 'config' multipart part via files; use the config argument instead.rz config.ttl text/turtler)rUrzEAdditional files can only be provided when config is a Turtle string.rrrrrrWrXrYrZr[r\)rrarrrr)r_rarMappingrfrrr^rAr=rrrcrhrirjrkrrlrr r ) r;rrrrUr extra_partsmultipart_filesrrrjrprrs r>createRepositoryManagement.creates#4  !):  "7 &#&&=? $!%33&*5;;=&9 &*5k I[III(o  fmDEB'2NE#** 7 GH'2  ++00(!)1 $$_ ++00(+-?@)! 1  % % '$$ \\--F}%(9#,,:K:K9L&MNTWW3'/ 0A0A/BC3$,S\\->->,?@3)-cll.?.?-@A ! sDD""G66B;G11G6cUR$r8rCrDs r>r= RepositoryManagement.http_clientNrFrAcgr8rr;rUrrs r>rbRepositoryManagement.getR #rAcgr8rrs r>rbrZrrAcgr8rrs r>rbrbs rAcgr8rrs r>rbrjs (+rAcUcSnUS;a[SUS35eSU0n0nUbX5S'URRSU3XES 9nUR5 US:Xa[ S0UR 5D6$US :Xa#[5RURS S 9$[SUS35e![[ 4an[S 5UeSnAff=f![an[SU35UeSnAff=f![RaVnURRS:Xa[!SUS35UeURRS:Xa [#S5UeeSnAff=f)aGet a repository's configuration. Parameters: repository_id: The identifier of the repository. content_type: The content type of the response. Can be `application/json` or `text/turtle`. Defaults to `application/json`. location: The location of the repository. Returns: RepositoryConfigBean: The repository configuration. Graph: The repository configuration in RDF. Raises: BadRequestError: If the content type is not supported. ResponseFormatError: If the response cannot be parsed. RepositoryNotFoundError: If the repository is not found. InternalServerError: If the server returns an internal error. Nr)rrzUnsupported content type: .rrrRr!Failed to parse GraphDB response.rturtle)r$formatzError parsing RDF: zUnhandled content type: rr8r9r[Internal server error.r)r^r=rbrcrrdrerrparserl Exceptionrhrirjrkr r )r;rUrrrrUrjrps r>rbrrs0  -L B B9,qIJ J\*  !):  ''++%m_5w,H  % % '11/B(--/BB .T 7==hmmH=MM!#;L>!KLL#I.-;!T-0CC5.IJPSST$$ ||''3.-!- <))S0)*BCL  s`3C3B.6C3=!CC3.C> C  CC3 C0C++C00C33EAEEcSS0nURRSU3UUR5S9nUR5 g ![R anUR RS:Xa#[SUR R35UeUR RS:Xa#[SUR R35UeUR RS :Xa#[S UR R35UeUR RS :Xa#[S UR R35UeeS nAff=f)arEdit a repository's configuration. Parameters: repository_id: The identifier of the repository. config: The repository configuration. Raises: BadRequestError: If the request is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. rrrRrrrrWrXrYrZr[r\N) r=rrrcrhrirjrkrrlrr r )r;rUrrrjrps r>editRepositoryManagement.editsM .  ''++%m_5^^%,H  % % '$$ ||''3.%(9#,,:K:K9L&MNTWW))S0'/ 0A0A/BC))S0$,S\\->->,?@))S0)-cll.?.?-@A  srRepositoryManagement.deletesH  !):  ''..%m_5f/H  % % '$$ ||''3.%(9#,,:K:K9L&MNTWW))S0'/ 0A0A/BC))S0$,S\\->->,?@))S0)-cll.?.?-@A  s-9E C5EEc0nUb[U5R5US'UbX4S'URRSUS3US9nUR 5 UR $![ Ra|nURRS:Xa [S5UeURRS :Xa [S 5UeURRS :Xa[S US 35UeeSnAff=f)aRestart a repository. Parameters: repository_id: The identifier of the repository. sync: Whether to sync the repository. location: The location of the repository. Returns: str: The response text. Raises: UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. RepositoryNotFoundError: If the repository is not found. NsyncrrRz/restartrTrWRequest is unauthorised.rYRequest is forbidden.rr8r9) rarr=rrcrlrhrirjrkrr r )r;rUrrrUrjrps r>restartRepositoryManagement.restarts$   Y__.F6N  !):  '',,%m_H=f-H  % % '== $$ ||''3.'(BCL))S0$%<=3F))S0-!- <  s9A$$C48A7C//C4c0nU(aX#S'URRSUS3US9nUR5 [S 0UR 5D6$![ [ 4an[S5UeSnAff=f![RaCnURRS:Xa#[SURR35UeeSnAff=f) a Get repository size. Parameters: repository_id: The identifier of the repository. location: The location of the repository. Raises: ResponseFormatError: If the response cannot be parsed. InternalServerError: If the server returns an internal error. rrRz/sizerTr Nr[r\r)r=rbrcr rdr^rerrhrirjrkr rlrs r>sizeRepositoryManagement.size% s !):  ''++%m_E:6,H  % % ' X)C  C)rshapes_repository_idcgr8r)r;rUrrrrs r>validateRepositoryManagement.validateE rA)rrrcgr8r)r;rUrrrrs r>r r!P r"rA)rcgr8r)r;rUrrs r>r r![ srA)rrrrc0nUbXFS'Ub^Ub [S5eUb [S5eSS0nURRSUSU3UUS 9nUR5 UR$Uc [S5e[US5=(a [U[5(+n U (a}SS0nS[R "[R"[$U5U=(d S4n SU 0n URRSUS3UUU S9nUR5 UR$U(d [S5eUSS.nURRSUS3UUUS9nUR5 UR$![ R ain U RRn U S :Xa [S 5U eU S :Xa [S 5U eU S:Xa#[SU RR35U eeSn A ff=f![ R ain U RRn U S :Xa [S 5U eU S :Xa [S 5U eU S:Xa#[SU RR35U eeSn A ff=f![ R ain U RRn U S :Xa [S 5U eU S :Xa [S 5U eU S:Xa#[SU RR35U eeSn A ff=f)aValidate repository data using SHACL shapes. Parameters: repository_id: The identifier of the repository. content_type: Content type of the request body (required for text payloads). content: SHACL shapes payload; string for text-based validation or file-like (binary) object for multipart validation. location: Optional repository location. shapes_repository_id: ID of repository containing SHACL shapes; when provided, no content is sent and shapes are fetched from that repository. Returns: str: Validation report as RDF Turtle. Raises: UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. InternalServerError: If the server returns an internal error. Nrz>content must not be provided when shapes_repository_id is set.zCcontent_type must not be provided when shapes_repository_id is set.rrrRz/validate/repository/)rrUrrWrrYrr[r\zcontent must be provided.rz shapes.ttlrz/validate/file)rrUrrz2content_type must be provided for text validation.rrz/validate/text)rrUrr)r^r=rrcrlrhrirjrkrr r rr_rarrrr)r;rUrrrrrUrrjrprr is_file_likerrs r>r r!d sR:  !):   +" T' Y /G ++00-m_rrsG (F $"& _0__ _B!!ZZ $ ##4# #  ##ZZ"# ### #  ##ZZ $ /   ZZ $ +++ + & ++$(# ;;!; ; & ;z&P$NTX& &(3&FP& &R:> ,6 @ZZ $%)     # ZZ $(#%)  !   # ZZ $ "    $(,0#+/xx! x * x  x)x xxrArc~\rSrSrSrS Sjr\S5r\S Sj5r\RS Sj5rSr SSjr S r g )SecurityManagementi z#GraphDB Security Management client.cXlgr8rCrs r>r?SecurityManagement.__init__ rrAcUR$r8rCrDs r>r=SecurityManagement.http_client rFrAcSS0nURRSUS9nUR5 UR5n[ U[ 5(d [ S5eU$![[4an[ SU35UeSnAff=f![RaCnURRS:Xa#[S URR35UeeSnAff=f) zCheck if security is enabled. Returns: bool: True if security is enabled, False otherwise. Raises: ResponseFormatError: If the response format is invalid. InternalServerError: If the server returns an internal error. rr/rest/securityrzResponse is not a boolean.rVNr[r\)r=rbrcrdr_rOrr^rerhrirjrkr rl)r;rrjrrps r>enabledSecurityManagement.enabled s !34G''++, $$ ||''3.)-cll.?.?-@A   s4.B 1A##B3BBB C!>CC!c[U[5(d [S5eSSS.nURR SX!S9nUR 5 g ![ RaxnURRS:Xa [S5UeURRS:Xa [S 5UeURRS :Xa [S 5UeeS nAff=f) a!Enable or disable security. Parameters: value: The value to set. Raises: TypeError: If the value is not a boolean. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the precondition is failed. zValue must be a boolean.rr&r0rrWrrYrrPrecondition failed.N) r_rOrer=rrcrhrirjrkrr r )r;rrrjrps r>r1r2 s%&&67 7 '9EWXG'',, '-H  % % '$$ ||''3.'(BCL))S0$%<=3F))S0-.DE3N  s/AC&A3CCcSS0nURRSUS9nUR5 [S 0UR 5D6$![ [ 4an[SU35UeSnAff=f![RaCnURRS:Xa#[SURR35UeeSnAff=f) z Check if free access is enabled. Returns: FreeAccessSettings: The free access settings. Raises: ResponseFormatError: If the response format is invalid. InternalServerError: If the server returns an internal error. rr/rest/security/free-accessrrVNr[r\r)r=rbrcrrdr^rerrhrirjrkr rl)r;rrjrps r>get_free_access_details*SecurityManagement.get_free_access_details& s !34G''++,g,H  % % ' ) $$ ||''3.)-cll.?.?-@A   s4.A1A A.A))A..A11C>CCcSSS.nURRSUUR5S9nUR5 g ![R axnUR RS:Xa [S5UeUR RS:Xa [S5UeUR RS :Xa [S 5UeeS nAff=f) a Enable or disable free access. Parameters: free_access_settings: The free access settings. Raises: UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the precondition is failed. rr&r6rrWrrYrrr4N) r=rrrcrhrirjrkrr r )r;free_access_settingsrrjrps r>set_free_access_details*SecurityManagement.set_free_access_detailsD s '9EWXG'',,,)113-H  % % '$$ ||''3.'(BCL))S0$%<=3F))S0-.DE3N  s>AC A3CC rCNr()rrO)rrO)r:r) rrrrrr?rr=r1setterr7r;rrrAr>r*r* sT-(!!< ^^:<rAr*cx\rSrSrSrSSjr\S5rSSjrSSjr SSjr SSjr SS jr SS jr SS jrS rg )UserManagementib zGraphDB User Management client.cXlgr8rCrs r>r?UserManagement.__init__e rrAcUR$r8rCrDs r>r=UserManagement.http_clienth rFrAcSS0nURRSUS9nUR5 UR5Vs/sHn[ S0UD6PM sn$s snf![ [ 4an[SU35UeSnAff=f![RanURRS:Xa [S5UeURRS :Xa [S 5UeURRS :Xa [S 5UeURRS :Xa#[SURR 35UeeSnAff=f)aZ Get all users. Returns: A list of users. Raises: ResponseFormatError: If the response format is invalid. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the precondition is failed. InternalServerError: If the server returns an internal error. rrz/rest/security/usersrrVNrWrrYrrr4r[r\r)r=rbrcrdr&r^rerrhrirjrkrr r r rl)r;rrjuserrps r>rfUserManagement.listl sG/0 ''++,BG+TH  % % ' 19A t AAA * )8> $$ ||''3.'(BCL))S0$%<=3F))S0-.DE3N))S0)-cll.?.?-@A  sG*BA AA A B0A??BBEB0E  Ec4SS0nURRSU3US9nUR5 [S 0UR 5D6$![ [ 4an[SU35UeSnAff=f![RanURRS:Xa [S5UeURRS :Xa [S 5UeURRS :Xa#[S URR35UeeSnAff=f)aE Get a user. Parameters: username: The username of the user. Returns: User: The user. Raises: ResponseFormatError: If the response format is invalid. ForbiddenError: If the request is forbidden. NotFoundError: If the user is not found. InternalServerError: If the server returns an internal error. rr/rest/security/users/rrVNrYrrUser not found.r[r\r)r=rbrcr&rdr^rerrhrirjrkr r r rl)r;usernamerrjrps r>rbUserManagement.get s"  !34G''++'z2G,H  % % ' .hmmo.. * )8> $$ ||''3.$%<=3F))S0#$56C?))S0)-cll.?.?-@A  s51A4A A1A,,A11A44DB DDc"[U[5(d [S5e[U[5(d [S5eSS0nURR SU3X2R 5S9nUR5 g ![RaxnURRS:Xa [S5UeURRS :Xa [S 5UeURRS :Xa [S 5UeeS nAff=f)aV Overwrite a user. Parameters: username: The username of the user. user: The user to overwrite. Raises: TypeError: if username is not a string or user is not an instance of User. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. NotFoundError: If the user is not found. Username must be a string.z!User must be an instance of User.rrrHrrWrrYrrrIN)r_rarer&r=rrrcrhrirjrkrr r r;rJrErrjrps r> overwriteUserManagement.overwrite s(C((89 9$%%?@ @ %'9:G''++'z2G,,.,H  % % '$$ ||''3.'(BCL))S0$%<=3F))S0#$56C?  s?BDA3D  DcP[U[5(d [S5e[U[5(d [S5eSS0nURR SU3X2R 5S9nUR5 g ![RanURRS:Xa#[SURR35UeURRS :Xa [S 5UeURRS :Xa [S 5UeeS nAff=f)aU Create a user. Parameters: username: The username of the user. user: The user to create. Raises: TypeError: if username is not a string or user is not an instance of UserCreate. BadRequestError: If the request is bad. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. rMz'User must be an instance of UserCreate.rrrHrr Bad request. rWrrYrN)r_rarer'r=rrrcrhrirjrkrrlrr rNs r>rUserManagement.create s (C((89 9$ ++EF F %'9:G'',,'z2G,,.-H  % % '$$ ||''3.% cll6G6G5H&IJPSS))S0'(BCL))S0$%<=3F  s?BD%B D  D%c:[U[5(d [S5eURR SU35nUR 5 g ![ RanURRS:Xa#[SURR35UeURRS:Xa [S5UeURRS:Xa [S5UeURRS :Xa [S 5UeeS nAff=f) a; Delete a user. Parameters: username: The username of the user. Raises: TypeError: if username is not a string. BadRequestError: If the request is bad. UnauthorisedError: If the request is unauthorised. ForbiddenError: If the request is forbidden. NotFoundError: If the user is not found. rMrHrrRrWrrYrrrIN)r_rarer=rrcrhrirjrkrrlrr r r;rJrjrps r>rUserManagement.delete s(C((89 9 ''..1Fxj/QRH  % % '$$ ||''3.% cll6G6G5H&IJPSS))S0'(BCL))S0$%<=3F))S0#$56C?  s.AD%B0DDc[U[5(d [S5e[U[[45(d [S5e[U[5(aUR 5nOUnSS0nUR RSU3XCS9nUR5 g ![RaRnURRS:Xa [S5UeURRS :Xa [S 5UeeS nAff=f) a Update a user. !!! Note Certain user fields are not updatable using PATCH. For example, at the time of writing, `grantedAuthorities` are not updatable, but `appSettings` are. Parameters: username: The username of the user. user: The user data to update, either as a UserUpdate instance or a dict. Raises: TypeError: if username is not a string or user is not an instance of UserUpdate or dict. ForbiddenError: If the request is forbidden. PreconditionFailedError: If the precondition is failed. rMz/User must be an instance of UserUpdate or dict.rrrHrrYrrr4N)r_rarer(rrr=rrcrhrirjrkr r )r;rJrE user_datarrjrps r>updateUserManagement.update s"(C((89 9$T 233MN N dJ ' ' II %'9:G''--'z2G.H  % % '$$ ||''3.$%<=3F))S0-.DE3N   s01B""D6A DDc[U[5(d [S5eURR SUS35nUR 5 UR 5$![RaxnURRS:Xa [S5UeURRS:Xa [S5UeURRS:Xa [S 5UeeS nAff=f) a` Retrieve custom roles associated with the user. Parameters: username: The username of the user. Returns: list[str]: The custom roles for the user. Raises: TypeError: if username is not a string. ForbiddenError: If the request is forbidden. NotFoundError: If the user is not found. InternalServerError: If the request fails. rMrHz /custom-rolesrYrrrIr[r N)r_rarer=rbrcrdrhrirjrkr r r rUs r> custom_rolesUserManagement.custom_rolesC s (C((89 9 ''++'z?H  % % '==? "$$ ||''3.$%<=3F))S0#$56C?))S0)*BCL  s>A!!C-5A3C((C-rCNr()rz list[User])rJrarr&)rJrarEr&rr))rJrarEr'rr))rJrarr))rJrarEzUserUpdate | dict[str, t.Any]rr))rJrarz t.List[str])rrrrrr?rr=rfrbrOrrrYr\rrrAr>r?r?b sF)(!!#J%N D D>&P rAr?c^\rSrSrSrS SU4Sjjjr\SSj5r\SSj5r\SSj5r \SSj5r \SSj5r \SS j5r \SS j5r SS jrS rU=r$) GraphDBClientif afGraphDB Client This client and its inner management objects perform HTTP requests via httpx and may raise httpx-specific exceptions. Errors documented by GraphDB in its OpenAPI specification are mapped to specific exceptions in this library where applicable. Error mappings are documented on each management method. The underlying httpx client is reused across requests, and connection pooling is handled automatically by httpx. Parameters: base_url: The base URL of the GraphDB server. auth: Authentication credentials. Can be a tuple (username, password) for basic auth, or a string for token-based auth (e.g., "GDB ") which is added as the Authorization header. timeout: Request timeout in seconds or an httpx.Timeout for fine-grained control (default: 30.0). kwargs: Additional keyword arguments to pass to the httpx.Client. c >[TU]"XU40UD6 [UR5Ul[ UR5Ul[UR5Ul[UR5Ul [UR5Ul [UR5Ul[UR5Ulgr8)r/r?rr=_cluster_grouprY _monitoringrp _recoveryrS_graphdb_repository_managerr_graphdb_repositoriesr* _securityr?_users)r;base_urlauthr:kwargsr1s r>r?GraphDBClient.__init__y s ;F;4T5E5EF/0@0@A+D,<,<=+rjGraphDBClient.cluster s"""rAcUR$r8)rbrDs r> monitoringGraphDBClient.monitoring srAcUR$r8)rcrDs r>recoveryGraphDBClient.recovery ~~rAcUR$)zAServer-level repository management operations (GraphDB-specific).)rdrDs r>rGraphDBClient.repositories s///rAcUR$r8)rerDs r>graphdb_repositories"GraphDBClient.graphdb_repositories s)))rAcUR$r8)rfrDs r>securityGraphDBClient.security rtrAcUR$r8)rgrDs r>usersGraphDBClient.users s {{rAcURRSXS.S9nUR5 URR SS5nUR S5(d [ S5eUR5n[R"XT5$![[4an[ SU35UeS nAff=f![[4an[ S U35UeS nAff=f![RannURRnUS :Xa#[!S URR"35UeUS :Xa#[%SURR"35UeeS nAff=f)aAuthenticate with GraphDB and obtain a GDB token. Parameters: username: The username to authenticate with. password: The password to authenticate with. Returns: An AuthenticatedUser instance containing user details and the GDB token. Raises: UnauthorisedError: If the credentials are invalid. BadRequestError: If the request body is invalid. ResponseFormatError: If the response cannot be parsed. z /rest/login)rJpasswordr AuthorizationrzGDB z.Authorization header missing or invalid formatz Failed to parse login response: Nz$Failed to parse authenticated user: rrrWzInvalid credentials: )r=rrcrrb startswithrrdr^rer from_responserhrirjrkrrlr)r;rJrrj auth_headerr$rprrs r>loginGraphDBClient.login sx# '',,"*A-H  % % '"**..CK))&11)D }}  (66tII  * )6se<  * ):3%@  $$ \\--F}%(9#,,:K:K9L&MNTWW3'+CLL,=,=+>?  sUA)C!,B=B:B7#B22B77C!:C CCC!!E#5A)EE#)rarerdrbrcrfrg)Ng>@)rhrariztuple[str, str] | str | Noner:zfloat | httpx.Timeoutrjzt.Any)rr)rrY)rrp)rrS)rr)rr*)rr?)rJrarrarr)rrrrrr?rrjrorrrrxr{r~rrrPrQs@r>r_r_f s*.2)- 77+7' 7  77 ##  00**22rAr_)Rr __future__rrdrrtypingrrhrdflib.contrib.rdf4jrdflibrrr!rdflib.contrib.graphdb.exceptionsrrr r r r r rrrrrdflib.contrib.graphdb.modelsrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,rdflib.contrib.graphdb.utilr-r.r/UnionrrarTupleOptionalrrIterable FilesTyper]r5rcontribrdf4jclientr-rSrYrprr*r?r_rrAr>rs"  ))    :-gg DDKGGAJJsOQWWUCe%<= =>GGAJJsOQWWUCe%<=qzz# NO Q  GGIIc;JJqwwsK'()+  HiiX Y Y xh%%,,77hV?,,33EE?4XXvJ J ZYYx@@FAAHrKrrA