generic

Documentation

Index

• func BuildNoOpWatermarkProgressorsFromBufferMap(bufferMap map[string]isb.BufferWriter) (fetch.Fetcher, map[string]publish.Publisher)
• func BuildNoOpWatermarkProgressorsFromEdgeList(bufferList []string) (fetch.Fetcher, map[string]publish.Publisher)
• func GetBufferNameList(bufferList []v1alpha1.Buffer) []string
• type NoOpWMProgressor
  • func NewNoOpWMProgressor() *NoOpWMProgressor
  • func (n NoOpWMProgressor) Close() error
  • func (n NoOpWMProgressor) GetHeadWatermark() processor.Watermark
  • func (n NoOpWMProgressor) GetLatestWatermark() processor.Watermark
  • func (n NoOpWMProgressor) GetWatermark(_ isb.Offset) processor.Watermark
  • func (n NoOpWMProgressor) PublishIdleWatermark()
  • func (n NoOpWMProgressor) PublishWatermark(_ processor.Watermark, _ isb.Offset)

Functions

func BuildNoOpWatermarkProgressorsFromBufferMap

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

func BuildNoOpWatermarkProgressorsFromEdgeList

func BuildNoOpWatermarkProgressorsFromEdgeList(bufferList []string) (fetch.Fetcher, map[string]publish.Publisher)

func GetBufferNameList

func GetBufferNameList(bufferList []v1alpha1.Buffer) []string

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) GetHeadWatermark

func (n NoOpWMProgressor) GetHeadWatermark() processor.Watermark

GetHeadWatermark returns the default head watermark.

func (NoOpWMProgressor) GetLatestWatermark

func (n NoOpWMProgressor) GetLatestWatermark() processor.Watermark

GetLatestWatermark returns the default watermark as the latest watermark.

func (NoOpWMProgressor) GetWatermark

func (n NoOpWMProgressor) GetWatermark(_ isb.Offset) processor.Watermark

GetWatermark returns the default watermark.

func (NoOpWMProgressor) PublishIdleWatermark

func (n NoOpWMProgressor) PublishIdleWatermark()

PublishIdleWatermark does a no-op idle watermark publish.

func (NoOpWMProgressor) PublishWatermark

func (n NoOpWMProgressor) PublishWatermark(_ processor.Watermark, _ isb.Offset)

PublishWatermark does a no-op watermark publish.