Modifier and Type | Class and Description |
---|---|
class |
Event<T extends HasMetadata>
An
AbstractEvent that represents another event that has
occurred to a Kubernetes resource, usually as found in an EventCache implementation. |
class |
SynchronizationEvent<T extends HasMetadata>
An
AbstractEvent that describes an EventCache
synchronization event. |
Modifier and Type | Method and Description |
---|---|
protected Collection<AbstractEvent<T>> |
EventQueue.compress(Collection<AbstractEvent<T>> events)
Performs a compression operation on the supplied
Collection of AbstractEvent s and returns the result of that
operation. |
Iterator<AbstractEvent<T>> |
EventQueue.iterator()
Synchronizes on this
EventQueue and, while holding its
monitor, returns an unmodifiable Iterator over its
contents. |
Modifier and Type | Method and Description |
---|---|
protected void |
EventDistributor.accept(AbstractEvent<? extends T> event)
Consumes the supplied
AbstractEvent by forwarding it to
the Consumer.accept(Object) method of each Consumer registered with
this EventDistributor . |
protected abstract void |
ResourceTrackingEventQueueConsumer.accept(AbstractEvent<? extends T> event)
Called to process a given
AbstractEvent from the EventQueue supplied to the ResourceTrackingEventQueueConsumer.accept(EventQueue) method,
with that EventQueue 's monitor held. |
Modifier and Type | Method and Description |
---|---|
void |
EventDistributor.addConsumer(Consumer<? super AbstractEvent<? extends T>> consumer)
Adds the supplied
Consumer to this EventDistributor as a listener that will be notified of each
AbstractEvent this EventDistributor receives. |
void |
EventDistributor.addConsumer(Consumer<? super AbstractEvent<? extends T>> consumer,
Function<? super Throwable,Boolean> errorHandler)
Adds the supplied
Consumer to this EventDistributor as a listener that will be notified of each
AbstractEvent this EventDistributor receives. |
protected Collection<AbstractEvent<T>> |
EventQueue.compress(Collection<AbstractEvent<T>> events)
Performs a compression operation on the supplied
Collection of AbstractEvent s and returns the result of that
operation. |
void |
EventQueue.forEach(Consumer<? super AbstractEvent<T>> action)
Synchronizes on this
EventQueue and, while holding its
monitor, invokes the Consumer.accept(Object) method on
the supplied Consumer for every AbstractEvent in
this EventQueue . |
void |
EventDistributor.removeConsumer(Consumer<? super AbstractEvent<? extends T>> consumer)
|
Copyright © 2017–2021, microBean™. All rights reserved.