(t *testing.T)
| 162 | } |
| 163 | |
| 164 | func TestCreateKeyValue(t *testing.T) { |
| 165 | s := RunBasicJetStreamServer() |
| 166 | defer shutdownJSServerAndRemoveStorage(t, s) |
| 167 | |
| 168 | nc, js := jsClient(t, s) |
| 169 | defer nc.Close() |
| 170 | ctx := context.Background() |
| 171 | |
| 172 | // invalid bucket name |
| 173 | _, err := js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: "TEST.", Description: "Test KV"}) |
| 174 | expectErr(t, err, jetstream.ErrInvalidBucketName) |
| 175 | |
| 176 | _, err = js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: "TEST", Description: "Test KV"}) |
| 177 | expectOk(t, err) |
| 178 | |
| 179 | // Check that we can't overwrite existing bucket. |
| 180 | _, err = js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: "TEST", Description: "New KV"}) |
| 181 | expectErr(t, err, jetstream.ErrBucketExists) |
| 182 | |
| 183 | // assert that we're backwards compatible |
| 184 | expectErr(t, err, jetstream.ErrStreamNameAlreadyInUse) |
| 185 | |
| 186 | // invalid configs |
| 187 | _, err = js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: "NEW", History: 200}) |
| 188 | expectErr(t, err, jetstream.ErrHistoryTooLarge) |
| 189 | } |
| 190 | |
| 191 | func TestUpdateKeyValue(t *testing.T) { |
| 192 | s := RunBasicJetStreamServer() |
nothing calls this directly
no test coverage detected