A B C D E G I K L M N P S

A

AbstractNotificationService - Class in co.cask.cdap.notifications.service

Common implementation of the the NotificationService that handles the subscriptions to all the notification feeds for the current process and that has the ability to push notifications to subscribers.

AbstractNotificationService(DatasetFramework, TransactionSystemClientService, NotificationFeedManager) - Constructor for class co.cask.cdap.notifications.service.AbstractNotificationService

B

BasicNotificationContext - Class in co.cask.cdap.notifications.service

Implementation of NotificationContext.

BasicNotificationContext(Id.Namespace, DatasetFramework, TransactionSystemClient) - Constructor for class co.cask.cdap.notifications.service.BasicNotificationContext

C

co.cask.cdap.notifications.feeds.guice - package co.cask.cdap.notifications.feeds.guice

co.cask.cdap.notifications.feeds.service - package co.cask.cdap.notifications.feeds.service

co.cask.cdap.notifications.guice - package co.cask.cdap.notifications.guice

co.cask.cdap.notifications.service - package co.cask.cdap.notifications.service

co.cask.cdap.notifications.service.inmemory - package co.cask.cdap.notifications.service.inmemory

co.cask.cdap.notifications.service.kafka - package co.cask.cdap.notifications.service.kafka

createFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.NotificationFeedService

createGson() - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

createNotificationFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.InMemoryNotificationFeedStore

createNotificationFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.MDSNotificationFeedStore

D

decode(ByteBuffer) - Static method in class co.cask.cdap.notifications.service.kafka.KafkaMessageCodec

deleteFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.NotificationFeedService

deleteNotificationFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.InMemoryNotificationFeedStore

deleteNotificationFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.MDSNotificationFeedStore

E

encode(KafkaMessage) - Static method in class co.cask.cdap.notifications.service.kafka.KafkaMessageCodec

execute(TxRunnable, TxRetryPolicy) - Method in class co.cask.cdap.notifications.service.BasicNotificationContext

G

getDistributedModules() - Method in class co.cask.cdap.notifications.feeds.guice.NotificationFeedServiceRuntimeModule

getDistributedModules() - Method in class co.cask.cdap.notifications.guice.NotificationServiceRuntimeModule

getFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.NotificationFeedService

getInMemoryModules() - Method in class co.cask.cdap.notifications.feeds.guice.NotificationFeedServiceRuntimeModule

getInMemoryModules() - Method in class co.cask.cdap.notifications.guice.NotificationServiceRuntimeModule

getKafkaTopicPartition(String, Id.NotificationFeed) - Static method in class co.cask.cdap.notifications.service.kafka.KafkaNotificationUtils

Map a Id.NotificationFeed to a Kafka topic partition.

getMessageFeed(String) - Static method in class co.cask.cdap.notifications.service.kafka.KafkaNotificationUtils

Return the Id.NotificationFeed attached to a Kafka message containing a notification.

getMessageKey(Id.NotificationFeed) - Static method in class co.cask.cdap.notifications.service.kafka.KafkaNotificationUtils

Build the key of a Kafka message based on a feed.

getNotificationFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.InMemoryNotificationFeedStore

getNotificationFeed(Id.NotificationFeed) - Method in class co.cask.cdap.notifications.feeds.service.MDSNotificationFeedStore

getStandaloneModules() - Method in class co.cask.cdap.notifications.feeds.guice.NotificationFeedServiceRuntimeModule

getStandaloneModules() - Method in class co.cask.cdap.notifications.guice.NotificationServiceRuntimeModule

getUncaughtExceptionLogger() - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

I

InMemoryNotificationFeedStore - Class in co.cask.cdap.notifications.feeds.service

Implementation of the NotificationFeedStore that keeps the feeds in memory.

InMemoryNotificationFeedStore() - Constructor for class co.cask.cdap.notifications.feeds.service.InMemoryNotificationFeedStore

InMemoryNotificationService - Class in co.cask.cdap.notifications.service.inmemory

In-memory Notification service that pushes notifications to subscribers.

InMemoryNotificationService(DatasetFramework, TransactionSystemClientService, NotificationFeedManager) - Constructor for class co.cask.cdap.notifications.service.inmemory.InMemoryNotificationService

K

KafkaMessageCodec - Class in co.cask.cdap.notifications.service.kafka

Encoder/decoder of Notifications to Kafka messages.

KafkaNotificationService - Class in co.cask.cdap.notifications.service.kafka

Kafka implementation of the NotificationService.

KafkaNotificationUtils - Class in co.cask.cdap.notifications.service.kafka

Util methods for using Notifications with Kafka.

L

listFeeds(Id.Namespace) - Method in class co.cask.cdap.notifications.feeds.service.NotificationFeedService

listNotificationFeeds(Id.Namespace) - Method in class co.cask.cdap.notifications.feeds.service.InMemoryNotificationFeedStore

listNotificationFeeds(Id.Namespace) - Method in class co.cask.cdap.notifications.feeds.service.MDSNotificationFeedStore

M

MDSNotificationFeedStore - Class in co.cask.cdap.notifications.feeds.service

Implementation of NotificationFeedStore that access MDS directly.

MDSNotificationFeedStore(TransactionExecutorFactory, DatasetFramework) - Constructor for class co.cask.cdap.notifications.feeds.service.MDSNotificationFeedStore

N

NotificationFeedService - Class in co.cask.cdap.notifications.feeds.service

Service side of the NotificationFeedManager.

NotificationFeedService(NotificationFeedStore) - Constructor for class co.cask.cdap.notifications.feeds.service.NotificationFeedService

NotificationFeedServiceRuntimeModule - Class in co.cask.cdap.notifications.feeds.guice

Guice modules for service side of the notification feed manager.

NotificationFeedServiceRuntimeModule() - Constructor for class co.cask.cdap.notifications.feeds.guice.NotificationFeedServiceRuntimeModule

notificationReceived(Id.NotificationFeed, JsonElement) - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

Called when a notification is received on a feed, to push it to all the handlers that subscribed to the feed.

NotificationServiceRuntimeModule - Class in co.cask.cdap.notifications.guice

Guice modules to use the NotificationService.

NotificationServiceRuntimeModule() - Constructor for class co.cask.cdap.notifications.guice.NotificationServiceRuntimeModule

P

publish(Id.NotificationFeed, N) - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

publish(Id.NotificationFeed, N, Type) - Method in class co.cask.cdap.notifications.service.inmemory.InMemoryNotificationService

publish(Id.NotificationFeed, N, Type) - Method in class co.cask.cdap.notifications.service.kafka.KafkaNotificationService

S

shutDown() - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

shutDown() - Method in class co.cask.cdap.notifications.service.inmemory.InMemoryNotificationService

shutDown() - Method in class co.cask.cdap.notifications.service.kafka.KafkaNotificationService

startUp() - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

startUp() - Method in class co.cask.cdap.notifications.service.inmemory.InMemoryNotificationService

startUp() - Method in class co.cask.cdap.notifications.service.kafka.KafkaNotificationService

subscribe(Id.NotificationFeed, NotificationHandler<N>) - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

subscribe(Id.NotificationFeed, NotificationHandler<N>, Executor) - Method in class co.cask.cdap.notifications.service.AbstractNotificationService

subscribe(Id.NotificationFeed, NotificationHandler<N>, Executor) - Method in class co.cask.cdap.notifications.service.kafka.KafkaNotificationService

A B C D E G I K L M N P S