package process

import (
	"git.oschina.net/cloudzone/smartgo/stgclient/consumer"
	"git.oschina.net/cloudzone/smartgo/stgcommon/message"
)

type PullResultExt struct {
	*consumer.PullResult
	suggestWhichBrokerId int64
	messageBinary        [] byte
}

func NewPullResultExt(pullStatus consumer.PullStatus, nextBeginOffset int64, minOffset int64, maxOffset int64,
msgFoundList []*message.MessageExt, suggestWhichBrokerId int64, messageBinary [] byte) *PullResultExt {
	pullResult := &consumer.PullResult{PullStatus:pullStatus, NextBeginOffset:nextBeginOffset,
		MinOffset:minOffset, MaxOffset:maxOffset, MsgFoundList:msgFoundList}
	return &PullResultExt{PullResult:pullResult, suggestWhichBrokerId:suggestWhichBrokerId, messageBinary:messageBinary}
}
{'avg_line_length': 39.36842105263158, 'max_line_length': 117, 'alphanum_fraction': 0.8248663101604278, 'licenses': ['Apache-2.0'], 'repository_name': 'wuhaiying83/smartgo', 'path': 'stgclient/process/pull_result_ext.go', 'size': 748, 'lang': 'GO'}