Package io.deephaven.enterprise.dnd.service.ticket

Class DatabaseTicketResolver

java.lang.Object

io.deephaven.server.session.TicketResolverBase

io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver

All Implemented Interfaces:

TicketResolver

@Singleton
public class DatabaseTicketResolver
extends TicketResolverBase

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.server.session.TicketResolver

TicketResolver.Authorization

Field Summary

Fields

Modifier and Type	Field	Description
static final int	NAMESPACE_PATH_INDEX
static final int	TABLE_NAME_PATH_INDEX
static final int	TYPE_PATH_INDEX

Fields inherited from class io.deephaven.server.session.TicketResolverBase

authorization

Constructor Summary

Constructors

Constructor	Description
DatabaseTicketResolver(AuthorizationProvider authProvider, Database database)

Method Summary

Modifier and Type	Method	Description
SessionState.ExportObject<org.apache.arrow.flight.impl.Flight.FlightInfo>	flightInfoFor(@Nullable SessionState session, org.apache.arrow.flight.impl.Flight.FlightDescriptor descriptor, String logId)
void	forAllFlightInfo(@Nullable SessionState session, Consumer<org.apache.arrow.flight.impl.Flight.FlightInfo> visitor)
String	getLogNameFor(ByteBuffer ticket, String logId)
<T> SessionState.ExportBuilder<T>	publish(SessionState session, ByteBuffer ticket, String logId, Runnable onPublish)
<T> SessionState.ExportBuilder<T>	publish(SessionState session, org.apache.arrow.flight.impl.Flight.FlightDescriptor descriptor, String logId, Runnable onPublish)
<T> SessionState.ExportObject<T>	resolve(@Nullable SessionState session, ByteBuffer ticket, String logId)
<T> SessionState.ExportObject<T>	resolve(@Nullable SessionState session, org.apache.arrow.flight.impl.Flight.FlightDescriptor descriptor, String logId)

Methods inherited from class io.deephaven.server.session.TicketResolverBase

flightDescriptorRoute, ticketRoute

Methods inherited from class java.lang.Object

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

Field Details

TYPE_PATH_INDEX

public static final int TYPE_PATH_INDEX

See Also:

• Constant Field Values

NAMESPACE_PATH_INDEX

public static final int NAMESPACE_PATH_INDEX

See Also:

• Constant Field Values

TABLE_NAME_PATH_INDEX

public static final int TABLE_NAME_PATH_INDEX

See Also:

• Constant Field Values

Constructor Details

DatabaseTicketResolver

@Inject
public DatabaseTicketResolver(AuthorizationProvider authProvider,
 Database database)

Method Details

resolve

public <T> SessionState.ExportObject<T> resolve(@Nullable
 @Nullable SessionState session,
 ByteBuffer ticket,
 String logId)

resolve

public <T> SessionState.ExportObject<T> resolve(@Nullable
 @Nullable SessionState session,
 org.apache.arrow.flight.impl.Flight.FlightDescriptor descriptor,
 String logId)

flightInfoFor

public SessionState.ExportObject<org.apache.arrow.flight.impl.Flight.FlightInfo> flightInfoFor(@Nullable
 @Nullable SessionState session,
 org.apache.arrow.flight.impl.Flight.FlightDescriptor descriptor,
 String logId)

getLogNameFor

public String getLogNameFor(ByteBuffer ticket,
 String logId)

forAllFlightInfo

public void forAllFlightInfo(@Nullable
 @Nullable SessionState session,
 Consumer<org.apache.arrow.flight.impl.Flight.FlightInfo> visitor)

publish

public <T> SessionState.ExportBuilder<T> publish(SessionState session,
 ByteBuffer ticket,
 String logId,
 Runnable onPublish)

publish

public <T> SessionState.ExportBuilder<T> publish(SessionState session,
 org.apache.arrow.flight.impl.Flight.FlightDescriptor descriptor,
 String logId,
 Runnable onPublish)