Package io.deephaven.server.session

Class ActionRouter

java.lang.Object

io.deephaven.server.session.ActionRouter

public final class ActionRouter
extends Object

Constructor Summary

Constructors

Constructor	Description
ActionRouter(Set<ActionResolver> resolvers)

Method Summary

Modifier and Type	Method	Description
void	doAction(@Nullable SessionState session, org.apache.arrow.flight.Action action, io.grpc.stub.StreamObserver<org.apache.arrow.flight.Result> observer)	Routes action to the appropriate ActionResolver.
void	listActions(@Nullable SessionState session, Consumer<org.apache.arrow.flight.ActionType> visitor)	Invokes visitor for all of the resolvers.

Methods inherited from class java.lang.Object

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

Constructor Details

ActionRouter

@Inject
public ActionRouter(Set<ActionResolver> resolvers)

Method Details

listActions

public void listActions(@Nullable
 @Nullable SessionState session,
 Consumer<org.apache.arrow.flight.ActionType> visitor)

Invokes visitor for all of the resolvers. Used as the basis for implementing FlightService ListActions.

Parameters:

session - the session

visitor - the visitor

doAction

public void doAction(@Nullable
 @Nullable SessionState session,
 org.apache.arrow.flight.Action action,
 io.grpc.stub.StreamObserver<org.apache.arrow.flight.Result> observer)

Routes action to the appropriate ActionResolver. Used as the basis for implementing FlightService DoAction.

Parameters:

session - the session

action - the action

observer - the observer

Throws:

io.grpc.StatusRuntimeException - if zero or more than one resolver is found