kernel/me.ahoo.wow.kernel.memory/InMemoryLeaseStore

InMemoryLeaseStore

class InMemoryLeaseStore(clock: Clock = Clock.systemUTC()) : LeaseStore

A LeaseStore in memory, for tests and single-process samples; its time comes from clock. One lock serializes every operation. A released lease is kept with expiry 0, so the next acquisition continues its epoch.

Constructors

InMemoryLeaseStore

constructor(clock: Clock = Clock.systemUTC())

Functions

acquire

open suspend override fun acquire(group: String, partition: Int, owner: String, ttl: Duration): Lease?

heartbeat

open suspend override fun heartbeat(service: String, node: String, address: String, ttl: Duration, groups: Set<String>): Member

leave

open suspend override fun leave(service: String, node: String)

members

open suspend override fun members(service: String): List<Member>

owners

open suspend override fun owners(group: String): List<Lease>

release

open suspend override fun release(group: String, partition: Int, owner: String): Boolean

renew

open suspend override fun renew(group: String, partitions: Collection<Int>, owner: String, ttl: Duration): List<Lease>