Package io.deephaven.kv.schema

Class SchemaStateAdapter

java.lang.Object

io.deephaven.kv.schema.SchemaStateAdapter

All Implemented Interfaces:

WatchClient.UnitListener

public class SchemaStateAdapter
extends Object
implements WatchClient.UnitListener

Implement WatchClient.UnitListener and present state updates to a WatchClient.StateListener. This now handles all updates of unparsed kv values, managing the top level schema state.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SchemaStateAdapter.Namespace	Roughly represents SchemaNamespace, with only the required metadata.
class	SchemaStateAdapter.State	The state of schemas in the kv store.

Constructor Summary

Constructors

Constructor	Description
SchemaStateAdapter(@NotNull SchemaContext schemaContext, WatchClient.StateListener<SchemaStateAdapter.State> listener, @NotNull KVClient kvClient, @NotNull WatchClient watchClient, @NotNull GetPrefix watchKeyPath)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<WatchClient.Watch>	getWatchFuture()	Get the watch future.
void	onCompleted()	Invoked on completion.
void	onError(@NotNull Throwable t)	Invoked on errors.
void	onNext(@NotNull WatchResponseUnit unit)	Invoked on new events.
void	publishInitial(@NotNull HeaderResponse initialHeader, @NotNull KeyValuesCollection initialState)	Initialize the state.
WatchClient.Watch	restartWatch()	After an error in the watch, restart it at the last known revision.

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaStateAdapter

public SchemaStateAdapter(@NotNull
 @NotNull SchemaContext schemaContext,
 @NotNull
 WatchClient.StateListener<SchemaStateAdapter.State> listener,
 @NotNull
 @NotNull KVClient kvClient,
 @NotNull
 @NotNull WatchClient watchClient,
 @NotNull
 @NotNull GetPrefix watchKeyPath)

Method Details

publishInitial

public void publishInitial(@NotNull
 @NotNull HeaderResponse initialHeader,
 @NotNull
 @NotNull KeyValuesCollection initialState)

Initialize the state.

Parameters:

initialHeader - the initial header

initialState - the initial state - all keys and values starting at the GetPrefix root

onNext

public void onNext(@NotNull
 @NotNull WatchResponseUnit unit)

Description copied from interface: WatchClient.UnitListener

Invoked on new events.

Can be called many times but is never called after WatchClient.UnitListener.onError(Throwable) or WatchClient.UnitListener.onCompleted() are called.

Specified by:

onNext in interface WatchClient.UnitListener

Parameters:

unit - the watch response unit

onError

public void onError(@NotNull
 @NotNull Throwable t)

Description copied from interface: WatchClient.UnitListener

Invoked on errors.

May only be called once and if called it must be the last method called.

Specified by:

onError in interface WatchClient.UnitListener

Parameters:

t - the error

onCompleted

public void onCompleted()

Description copied from interface: WatchClient.UnitListener

Invoked on completion.

May only be called once and if called it must be the last method called.

Specified by:

onCompleted in interface WatchClient.UnitListener

getWatchFuture

public CompletableFuture<WatchClient.Watch> getWatchFuture()

Get the watch future.

Returns:

the watch future

restartWatch

public WatchClient.Watch restartWatch()

After an error in the watch, restart it at the last known revision.

Returns:

the new watch