Package io.deephaven.auth.codegen.impl

Interface ConsoleServiceAuthWiring

All Superinterfaces:
ServiceAuthWiring<ConsoleServiceGrpc.ConsoleServiceImplBase>
All Known Implementing Classes:
ConsoleServiceAuthWiring.AllowAll, ConsoleServiceAuthWiring.DenyAll, ConsoleServiceAuthWiring.TestUseOnly
public interface ConsoleServiceAuthWiring extends ServiceAuthWiring<ConsoleServiceGrpc.ConsoleServiceImplBase>
This interface provides type-safe authorization hooks for ConsoleServiceGrpc.

  • Method Details

    • intercept

      default io.grpc.ServerServiceDefinition intercept(ConsoleServiceGrpc.ConsoleServiceImplBase delegate)
      Wrap the real implementation with authorization checks.
      Specified by:
      intercept in interface ServiceAuthWiring<ConsoleServiceGrpc.ConsoleServiceImplBase>
      Parameters:
      delegate - the real service implementation
      Returns:
      the wrapped service implementation

    • onMessageReceivedGetConsoleTypes

      void onMessageReceivedGetConsoleTypes(AuthContext authContext, GetConsoleTypesRequest request)
      Authorize a request to GetConsoleTypes.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke GetConsoleTypes

    • onMessageReceivedStartConsole

      void onMessageReceivedStartConsole(AuthContext authContext, StartConsoleRequest request)
      Authorize a request to StartConsole.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke StartConsole

    • onMessageReceivedGetHeapInfo

      void onMessageReceivedGetHeapInfo(AuthContext authContext, GetHeapInfoRequest request)
      Authorize a request to GetHeapInfo.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke GetHeapInfo

    • onMessageReceivedSubscribeToLogs

      void onMessageReceivedSubscribeToLogs(AuthContext authContext, LogSubscriptionRequest request)
      Authorize a request to SubscribeToLogs.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke SubscribeToLogs

    • onMessageReceivedExecuteCommand

      void onMessageReceivedExecuteCommand(AuthContext authContext, ExecuteCommandRequest request)
      Authorize a request to ExecuteCommand.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke ExecuteCommand

    • onMessageReceivedCancelCommand

      void onMessageReceivedCancelCommand(AuthContext authContext, CancelCommandRequest request)
      Authorize a request to CancelCommand.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke CancelCommand

    • onMessageReceivedBindTableToVariable

      void onMessageReceivedBindTableToVariable(AuthContext authContext, BindTableToVariableRequest request)
      Authorize a request to BindTableToVariable.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke BindTableToVariable

    • onCallStartedAutoCompleteStream

      void onCallStartedAutoCompleteStream(AuthContext authContext)
      Authorize a request to open a client-streaming rpc AutoCompleteStream.
      Parameters:
      authContext - the authentication context of the request
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke AutoCompleteStream

    • onMessageReceivedAutoCompleteStream

      void onMessageReceivedAutoCompleteStream(AuthContext authContext, AutoCompleteRequest request)
      Authorize a request to AutoCompleteStream.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke AutoCompleteStream

    • onMessageReceivedCancelAutoComplete

      void onMessageReceivedCancelAutoComplete(AuthContext authContext, CancelAutoCompleteRequest request)
      Authorize a request to CancelAutoComplete.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke CancelAutoComplete

    • onMessageReceivedOpenAutoCompleteStream

      void onMessageReceivedOpenAutoCompleteStream(AuthContext authContext, AutoCompleteRequest request)
      Authorize a request to OpenAutoCompleteStream.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke OpenAutoCompleteStream

    • onMessageReceivedNextAutoCompleteStream

      void onMessageReceivedNextAutoCompleteStream(AuthContext authContext, AutoCompleteRequest request)
      Authorize a request to NextAutoCompleteStream.
      Parameters:
      authContext - the authentication context of the request
      request - the request to authorize
      Throws:
      io.grpc.StatusRuntimeException - if the user is not authorized to invoke NextAutoCompleteStream