Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Minor bugs fix in ORU-app simulator
[nonrtric.git]
/
dmaap-mediator-producer
/
internal
/
jobs
/
jobs.go
diff --git
a/dmaap-mediator-producer/internal/jobs/jobs.go
b/dmaap-mediator-producer/internal/jobs/jobs.go
index
c84e277
..
86bfe05
100644
(file)
--- 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
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
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"`
type Parameters struct {
BufferTimeout BufferTimeout `json:"bufferTimeout"`
-}
+}
// @name Parameters
type BufferTimeout struct {
MaxSize int `json:"maxSize"`
MaxTimeMiliseconds int64 `json:"maxTimeMiliseconds"`
type BufferTimeout struct {
MaxSize int `json:"maxSize"`
MaxTimeMiliseconds int64 `json:"maxTimeMiliseconds"`
-}
+}
// @name BufferTimeout
func (j *job) start() {
if j.isJobBuffered() {
func (j *job) start() {
if j.isJobBuffered() {