idlehandler

Dec 18, 2023

Changes in this version

+ type SourceIdleHandler struct

+ func NewSourceIdleHandler(config *dfv1.Watermark, fetcher fetch.SourceFetcher, ...) *SourceIdleHandler

+ func (iw *SourceIdleHandler) IsSourceIdling() bool

+ func (iw *SourceIdleHandler) PublishSourceIdleWatermark(partitions []int32)

+ func (iw *SourceIdleHandler) Reset()

Apr 3, 2023

Changes in this version

+ func PublishIdleWatermark(ctx context.Context, toBuffer isb.BufferWriter, publisher publish.Publisher, ...)