Public | Automated Build

Last pushed: 2 months ago
Short Description
Full Description

Concept publisher (concept-publisher)

Fetches concepts from concept-transformers and adds them to kafka.


go get -u
go get -u
cd $GOPATH/src/
govendor sync
go build .


GET /jobs

Return all the jobs' ids.

POST /jobs

  • concept: the name of the concept type. It's important because there are unusual cases when this name differs from what is in the URL path.
  • url: url to use to get the transformed concept
    • it must be an absolute path
    • {url}/__count returns the number of concepts
    • {url}/__ids that lists the identities of the resources in the form '{"id":"abc"}\n{"id":"def"}'
    • {url}/{uid} that returns the transformed concept in UPP json format
  • gtgUrl: url to check that the transformer has finished reloading after a reload call.
    Not all applications expose a good-to-go endpoint, if you still want a successful publish, make sure they don't expose
    reload either (than it doesn't come to ask for __gtg) or put a dummy endpoint that works and gives a 200.
  • ids (optional): list if ids to publish - if the list is not empty ids will not be looked up via the __ids endpoint on the transformer and only the uuids from the list will be published
  • throttle: no of req/s when calling the transformers to get transformed content
  • authorization (optional)


curl -X POST -H "Content-Type: application/json" localhost:8080/jobs --data '
  "concept": "special-reports",
  "url": "http://special-reports-transformer:8080/transformers/special-reports/",
  "gtgUrl": "http://special-reports-transformer:8080/__gtg",
  "throttle": 1000,
  "authorization": "Basic base64user:pass"

curl -X POST -H "Content-Type: application/json" localhost:8080/jobs --data '
  "concept": "brands",
  "ids": ["uuid1", "uuid2"],
  "url": "",
  "gtgUrl": "",
  "throttle": 1000

GET /jobs/{id}

You can add the parameter full to see the optionally given defined IDs and the failedIDs of the job.

e.g. curl -H "Accept: application/json" localhost:8080/jobs/job_123456?full

Get detailed job status, should it be in progress, completed or failed.

DELETE /jobs/{id}

Deletes the job. Works only if the job is terminated.

Docker Pull Command

Comments (0)