couchbase-commons

Usage

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)

TypedCouchbaseRepository

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)

CouchbaseSetRepository

val repository = CouchbaseSetRepository(collection, DTO::class.java, meterRegistry)

val ttl = Duration.ofSeconds(60)
repository.add("somekey", setOf(DTO("id_1", "value_1")), ttl = ttl)