publish

Documentation

Index

• type Publish
  • func NewPublish(ctx context.Context, processorEntity processor.ProcessorEntitier, ...) *Publish
  • func (p *Publish) Cleanup()
  • func (p *Publish) GetLatestWatermark() processor.Watermark
  • func (p *Publish) PublishWatermark(wm processor.Watermark, offset isb.Offset)
• type PublishOption
  • func WithAutoRefreshHeartbeat(enable bool) 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, keyspace string, js nats.JetStreamContext, heartbeatBucket nats.KeyValue, inputOpts ...PublishOption) *Publish

NewPublish returns `Publish`.

func (*Publish) Cleanup

func (p *Publish) Cleanup()

Cleanup cleans up the data associated with key. TODO: move this to control plane

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.

type PublishOption

type PublishOption func(*publishOptions)

func WithAutoRefreshHeartbeat

func WithAutoRefreshHeartbeat(enable bool) 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
}

Publisher interface defines how to publish Watermark for a ProcessorEntity.