publish

Documentation

Index

• type PublishOption
  • func IsSink() PublishOption
  • func IsSource() PublishOption
  • func WithAutoRefreshHeartbeatDisabled() PublishOption
  • func WithDelay(t time.Duration) PublishOption
  • func WithPodHeartbeatRate(rate int64) PublishOption
• type Publisher
  • func NewPublish(ctx context.Context, processorEntity processor.ProcessorEntitier, ...) Publisher

Types

type PublishOption

type PublishOption func(*publishOptions)

func IsSink

func IsSink() PublishOption

IsSink indicates it's a sink publisher

func IsSource

func IsSource() PublishOption

IsSource indicates it's a source publisher

func WithAutoRefreshHeartbeatDisabled

func WithAutoRefreshHeartbeatDisabled() PublishOption

func WithDelay

func WithDelay(t time.Duration) PublishOption

WithDelay sets the watermark delay

func WithPodHeartbeatRate

func WithPodHeartbeatRate(rate int64) PublishOption

type Publisher

type Publisher interface {
	// PublishWatermark publishes the watermark.
	PublishWatermark(processor.Watermark, isb.Offset)
	// GetLatestWatermark returns the latest published watermark.
	GetLatestWatermark() processor.Watermark
	// StopPublisher stops the publisher
	StopPublisher()
}

Publisher interface defines how to publish Watermark for a ProcessorEntity.

func NewPublish

func NewPublish(ctx context.Context, processorEntity processor.ProcessorEntitier, watermarkStores store.WatermarkStorer, inputOpts ...PublishOption) Publisher

NewPublish returns `Publish`.