apache / rocketmq-client-go

@@ -84,6 +84,9 @@
Loading
84 84
	Rebalance()
85 85
	IsUnitMode() bool
86 86
	GetConsumerRunningInfo() *ConsumerRunningInfo
87 +
	GetcType() string
88 +
	GetModel() string
89 +
	GetWhere() string
87 90
}
88 91
89 92
func DefaultClientOptions() ClientOptions {
@@ -454,9 +457,9 @@
Loading
454 457
		consumer := value.(InnerConsumer)
455 458
		cData := consumerData{
456 459
			GroupName:         key.(string),
457 -
			CType:             "CONSUME_PASSIVELY",
458 -
			MessageModel:      "CLUSTERING",
459 -
			Where:             "CONSUME_FROM_FIRST_OFFSET",
460 +
			CType:             consumeType(consumer.GetcType()),
461 +
			MessageModel:      strings.ToUpper(consumer.GetModel()),
462 +
			Where:             consumer.GetWhere(),
460 463
			UnitMode:          consumer.IsUnitMode(),
461 464
			SubscriptionDatas: consumer.SubscriptionDataList(),
462 465
		}

@@ -267,6 +267,28 @@
Loading
267 267
	return pc.unitMode
268 268
}
269 269
270 +
func (pc *pushConsumer) GetcType() string {
271 +
	return string(pc.cType)
272 +
}
273 +
274 +
func (pc *pushConsumer) GetModel() string {
275 +
	return pc.model.String()
276 +
}
277 +
278 +
func (pc *pushConsumer) GetWhere() string {
279 +
	switch pc.fromWhere {
280 +
	case ConsumeFromLastOffset:
281 +
		return "CONSUME_FROM_LAST_OFFSET"
282 +
	case ConsumeFromFirstOffset:
283 +
		return "CONSUME_FROM_FIRST_OFFSET"
284 +
	case ConsumeFromTimestamp:
285 +
		return "CONSUME_FROM_TIMESTAMP"
286 +
	default:
287 +
		return "UNKOWN"
288 +
	}
289 +
290 +
}
291 +
270 292
func (pc *pushConsumer) GetConsumerRunningInfo() *internal.ConsumerRunningInfo {
271 293
	info := internal.NewConsumerRunningInfo()
272 294
Files Coverage
consumer 26.27%
internal 22.21%
primitive 20.00%
producer 31.43%
Project Totals (48 files) 24.59%
Notifications are pending CI completion. Periodically Codecov will check the CI state, when complete notifications will be submitted. Push notifications now.
700.2
TRAVIS_OS_NAME=linux
1.12.x=.12.x
700.1
1.11.x=.11.x
TRAVIS_OS_NAME=linux

No yaml found.

Create your codecov.yml to customize your Codecov experience

Sunburst
The inner-most circle is the entire project, moving away from the center are folders then, finally, a single file. The size and color of each slice is representing the number of statements and the coverage, respectively.
Icicle
The top section represents the entire project. Proceeding with folders and finally individual files. The size and color of each slice is representing the number of statements and the coverage, respectively.
Grid
Each block represents a single file in the project. The size and color of each block is represented by the number of statements and the coverage, respectively.
Loading