- raf - Variable in class io.zeebe.util.allocation.AllocatedMappedFile
-
- rawBuffer - Variable in class io.zeebe.util.allocation.AllocatedBuffer
-
- read(InputStream, byte[]) - Static method in class io.zeebe.util.StreamUtil
-
- read(InputStream, MutableDirectBuffer, int) - Static method in class io.zeebe.util.StreamUtil
-
- read(InputStream, byte[], int) - Static method in class io.zeebe.util.StreamUtil
-
- read(InputStream) - Static method in class io.zeebe.util.StreamUtil
-
- read(String, Class<T>) - Static method in class io.zeebe.util.TomlConfigurationReader
-
- read(InputStream, Class<T>) - Static method in class io.zeebe.util.TomlConfigurationReader
-
- readBuffer - Variable in class io.zeebe.util.buffer.DirectBufferReader
-
- readBytes(VarDataUtil.VarDataReader, VarDataUtil.VarDataLengthProvider) - Static method in class io.zeebe.util.VarDataUtil
-
- readBytes(VarDataUtil.VarDataReader, int) - Static method in class io.zeebe.util.VarDataUtil
-
- readBytes(VarDataUtil.VarDataReader, int, int) - Static method in class io.zeebe.util.VarDataUtil
-
- readIntoBuffer(DirectBuffer, int, DirectBuffer) - Static method in class io.zeebe.util.buffer.BufferUtil
-
- readIntoBuffer(DirectBuffer, int, BufferReader) - Static method in class io.zeebe.util.buffer.BufferUtil
-
NOTE: as opposed to readIntoBuffer above, this does not clone the buffer to be read, just wraps
it.
- readLong(InputStream) - Static method in class io.zeebe.util.StreamUtil
-
- recordRunnerBusyTime(long) - Method in class io.zeebe.util.sched.metrics.ActorThreadMetrics
-
- recordRunnerIdleTime(long) - Method in class io.zeebe.util.sched.metrics.ActorThreadMetrics
-
- ReflectUtil - Class in io.zeebe.util
-
- ReflectUtil() - Constructor for class io.zeebe.util.ReflectUtil
-
- registerConsumer(ActorCondition) - Method in class io.zeebe.util.sched.channel.ActorConditions
-
- registerConsumer(ActorCondition) - Method in class io.zeebe.util.sched.channel.ConcurrentQueueChannel
-
- registerConsumer(ActorCondition) - Method in interface io.zeebe.util.sched.channel.ConsumableChannel
-
- registerConsumer(ActorCondition) - Method in class io.zeebe.util.sched.channel.OneToOneRingBufferChannel
-
- release() - Method in interface io.zeebe.util.PooledFuture
-
- remove(Object) - Method in class io.zeebe.util.BoundedArrayQueue
-
- remove() - Method in class io.zeebe.util.BoundedArrayQueue
-
- remove(long) - Method in class io.zeebe.util.cache.ExpandableBufferCache
-
- remove(int) - Method in class io.zeebe.util.collection.CompactList
-
Removes the element at the specified position in this list.
- remove(T) - Method in class io.zeebe.util.collection.ReusableObjectList
-
- remove(TimerSubscription) - Method in class io.zeebe.util.sched.ActorTimerQueue
-
- remove() - Method in class io.zeebe.util.sched.channel.ConcurrentQueueChannel
-
- remove(Object) - Method in class io.zeebe.util.sched.channel.ConcurrentQueueChannel
-
- remove(Object) - Method in class io.zeebe.util.sched.ClosedQueue
-
- remove() - Method in class io.zeebe.util.sched.ClosedQueue
-
- removeAll(Collection<?>) - Method in class io.zeebe.util.BoundedArrayQueue
-
- removeAll(Collection<?>) - Method in class io.zeebe.util.sched.channel.ConcurrentQueueChannel
-
- removeAll(Collection<?>) - Method in class io.zeebe.util.sched.ClosedQueue
-
- removeConsumer(ActorCondition) - Method in class io.zeebe.util.sched.channel.ActorConditions
-
- removeConsumer(ActorCondition) - Method in class io.zeebe.util.sched.channel.ConcurrentQueueChannel
-
- removeConsumer(ActorCondition) - Method in interface io.zeebe.util.sched.channel.ConsumableChannel
-
- removeConsumer(ActorCondition) - Method in class io.zeebe.util.sched.channel.OneToOneRingBufferChannel
-
- removeFirst() - Method in class io.zeebe.util.sched.ClosedQueue
-
- removeFirstOccurrence(Object) - Method in class io.zeebe.util.sched.ClosedQueue
-
- removeLast() - Method in class io.zeebe.util.sched.ClosedQueue
-
- removeLastOccurrence(Object) - Method in class io.zeebe.util.sched.ClosedQueue
-
- removeTimer(TimerSubscription) - Method in class io.zeebe.util.sched.ActorThread
-
Must be called from this thread, remove a scheduled job.
- replace(Path, Path) - Static method in class io.zeebe.util.FileUtil
-
Overwrites file at dest with src.
- reportExecutionTime(long) - Method in class io.zeebe.util.sched.ActorTask
-
- reportExecutionTime(long) - Method in class io.zeebe.util.sched.metrics.TaskMetrics
-
- request() - Method in class io.zeebe.util.collection.ObjectPool
-
- requestClose() - Method in class io.zeebe.util.sched.ActorTask
-
- RequestWriter - Interface in io.zeebe.util.buffer
-
- requiredBufferCapacity(int, int) - Static method in class io.zeebe.util.collection.CompactListDescriptor
-
- reset() - Method in class io.zeebe.util.buffer.DirectBufferWriter
-
- reset() - Method in class io.zeebe.util.collection.CompactListIterator
-
Reset the current position of iterator.
- reset() - Method in interface io.zeebe.util.collection.Reusable
-
- reset() - Method in class io.zeebe.util.sched.clock.ControlledActorClock
-
- resolve(T) - Method in interface io.zeebe.util.PooledFuture
-
- resubmit() - Method in class io.zeebe.util.sched.ActorTask
-
- retainAll(Collection<?>) - Method in class io.zeebe.util.BoundedArrayQueue
-
- retainAll(Collection<?>) - Method in class io.zeebe.util.sched.channel.ConcurrentQueueChannel
-
- retainAll(Collection<?>) - Method in class io.zeebe.util.sched.ClosedQueue
-
- rethrowUnchecked(Throwable) - Static method in class io.zeebe.util.LangUtil
-
- returnObject(T) - Method in class io.zeebe.util.collection.ObjectPool
-
- Reusable - Interface in io.zeebe.util.collection
-
- ReusableObjectList<T extends Reusable> - Class in io.zeebe.util.collection
-
An expendable list of reusable objects.
- ReusableObjectList(Supplier<T>) - Constructor for class io.zeebe.util.collection.ReusableObjectList
-
- run() - Method in interface io.zeebe.util.LogUtil.ThrowingRunnable
-
- run(Runnable) - Method in class io.zeebe.util.sched.ActorControl
-
Runnables submitted by the actor itself are executed while the actor is in any of its lifecycle
phases.
- run() - Method in class io.zeebe.util.sched.ActorThread
-
- run() - Method in class io.zeebe.util.sched.BlockingPollSubscription
-
- run() - Method in class io.zeebe.util.sched.future.FutureContinuationRunnable
-
- run() - Method in class io.zeebe.util.sched.RunnableAdapter
-
- run() - Method in class io.zeebe.util.sched.TimerSubscription
-
- runAsync(Consumer<CompletableFuture<T>>) - Method in class io.zeebe.util.DeferredCommandContext
-
- runAsync(Runnable) - Method in class io.zeebe.util.DeferredCommandContext
-
Use this when no future is required.
- runAtFixedRate(Duration, Runnable) - Method in class io.zeebe.util.sched.ActorControl
-
Scheduled a repeating timer
- runBlocking(Runnable) - Method in class io.zeebe.util.sched.ActorControl
-
run a blocking task
- runBlocking(Runnable, Consumer<Throwable>) - Method in class io.zeebe.util.sched.ActorControl
-
The provided runnable is executed in any of the actor's lifecycle phases.
- runDelayed(Duration, Runnable) - Method in class io.zeebe.util.sched.ActorControl
-
- RunnableAdapter<T> - Class in io.zeebe.util.sched
-
- RunnableAdapter(Callable<T>) - Constructor for class io.zeebe.util.sched.RunnableAdapter
-
- runOnCompletion(ActorFuture<T>, BiConsumer<T, Throwable>) - Method in class io.zeebe.util.sched.ActorControl
-
Invoke the callback when the given future is completed (successfully or exceptionally).
- runOnCompletion(Collection<ActorFuture<T>>, Consumer<Throwable>) - Method in class io.zeebe.util.sched.ActorControl
-
Invoke the callback when the given futures are completed (successfully or exceptionally).
- runOnCompletionBlockingCurrentPhase(ActorFuture<T>, BiConsumer<T, Throwable>) - Method in class io.zeebe.util.sched.ActorControl
-
Invoke the callback when the given future is completed (successfully or exceptionally).
- runOnFirstCompletion(Collection<ActorFuture<T>>, BiConsumer<T, Throwable>) - Method in class io.zeebe.util.sched.ActorControl
-
Invoke the callback when the first future is completed successfully, or when all futures are
completed exceptionally.
- runOnFirstCompletion(Collection<ActorFuture<T>>, BiConsumer<T, Throwable>, Consumer<T>) - Method in class io.zeebe.util.sched.ActorControl
-
Invoke the callback when the first future is completed successfully, or when all futures are
completed exceptionally.
- runUntilDone(Runnable) - Method in class io.zeebe.util.sched.ActorControl
-