publish

Documentation

Index

• type Publish
  • func NewPublish(ctx context.Context, processorEntity processor.ProcessorEntitier, ...) *Publish
  • func (p *Publish) GetLatestWatermark() processor.Watermark
  • func (p *Publish) PublishWatermark(wm processor.Watermark, offset isb.Offset)
  • func (p *Publish) StopPublisher()
• type PublishOption
  • func WithAutoRefreshHeartbeatDisabled() PublishOption
  • func WithBucketConfigs(cfgs *nats.KeyValueConfig) PublishOption
  • func WithPodHeartbeatRate(rate int64) PublishOption
• type Publisher

Types

type Publish

type Publish struct {
	// contains filtered or unexported fields
}

Publish publishes the watermark for a processor entity.

func NewPublish

func NewPublish(ctx context.Context, processorEntity processor.ProcessorEntitier, hbStore store.WatermarkKVStorer, otStore store.WatermarkKVStorer, inputOpts ...PublishOption) *Publish

NewPublish returns `Publish`.

func (*Publish) GetLatestWatermark

func (p *Publish) GetLatestWatermark() processor.Watermark

GetLatestWatermark returns the latest watermark for that processor.

func (*Publish) PublishWatermark

func (p *Publish) PublishWatermark(wm processor.Watermark, offset isb.Offset)

PublishWatermark publishes watermark and will retry until it can succeed. It will not publish if the new-watermark is less than the current head watermark.

func (*Publish) StopPublisher

func (p *Publish) StopPublisher()

StopPublisher stops the publisher and cleans up the data associated with key.

type PublishOption

type PublishOption func(*publishOptions)

func WithAutoRefreshHeartbeatDisabled

func WithAutoRefreshHeartbeatDisabled() PublishOption

func WithBucketConfigs

func WithBucketConfigs(cfgs *nats.KeyValueConfig) PublishOption

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.