in compliance/kibana.go [234:271]
func (k *Kibana) createAgentPolicyForPackage(name string) (*agentPolicyResponse, error) {
agentPolicyRequest := agentPolicyRequest{
Name: k.buildPolicyName(name),
Namespace: "default",
}
body, err := json.Marshal(agentPolicyRequest)
if err != nil {
return nil, err
}
req, err := k.newRequest(http.MethodPost, apiAgentPolicyPath, bytes.NewReader(body))
if err != nil {
return nil, err
}
resp, err := k.client.Do(req)
if err != nil {
return nil, err
}
defer resp.Body.Close()
if resp.StatusCode >= 400 {
respBody, err := io.ReadAll(resp.Body)
if err != nil {
return nil, fmt.Errorf("failed to read response body (status: %d)", resp.StatusCode)
}
return nil, fmt.Errorf("request failed with status %d, body: %s", resp.StatusCode, string(respBody))
}
var agentPolicy agentPolicyResponse
err = json.NewDecoder(resp.Body).Decode(&agentPolicy)
if err != nil {
return nil, err
}
return &agentPolicy, nil
}