Versions in this module Expand all Collapse all v1 v1.0.1 Jun 11, 2024 v1.0.0 Jun 11, 2024 Changes in this version + type GetProgress func() (bytesScanned int64, bytesProcessed int64) + type MessageHandler struct + func NewMessageHandler(ctx context.Context, w *bufio.Writer, getProgressFunc GetProgress) *MessageHandler + func (mh *MessageHandler) Finish(bytesScanned, bytesProcessed int64) error + func (mh *MessageHandler) FinishWithError(errorCode, errorMessage string) error + func (mh *MessageHandler) SendRecord(payload []byte) error