Package org.apache.ignite.client.handler

Class ClientHandlerModule

java.lang.Object
org.apache.ignite.client.handler.ClientHandlerModule
All Implemented Interfaces:
org.apache.ignite.internal.compute.executor.platform.PlatformComputeTransport, org.apache.ignite.internal.lang.Debuggable, org.apache.ignite.internal.manager.IgniteComponent
public class ClientHandlerModule extends Object implements org.apache.ignite.internal.manager.IgniteComponent, org.apache.ignite.internal.compute.executor.platform.PlatformComputeTransport
Client handler module maintains TCP endpoint for thin client connections.

  • Field Summary

    Fields inherited from interface org.apache.ignite.internal.lang.Debuggable

    INDENTATION

  • Constructor Summary

    Constructors
    Constructor
    Description
    ClientHandlerModule(org.apache.ignite.internal.sql.engine.QueryProcessor queryProcessor, org.apache.ignite.internal.table.IgniteTablesInternal igniteTables, org.apache.ignite.internal.tx.TxManager txManager, org.apache.ignite.internal.compute.IgniteComputeInternal igniteCompute, org.apache.ignite.internal.network.ClusterService clusterService, org.apache.ignite.internal.network.NettyBootstrapFactory bootstrapFactory, Supplier<ClusterInfo> clusterInfoSupplier, org.apache.ignite.internal.metrics.MetricManager metricManager, ClientHandlerMetricSource metrics, org.apache.ignite.internal.security.authentication.AuthenticationManager authenticationManager, org.apache.ignite.internal.hlc.ClockService clockService, org.apache.ignite.internal.schema.SchemaSyncService schemaSyncService, org.apache.ignite.internal.catalog.CatalogService catalogService, org.apache.ignite.internal.placementdriver.PlacementDriver placementDriver, org.apache.ignite.client.handler.configuration.ClientConnectorConfiguration clientConnectorConfiguration, org.apache.ignite.internal.lowwatermark.LowWatermark lowWatermark, org.apache.ignite.internal.components.NodeProperties nodeProperties, Executor partitionOperationsExecutor)
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    enable()
    Enables request handling.
    ClientInboundMessageHandler
    handler()
     
    InetSocketAddress
    localAddress()
    Returns the local address where this handler is bound to.
    CompletableFuture<org.apache.ignite.internal.compute.executor.platform.PlatformComputeConnection>
    registerComputeExecutorId(String computeExecutorId)
     
    String
    serverAddress()
     
    boolean
    sslEnabled()
     
    CompletableFuture<Void>
    startAsync(org.apache.ignite.internal.manager.ComponentContext componentContext)
    CompletableFuture<Void>
    stopAsync(org.apache.ignite.internal.manager.ComponentContext componentContext)

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.ignite.internal.lang.Debuggable

    dumpState

    Methods inherited from interface org.apache.ignite.internal.manager.IgniteComponent

    beforeNodeStop, stopAsync

  • Constructor Details

    • ClientHandlerModule

      public ClientHandlerModule(org.apache.ignite.internal.sql.engine.QueryProcessor queryProcessor, org.apache.ignite.internal.table.IgniteTablesInternal igniteTables, org.apache.ignite.internal.tx.TxManager txManager, org.apache.ignite.internal.compute.IgniteComputeInternal igniteCompute, org.apache.ignite.internal.network.ClusterService clusterService, org.apache.ignite.internal.network.NettyBootstrapFactory bootstrapFactory, Supplier<ClusterInfo> clusterInfoSupplier, org.apache.ignite.internal.metrics.MetricManager metricManager, ClientHandlerMetricSource metrics, org.apache.ignite.internal.security.authentication.AuthenticationManager authenticationManager, org.apache.ignite.internal.hlc.ClockService clockService, org.apache.ignite.internal.schema.SchemaSyncService schemaSyncService, org.apache.ignite.internal.catalog.CatalogService catalogService, org.apache.ignite.internal.placementdriver.PlacementDriver placementDriver, org.apache.ignite.client.handler.configuration.ClientConnectorConfiguration clientConnectorConfiguration, org.apache.ignite.internal.lowwatermark.LowWatermark lowWatermark, org.apache.ignite.internal.components.NodeProperties nodeProperties, Executor partitionOperationsExecutor)
      Constructor.
      Parameters:
      queryProcessor - Sql query processor.
      igniteTables - Ignite.
      txManager - Transaction manager.
      igniteCompute - Compute.
      clusterService - Cluster.
      bootstrapFactory - Bootstrap factory.
      clusterInfoSupplier - ClusterInfo supplier.
      metricManager - Metric manager.
      authenticationManager - Authentication manager.
      clockService - Clock service.
      clientConnectorConfiguration - Configuration of the connector.
      lowWatermark - Low watermark.
      partitionOperationsExecutor - Executor for a partition operation.

  • Method Details

    • startAsync

      public CompletableFuture<Void> startAsync(org.apache.ignite.internal.manager.ComponentContext componentContext)
      Specified by:
      startAsync in interface org.apache.ignite.internal.manager.IgniteComponent

    • stopAsync

      public CompletableFuture<Void> stopAsync(org.apache.ignite.internal.manager.ComponentContext componentContext)
      Specified by:
      stopAsync in interface org.apache.ignite.internal.manager.IgniteComponent

    • localAddress

      public InetSocketAddress localAddress()
      Returns the local address where this handler is bound to.
      Returns:
      the local address of this module.
      Throws:
      org.apache.ignite.internal.lang.IgniteInternalException - if the module is not started.

    • enable

      public void enable()
      Enables request handling.

    • handler

      @TestOnly public ClientInboundMessageHandler handler()

    • serverAddress

      public String serverAddress()
      Specified by:
      serverAddress in interface org.apache.ignite.internal.compute.executor.platform.PlatformComputeTransport

    • sslEnabled

      public boolean sslEnabled()
      Specified by:
      sslEnabled in interface org.apache.ignite.internal.compute.executor.platform.PlatformComputeTransport

    • registerComputeExecutorId

      public CompletableFuture<org.apache.ignite.internal.compute.executor.platform.PlatformComputeConnection> registerComputeExecutorId(String computeExecutorId)
      Specified by:
      registerComputeExecutorId in interface org.apache.ignite.internal.compute.executor.platform.PlatformComputeTransport