A B C D E F G H I L M O P R S T U V W

A

AbstractMessageTable - Class in co.cask.cdap.messaging.store

Contains common logic for implementation of MessageTable.

AbstractMessageTable() - Constructor for class co.cask.cdap.messaging.store.AbstractMessageTable

AbstractPayloadTable - Class in co.cask.cdap.messaging.store

Contains common logic for implementation of PayloadTable.

AbstractPayloadTable() - Constructor for class co.cask.cdap.messaging.store.AbstractPayloadTable

addAll(Iterator<T>) - Method in class co.cask.cdap.messaging.cache.MessageCache

Adds a list of entries to the cache.

addPayloads(byte[]...) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Adds a list of byte arrays as the payloads of the request.

addPayloads(String...) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Adds a list of Strings as the payloads of the request.

addPayloads(Iterator<byte[]>) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Adds a list of byte arrays as the payloads of the request.

alwaysAccept() - Static method in class co.cask.cdap.messaging.store.MessageFilter

Creates a MessageFilter that always accept.

apply(T) - Method in class co.cask.cdap.messaging.store.MessageFilter

apply(MessageTable.Entry) - Method in class co.cask.cdap.messaging.store.TransactionMessageFilter

B

bindHandlers(Binder, String) - Static method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

build() - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Creates a StoreRequest based on the settings in this builder.

C

CachingTableFactory - Class in co.cask.cdap.messaging.store.cache

A TableFactory with optional caching for MessageTable that it creates.

clear() - Method in class co.cask.cdap.messaging.cache.MessageCache

Clears the cache.

clear() - Method in class co.cask.cdap.messaging.store.cache.DefaultMessageTableCacheProvider

clear() - Method in interface co.cask.cdap.messaging.store.cache.MessageTableCacheProvider

Resets all MessageCache created by this cache provider.

ClientMessagingService - Class in co.cask.cdap.messaging.client

The client implementation of MessagingService.

ClientMessagingService(DiscoveryServiceClient) - Constructor for class co.cask.cdap.messaging.client.ClientMessagingService

close() - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

close() - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

co.cask.cdap.messaging - package co.cask.cdap.messaging

co.cask.cdap.messaging.cache - package co.cask.cdap.messaging.cache

co.cask.cdap.messaging.client - package co.cask.cdap.messaging.client

co.cask.cdap.messaging.data - package co.cask.cdap.messaging.data

co.cask.cdap.messaging.distributed - package co.cask.cdap.messaging.distributed

co.cask.cdap.messaging.guice - package co.cask.cdap.messaging.guice

co.cask.cdap.messaging.server - package co.cask.cdap.messaging.server

co.cask.cdap.messaging.service - package co.cask.cdap.messaging.service

co.cask.cdap.messaging.store - package co.cask.cdap.messaging.store

co.cask.cdap.messaging.store.cache - package co.cask.cdap.messaging.store.cache

co.cask.cdap.messaging.store.hbase - package co.cask.cdap.messaging.store.hbase

co.cask.cdap.messaging.store.leveldb - package co.cask.cdap.messaging.store.leveldb

COL - Static variable in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

COLUMN_FAMILY - Static variable in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

computeNext() - Method in class co.cask.cdap.messaging.StoreRequest

configure() - Method in class co.cask.cdap.messaging.guice.MessagingClientModule

ConsumeRequest() - Constructor for class co.cask.cdap.messaging.Schemas.V1.ConsumeRequest

ConsumeResponse() - Constructor for class co.cask.cdap.messaging.Schemas.V1.ConsumeResponse

CoreMessagingService - Class in co.cask.cdap.messaging.service

The core implementation of MessagingService.

createMessageTable(String) - Method in class co.cask.cdap.messaging.store.cache.CachingTableFactory

createMessageTable(String) - Method in class co.cask.cdap.messaging.store.ForwardingTableFactory

createMessageTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

createMessageTable(String) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

createMessageTable(String) - Method in interface co.cask.cdap.messaging.store.TableFactory

createMetadataTable(String) - Method in class co.cask.cdap.messaging.store.cache.CachingTableFactory

createMetadataTable(String) - Method in class co.cask.cdap.messaging.store.ForwardingTableFactory

createMetadataTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

createMetadataTable(String) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

createMetadataTable(String) - Method in interface co.cask.cdap.messaging.store.TableFactory

createPayloadTable(String) - Method in class co.cask.cdap.messaging.store.cache.CachingTableFactory

createPayloadTable(String) - Method in class co.cask.cdap.messaging.store.ForwardingTableFactory

createPayloadTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

createPayloadTable(String) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

createPayloadTable(String) - Method in interface co.cask.cdap.messaging.store.TableFactory

createTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

createTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

createTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.MessagingService

Creates a topic with the given metadata.

createTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

createTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

createTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

createTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Create a topic with properties.

createTopicIfNotExists(MessagingService, TopicId) - Static method in class co.cask.cdap.messaging.MessagingServices

createTopicIfNotExists(MessagingService, TopicMetadata) - Static method in class co.cask.cdap.messaging.MessagingServices

D

DefaultMessageTableCacheProvider - Class in co.cask.cdap.messaging.store.cache

The default implementation of MessageTableCacheProvider.

DELEGATE_TABLE_FACTORY - Static variable in class co.cask.cdap.messaging.store.cache.CachingTableFactory

deleteTopic(TopicId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

deleteTopic(TopicId) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

deleteTopic(TopicId) - Method in interface co.cask.cdap.messaging.MessagingService

Deletes a topic

deleteTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

deleteTopic(TopicId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

deleteTopic(TopicId) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

deleteTopic(TopicId) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Delete a topic.

disableMessageTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

disablePayloadTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

doComputeNext() - Method in class co.cask.cdap.messaging.StoreRequest

Returns the next message payloads or return null to signal the end of payload messages.

E

EntryUpdater() - Constructor for class co.cask.cdap.messaging.cache.MessageCache.EntryUpdater

equals(Object) - Method in class co.cask.cdap.messaging.data.MessageId

equals(Object) - Method in class co.cask.cdap.messaging.TopicMetadata

exists() - Method in class co.cask.cdap.messaging.TopicMetadata

Check whether the topic exists.

F

fetch() - Method in class co.cask.cdap.messaging.MessageFetcher

Returns a CloseableIterator that iterates over messages fetched from the messaging system.

fetch(TopicMetadata, long, int, Transaction) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

fetch(TopicMetadata, MessageId, boolean, int, Transaction) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

fetch(TopicMetadata, long, MessageId, boolean, int) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

fetch(TopicMetadata, long, int, Transaction) - Method in interface co.cask.cdap.messaging.store.MessageTable

Fetches message table entries in the given topic that were publish on or after the given start time.

fetch(TopicMetadata, MessageId, boolean, int, Transaction) - Method in interface co.cask.cdap.messaging.store.MessageTable

Fetches message table entries in the given topic, starting from the given MessageId.

fetch(TopicMetadata, long, MessageId, boolean, int) - Method in interface co.cask.cdap.messaging.store.PayloadTable

Fetches entries from the payload table under the given topic, starting from the given MessageId.

FetchHandler - Class in co.cask.cdap.messaging.server

A netty http handler for handling message fetching REST API for the messaging system.

filter(long) - Method in class co.cask.cdap.messaging.store.TransactionMessageFilter

ForwardingTableFactory - Class in co.cask.cdap.messaging.store

A TableFactory that forwards all operations to another TableFactory.

ForwardingTableFactory() - Constructor for class co.cask.cdap.messaging.store.ForwardingTableFactory

G

GENERATION_KEY - Static variable in class co.cask.cdap.messaging.TopicMetadata

getComparator() - Method in class co.cask.cdap.messaging.cache.MessageCache

Returns the Comparator used by this cache.

getDelegate() - Method in class co.cask.cdap.messaging.store.cache.CachingTableFactory

getDelegate() - Method in class co.cask.cdap.messaging.store.ForwardingTableFactory

Returns the TableFactory that this class forwards to.

getDescription() - Method in class co.cask.cdap.messaging.distributed.MessagingServiceManager

getDistributedModules() - Method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

getEndSequenceId() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the sequence id being used for the last payload published with the given transaction write pointer.

getEndTimestamp() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the timestamp being used for the last payload published with the given transaction write pointer.

getFirstInCache() - Method in interface co.cask.cdap.messaging.cache.MessageCache.Scanner

Returns the first (smallest) entry in the cache when this scanner was created.

getGeneration() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getGeneration() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getGeneration() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the generation id of the topic.

getGeneration() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the generation id of the topic.

getGeneration() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the generation id for the topic.

getHardLimit() - Method in class co.cask.cdap.messaging.cache.MessageCache.Limits

getId() - Method in class co.cask.cdap.messaging.data.RawMessage

Returns the unique id of this message.

getInMemoryModules() - Method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

getKey() - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

getKey() - Method in class co.cask.cdap.messaging.store.RawPayloadTableEntry

getLimit() - Method in class co.cask.cdap.messaging.MessageFetcher

getLimits() - Method in class co.cask.cdap.messaging.cache.MessageCache

Returns the current soft and hard limits of this cache.

getMaxInstances() - Method in class co.cask.cdap.messaging.distributed.MessagingServiceManager

getMessageCache(TopicId) - Method in class co.cask.cdap.messaging.store.cache.DefaultMessageTableCacheProvider

getMessageCache(TopicId) - Method in interface co.cask.cdap.messaging.store.cache.MessageTableCacheProvider

Returns a MessageCache for the given topic.

getMetadata(TopicId) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

getMetadata(TopicId) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Fetch the metadata of the TopicId.

getMinRetain() - Method in class co.cask.cdap.messaging.cache.MessageCache.Limits

getPayload() - Method in class co.cask.cdap.messaging.data.RawMessage

Returns the published content of this message.

getPayload() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getPayload() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getPayload() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the message payload if MessageTable.Entry.isPayloadReference() return false; otherwise null will be returned.

getPayload() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the message payload.

getPayload() - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

getPayloadSequenceId() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the sequence id generated when the message was written to the Payload Table.

getPayloadSequenceId() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getPayloadSequenceId() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the sequence id generated when the payload was written to the payload table.

getPayloadWriteTimestamp() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the timestamp when the message was written to the Payload Table.

getPayloadWriteTimestamp() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getPayloadWriteTimestamp() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the timestamp in milliseconds when the payload was written to the payload table.

getProperties() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the raw properties for the topic.

getPublishTimestamp() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the publish timestamp in milliseconds of the message.

getPublishTimestamp() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getPublishTimestamp() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the timestamp in milliseconds when this entry was written to the message table.

getRawId() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the raw bytes representation of the message id.

getReduceTrigger() - Method in class co.cask.cdap.messaging.cache.MessageCache.Limits

getSequenceId() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the sequence id generated when the message was written.

getSequenceId() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getSequenceId() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the sequence id generated when this entry was written to the message table.

getStandaloneModules() - Method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

getStartOffset() - Method in class co.cask.cdap.messaging.MessageFetcher

getStartSequenceId() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the sequence id being used for the first payload published with the given transaction write pointer.

getStartTime() - Method in class co.cask.cdap.messaging.MessageFetcher

getStartTimestamp() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the timestamp being used for the first payload published with the given transaction write pointer.

getSystemTopics(CConfiguration, boolean) - Static method in class co.cask.cdap.messaging.MessagingServiceUtils

Returns a set of system TopicId as configured by the Constants.MessagingSystem#SYSTEM_TOPICS property.

getTopic(TopicId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

getTopic(TopicId) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

getTopic(TopicId) - Method in interface co.cask.cdap.messaging.MessagingService

Returns the metadata of the given topic.

getTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

getTopic(TopicId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

getTopicId() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getTopicId() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getTopicId() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the topic id that the entry belongs to.

getTopicId() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the topic id that the entry belongs to.

getTopicId() - Method in class co.cask.cdap.messaging.StoreRequest

getTopicId() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the topic id that this metadata is associated with.

getTransaction() - Method in class co.cask.cdap.messaging.MessageFetcher

getTransactionWritePointer() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the transaction write pointer used when the message was published.

getTransactionWritePointer() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getTransactionWritePointer() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getTransactionWritePointer() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the transaction write pointer stored in this entry.

getTransactionWritePointer() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the transaction write pointer for storing the payload.

getTransactionWritePointer() - Method in class co.cask.cdap.messaging.StoreRequest

Returns the transaction write pointer if the message is going to be published transactionally, that is when StoreRequest.isTransactional() returns true.

getTTL() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the time-to-live in seconds property of the topic.

getTxPtr() - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

getValue() - Method in class co.cask.cdap.messaging.store.RawPayloadTableEntry

H

hashCode() - Method in class co.cask.cdap.messaging.data.MessageId

hashCode() - Method in class co.cask.cdap.messaging.TopicMetadata

hasPayload() - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Returns true if there is some payload in this builder.

HBaseMetadataTable - Class in co.cask.cdap.messaging.store.hbase

HBase implementation of MetadataTable.

HBaseTableFactory - Class in co.cask.cdap.messaging.store.hbase

A TableFactory for creating messaging tables backed by HBase.

I

ImmutableMessageTableEntry - Class in co.cask.cdap.messaging.store

An immutable implementation of MessageTable.Entry.

ImmutableMessageTableEntry(byte[], byte[], byte[]) - Constructor for class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

ImmutablePayloadTableEntry - Class in co.cask.cdap.messaging.store

An immutable implementation of PayloadTable.Entry.

ImmutablePayloadTableEntry(byte[], byte[]) - Constructor for class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

isIncludeStart() - Method in class co.cask.cdap.messaging.MessageFetcher

isPayloadReference() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

isPayloadReference() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns true if the entry is a reference to messages stored in payload table.

isTransactional() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

isTransactional() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns true if the message is a transactional message

isTransactional() - Method in class co.cask.cdap.messaging.StoreRequest

Returns true if the message should be published transactionally.

L

LeaderElectionMessagingService - Class in co.cask.cdap.messaging.distributed

A MessagingService that performs lead-election and only operates if it is currently a leader.

LevelDBPayloadTable - Class in co.cask.cdap.messaging.store.leveldb

LevelDB implementation of PayloadTable.

LevelDBPayloadTable(DB) - Constructor for class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

LevelDBTableFactory - Class in co.cask.cdap.messaging.store.leveldb

A TableFactory for creating tables used by the messaging system using the LevelDB implementation.

LevelDBTableFactory(CConfiguration) - Constructor for class co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

Limits(long, long, long) - Constructor for class co.cask.cdap.messaging.cache.MessageCache.Limits

listTopics(NamespaceId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

listTopics(NamespaceId) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

listTopics(NamespaceId) - Method in interface co.cask.cdap.messaging.MessagingService

Returns the list of topics available under the given namespace.

listTopics(HttpRequest, HttpResponder, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

listTopics(NamespaceId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

listTopics(NamespaceId) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

listTopics() - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

listTopics(NamespaceId) - Method in interface co.cask.cdap.messaging.store.MetadataTable

List all the topics in a namespace.

listTopics() - Method in interface co.cask.cdap.messaging.store.MetadataTable

List all topics in the messaging system.

M

MessageCache<T> - Class in co.cask.cdap.messaging.cache

An in-memory cache for messages.

MessageCache(Comparator<T>, MessageCache.Weigher<T>, MessageCache.Limits, MetricsContext) - Constructor for class co.cask.cdap.messaging.cache.MessageCache

Creates a new instance of the cache.

MessageCache.EntryUpdater<T> - Class in co.cask.cdap.messaging.cache

A updater for updating an entry.

MessageCache.Limits - Class in co.cask.cdap.messaging.cache

Carries the limits for the MessageCache.

MessageCache.Scanner<T> - Interface in co.cask.cdap.messaging.cache

This interface is for accessing cached entries.

MessageCache.Weigher<T> - Interface in co.cask.cdap.messaging.cache

This interface is for calculating the weight of a cache entry.

MessageFetcher - Class in co.cask.cdap.messaging

A builder to setup parameters for fetching messages from the messaging system.

MessageFetcher() - Constructor for class co.cask.cdap.messaging.MessageFetcher

MessageFilter<T> - Class in co.cask.cdap.messaging.store

Filter messages read from MessageTable.

MessageFilter() - Constructor for class co.cask.cdap.messaging.store.MessageFilter

MessageFilter.Result - Enum in co.cask.cdap.messaging.store

The result of the filtering.

MessageId - Class in co.cask.cdap.messaging.data

Uniquely identifies a message in the Messaging System.

MessageId(byte[]) - Constructor for class co.cask.cdap.messaging.data.MessageId

Creates a instance based on the given raw id bytes.

MessageTable - Interface in co.cask.cdap.messaging.store

An interface defining the Message Table operations.

MessageTable.Entry - Interface in co.cask.cdap.messaging.store

Represents an entry (row) in the message table.

MessageTableCacheProvider - Interface in co.cask.cdap.messaging.store.cache

A provider to provide MessageCache over MessageTable.Entry based on TopicId.

MessagingClientModule - Class in co.cask.cdap.messaging.guice

The Guice module to provide binding for messaging system client.

MessagingClientModule() - Constructor for class co.cask.cdap.messaging.guice.MessagingClientModule

MessagingHttpService - Class in co.cask.cdap.messaging.server

The http server for supporting messaging system REST API.

MessagingHttpService(CConfiguration, DiscoveryService, MetricsCollectionService, MessagingService, Set<HttpHandler>) - Constructor for class co.cask.cdap.messaging.server.MessagingHttpService

MessagingServerRuntimeModule - Class in co.cask.cdap.messaging.guice

Provides Guice modules for the messaging server.

MessagingServerRuntimeModule() - Constructor for class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

MessagingService - Interface in co.cask.cdap.messaging

Main interface to interact with the transactional messaging system.

MessagingServiceManager - Class in co.cask.cdap.messaging.distributed

A MasterServiceManager used in distributed mode.

MessagingServices - Class in co.cask.cdap.messaging

Utility class to help interact with messaging service.

MessagingServiceUtils - Class in co.cask.cdap.messaging

A util class for TMS.

MetadataHandler - Class in co.cask.cdap.messaging.server

A netty http handler for metadata REST API for the messaging system.

MetadataTable - Interface in co.cask.cdap.messaging.store

Table to store information about the topics and their properties.

O

of(TopicId) - Static method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Creates a new StoreRequestBuilder instance.

P

PayloadTable - Interface in co.cask.cdap.messaging.store

An interface defining the Payload Table operations.

PayloadTable.Entry - Interface in co.cask.cdap.messaging.store

Represents an entry (row) in the payload table.

persist(Iterator<RawMessageTableEntry>) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

Store the RawMessageTableEntrys persistently.

persist(Iterator<RawPayloadTableEntry>) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

Store the RawPayloadTableEntrys persistently.

persist(Iterator<RawPayloadTableEntry>) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

poll(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.FetchHandler

prepareFetch(TopicId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

prepareFetch(TopicId) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

prepareFetch(TopicId) - Method in interface co.cask.cdap.messaging.MessagingService

Prepares to fetch messages from the given topic.

prepareFetch(TopicId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

pruneMessages(TopicMetadata, long) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

Delete messages of a TopicId that has exceeded the TTL or if it belongs to an older generation

publish(StoreRequest) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

publish(StoreRequest) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

publish(StoreRequest) - Method in interface co.cask.cdap.messaging.MessagingService

Publishes a list of messages to the messaging system.

publish(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.StoreHandler

publish(StoreRequest) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

PublishRequest() - Constructor for class co.cask.cdap.messaging.Schemas.V1.PublishRequest

PublishResponse() - Constructor for class co.cask.cdap.messaging.Schemas.V1.PublishResponse

publishWithRetry(MessagingService, TopicId, RetryStrategy, byte[]...) - Static method in class co.cask.cdap.messaging.MessagingServices

putRawId(long, short, long, short, byte[], int) - Static method in class co.cask.cdap.messaging.data.MessageId

Computes the message raw ID and store it in the given byte array.

R

RAW_ID_SIZE - Static variable in class co.cask.cdap.messaging.data.MessageId

RawMessage - Class in co.cask.cdap.messaging.data

Represents a unique message in the messaging system.

RawMessage(byte[], byte[]) - Constructor for class co.cask.cdap.messaging.data.RawMessage

RawMessageTableEntry - Class in co.cask.cdap.messaging.store

Container class that contains raw bytes corresponding to an entry in the Message Table.

RawMessageTableEntry() - Constructor for class co.cask.cdap.messaging.store.RawMessageTableEntry

RawPayloadTableEntry - Class in co.cask.cdap.messaging.store

Container class for raw bytes corresponding to key, value of the Payload Table.

RawPayloadTableEntry() - Constructor for class co.cask.cdap.messaging.store.RawPayloadTableEntry

read(byte[], byte[]) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

Read the RawMessageTableEntrys given a key range.

read(byte[], byte[], int) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

Read the RawPayloadTableEntrys given a key range.

read(byte[], byte[], int) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

resize(MessageCache.Limits) - Method in class co.cask.cdap.messaging.cache.MessageCache

Resize the cache limits.

rollback(TopicId, RollbackDetail) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

rollback(TopicId, RollbackDetail) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

rollback(TopicId, RollbackDetail) - Method in interface co.cask.cdap.messaging.MessagingService

Rollbacks messages published to the given topic with the given transaction.

rollback(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.StoreHandler

rollback(TopicId, RollbackDetail) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

rollback(byte[], byte[], byte[]) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

Rollback the transactionally published messages in the Table in the given key range.

rollback(TopicMetadata, RollbackDetail) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

rollback(TopicMetadata, RollbackDetail) - Method in interface co.cask.cdap.messaging.store.MessageTable

Rollback entries stored earlier, as deleted, under the given topic based on the given information.

RollbackDetail - Interface in co.cask.cdap.messaging

This interface represents information needed to rollback message published transactionally.

S

scan(T, boolean, int, MessageFilter<T>) - Method in class co.cask.cdap.messaging.cache.MessageCache

Creates a MessageCache.Scanner for fetching cached entries in ascending order.

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.ConsumeRequest

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.ConsumeResponse

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.PublishRequest

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.PublishResponse

Schemas - Class in co.cask.cdap.messaging

Helper class for getting various Schema used by the messaging system.

Schemas.V1 - Class in co.cask.cdap.messaging

Contains Schema for V1 protocol.

Schemas.V1.ConsumeRequest - Class in co.cask.cdap.messaging

Contains schema for consume request.

Schemas.V1.ConsumeResponse - Class in co.cask.cdap.messaging

Contains schema for consume response.

Schemas.V1.PublishRequest - Class in co.cask.cdap.messaging

Contains schema for publish request.

Schemas.V1.PublishResponse - Class in co.cask.cdap.messaging

Contains schema for publish response.

set(byte[], byte[], byte[]) - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

set(byte[], byte[]) - Method in class co.cask.cdap.messaging.store.RawPayloadTableEntry

setLimit(int) - Method in class co.cask.cdap.messaging.MessageFetcher

Sets the maximum limit on number of messages to be fetched.

setStartMessage(byte[], boolean) - Method in class co.cask.cdap.messaging.MessageFetcher

Setup the message fetching starting point based on the given message id.

setStartTime(long) - Method in class co.cask.cdap.messaging.MessageFetcher

Setup the message fetching start time (publish time).

setTransaction(Long) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Sets the transaction write pointer to be used for the request.

setTransaction(Transaction) - Method in class co.cask.cdap.messaging.MessageFetcher

Sets the transaction to use for fetching.

shutDown() - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

shutDown() - Method in class co.cask.cdap.messaging.server.MessagingHttpService

shutDown() - Method in class co.cask.cdap.messaging.service.CoreMessagingService

startUp() - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

startUp() - Method in class co.cask.cdap.messaging.server.MessagingHttpService

startUp() - Method in class co.cask.cdap.messaging.service.CoreMessagingService

store(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.StoreHandler

store(Iterator<? extends MessageTable.Entry>) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

store(Iterator<? extends PayloadTable.Entry>) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

store(Iterator<? extends MessageTable.Entry>) - Method in interface co.cask.cdap.messaging.store.MessageTable

Stores a list of entries to the message table under the given topic.

store(Iterator<? extends PayloadTable.Entry>) - Method in interface co.cask.cdap.messaging.store.PayloadTable

Stores a list of entries to the payload table under the given topic.

StoreHandler - Class in co.cask.cdap.messaging.server

A netty http handler for handling message storage REST API for the messaging system.

storePayload(StoreRequest) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

storePayload(StoreRequest) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

storePayload(StoreRequest) - Method in interface co.cask.cdap.messaging.MessagingService

Stores a list of messages to the messaging system.

storePayload(StoreRequest) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

StoreRequest - Class in co.cask.cdap.messaging

This class represents messages to be store to the messaging system.

StoreRequest(TopicId, boolean, long) - Constructor for class co.cask.cdap.messaging.StoreRequest

StoreRequestBuilder - Class in co.cask.cdap.messaging.client

A builder to create StoreRequest instances.

T

TableFactory - Interface in co.cask.cdap.messaging.store

A factory to create instances of MessageTable, PayloadTable and MetadataTable.

TopicMetadata - Class in co.cask.cdap.messaging

Represents metadata about a messaging topic.

TopicMetadata(TopicId, Map<String, String>) - Constructor for class co.cask.cdap.messaging.TopicMetadata

Creates a new instance for the given topic with the associated properties.

TopicMetadata(TopicId, Map<String, String>, boolean) - Constructor for class co.cask.cdap.messaging.TopicMetadata

Creates a new instance for the given topic with the associated properties.

TopicMetadata(TopicId, Object...) - Constructor for class co.cask.cdap.messaging.TopicMetadata

Creates a new instance for the given topic with the associated properties.

toString() - Method in class co.cask.cdap.messaging.TopicMetadata

TransactionMessageFilter - Class in co.cask.cdap.messaging.store

A MessageFilter that filter MessageTable.Entry based on a given transaction.

TransactionMessageFilter(Transaction) - Constructor for class co.cask.cdap.messaging.store.TransactionMessageFilter

TTL_KEY - Static variable in class co.cask.cdap.messaging.TopicMetadata

U

updateEntries(T, T, MessageCache.EntryUpdater<T>) - Method in class co.cask.cdap.messaging.cache.MessageCache

Updates entries in the cache.

updateEntry(T) - Method in class co.cask.cdap.messaging.cache.MessageCache.EntryUpdater

Updates the entry.

updateTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

updateTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.distributed.LeaderElectionMessagingService

updateTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.MessagingService

Updates the metadata of a topic.

updateTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

updateTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

updateTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

updateTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Updates the topic properties.

upgradeMessageTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

upgradePayloadTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

V

V1() - Constructor for class co.cask.cdap.messaging.Schemas.V1

valueOf(String) - Static method in enum co.cask.cdap.messaging.store.MessageFilter.Result

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

values() - Static method in enum co.cask.cdap.messaging.store.MessageFilter.Result

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

W

weight(T) - Method in interface co.cask.cdap.messaging.cache.MessageCache.Weigher

A B C D E F G H I L M O P R S T U V W