jetbucket

Documentation

Index

• Variables
• type Bucket
  • func NewBucket[T any](bucket bucket) Bucket[T]
• type Watcher
  • func NewWatcher[T any](w watcher) Watcher[T]

Variables

var ErrInitialValuesOver = errors.New("initial values done")

Types

type Bucket

type Bucket[T any] interface {
	Get(ctx context.Context, key string) (jetstream.KeyValueEntry, *T, error)
	Put(ctx context.Context, key string, mod *T) (rev uint64, err error)
	Delete(ctx context.Context, key string, opts ...jetstream.KVDeleteOpt) error
	Watch(ctx context.Context, match string, opts ...jetstream.WatchOpt) (Watcher[T], error)
	WatchAll(ctx context.Context, opts ...jetstream.WatchOpt) (Watcher[T], error)
}

func NewBucket

func NewBucket[T any](bucket bucket) Bucket[T]

type Watcher

type Watcher[T any] interface {
	Next() (jetstream.KeyValueEntry, *T, error)
	Stop() error
}

func NewWatcher

func NewWatcher[T any](w watcher) Watcher[T]