type JobDefinition struct {
InfoTypeID string `json:"info_type_id"`
JobOwner string `json:"job_owner"`
- JobResultURI string `json:"job_result_uri"`
+ StatusNotificationURI string `json:"status_notification_uri"`
JobDefinition struct {
- KafkaOutputTopic string `json:"kafkaOutputTopic"`
- FilterType string `json:"filterType"`
Filter json.RawMessage `json:"filter"`
DeliveryInfo struct {
Topic string `json:"topic"`
var log_payload = os.Getenv("LOG_PAYLOAD")
-// This are optional - if rapp is fethcing the token instead of the side car
+// These are optional - if rapp is fethcing the token instead of the side car
var creds_grant_type = os.Getenv("CREDS_GRANT_TYPE")
var creds_client_secret = os.Getenv("CREDS_CLIENT_SECRET")
var creds_client_id = os.Getenv("CREDS_CLIENT_ID")
os.Exit(1)
}
job_type := job_json.InfoTypeID
- job_json.JobDefinition.KafkaOutputTopic = topic
job_json.JobDefinition.DeliveryInfo.Topic = topic
job_json.JobDefinition.DeliveryInfo.BootStrapServers = bootstrapserver
- gid = "pm-rapp-" + job_type + "-" + rapp_id
+ gid = "pm-rapp-" + job_type + "-" + rapp_id
- jobid = "rapp-job-" + job_type + "-" + rapp_id
+ jobid = "rapp-job-" + job_type + "-" + rapp_id
json_bytes, err := json.Marshal(job_json)
if err != nil {
}
if jwt_file != "" || creds_service_url != "" {
if accessToken != "" {
- req.Header.Add("authorization", accessToken)
+ req.Header.Set("Authorization", "Bearer "+accessToken)
} else {
log.Error("Cannot create http request for url: ", url, " - token missing")
return false, nil
}
}
} else {
- log.Error("Bad response, method: ", method, " url: ", url, " resp: ", resp.StatusCode)
+ log.Error("Bad response, method: ", method, " url: ", url, " resp: ", resp.StatusCode, " resp: ", resp)
}
}
}