Library scope: | GLOBAL |
---|
Python invocation of several parallel publish-notifications RPCs.
Get http response from write-transactions rpc if available.
:return: None or a triple consisting of response time, prefix identifier and response object :rtype: (str, str, requests.Response)
Invoke produce-transactions rpcs on given nodes.
:param host_list: IP addresses of odl nodes :type host_list: list[str] :param index_list: node indices which correspond to the ip addresses :type index_list: list[int] :param id_prefix: identifier prefix :type id_prefix: str :param duration: time in seconds :type duration: int :param rate: produce transactions rate in transactions per second :type rate: int :param isolated_transactions_flag: isolated transactions flag :type isolated_transactions_flag: bool :param reset_globals: reset global variable dict :type reset_globals: bool
Invoke write-transactions rpc on given nodes.
:param host_list: IP addresses of odl nodes :type host_list: list[str] :param index_list: node indices which correspond to the ip addresses :type index_list: list[int] :param id_prefix: identifier prefix :type id_prefix: str :param duration: time in seconds :type duration: int :param rate: writing transactions rate in transactions per second :type rate: int :param chained_flag: specify chained vs. simple transactions :type chained_flag: bool :param reset_globals: reset global variable dict :type reset_globals: bool
Blocking call, waitig for responses from all threads.
:return: list of triples; triple consists of response time, prefix identifier and response object :rtype: list[(str, str, requests.Response)]