kvs is the implementation of KeyValue
| 432 | |
| 433 | // kvs is the implementation of KeyValue |
| 434 | type kvs struct { |
| 435 | name string |
| 436 | streamName string |
| 437 | pre string |
| 438 | putPre string |
| 439 | pushJS nats.JetStreamContext |
| 440 | js *jetStream |
| 441 | stream Stream |
| 442 | // If true, it means that APIPrefix/Domain was set in the context |
| 443 | // and we need to add something to some of our high level protocols |
| 444 | // (such as Put, etc..) |
| 445 | useJSPfx bool |
| 446 | // To know if we can use the stream direct get API |
| 447 | useDirect bool |
| 448 | } |
| 449 | |
| 450 | // KeyValueOp represents the type of KV operation (Put, Delete, Purge). It is a |
| 451 | // part of KeyValueEntry. |
nothing calls this directly
no outgoing calls
no test coverage detected