dependencies {
implementation "pl.allegro.tech.couchbase-commons:couchbase:1.0"
}
val bucket = cluster.bucket(bucketName)
val reactiveCollection = bucket.defaultCollection()
val collection = ReactiveCouchbaseCollection(reactiveCollection).withPrefix(prefix)
val repository = TypedCouchbaseRepository(collection, DTO::class.java, SimpleMeterRegistry())
val dto = DTO("key", "value")
repository.put(dto.id, dto).block()
val actualDto = repository.get(dto.id)
val repository = CouchbaseSetRepository(collection, DTO::class.java, meterRegistry)
val ttl = Duration.ofSeconds(60)
repository.add("somekey", setOf(DTO("id_1", "value_1")), ttl = ttl)