generic

Documentation

Index

• func BuildNoOpWatermarkProgressorsFromBufferList(toBuffers []string) (fetch.Fetcher, map[string]publish.Publisher)
• func BuildNoOpWatermarkProgressorsFromBufferMap(bufferMap map[string][]isb.BufferWriter) (fetch.Fetcher, map[string]publish.Publisher)
• type NoOpWMProgressor
  • func NewNoOpWMProgressor() *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)

Functions

func BuildNoOpWatermarkProgressorsFromBufferList

func BuildNoOpWatermarkProgressorsFromBufferList(toBuffers []string) (fetch.Fetcher, map[string]publish.Publisher)

func BuildNoOpWatermarkProgressorsFromBufferMap

func BuildNoOpWatermarkProgressorsFromBufferMap(bufferMap map[string][]isb.BufferWriter) (fetch.Fetcher, map[string]publish.Publisher)

Types

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

func (n NoOpWMProgressor) Close() error

Close stops the no-op progressor.

func (NoOpWMProgressor) ComputeHeadIdleWMB

func (n NoOpWMProgressor) ComputeHeadIdleWMB(int32) wmb.WMB

ComputeHeadIdleWMB returns the default WMB.

func (NoOpWMProgressor) ComputeHeadWatermark

func (n NoOpWMProgressor) ComputeHeadWatermark(int32) wmb.Watermark

ComputeHeadWatermark returns the default head watermark.

func (NoOpWMProgressor) ComputeWatermark

func (n NoOpWMProgressor) ComputeWatermark(isb.Offset, int32) wmb.Watermark

func (NoOpWMProgressor) GetLatestWatermark

func (n NoOpWMProgressor) GetLatestWatermark() wmb.Watermark

GetLatestWatermark returns the default watermark as the latest watermark.

func (NoOpWMProgressor) PublishIdleWatermark

func (n NoOpWMProgressor) PublishIdleWatermark(wmb.Watermark, isb.Offset, int32)

PublishIdleWatermark does a no-op idle watermark publish.

func (NoOpWMProgressor) PublishWatermark

func (n NoOpWMProgressor) PublishWatermark(wmb.Watermark, isb.Offset, int32)

PublishWatermark does a no-op watermark publish.