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

Method CreateKeyValue

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

CreateKeyValue will create a KeyValue store with the given configuration. If a KeyValue store with the same name already exists and the configuration is different, ErrBucketExists will be returned.

(ctx context.Context, cfg KeyValueConfig)

Source from the content-addressed store, hash-verified

45 // If a KeyValue store with the same name already exists and the
46 // configuration is different, ErrBucketExists will be returned.
47 CreateKeyValue(ctx context.Context, cfg KeyValueConfig) (KeyValue, error)
48
49 // UpdateKeyValue will update an existing KeyValue store with the given
50 // configuration.

Callers 15

TestKeyValueBasicsFunction · 0.65
TestKeyValueHistoryFunction · 0.65
TestKeyValueWatchFunction · 0.65
TestKeyValueWatchContextFunction · 0.65
TestKeyValueWatchContextUpdatesFunction · 0.65
TestKeyValueBindStoreFunction · 0.65
TestKeyValueDeleteStoreFunction · 0.65
TestKeyValueDeleteVsPurgeFunction · 0.65
TestKeyValueDeleteTombstonesFunction · 0.65
TestKeyValuePurgeDeletesMarkerThresholdFunction · 0.65
TestKeyValueKeysFunction · 0.65
TestKeyValueListKeysFunction · 0.65

Implementers 1

jetStreamjetstream/jetstream.go

Calls

no outgoing calls

Tested by 15

TestKeyValueBasicsFunction · 0.52
TestKeyValueHistoryFunction · 0.52
TestKeyValueWatchFunction · 0.52
TestKeyValueWatchContextFunction · 0.52
TestKeyValueWatchContextUpdatesFunction · 0.52
TestKeyValueBindStoreFunction · 0.52
TestKeyValueDeleteStoreFunction · 0.52
TestKeyValueDeleteVsPurgeFunction · 0.52
TestKeyValueDeleteTombstonesFunction · 0.52
TestKeyValuePurgeDeletesMarkerThresholdFunction · 0.52
TestKeyValueKeysFunction · 0.52
TestKeyValueListKeysFunction · 0.52