fixed pull consumer start, added pull consumer params into channeltem…
16.94% of diff hit (target 43.57%)
View this Pull Request on Codecov
16.94% of diff hit (target 43.57%)
Annotations
Check warning on line 67 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L67
Added line #L67 was not covered by tests
Check warning on line 75 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L73-L75
Added lines #L73 - L75 were not covered by tests
Check warning on line 124 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L123-L124
Added lines #L123 - L124 were not covered by tests
Check warning on line 129 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L126-L129
Added lines #L126 - L129 were not covered by tests
Check warning on line 133 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L132-L133
Added lines #L132 - L133 were not covered by tests
Check warning on line 138 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L136-L138
Added lines #L136 - L138 were not covered by tests
Check warning on line 141 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L141
Added line #L141 was not covered by tests
Check warning on line 146 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L144-L146
Added lines #L144 - L146 were not covered by tests
Check warning on line 152 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L148-L152
Added lines #L148 - L152 were not covered by tests
Check warning on line 155 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L154-L155
Added lines #L154 - L155 were not covered by tests
Check warning on line 159 in pkg/channel/jetstream/dispatcher/defaults.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/defaults.go#L159
Added line #L159 was not covered by tests
Check warning on line 189 in pkg/channel/jetstream/dispatcher/dispatcher.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/dispatcher.go#L189
Added line #L189 was not covered by tests
Check warning on line 231 in pkg/channel/jetstream/dispatcher/dispatcher.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/dispatcher.go#L230-L231
Added lines #L230 - L231 were not covered by tests
Check warning on line 239 in pkg/channel/jetstream/dispatcher/dispatcher.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/dispatcher.go#L239
Added line #L239 was not covered by tests
Check warning on line 287 in pkg/channel/jetstream/dispatcher/dispatcher.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/dispatcher.go#L286-L287
Added lines #L286 - L287 were not covered by tests
Check warning on line 295 in pkg/channel/jetstream/dispatcher/dispatcher.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/dispatcher.go#L291-L295
Added lines #L291 - L295 were not covered by tests
Check warning on line 300 in pkg/channel/jetstream/dispatcher/dispatcher.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/dispatcher.go#L297-L300
Added lines #L297 - L300 were not covered by tests
Check warning on line 305 in pkg/channel/jetstream/dispatcher/dispatcher.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/dispatcher.go#L302-L305
Added lines #L302 - L305 were not covered by tests
Check warning on line 39 in pkg/channel/jetstream/dispatcher/internal/message.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/internal/message.go#L38-L39
Added lines #L38 - L39 were not covered by tests
Check warning on line 43 in pkg/channel/jetstream/dispatcher/internal/message.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/internal/message.go#L42-L43
Added lines #L42 - L43 were not covered by tests
Check warning on line 47 in pkg/channel/jetstream/dispatcher/internal/message.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/internal/message.go#L46-L47
Added lines #L46 - L47 were not covered by tests
Check warning on line 51 in pkg/channel/jetstream/dispatcher/internal/message.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/internal/message.go#L50-L51
Added lines #L50 - L51 were not covered by tests
Check warning on line 55 in pkg/channel/jetstream/dispatcher/internal/message.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/internal/message.go#L54-L55
Added lines #L54 - L55 were not covered by tests
Check warning on line 59 in pkg/channel/jetstream/dispatcher/internal/message.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/internal/message.go#L58-L59
Added lines #L58 - L59 were not covered by tests
Check warning on line 63 in pkg/channel/jetstream/dispatcher/internal/message.go
codecov / codecov/patch
pkg/channel/jetstream/dispatcher/internal/message.go#L62-L63
Added lines #L62 - L63 were not covered by tests