Code Review
/
nonrtric
/
plt
/
ranpm.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Changing the image location pointing to release repo
[nonrtric/plt/ranpm.git]
/
pm-rapp
/
main.go
diff --git
a/pm-rapp/main.go
b/pm-rapp/main.go
index
c718add
..
86f1b3c
100644
(file)
--- a/
pm-rapp/main.go
+++ b/
pm-rapp/main.go
@@
-45,10
+45,8
@@
import (
type JobDefinition struct {
InfoTypeID string `json:"info_type_id"`
JobOwner string `json:"job_owner"`
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 {
JobDefinition struct {
- KafkaOutputTopic string `json:"kafkaOutputTopic"`
- FilterType string `json:"filterType"`
Filter json.RawMessage `json:"filter"`
DeliveryInfo struct {
Topic string `json:"topic"`
Filter json.RawMessage `json:"filter"`
DeliveryInfo struct {
Topic string `json:"topic"`
@@
-165,13
+163,12
@@
func main() {
os.Exit(1)
}
job_type := job_json.InfoTypeID
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
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 {
json_bytes, err := json.Marshal(job_json)
if err != nil {