jetstream

Documentation

Overview

Package jetstream package implements the kv store and watcher using Jetstream.

Index

• func NewKVJetStreamKVStore(ctx context.Context, kvName string, client *jsclient.Client, opts ...Option) (kvs.KVStorer, error)
• type Option
  • func WithWatcherCreationThreshold(d time.Duration) Option

Functions

func NewKVJetStreamKVStore

func NewKVJetStreamKVStore(ctx context.Context, kvName string, client *jsclient.Client, opts ...Option) (kvs.KVStorer, error)

NewKVJetStreamKVStore returns KVJetStreamStore.

Types

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