Package io.kroxylicious.proxy.internal

Class KafkaSession

java.lang.Object
io.kroxylicious.proxy.internal.KafkaSession
public class KafkaSession extends Object

  • Constructor Details

  • Method Details

    • transitionTo

      public KafkaSession transitionTo(KafkaSessionState newState)

    • sessionId

      public String sessionId()

    • currentState

      public KafkaSessionState currentState()

    • setHaProxyContext

      public void setHaProxyContext(HaProxyContext context)
      Store the HaProxy PROXY-protocol context for this session.
      Parameters:
      context - the immutable context extracted from the decoded message

    • haProxyContext

      @Nullable public HaProxyContext haProxyContext()
      Returns:
      the HaProxy message received for this session, or null if none.

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object