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 JSKVWatcherOption

Functions

func NewKVJetStreamKVStore

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

NewKVJetStreamKVStore returns KVJetStreamStore.

func NewKVJetStreamKVWatch

func NewKVJetStreamKVWatch(ctx context.Context, pipelineName string, kvBucketName string, client jsclient.JetStreamClient, opts ...JSKVWatcherOption) (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 JSKVWatcherOption

type JSKVWatcherOption func(*jetStreamWatch) error

JSKVWatcherOption is to pass in Jetstream options.