Skip to content

Commit 306cdda

Browse files
committed
add update broker to controller/broker mgmt object
1 parent a7efa2e commit 306cdda

File tree

3 files changed

+15
-0
lines changed

3 files changed

+15
-0
lines changed

fabric_cf/actor/core/apis/abc_client_actor_management_object.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,15 @@ def add_broker(self, *, broker: ProxyAvro, caller: AuthToken) -> ResultAvro:
116116
@return success or failure status
117117
"""
118118

119+
@abstractmethod
120+
def update_broker(self, *, broker: ProxyAvro, caller: AuthToken) -> ResultAvro:
121+
"""
122+
Update a broker
123+
@param broker: broker_proxy to be added
124+
@param caller: caller
125+
@return success or failure status
126+
"""
127+
119128
@abstractmethod
120129
def get_broker_query_model(self, *, broker: ID, caller: AuthToken, id_token: str,
121130
level: int, graph_format: GraphFormat) -> ResultBrokerQueryModelAvro:

fabric_cf/actor/core/manage/broker_management_object.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,9 @@ def get_brokers(self, *, caller: AuthToken, broker_id: ID = None) -> ResultProxy
9393
def add_broker(self, *, broker: ProxyAvro, caller: AuthToken) -> ResultAvro:
9494
return self.client_helper.add_broker(broker=broker, caller=caller)
9595

96+
def update_broker(self, *, broker: ProxyAvro, caller: AuthToken) -> ResultAvro:
97+
return self.client_helper.update_broker(broker=broker, caller=caller)
98+
9699
def get_broker_query_model(self, *, broker: ID, caller: AuthToken, id_token: str,
97100
level: int, graph_format: GraphFormat) -> ResultBrokerQueryModelAvro:
98101
return self.client_helper.get_broker_query_model(broker=broker, caller=caller, id_token=id_token, level=level,

fabric_cf/actor/core/manage/controller_management_object.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,9 @@ def get_brokers(self, *, caller: AuthToken, broker_id: ID = None) -> ResultProxy
9797
def add_broker(self, *, broker: ProxyAvro, caller: AuthToken) -> ResultAvro:
9898
return self.client_helper.add_broker(broker=broker, caller=caller)
9999

100+
def update_broker(self, *, broker: ProxyAvro, caller: AuthToken) -> ResultAvro:
101+
return self.client_helper.add_broker(broker=broker, caller=caller)
102+
100103
def get_broker_query_model(self, *, broker: ID, caller: AuthToken, id_token: str,
101104
level: int, graph_format: GraphFormat) -> ResultBrokerQueryModelAvro:
102105
return self.client_helper.get_broker_query_model(broker=broker, caller=caller, id_token=id_token, level=level,

0 commit comments

Comments
 (0)