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

A

abort() - Method in interface io.pravega.client.stream.Transaction

Drops the transaction, causing all events written to it to be deleted.

AbstractNotifier<T extends Notification> - Class in io.pravega.client.stream.notifications.notifier

AbstractNotifier which is used by all types of Notifiers.

AbstractNotifier(NotificationSystem, ScheduledExecutorService) - Constructor for class io.pravega.client.stream.notifications.notifier.AbstractNotifier

AbstractPollingNotifier<T extends Notification> - Class in io.pravega.client.stream.notifications.notifier

addListeners(String, Listener<T>, ScheduledExecutorService) - Method in class io.pravega.client.stream.notifications.NotificationSystem

applyTo(StateT, Revision) - Method in interface io.pravega.client.state.InitialUpdate

applyTo(StateT, Revision) - Method in interface io.pravega.client.state.Update

Return an object of type StateT that is the same as oldState with this update applied to it.

asImpl() - Method in interface io.pravega.client.state.Revision

Returns the actual instance.

asImpl() - Method in interface io.pravega.client.stream.Checkpoint

For internal use.

asImpl() - Method in interface io.pravega.client.stream.EventPointer

Used internally.

asImpl() - Method in interface io.pravega.client.stream.Position

Used internally.

B

BatchClient - Interface in io.pravega.client.batch

Please note this is an experimental API.

beginTxn() - Method in interface io.pravega.client.stream.EventStreamWriter

Start a new transaction on this stream.

byDataRate(int, int, int) - Static method in class io.pravega.client.stream.ScalingPolicy

Create a scaling policy to configure a stream to scale up and down according to byte rate.

byEventRate(int, int, int) - Static method in class io.pravega.client.stream.ScalingPolicy

Create a scaling policy to configure a stream to scale up and down according to event rate.

bySizeBytes(long) - Static method in class io.pravega.client.stream.RetentionPolicy

Create a retention policy to configure a stream to truncate a stream according to the amount of data currently stored.

byTime(Duration) - Static method in class io.pravega.client.stream.RetentionPolicy

Create a retention policy to configure a stream to periodically truncated according to the specified duration.

C

Checkpoint - Interface in io.pravega.client.stream

checkStatus() - Method in interface io.pravega.client.stream.Transaction

Gets the status of the transaction.

ClientFactory - Interface in io.pravega.client

Used to create Writers, Readers, and Synchronizers operating on a stream.

close() - Method in interface io.pravega.client.admin.ReaderGroupManager

Close this manager class.

close() - Method in interface io.pravega.client.admin.StreamManager

Closes the stream manager.

close() - Method in interface io.pravega.client.batch.SegmentIterator

Closes the iterator, freeing any resources associated with it.

close() - Method in interface io.pravega.client.ClientFactory

Closes the client factory.

close() - Method in interface io.pravega.client.state.RevisionedStreamClient

Closes the client and frees any resources associated with it.

close() - Method in interface io.pravega.client.state.StateSynchronizer

Closes the StateSynchronizer and frees any resources associated with it.

close() - Method in interface io.pravega.client.stream.EventStreamReader

Close the reader.

close() - Method in interface io.pravega.client.stream.EventStreamWriter

Calls flush and then closes the writer.

close() - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter

Calls flush and then closes the writer.

commit() - Method in interface io.pravega.client.stream.Transaction

Causes all messages previously written to the transaction to go into the stream contiguously.

compact(Function<StateT, InitialUpdate<StateT>>) - Method in interface io.pravega.client.state.StateSynchronizer

Provide a function that generates compacted version of localState so that we can drop some of the history updates.

compareAndSetMark(Revision, Revision) - Method in interface io.pravega.client.state.RevisionedStreamClient

Records a provided location that can later be obtained by calling RevisionedStreamClient.getMark().

compareTo(Sequence) - Method in class io.pravega.client.stream.Sequence

create(URI) - Static method in interface io.pravega.client.admin.StreamManager

Creates a new instance of StreamManager.

create(String, Revision) - Method in interface io.pravega.client.state.InitialUpdate

Returns an object of type StateT with the provided revision.

createBatchClient() - Method in interface io.pravega.client.ClientFactory

Create a new batch client.

createEventWriter(String, Serializer<T>, EventWriterConfig) - Method in interface io.pravega.client.ClientFactory

Creates a new writer that can write to the specified stream.

createReader(String, String, Serializer<T>, ReaderConfig) - Method in interface io.pravega.client.ClientFactory

Creates (or recreates) a new reader that is part of a ReaderGroup.

createReaderGroup(String, ReaderGroupConfig, Set<String>) - Method in interface io.pravega.client.admin.ReaderGroupManager

Creates a new ReaderGroup Readers will be able to join the group by calling ClientFactory.createReader(String, String, Serializer, ReaderConfig) .

createRevisionedStreamClient(String, Serializer<T>, SynchronizerConfig) - Method in interface io.pravega.client.ClientFactory

Creates a new RevisionedStreamClient that will work with the specified stream.

createScope(String) - Method in interface io.pravega.client.admin.StreamManager

Creates a new scope.

createStateSynchronizer(String, Serializer<UpdateT>, Serializer<InitT>, SynchronizerConfig) - Method in interface io.pravega.client.ClientFactory

Creates a new StateSynchronizer that will work on the specified stream.

createStream(String, String, StreamConfiguration) - Method in interface io.pravega.client.admin.StreamManager

Creates a new stream

D

deleteReaderGroup(String) - Method in interface io.pravega.client.admin.ReaderGroupManager

Deletes a reader group, removing any state associated with it.

deleteScope(String) - Method in interface io.pravega.client.admin.StreamManager

Deletes an existing scope.

deleteStream(String, String) - Method in interface io.pravega.client.admin.StreamManager

Deletes the provided stream.

deserialize(ByteBuffer) - Method in interface io.pravega.client.stream.Serializer

Deserializes the given ByteBuffer into an event.

disableAutomaticCheckpoints() - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder

Disables automatic checkpointing.

E

EndOfDataNotification - Class in io.pravega.client.stream.notifications

Class to represent a end of data notification.

EndOfDataNotification() - Constructor for class io.pravega.client.stream.notifications.EndOfDataNotification

EndOfDataNotifier - Class in io.pravega.client.stream.notifications.notifier

EndOfDataNotifier(NotificationSystem, StateSynchronizer<ReaderGroupState>, ScheduledExecutorService) - Constructor for class io.pravega.client.stream.notifications.notifier.EndOfDataNotifier

EventPointer - Interface in io.pravega.client.stream

A pointer to an event.

EventRead<T> - Interface in io.pravega.client.stream

An event that was read from a stream or a checkpoint marker if one has been requested.

EventStreamReader<T> - Interface in io.pravega.client.stream

A reader for a stream.

EventStreamWriter<Type> - Interface in io.pravega.client.stream

A writer can write events to a stream.

EventWriterConfig - Class in io.pravega.client.stream

EventWriterConfig() - Constructor for class io.pravega.client.stream.EventWriterConfig

EventWriterConfig.EventWriterConfigBuilder - Class in io.pravega.client.stream

EventWriterConfigBuilder() - Constructor for class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder

executor - Variable in class io.pravega.client.stream.notifications.notifier.AbstractNotifier

F

fetchEvent(EventPointer) - Method in interface io.pravega.client.stream.EventStreamReader

Re-read an event that was previously read, by passing the pointer returned from EventRead.getEventPointer().

fetchLatestRevision() - Method in interface io.pravega.client.state.RevisionedStreamClient

Returns the latest revision.

fetchOldestRevision() - Method in interface io.pravega.client.state.RevisionedStreamClient

Returns the oldest revision that reads can start from.

fetchUpdates() - Method in interface io.pravega.client.state.StateSynchronizer

Fetch and apply all updates needed to the state object held locally up to date.

fixed(int) - Static method in class io.pravega.client.stream.ScalingPolicy

Create a scaling policy to configure a stream to have a fixed number of segments.

flush() - Method in interface io.pravega.client.stream.EventStreamWriter

Block until all events that have been passed to writeEvent's corresponding futures have completed.

flush() - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter

Block until all events that have been passed to writeEvent's corresponding futures have completed.

flush() - Method in interface io.pravega.client.stream.Transaction

Blocks until all events passed to Transaction.writeEvent(String, Object) make it to durable storage.

G

getCheckpointName() - Method in interface io.pravega.client.stream.EventRead

If a checkpoint has been requested this will return the checkpointName passed to ReaderGroup.initiateCheckpoint(String,ScheduledExecutorService) otherwise this will return null.

getConfig() - Method in interface io.pravega.client.stream.EventStreamReader

Gets the configuration that this reader was created with.

getConfig() - Method in interface io.pravega.client.stream.EventStreamWriter

Returns the configuration that this writer was create with.

getConfig() - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter

Returns the configuration that this writer was create with.

getEndOfDataNotifier(ScheduledExecutorService) - Method in class io.pravega.client.stream.notifications.NotifierFactory

getEndOfDataNotifier(ScheduledExecutorService) - Method in interface io.pravega.client.stream.notifications.ReaderGroupNotificationListener

Get an end of data notifier for a given reader group.

getEvent() - Method in interface io.pravega.client.stream.EventRead

Returns the event that is wrapped in this EventRead or null a timeout occurred or if a checkpoint was requested.

getEventPointer() - Method in interface io.pravega.client.stream.EventRead

Returns a pointer object for the event read.

getGroupName() - Method in interface io.pravega.client.stream.ReaderGroup

Returns the name of the group.

getMark() - Method in interface io.pravega.client.state.RevisionedStreamClient

Returns a location previously set by RevisionedStreamClient.compareAndSetMark(Revision, Revision).

getMetrics() - Method in interface io.pravega.client.stream.ReaderGroup

Returns metrics for this reader group.

getName() - Method in interface io.pravega.client.stream.Checkpoint

Returns the name of the Checkpoint specified in ReaderGroup.initiateCheckpoint(String, java.util.concurrent.ScheduledExecutorService).

getOffset() - Method in interface io.pravega.client.batch.SegmentIterator

Provides an offset which can be used to re-create a segmentIterator at this position by calling BatchClient#readSegment(io.pravega.client.segment.impl.Segment, io.pravega.client.stream.Serializer, long).

getOnlineReaders() - Method in interface io.pravega.client.stream.ReaderGroup

Returns a set of readerIds for the readers that are considered to be online by the group.

getPosition() - Method in interface io.pravega.client.stream.EventRead

The position in the stream that represents where the reader is immediately following this event.

getReaderGroup(String) - Method in interface io.pravega.client.admin.ReaderGroupManager

Returns the requested reader group.

getRevision() - Method in interface io.pravega.client.state.Revisioned

Returns the revision corresponding to this object.

getScope() - Method in interface io.pravega.client.stream.ReaderGroup

Returns the scope of the stream which the group is associated with.

getScope() - Method in interface io.pravega.client.stream.Stream

Gets the scope of this stream.

getScopedName() - Method in interface io.pravega.client.stream.Stream

Gets the scoped name of this stream.

getScopedStreamName() - Method in interface io.pravega.client.state.Revisioned

Returns the scoped name of this stream used to persist this object.

getSegmentNotifier(ScheduledExecutorService) - Method in class io.pravega.client.stream.notifications.NotifierFactory

getSegmentNotifier(ScheduledExecutorService) - Method in interface io.pravega.client.stream.notifications.ReaderGroupNotificationListener

Get a segment notifier for a given reader group.

getState() - Method in interface io.pravega.client.state.StateSynchronizer

Gets the state object currently held in memory.

getStreamCuts() - Method in interface io.pravega.client.stream.ReaderGroup

Returns a stream cut for each stream that this reader group is reading from.

getStreamName() - Method in interface io.pravega.client.stream.Stream

Gets the name of this stream (Not including the scope).

getStreamNames() - Method in interface io.pravega.client.stream.ReaderGroup

Returns the set of stream names which was used to configure this group.

getTransactionTimeoutScaleGracePeriod() - Method in class io.pravega.client.stream.EventWriterConfig

getTxn(UUID) - Method in interface io.pravega.client.stream.EventStreamWriter

Returns a previously created transaction.

getTxnId() - Method in interface io.pravega.client.stream.Transaction

Returns a unique ID that can be used to identify this transaction.

getType() - Method in class io.pravega.client.stream.notifications.notifier.EndOfDataNotifier

getType() - Method in class io.pravega.client.stream.notifications.notifier.SegmentNotifier

getType() - Method in interface io.pravega.client.stream.notifications.Observable

Get the notification type.

I

IdempotentEventStreamWriter<Type> - Interface in io.pravega.client.stream

A writer can write events to a stream.

initialize(InitialUpdate<StateT>) - Method in interface io.pravega.client.state.StateSynchronizer

This method can be used to provide an initial value for a new stream if the stream has not been previously initialized.

InitialUpdate<StateT extends Revisioned> - Interface in io.pravega.client.state

A constructor for a StateT object.

initiateCheckpoint(String, ScheduledExecutorService) - Method in interface io.pravega.client.stream.ReaderGroup

Initiate a checkpoint.

InvalidStreamException - Exception in io.pravega.client.stream

InvalidStreamException(String) - Constructor for exception io.pravega.client.stream.InvalidStreamException

InvalidStreamException(Throwable) - Constructor for exception io.pravega.client.stream.InvalidStreamException

InvalidStreamException(String, Throwable) - Constructor for exception io.pravega.client.stream.InvalidStreamException

io.pravega.client - package io.pravega.client

io.pravega.client.admin - package io.pravega.client.admin

io.pravega.client.batch - package io.pravega.client.batch

io.pravega.client.state - package io.pravega.client.state

io.pravega.client.stream - package io.pravega.client.stream

io.pravega.client.stream.notifications - package io.pravega.client.stream.notifications

io.pravega.client.stream.notifications.notifier - package io.pravega.client.stream.notifications.notifier

isCheckpoint() - Method in interface io.pravega.client.stream.EventRead

A boolean indicating if this is a checkpoint.

isListenerPresent(String) - Method in class io.pravega.client.stream.notifications.NotificationSystem

Check if a Listener is present for a given notification type.

L

Listener<T> - Interface in io.pravega.client.stream.notifications

Listener interface for receiving notifications.

listSegments(Stream) - Method in interface io.pravega.client.batch.BatchClient

Provides a list of segments and their metadata for a given stream.

M

MAX_EVENT_SIZE - Static variable in interface io.pravega.client.stream.Serializer

The maximum event size, in bytes.

MAX_VALUE - Static variable in class io.pravega.client.stream.Sequence

MIN_VALUE - Static variable in class io.pravega.client.stream.Sequence

N

Notification - Class in io.pravega.client.stream.notifications

Represents base notification type.

Notification() - Constructor for class io.pravega.client.stream.notifications.Notification

NotificationSystem - Class in io.pravega.client.stream.notifications

NotificationSystem() - Constructor for class io.pravega.client.stream.notifications.NotificationSystem

NotifierFactory - Class in io.pravega.client.stream.notifications

Factory used to create different types of notifiers.

NotifierFactory(NotificationSystem, Supplier<StateSynchronizer<ReaderGroupState>>) - Constructor for class io.pravega.client.stream.notifications.NotifierFactory

notify(T) - Method in class io.pravega.client.stream.notifications.NotificationSystem

This method will ensure the notification is intimated to the listeners of the same type.

notifySystem - Variable in class io.pravega.client.stream.notifications.notifier.AbstractNotifier

O

Observable<T> - Interface in io.pravega.client.stream.notifications

This represents an observable notification.

onNotification(T) - Method in interface io.pravega.client.stream.notifications.Listener

P

PingFailedException - Exception in io.pravega.client.stream

Transaction heartbeat to a controller instance failed, because of one of the following reasons.

PingFailedException() - Constructor for exception io.pravega.client.stream.PingFailedException

PingFailedException(Throwable) - Constructor for exception io.pravega.client.stream.PingFailedException

PingFailedException(String, Throwable) - Constructor for exception io.pravega.client.stream.PingFailedException

PingFailedException(String) - Constructor for exception io.pravega.client.stream.PingFailedException

Position - Interface in io.pravega.client.stream

A position in a stream.

R

ReaderConfig - Class in io.pravega.client.stream

ReaderConfig() - Constructor for class io.pravega.client.stream.ReaderConfig

ReaderConfig.ReaderConfigBuilder - Class in io.pravega.client.stream

ReaderConfigBuilder() - Constructor for class io.pravega.client.stream.ReaderConfig.ReaderConfigBuilder

ReaderGroup - Interface in io.pravega.client.stream

A reader group is a collection of readers that collectively read all the events in the stream.

ReaderGroupConfig - Class in io.pravega.client.stream

ReaderGroupConfig() - Constructor for class io.pravega.client.stream.ReaderGroupConfig

ReaderGroupConfig.ReaderGroupConfigBuilder - Class in io.pravega.client.stream

ReaderGroupConfigBuilder() - Constructor for class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder

ReaderGroupManager - Interface in io.pravega.client.admin

Used to create and manage reader groups.

ReaderGroupMetrics - Interface in io.pravega.client.stream

ReaderGroupNotificationListener - Interface in io.pravega.client.stream.notifications

ReaderGroup notification listener interface.

readerOffline(String, Position) - Method in interface io.pravega.client.stream.ReaderGroup

Invoked when a reader that was added to the group is no longer consuming events.

readFrom(Revision) - Method in interface io.pravega.client.state.RevisionedStreamClient

Read all data after a specified revision to the end of the stream.

readNextEvent(long) - Method in interface io.pravega.client.stream.EventStreamReader

Gets the next event in the stream.

readSegment(Segment, Serializer<T>) - Method in interface io.pravega.client.batch.BatchClient

Provides a SegmentIterator to read the events in the requested segment starting from the beginning of the segment and ending at the current end of the segment.

readSegment(Segment, Serializer<T>, long, long) - Method in interface io.pravega.client.batch.BatchClient

Provides a SegmentIterator to read the events after the startingOffset but before the endingOffset in the requested segment.

registerListener(Listener<T>) - Method in class io.pravega.client.stream.notifications.notifier.AbstractNotifier

registerListener(Listener<EndOfDataNotification>) - Method in class io.pravega.client.stream.notifications.notifier.EndOfDataNotifier

registerListener(Listener<SegmentNotification>) - Method in class io.pravega.client.stream.notifications.notifier.SegmentNotifier

registerListener(Listener<T>) - Method in interface io.pravega.client.stream.notifications.Observable

Register listener for notification type T.

ReinitializationRequiredException - Exception in io.pravega.client.stream

ReinitializationRequiredException() - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException

ReinitializationRequiredException(Throwable) - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException

ReinitializationRequiredException(String, Throwable) - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException

ReinitializationRequiredException(String) - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException

removeListener(String, Listener<T>) - Method in class io.pravega.client.stream.notifications.NotificationSystem

Remove Listener of a given notification type.

removeListeners(String) - Method in class io.pravega.client.stream.notifications.NotificationSystem

Remove all listeners of a notification type.

resetReadersToCheckpoint(Checkpoint) - Method in interface io.pravega.client.stream.ReaderGroup

Given a Checkpoint, restore the reader group to the provided checkpoint.

RetentionPolicy - Class in io.pravega.client.stream

RetentionPolicy() - Constructor for class io.pravega.client.stream.RetentionPolicy

RetentionPolicy.RetentionType - Enum in io.pravega.client.stream

Revision - Interface in io.pravega.client.state

A maker for a version of a Revisioned object.

Revisioned - Interface in io.pravega.client.state

An object that has a revision associated with it.

RevisionedStreamClient<T> - Interface in io.pravega.client.state

Provides a stream that can be read and written to with strong consistency.

S

ScalingPolicy - Class in io.pravega.client.stream

A policy that specifies how the number of segments in a stream should scale over time.

ScalingPolicy() - Constructor for class io.pravega.client.stream.ScalingPolicy

ScalingPolicy.ScaleType - Enum in io.pravega.client.stream

sealStream(String, String) - Method in interface io.pravega.client.admin.StreamManager

Seal an existing stream.

SegmentInfo - Class in io.pravega.client.batch

SegmentInfo() - Constructor for class io.pravega.client.batch.SegmentInfo

SegmentIterator<T> - Interface in io.pravega.client.batch

Please note this is an experimental API.

SegmentNotification - Class in io.pravega.client.stream.notifications

Class to represent a segment notification.

SegmentNotification() - Constructor for class io.pravega.client.stream.notifications.SegmentNotification

SegmentNotifier - Class in io.pravega.client.stream.notifications.notifier

SegmentNotifier(NotificationSystem, StateSynchronizer<ReaderGroupState>, ScheduledExecutorService) - Constructor for class io.pravega.client.stream.notifications.notifier.SegmentNotifier

Sequence - Class in io.pravega.client.stream

A wrapper for two numbers.

Sequence() - Constructor for class io.pravega.client.stream.Sequence

serialize(T) - Method in interface io.pravega.client.stream.Serializer

Serializes the given event.

Serializer<T> - Interface in io.pravega.client.stream

Takes events being written and serializes them to byteBuffers so they can be sent over the wire and deserializes these same byte buffers back into objects.

startingTime(long) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder

Returns a config builder that started at a given time.

StateSynchronizer<StateT extends Revisioned> - Interface in io.pravega.client.state

Provides a means to have state that is synchronized between many processes.

Stream - Interface in io.pravega.client.stream

A stream can be thought of as an unbounded sequence of events.

StreamConfiguration - Class in io.pravega.client.stream

The configuration of a Stream.

StreamConfiguration() - Constructor for class io.pravega.client.stream.StreamConfiguration

StreamConfiguration.StreamConfigurationBuilder - Class in io.pravega.client.stream

StreamConfigurationBuilder() - Constructor for class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder

StreamInfo - Class in io.pravega.client.batch

StreamInfo() - Constructor for class io.pravega.client.batch.StreamInfo

StreamManager - Interface in io.pravega.client.admin

Used to create, delete, and manage Streams and ReaderGroups.

SynchronizerConfig - Class in io.pravega.client.state

The configuration for a Consistent replicated state synchronizer.

SynchronizerConfig() - Constructor for class io.pravega.client.state.SynchronizerConfig

SynchronizerConfig.SynchronizerConfigBuilder - Class in io.pravega.client.state

SynchronizerConfigBuilder() - Constructor for class io.pravega.client.state.SynchronizerConfig.SynchronizerConfigBuilder

T

Transaction<Type> - Interface in io.pravega.client.stream

Provides a mechanism for writing many events atomically.

Transaction.Status - Enum in io.pravega.client.stream

TruncatedDataException - Exception in io.pravega.client.stream

TruncatedDataException() - Constructor for exception io.pravega.client.stream.TruncatedDataException

Creates a new instance of TruncatedDataException class.

TruncatedDataException(Throwable) - Constructor for exception io.pravega.client.stream.TruncatedDataException

Creates a new instance of TruncatedDataException class.

TruncatedDataException(String, Throwable) - Constructor for exception io.pravega.client.stream.TruncatedDataException

Creates a new instance of TruncatedDataException class.

TruncatedDataException(String) - Constructor for exception io.pravega.client.stream.TruncatedDataException

Creates a new instance of TruncatedDataException class.

truncateStream(String, String, StreamCut) - Method in interface io.pravega.client.admin.StreamManager

Truncate stream at given stream cut.

truncateToRevision(Revision) - Method in interface io.pravega.client.state.RevisionedStreamClient

Removes all data through the revision provided (inclusive).

TxnFailedException - Exception in io.pravega.client.stream

A transaction has failed.

TxnFailedException() - Constructor for exception io.pravega.client.stream.TxnFailedException

Creates a new instance of TxnFailedException class.

TxnFailedException(Throwable) - Constructor for exception io.pravega.client.stream.TxnFailedException

Creates a new instance of TxnFailedException class.

TxnFailedException(String, Throwable) - Constructor for exception io.pravega.client.stream.TxnFailedException

Creates a new instance of TxnFailedException class.

TxnFailedException(String) - Constructor for exception io.pravega.client.stream.TxnFailedException

Creates a new instance of TxnFailedException class.

U

unreadBytes() - Method in interface io.pravega.client.stream.ReaderGroupMetrics

Returns the number of bytes between the last recorded position of the readers in the ReaderGroup and the end of the stream.

unregisterAllListeners() - Method in class io.pravega.client.stream.notifications.notifier.AbstractNotifier

unregisterAllListeners() - Method in class io.pravega.client.stream.notifications.notifier.AbstractPollingNotifier

unregisterAllListeners() - Method in interface io.pravega.client.stream.notifications.Observable

Remove all listeners for a given type.

unregisterListener(Listener<T>) - Method in class io.pravega.client.stream.notifications.notifier.AbstractNotifier

unregisterListener(Listener<T>) - Method in class io.pravega.client.stream.notifications.notifier.AbstractPollingNotifier

unregisterListener(Listener<T>) - Method in interface io.pravega.client.stream.notifications.Observable

Remove a listener.

Update<StateT extends Revisioned> - Interface in io.pravega.client.state

An update to a StateT object coordinated via a StateSynchronizer.

updateConfig(ReaderGroupConfig, Set<String>) - Method in interface io.pravega.client.stream.ReaderGroup

Updates a reader group.

updateState(Function<StateT, List<? extends Update<StateT>>>) - Method in interface io.pravega.client.state.StateSynchronizer

Creates a new update for the latest state object and applies it atomically.

updateStateUnconditionally(Update<StateT>) - Method in interface io.pravega.client.state.StateSynchronizer

Persists the provided update.

updateStateUnconditionally(List<? extends Update<StateT>>) - Method in interface io.pravega.client.state.StateSynchronizer

Same as StateSynchronizer.updateStateUnconditionally(Update), except it persists multiple updates at the same time so they will not be interleaved with other updates.

updateStream(String, String, StreamConfiguration) - Method in interface io.pravega.client.admin.StreamManager

Change the configuration for an existing stream.

V

valueOf(String) - Static method in enum io.pravega.client.stream.RetentionPolicy.RetentionType

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

valueOf(String) - Static method in enum io.pravega.client.stream.ScalingPolicy.ScaleType

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

valueOf(String) - Static method in enum io.pravega.client.stream.Transaction.Status

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

values() - Static method in enum io.pravega.client.stream.RetentionPolicy.RetentionType

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

values() - Static method in enum io.pravega.client.stream.ScalingPolicy.ScaleType

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

values() - Static method in enum io.pravega.client.stream.Transaction.Status

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

W

withScope(String, URI) - Static method in interface io.pravega.client.admin.ReaderGroupManager

Creates a new instance of ReaderGroupManager.

withScope(String, URI) - Static method in interface io.pravega.client.ClientFactory

Creates a new instance of Client Factory.

writeConditionally(Revision, T) - Method in interface io.pravega.client.state.RevisionedStreamClient

If the supplied revision is the latest revision in the stream write the provided value and return the new revision.

writeEvent(Type) - Method in interface io.pravega.client.stream.EventStreamWriter

Send an event to the stream.

writeEvent(String, Type) - Method in interface io.pravega.client.stream.EventStreamWriter

Write an event to the stream.

writeEvent(String, Sequence, Type) - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter

Send an event to the stream.

writeEvent(Type) - Method in interface io.pravega.client.stream.Transaction

Sends an event to the stream just like EventStreamWriter.writeEvent(Type) but with the caveat that the message will not be visible to anyone until Transaction.commit() is called.

writeEvent(String, Type) - Method in interface io.pravega.client.stream.Transaction

Sends an event to the stream just like EventStreamWriter.writeEvent(Type) but with the caveat that the message will not be visible to anyone until Transaction.commit() is called.

writeUnconditionally(T) - Method in interface io.pravega.client.state.RevisionedStreamClient

Write a new value to the stream.

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