MCPcopy
hub / github.com/nats-io/nats.go / KeyValue

Method KeyValue

jetstream/kv.go:40–40  ·  view source on GitHub ↗

KeyValue will lookup and bind to an existing KeyValue store. If the KeyValue store with given name does not exist, ErrBucketNotFound will be returned.

(ctx context.Context, bucket string)

Source from the content-addressed store, hash-verified

38 // If the KeyValue store with given name does not exist,
39 // ErrBucketNotFound will be returned.
40 KeyValue(ctx context.Context, bucket string) (KeyValue, error)
41
42 // CreateKeyValue will create a KeyValue store with the given
43 // configuration.

Callers 7

TestKeyValueBindStoreFunction · 0.65
TestKeyValueDeleteStoreFunction · 0.65
TestKeyValueNonDirectGetFunction · 0.65
TestKeyValueBindStoreFunction · 0.65
TestKeyValueDeleteStoreFunction · 0.65

Implementers 1

jetStreamjetstream/jetstream.go

Calls

no outgoing calls

Tested by 7

TestKeyValueBindStoreFunction · 0.52
TestKeyValueDeleteStoreFunction · 0.52
TestKeyValueNonDirectGetFunction · 0.52
TestKeyValueBindStoreFunction · 0.52
TestKeyValueDeleteStoreFunction · 0.52