C D E G H L M N P R S T V

C

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

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

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

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

configure() - Method in class co.cask.cdap.notifications.feeds.client.NotificationFeedClientModule

createFeed(NotificationFeedInfo) - Method in class co.cask.cdap.notifications.feeds.client.RemoteNotificationFeedManager

createFeed(NotificationFeedInfo) - Method in interface co.cask.cdap.notifications.feeds.NotificationFeedManager

Create a notification feed.

createFeed(NotificationFeedInfo) - Method in class co.cask.cdap.notifications.feeds.service.NoOpNotificationFeedManager

createNotificationFeed(NotificationFeedInfo) - Method in interface co.cask.cdap.notifications.feeds.service.NotificationFeedStore

Creates a new Notification feed.

D

deleteFeed(NotificationFeedId) - Method in class co.cask.cdap.notifications.feeds.client.RemoteNotificationFeedManager

deleteFeed(NotificationFeedId) - Method in interface co.cask.cdap.notifications.feeds.NotificationFeedManager

Deletes the feed from the manager store.

deleteFeed(NotificationFeedId) - Method in class co.cask.cdap.notifications.feeds.service.NoOpNotificationFeedManager

deleteNotificationFeed(NotificationFeedId) - Method in interface co.cask.cdap.notifications.feeds.service.NotificationFeedStore

Deletes a Notification feed from the metadata store.

E

execute(TxRunnable, TxRetryPolicy) - Method in interface co.cask.cdap.notifications.service.NotificationContext

Execute a set of operations on datasets via a TxRunnable that are committed as a single transaction.

G

getFeed(NotificationFeedId) - Method in class co.cask.cdap.notifications.feeds.client.RemoteNotificationFeedManager

getFeed(NotificationFeedId) - Method in interface co.cask.cdap.notifications.feeds.NotificationFeedManager

Get a NotificationFeedId based on the feed.getId() method of the feed argument.

getFeed(NotificationFeedId) - Method in class co.cask.cdap.notifications.feeds.service.NoOpNotificationFeedManager

getId() - Method in exception co.cask.cdap.notifications.feeds.NotificationFeedNotFoundException

getNotificationFeed(NotificationFeedId) - Method in interface co.cask.cdap.notifications.feeds.service.NotificationFeedStore

Retrieves a Notification feed from the metadata store.

getNotificationType() - Method in interface co.cask.cdap.notifications.service.NotificationHandler

H

handleFailure(int, Throwable) - Method in class co.cask.cdap.notifications.service.TxRetryPolicy

Specify how failure should be handled.

L

listFeeds(NamespaceId) - Method in class co.cask.cdap.notifications.feeds.client.RemoteNotificationFeedManager

listFeeds(NamespaceId) - Method in interface co.cask.cdap.notifications.feeds.NotificationFeedManager

List all the NotificationFeedInfos present in the manager store for a namespace.

listFeeds(NamespaceId) - Method in class co.cask.cdap.notifications.feeds.service.NoOpNotificationFeedManager

listNotificationFeeds(NamespaceId) - Method in interface co.cask.cdap.notifications.feeds.service.NotificationFeedStore

Lists all registered Notification feeds for the namespace.

M

maxRetries(int) - Static method in class co.cask.cdap.notifications.service.TxRetryPolicy

Create a TxRetryPolicy object that retries a maximum of tries.

N

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

Implementation of the NotificationFeedManager used for testing purposes.

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

NotificationContext - Interface in co.cask.cdap.notifications.service

Context accessible when handling the reception of a Notification by the NotificationHandler.received(N, co.cask.cdap.notifications.service.NotificationContext) method.

NotificationException - Exception in co.cask.cdap.notifications.service

Exceptions about notifications.

NotificationException(String) - Constructor for exception co.cask.cdap.notifications.service.NotificationException

NotificationException(Throwable) - Constructor for exception co.cask.cdap.notifications.service.NotificationException

NotificationException(String, Throwable) - Constructor for exception co.cask.cdap.notifications.service.NotificationException

NotificationFeedClientModule - Class in co.cask.cdap.notifications.feeds.client

Guice module to connect to a remote NotificationFeedManager.

NotificationFeedClientModule() - Constructor for class co.cask.cdap.notifications.feeds.client.NotificationFeedClientModule

NotificationFeedException - Exception in co.cask.cdap.notifications.feeds

Exceptions about notification feed.

NotificationFeedException(String) - Constructor for exception co.cask.cdap.notifications.feeds.NotificationFeedException

NotificationFeedException(Throwable) - Constructor for exception co.cask.cdap.notifications.feeds.NotificationFeedException

NotificationFeedException(String, Throwable) - Constructor for exception co.cask.cdap.notifications.feeds.NotificationFeedException

NotificationFeedManager - Interface in co.cask.cdap.notifications.feeds

Manager for NotificationFeedId objects.

NotificationFeedNotFoundException - Exception in co.cask.cdap.notifications.feeds

Exception thrown when a NotificationFeedId object is not found.

NotificationFeedNotFoundException(NotificationFeedId) - Constructor for exception co.cask.cdap.notifications.feeds.NotificationFeedNotFoundException

NotificationFeedStore - Interface in co.cask.cdap.notifications.feeds.service

Store for NotificationFeedId objects.

NotificationHandler<N> - Interface in co.cask.cdap.notifications.service

Notification handler passed when subscribing to a NotificationFeedId using NotificationService.subscribe(co.cask.cdap.proto.id.NotificationFeedId, co.cask.cdap.notifications.service.NotificationHandler<N>).

NotificationService - Interface in co.cask.cdap.notifications.service

A Notification service for publishing and subscribing to notifications.

P

publish(NotificationFeedId, N) - Method in interface co.cask.cdap.notifications.service.NotificationService

Send one Notification asynchronously.

publish(NotificationFeedId, N, Type) - Method in interface co.cask.cdap.notifications.service.NotificationService

Send one Notification asynchronously.

R

received(N, NotificationContext) - Method in interface co.cask.cdap.notifications.service.NotificationHandler

Method called when a notification is received by this handler.

RemoteNotificationFeedManager - Class in co.cask.cdap.notifications.feeds.client

Implementation of the NotificationFeedManager that connects to a remote feed manager service through internal RESTful APIs.

RemoteNotificationFeedManager(DiscoveryServiceClient) - Constructor for class co.cask.cdap.notifications.feeds.client.RemoteNotificationFeedManager

S

subscribe(NotificationFeedId, NotificationHandler<N>) - Method in interface co.cask.cdap.notifications.service.NotificationService

Subscribe to the notification received on the feed, and handle the notifications with the handler.

subscribe(NotificationFeedId, NotificationHandler<N>, Executor) - Method in interface co.cask.cdap.notifications.service.NotificationService

Subscribe to the notification received on the feed, and handle the notifications with the handler.

T

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

Retry policy object used by the NotificationContext.execute(co.cask.cdap.api.TxRunnable, co.cask.cdap.notifications.service.TxRetryPolicy) method to specify behavior when transaction execution fails.

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

TxRetryPolicy.Policy - Enum in co.cask.cdap.notifications.service

Failure policy option enum.

V

valueOf(String) - Static method in enum co.cask.cdap.notifications.service.TxRetryPolicy.Policy

Returns the enum constant of this type with the specified name.

values() - Static method in enum co.cask.cdap.notifications.service.TxRetryPolicy.Policy

Returns an array containing the constants of this enum type, in the order they are declared.

C D E G H L M N P R S T V