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
- func NewGenericEdgeFetch(ctx context.Context, bufferName string, ...) fetch.Fetcher
- func NewGenericSourceFetch(ctx context.Context, sourceBufferName string, ...) fetch.Fetcher
- type NoOpWMProgressor
- func (n NoOpWMProgressor) GetHeadWatermark() processor.Watermark
- func (n NoOpWMProgressor) GetLatestWatermark() processor.Watermark
- func (n NoOpWMProgressor) GetWatermark(_ isb.Offset) processor.Watermark
- func (n NoOpWMProgressor) PublishWatermark(_ processor.Watermark, _ isb.Offset)
- func (n NoOpWMProgressor) StopPublisher()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildNoOpWatermarkProgressorsFromBufferMap ¶ added in v0.5.5
func BuildNoOpWatermarkProgressorsFromEdgeList ¶ added in v0.5.5
func GetBufferNameList ¶ added in v0.5.5
func NewGenericEdgeFetch ¶ added in v0.5.6
func NewGenericEdgeFetch(ctx context.Context, bufferName string, storeWatcher store.WatermarkStoreWatcher) fetch.Fetcher
NewGenericEdgeFetch returns a Fetcher, which fetches watermarks from bufferName by consulting the corresponding storeWatcher
func NewGenericSourceFetch ¶ added in v0.5.6
func NewGenericSourceFetch(ctx context.Context, sourceBufferName string, storeWatcher store.WatermarkStoreWatcher) fetch.Fetcher
NewGenericSourceFetch returns Fetcher, where sourceBufferName is the source buffer of the source vertex.
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) GetHeadWatermark ¶ added in v0.5.4
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) PublishWatermark ¶
func (n NoOpWMProgressor) PublishWatermark(_ processor.Watermark, _ isb.Offset)
PublishWatermark does a no-op publish.
func (NoOpWMProgressor) StopPublisher ¶
func (n NoOpWMProgressor) StopPublisher()
StopPublisher stops the no-op publisher.
Source Files
Directories