Documentation
¶
Index ¶
- func BuildNoOpSourceWatermarkProgressors(toBuffers []string) (fetch.SourceFetcher, map[string]publish.Publisher)
- func BuildNoOpSourceWatermarkProgressorsFromBufferMap(bufferMap map[string][]isb.BufferWriter) (fetch.SourceFetcher, map[string]publish.Publisher)
- func BuildNoOpWatermarkProgressorsFromBufferList(toBuffers []string) (fetch.Fetcher, map[string]publish.Publisher)
- func BuildNoOpWatermarkProgressorsFromBufferMap(bufferMap map[string][]isb.BufferWriter) (fetch.Fetcher, map[string]publish.Publisher)
- type NoOpSourceWMProgressor
- func (n NoOpSourceWMProgressor) Close() error
- func (n NoOpSourceWMProgressor) ComputeHeadWatermark(int32) wmb.Watermark
- func (n NoOpSourceWMProgressor) ComputeWatermark() wmb.Watermark
- func (n NoOpSourceWMProgressor) GetLatestWatermark() wmb.Watermark
- func (n NoOpSourceWMProgressor) PublishIdleWatermark(_ wmb.Watermark, _ isb.Offset, _ int32)
- func (n NoOpSourceWMProgressor) PublishWatermark(_ wmb.Watermark, _ isb.Offset, _ int32)
- type NoOpWMProgressor
- func (n NoOpWMProgressor) Close() error
- func (n NoOpWMProgressor) ComputeHeadIdleWMB(int32) wmb.WMB
- func (n NoOpWMProgressor) ComputeHeadWatermark(int32) wmb.Watermark
- func (n NoOpWMProgressor) ComputeWatermark(isb.Offset, int32) wmb.Watermark
- func (n NoOpWMProgressor) GetLatestWatermark() wmb.Watermark
- func (n NoOpWMProgressor) PublishIdleWatermark(wmb.Watermark, isb.Offset, int32)
- func (n NoOpWMProgressor) PublishWatermark(wmb.Watermark, isb.Offset, int32)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildNoOpSourceWatermarkProgressors ¶ added in v1.1.0
func BuildNoOpSourceWatermarkProgressorsFromBufferMap ¶ added in v1.1.0
func BuildNoOpSourceWatermarkProgressorsFromBufferMap(bufferMap map[string][]isb.BufferWriter) (fetch.SourceFetcher, map[string]publish.Publisher)
func BuildNoOpWatermarkProgressorsFromBufferList ¶ added in v0.8.1
func BuildNoOpWatermarkProgressorsFromBufferMap ¶ added in v0.5.5
Types ¶
type NoOpSourceWMProgressor ¶ added in v1.1.0
type NoOpSourceWMProgressor struct {
}
func NewNoOpSourceWMProgressor ¶ added in v1.1.0
func NewNoOpSourceWMProgressor() *NoOpSourceWMProgressor
func (NoOpSourceWMProgressor) Close ¶ added in v1.1.0
func (n NoOpSourceWMProgressor) Close() error
Close stops the no-op progressor.
func (NoOpSourceWMProgressor) ComputeHeadWatermark ¶ added in v1.1.0
func (n NoOpSourceWMProgressor) ComputeHeadWatermark(int32) wmb.Watermark
ComputeHeadWatermark returns the default head watermark.
func (NoOpSourceWMProgressor) ComputeWatermark ¶ added in v1.1.0
func (n NoOpSourceWMProgressor) ComputeWatermark() wmb.Watermark
ComputeWatermark returns the default watermark.
func (NoOpSourceWMProgressor) GetLatestWatermark ¶ added in v1.1.0
func (n NoOpSourceWMProgressor) GetLatestWatermark() wmb.Watermark
GetLatestWatermark returns the default watermark as the latest watermark.
func (NoOpSourceWMProgressor) PublishIdleWatermark ¶ added in v1.1.0
PublishIdleWatermark does a no-op idle watermark publish.
func (NoOpSourceWMProgressor) PublishWatermark ¶ added in v1.1.0
PublishWatermark does a no-op watermark publish.
type NoOpWMProgressor ¶
type NoOpWMProgressor struct {
}
NoOpWMProgressor is a no-op watermark progressor. As the name suggests, it does not do anything, no watermark is progressed. NoOpWMProgressor is used when watermarking is disabled.
func NewNoOpWMProgressor ¶
func NewNoOpWMProgressor() *NoOpWMProgressor
NewNoOpWMProgressor returns NoOpWMProgressor.
func (NoOpWMProgressor) Close ¶ added in v0.6.3
func (n NoOpWMProgressor) Close() error
Close stops the no-op progressor.
func (NoOpWMProgressor) ComputeHeadIdleWMB ¶ added in v0.10.0
func (n NoOpWMProgressor) ComputeHeadIdleWMB(int32) wmb.WMB
ComputeHeadIdleWMB returns the default WMB.
func (NoOpWMProgressor) ComputeHeadWatermark ¶ added in v0.10.0
func (n NoOpWMProgressor) ComputeHeadWatermark(int32) wmb.Watermark
ComputeHeadWatermark returns the default head watermark.
func (NoOpWMProgressor) ComputeWatermark ¶ added in v0.10.0
func (NoOpWMProgressor) GetLatestWatermark ¶
func (n NoOpWMProgressor) GetLatestWatermark() wmb.Watermark
GetLatestWatermark returns the default watermark as the latest watermark.
func (NoOpWMProgressor) PublishIdleWatermark ¶ added in v0.7.1
PublishIdleWatermark does a no-op idle watermark publish.
func (NoOpWMProgressor) PublishWatermark ¶
PublishWatermark does a no-op watermark publish.
Source Files
Directories