CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
25 namespace catapult {
namespace model {
class TransactionRegistry; } }
27 namespace catapult {
namespace observers {
40 const std::string&
name()
const override;
ReverseNotificationObserverAdapter(NotificationObserverPointer &&pObserver, NotificationPublisherPointer &&pPublisher)
Creates a new adapter around pObserver and pPublisher.
Definition: ReverseNotificationObserverAdapter.cpp:52
NotificationObserverPointerT< model::Notification > NotificationObserverPointer
Definition: ReverseNotificationObserverAdapter.h:32
A notification observer to entity observer adapter that reverses the order of raised notifications.
Definition: ReverseNotificationObserverAdapter.h:30
std::vector< std::vector< uint8_t > > m_notificationBuffers
Definition: ReverseNotificationObserverAdapter.cpp:48
Context passed to all the observers.
Definition: ObserverContext.h:78
void notify(const model::WeakEntityInfo &entityInfo, ObserverContext &context) const override
Notifies the observer with an entityInfo to process and an observer context.
Definition: ReverseNotificationObserverAdapter.cpp:63
Publish notification on observer channel.
constexpr bool IsSet(NotificationType type, NotificationChannel channel)
Checks if type has channel set.
Definition: NotificationType.h:61
model::AccountAddressNotification Notification
Definition: AddressValidator.cpp:27
Definition: EntityObserver.h:30
NotificationPublisherPointer m_pPublisher
Definition: ReverseNotificationObserverAdapter.h:46
std::unique_ptr< const model::NotificationPublisher > NotificationPublisherPointer
Definition: ReverseNotificationObserverAdapter.h:33
Wrapper around a strongly typed entity and its associated metadata.
Definition: WeakEntityInfo.h:33
const std::string & name() const override
Gets the observer name.
Definition: ReverseNotificationObserverAdapter.cpp:59
SynchronizationFilter CreateReversedTimestampsFilter()
Creates a filter that filters out samples where send and receive timestamps don't have proper order.
Definition: ReversedTimestampsFilter.cpp:26
NotificationObserverT< model::Notification > NotificationObserver
A notification observer for processing a generic Notification.
Definition: ObserverTypes.h:30
std::unique_ptr< const NotificationObserverT< TNotification > > NotificationObserverPointerT
A notification observer (unique) pointer.
Definition: ObserverTypes.h:34
predicate< const TimeSynchronizationSample &, NodeAge > SynchronizationFilter
Signature of a synchronization filter.
Definition: SynchronizationFilters.h:29
NotificationObserverPointer m_pObserver
Definition: ReverseNotificationObserverAdapter.h:45
Definition: AddressExtractionExtension.cpp:28