Documentation
¶
Index ¶
- func CreateKeyValue(nc *nats.Conn, js nats.JetStreamContext, cfg *nats.KeyValueConfig) (nats.KeyValue, error)
- func KVDelete(js nats.JetStreamContext, kv nats.KeyValue, key string) error
- func KVGet(js nats.JetStreamContext, kv nats.KeyValue, key string) (nats.KeyValueEntry, error)
- func KVPut(js nats.JetStreamContext, kv nats.KeyValue, key string, value []byte) (revision uint64, err error)
- func KVUpdate(js nats.JetStreamContext, kv nats.KeyValue, key string, value []byte, ...) (uint64, error)
- func KeyValid(key string) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateKeyValue ¶
func CreateKeyValue(nc *nats.Conn, js nats.JetStreamContext, cfg *nats.KeyValueConfig) (nats.KeyValue, error)
CreateKeyValue will create a KeyValue store with the following configuration.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.