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=3b2f07a98d1d5e2f83aaf05fede3f07379d48b88;hp=c84e2773e1c42447270a7fc03c9f3b980b9b2506;hpb=8170f78af913d337f874477ba5dd93411e9e69da;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() {