co.cask.cdap.notifications.feeds.service

Class MDSNotificationFeedStore

java.lang.Object

co.cask.cdap.notifications.feeds.service.MDSNotificationFeedStore

All Implemented Interfaces:

NotificationFeedStore

public final class MDSNotificationFeedStore
extends Object
implements NotificationFeedStore

Implementation of NotificationFeedStore that access MDS directly.

Constructor Summary

Constructors

Constructor and Description
MDSNotificationFeedStore(org.apache.tephra.TransactionExecutorFactory txExecutorFactory, DatasetFramework dsFramework)

Method Summary

Methods

Modifier and Type	Method and Description
Id.NotificationFeed	createNotificationFeed(Id.NotificationFeed feed)
Id.NotificationFeed	deleteNotificationFeed(Id.NotificationFeed feed)
Id.NotificationFeed	getNotificationFeed(Id.NotificationFeed feed)
List<Id.NotificationFeed>	listNotificationFeeds(Id.Namespace namespace)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MDSNotificationFeedStore

@Inject
public MDSNotificationFeedStore(org.apache.tephra.TransactionExecutorFactory txExecutorFactory,
                               DatasetFramework dsFramework)

Method Detail

createNotificationFeed

public Id.NotificationFeed createNotificationFeed(Id.NotificationFeed feed)

Specified by:

createNotificationFeed in interface NotificationFeedStore

getNotificationFeed

public Id.NotificationFeed getNotificationFeed(Id.NotificationFeed feed)

Specified by:

getNotificationFeed in interface NotificationFeedStore

deleteNotificationFeed

public Id.NotificationFeed deleteNotificationFeed(Id.NotificationFeed feed)

Specified by:

deleteNotificationFeed in interface NotificationFeedStore

listNotificationFeeds

public List<Id.NotificationFeed> listNotificationFeeds(Id.Namespace namespace)

Specified by:

listNotificationFeeds in interface NotificationFeedStore