Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface IAtomicLong

IAtomicLong is a redundant and highly available distributed counter for 64-bit integers (long type in java).

It works on top of the Raft consensus algorithm. It offers linearizability during crash failures and network partitions. It is CP with respect to the CAP principle. If a network partition occurs, it remains available on at most one side of the partition.

IAtomicLong implementation does not offer exactly-once / effectively-once execution semantics. It goes with at-least-once execution semantics by default and can cause an API call to be committed multiple times in case of CP member failures. It can be tuned to offer at-most-once execution semantics. Please see fail-on-indeterminate-operation-state server-side setting.

Hierarchy

Index

Methods

Methods

addAndGet

  • addAndGet(delta: number | Long): Promise<Long>

  • Atomically adds the given value to the current value.

    Parameters

    • delta: number | Long

      the value to add to the current value

    Returns Promise<Long>

    the updated value, the given value added to the current value

compareAndSet

  • compareAndSet(expect: number | Long, update: number | Long): Promise<boolean>

  • Atomically sets the value to the given updated value only if the current value equals the expected value.

    Parameters

    • expect: number | Long

      the expected value

    • update: number | Long

      the new value

    Returns Promise<boolean>

    true if successful; or false if the actual value was not equal to the expected value.

decrementAndGet

  • decrementAndGet(): Promise<Long>

  • Atomically decrements the current value by one.

    Returns Promise<Long>

    the updated value, the current value decremented by one

destroy

  • destroy(): Promise<void>

get

  • get(): Promise<Long>

getAndAdd

  • getAndAdd(delta: number | Long): Promise<Long>

  • Atomically adds the given value to the current value.

    Parameters

    • delta: number | Long

      the value to add to the current value

    Returns Promise<Long>

    the old value before the add

getAndDecrement

  • getAndDecrement(): Promise<Long>

getAndIncrement

  • getAndIncrement(): Promise<Long>

getAndSet

  • getAndSet(newValue: number | Long): Promise<Long>

  • Atomically sets the given value and returns the old value.

    Parameters

    • newValue: number | Long

      the new value

    Returns Promise<Long>

    the old value

getName

  • getName(): string

getPartitionKey

  • getPartitionKey(): string

getServiceName

  • getServiceName(): string

incrementAndGet

  • incrementAndGet(): Promise<Long>

  • Atomically increments the current value by one.

    Returns Promise<Long>

    the updated value, the current value incremented by one

set

  • set(newValue: number | Long): Promise<void>

  • Atomically sets the given value.

    Parameters

    • newValue: number | Long

      the new value

    Returns Promise<void>

Generated using TypeDoc