PolicyAdminAuth
${policyadmin}= Create list policyadmin zb!XztG34
- [return] ${policyadmin}
+ RETURN ${policyadmin}
PerformPostRequest
[Arguments] ${domain} ${url} ${expectedstatus} ${postjson} ${params} ${auth}
${headers}= Create Dictionary Accept=application/json Content-Type=application/json
${resp}= POST On Session policy ${url} data=${postjson} params=${params} headers=${headers} expected_status=${expectedstatus}
Log Received response from policy ${resp.text}
- [return] ${resp}
+ RETURN ${resp}
PerformPutRequest
[Arguments] ${domain} ${url} ${expectedstatus} ${params} ${auth}
${headers}= Create Dictionary Accept=application/json Content-Type=application/json
${resp}= PUT On Session policy ${url} params=${params} headers=${headers} expected_status=${expectedstatus}
Log Received response from policy ${resp.text}
- [return] ${resp}
+ RETURN ${resp}
PerformGetRequest
[Arguments] ${domain} ${url} ${expectedstatus} ${params} ${auth}
${headers}= Create Dictionary Accept=application/json Content-Type=application/json
${resp}= GET On Session policy ${url} params=${params} headers=${headers} expected_status=${expectedstatus}
Log Received response from policy ${resp.text}
- [return] ${resp}
+ RETURN ${resp}
PerformDeleteRequest
[Arguments] ${domain} ${url} ${expectedstatus} ${auth}
${session}= Create Session policy http://${domain} auth=${auth}
${resp}= GET On Session policy ${context_path}metrics expected_status=200
Log Received response from policy ${resp.text}
- [return] ${resp}
+ RETURN ${resp}
QueryPrometheus
[Arguments] ${query}
${resp}= GET http://${PROMETHEUS_IP}/api/v1/query ${params}
Status Should Be OK
Log Received response from Prometheus ${resp.text}
- [return] ${resp.json()}
+ RETURN ${resp.json()}
ValidateResponseTime
[Arguments] ${job} ${uri} ${method} ${timeLimit}
[Arguments] ${topic} ${expected_status}
${resp}= Run Process ${CURDIR}/kafka_consumer.py ${topic} 60 ${expected_status} ${KAFKA_IP}
Should Contain ${resp.stdout} ${expected_status}
- [Return] ${resp.stdout}
+ RETURN ${resp.stdout}
GetKafkaTopic
[Arguments] ${topic}
${headers}= Create Dictionary Accept=application/json Content-Type=application/json
${resp}= GET On Session policy ${url} headers=${headers} expected_status=${expectedstatus}
Log Received response from policy ${resp.text}
- [return] ${resp}
+ RETURN ${resp}
PerformPostRequest
[Arguments] ${url} ${params} ${domain} ${jsonfile} ${filepath} ${contenttype} ${expectedstatus}
${headers}= Create Dictionary Accept=application/${contenttype} Content-Type=application/${contenttype}
${resp}= POST On Session policy ${url} params=${params} data=${postjson} headers=${headers} expected_status=${expectedstatus}
Log Received response from policy ${resp.text}
- [return] ${resp}
+ RETURN ${resp}
OnSet
[Arguments] ${file}
${data}= Get File ${file}
${resp}= Run Process ${CURDIR}/kafka_producer.py unauthenticated.dcae_cl_output ${data} ${KAFKA_IP}
Log Response from kafka ${resp.stdout}
- [Return] ${resp.stdout}
+ RETURN ${resp.stdout}
[Arguments] ${url}
${hcauth}= PolicyAdminAuth
${resp}= PerformGetRequest ${POLICY_PDPX_IP} ${url} 200 null ${hcauth}
- [return] ${resp}
+ RETURN ${resp}
DecisionPostReq
[Arguments] ${postjson} ${abbr}
${hcauth}= PolicyAdminAuth
${resp}= PerformPostRequest ${POLICY_PDPX_IP} /policy/pdpx/v1/decision 200 ${postjson} ${abbr} ${hcauth}
- [return] ${resp}
+ RETURN ${resp}