Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GenericProgress ¶
type GenericProgress struct {
// contains filtered or unexported fields
}
GenericProgress implements `Progressor` to progress the watermark for UDFs and Sinks.
func NewGenericProgress ¶
func NewGenericProgress(ctx context.Context, processorName string, fetchKeyspace string, publishKeyspace string, js nats.JetStreamContext, inputOpts ...GenericProgressOption) *GenericProgress
NewGenericProgress will move the watermark for all the UDF vertices.
func (*GenericProgress) GetLatestWatermark ¶
func (u *GenericProgress) GetLatestWatermark() processor.Watermark
GetLatestWatermark returns the latest head watermark.
func (*GenericProgress) GetWatermark ¶
func (u *GenericProgress) GetWatermark(offset isb.Offset) processor.Watermark
GetWatermark gets the watermark.
func (*GenericProgress) PublishWatermark ¶
func (u *GenericProgress) PublishWatermark(watermark processor.Watermark, offset isb.Offset)
PublishWatermark publishes the watermark.
type GenericProgressOption ¶
type GenericProgressOption func(options *genericProgressOptions)
GenericProgressOption sets options for GenericProgress.
func WithSeparateOTBuckets ¶
func WithSeparateOTBuckets(separate bool) GenericProgressOption
WithSeparateOTBuckets creates a different bucket for maintaining each processor offset-timeline.
Source Files
Click to show internal directories.
Click to hide internal directories.