(ctx context.Context, location, key string, value interface{})
| 310 | } |
| 311 | |
| 312 | func (cc *CouchbaseCluster) InsertMetadataDocument(ctx context.Context, location, key string, value interface{}) (newCAS uint64, err error) { |
| 313 | if cc == nil { |
| 314 | return 0, errors.New("nil CouchbaseCluster") |
| 315 | } |
| 316 | |
| 317 | b, teardown, err := cc.getBucket(ctx, location) |
| 318 | if err != nil { |
| 319 | return 0, err |
| 320 | } |
| 321 | defer teardown() |
| 322 | |
| 323 | return cc.configPersistence.insertConfig(b.DefaultCollection(), key, value) |
| 324 | } |
| 325 | |
| 326 | // WriteMetadataDocument writes a metadata document, and fails on CAS mismatch |
| 327 | func (cc *CouchbaseCluster) WriteMetadataDocument(ctx context.Context, location, docID string, cas uint64, value interface{}) (newCAS uint64, err error) { |
nothing calls this directly
no test coverage detected