Package org.apache.storm.messaging

Interface IConnection

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
Client, ConnectionWithStatus
public interface IConnection extends AutoCloseable

  • Method Details

    • sendLoadMetrics

      void sendLoadMetrics(Map<Integer,Double> taskToLoad)
      Send load metrics to all downstream connections.
      Parameters:
      taskToLoad - a map from the task id to the load for that task.

    • sendBackPressureStatus

      void sendBackPressureStatus(BackPressureStatus bpStatus)
      Sends the back pressure metrics to all downstream connections.

    • send

      void send(Iterator<TaskMessage> msgs)
      send batch messages.

    • getLoad

      Map<Integer,Load> getLoad(Collection<Integer> tasks)
      Get the current load for the given tasks.
      Parameters:
      tasks - the tasks to look for.
      Returns:
      a Load for each of the tasks it knows about.

    • getPort

      int getPort()
      Get the port for this connection.
      Returns:
      The port this connection is using

    • close

      void close()
      close this connection.
      Specified by:
      close in interface AutoCloseable