mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-01-07 19:31:51 +08:00
cb7f2fa6fd
Related to #39095 https://go.dev/doc/modules/version-numbers Update pkg version according to golang dep version convention --------- Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
33 lines
918 B
Go
33 lines
918 B
Go
package consumer
|
|
|
|
import (
|
|
"github.com/milvus-io/milvus/pkg/v2/streaming/util/message"
|
|
)
|
|
|
|
// timeTickOrderMessageHandler is a message handler that will record the last sent message id.
|
|
type timeTickOrderMessageHandler struct {
|
|
inner message.Handler
|
|
lastConfirmedMessageID message.MessageID
|
|
lastTimeTick uint64
|
|
}
|
|
|
|
func (mh *timeTickOrderMessageHandler) Handle(handleParam message.HandleParam) message.HandleResult {
|
|
var lastConfirmedMessageID message.MessageID
|
|
var lastTimeTick uint64
|
|
if handleParam.Message != nil {
|
|
lastConfirmedMessageID = handleParam.Message.LastConfirmedMessageID()
|
|
lastTimeTick = handleParam.Message.TimeTick()
|
|
}
|
|
|
|
result := mh.inner.Handle(handleParam)
|
|
if result.MessageHandled {
|
|
mh.lastConfirmedMessageID = lastConfirmedMessageID
|
|
mh.lastTimeTick = lastTimeTick
|
|
}
|
|
return result
|
|
}
|
|
|
|
func (mh *timeTickOrderMessageHandler) Close() {
|
|
mh.inner.Close()
|
|
}
|