Package io.deephaven.kv.meta

Class MetaInfoContext

java.lang.Object

io.deephaven.kv.KeyPathContextBase

io.deephaven.kv.meta.MetaInfoContext

All Implemented Interfaces:

Context, KeyPathContext

public final class MetaInfoContext
extends KeyPathContextBase

A structured KeyPath model around UpdateInfo, and metadata related concerns. See MetaInfoContext.Description for the model.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	MetaInfoContext.Description	The description is composed of the following entries: CREATED, UPDATED, GUARD, SUCCESS, and FAIL.
static interface	MetaInfoContext.GetMetaInfoRequest
class	MetaInfoContext.IllegalMetaContextException
class	MetaInfoContext.Meta

Field Summary

Fields

Modifier and Type	Field	Description
static final KeyPathContextDescription.Entry<UpdateInfoContext,KeyPath>	CREATED	An entry for MetaInfo.getCreated() with the part "created"
static final KeyPathContextDescription.Entry<UpdateCountContext,KeyPath>	FAIL	An entry for MetaInfo.getFailCount() with the part "fail"
static final KeyPathContextDescription.Entry<ModContext,KeyPath>	GUARD	An entry for MetaInfo.getModificationRevision() with the part "guard"
static final KeyPathContextDescription.Entry<UpdateCountContext,KeyPath>	SUCCESS	An entry for MetaInfo.getSuccessCount() with the part "success"
static final KeyPathContextDescription.Entry<UpdateInfoContext,KeyPath>	UPDATED	An entry for MetaInfo.getUpdated() with the part "updated"

Fields inherited from class io.deephaven.kv.KeyPathContextBase

context, description

Constructor Summary

Constructors

Constructor	Description
MetaInfoContext(KeyPath context)

Method Summary

Modifier and Type	Method	Description
AtomicDirectoryContext.AtomicUpdateWrt	asCreateOrFail(UpdateInfo info, Composable onSuccess, Composable onFailure)	For use as a top-level WRT, where we expect the context to not exist
MetaInfoContext.Meta	asMeta()
AtomicDirectoryContext.AtomicUpdateWrt	asUpdateOrFail(UpdateInfo info, Composable onSuccess, Composable onFailure)	For use as a top-level WRT, where we expect the context to have the given mod-rev
static KeyPathContextDescription.Entry<MetaInfoContext,KeyPath>	entry(String part)
static boolean	isGuard(KeyPath strings)	Check whether a KeyPath is a guard path
UpdateCountContext	resolveFail()
ModContext	resolveGuard()
CompletableFuture<WatchClient.Watch>	watch(KVClient kvClient, WatchClient watchClient, UpdateInfoContext.UpdateInfoListener listener)
WatchClient.Watch	watch(WatchClient client, ModContext.ModContextListener listener)
WatchClient.Watch	watch(WatchClient client, ModContext.ModContextListener listener, long modRev)

Methods inherited from class io.deephaven.kv.KeyPathContextBase

equals, getDescription, getPath, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.kv.KeyPathContext

resolve

Field Details

CREATED

public static final KeyPathContextDescription.Entry<UpdateInfoContext,KeyPath> CREATED

An entry for MetaInfo.getCreated() with the part "created"

UPDATED

public static final KeyPathContextDescription.Entry<UpdateInfoContext,KeyPath> UPDATED

An entry for MetaInfo.getUpdated() with the part "updated"

GUARD

public static final KeyPathContextDescription.Entry<ModContext,KeyPath> GUARD

An entry for MetaInfo.getModificationRevision() with the part "guard"

SUCCESS

public static final KeyPathContextDescription.Entry<UpdateCountContext,KeyPath> SUCCESS

An entry for MetaInfo.getSuccessCount() with the part "success"

FAIL

public static final KeyPathContextDescription.Entry<UpdateCountContext,KeyPath> FAIL

An entry for MetaInfo.getFailCount() with the part "fail"

Constructor Details

MetaInfoContext

public MetaInfoContext(KeyPath context)

Method Details

isGuard

public static boolean isGuard(KeyPath strings)

Check whether a KeyPath is a guard path

Parameters:

strings - The KeyPath to check

Returns:

true for guard paths, false for non-guard paths

entry

public static KeyPathContextDescription.Entry<MetaInfoContext,KeyPath> entry(String part)

resolveGuard

public ModContext resolveGuard()

resolveFail

public UpdateCountContext resolveFail()

watch

public WatchClient.Watch watch(WatchClient client,
 ModContext.ModContextListener listener)

watch

public WatchClient.Watch watch(WatchClient client,
 ModContext.ModContextListener listener,
 long modRev)

watch

public CompletableFuture<WatchClient.Watch> watch(KVClient kvClient,
 WatchClient watchClient,
 UpdateInfoContext.UpdateInfoListener listener)

asCreateOrFail

public AtomicDirectoryContext.AtomicUpdateWrt asCreateOrFail(UpdateInfo info,
 Composable onSuccess,
 Composable onFailure)

For use as a top-level WRT, where we expect the context to not exist

asUpdateOrFail

public AtomicDirectoryContext.AtomicUpdateWrt asUpdateOrFail(UpdateInfo info,
 Composable onSuccess,
 Composable onFailure)

For use as a top-level WRT, where we expect the context to have the given mod-rev

asMeta

public MetaInfoContext.Meta asMeta()