X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Finternal%2Fjobs%2Fjobs.go;h=86bfe05c334963d13fda4744aacd59d7923dbefe;hb=2a6b1317357b5387f98e846c3b0387384cbadf4b;hp=c84e2773e1c42447270a7fc03c9f3b980b9b2506;hpb=4a9589b4743667175a584e628e4fd0f97499482a;p=nonrtric.git diff --git a/dmaap-mediator-producer/internal/jobs/jobs.go b/dmaap-mediator-producer/internal/jobs/jobs.go index c84e2773..86bfe05c 100644 --- a/dmaap-mediator-producer/internal/jobs/jobs.go +++ b/dmaap-mediator-producer/internal/jobs/jobs.go @@ -51,7 +51,7 @@ type JobInfo struct { InfoJobData Parameters `json:"info_job_data"` InfoTypeIdentity string `json:"info_type_identity"` sourceType sourceType -} +} // @name JobInfo type JobTypesManager interface { LoadTypesFromConfiguration(types []config.TypeDefinition) []config.TypeDefinition @@ -327,12 +327,12 @@ func newJob(j JobInfo, c restclient.HTTPClient) job { type Parameters struct { BufferTimeout BufferTimeout `json:"bufferTimeout"` -} +} // @name Parameters type BufferTimeout struct { MaxSize int `json:"maxSize"` MaxTimeMiliseconds int64 `json:"maxTimeMiliseconds"` -} +} // @name BufferTimeout func (j *job) start() { if j.isJobBuffered() {