jetstream

Documentation

Overview

Package jetstream package implements the watermark progression using Jetstream as the KV store.

Index

• func NewKVJetStreamKVStore(ctx context.Context, pipelineName string, bucketName string, ...) (store.WatermarkKVStorer, error)
• func NewKVJetStreamKVWatch(ctx context.Context, pipelineName string, kvBucketName string, ...) (store.WatermarkKVWatcher, error)
• type JSKVStoreOption
• type Option
  • func WithWatcherCreationThreshold(d time.Duration) Option

Functions

func NewKVJetStreamKVStore

func NewKVJetStreamKVStore(ctx context.Context, pipelineName string, bucketName string, client *jsclient.NATSClient, opts ...JSKVStoreOption) (store.WatermarkKVStorer, error)

NewKVJetStreamKVStore returns KVJetStreamStore.

func NewKVJetStreamKVWatch

func NewKVJetStreamKVWatch(ctx context.Context, pipelineName string, kvBucketName string, client *jsclient.NATSClient, opts ...Option) (store.WatermarkKVWatcher, error)

NewKVJetStreamKVWatch returns KVJetStreamWatch specific to JetStream which implements the WatermarkKVWatcher interface.

Types

type JSKVStoreOption

type JSKVStoreOption func(*jetStreamStore) error

JSKVStoreOption is to pass in JetStream options.

type Option

type Option func(*options)

Option is a function on the options kv watcher

func WithWatcherCreationThreshold

func WithWatcherCreationThreshold(d time.Duration) Option

WithWatcherCreationThreshold sets the watcherCreationThreshold