final case class SocketData(streamsStarted: Long = 0L, streamsSucceeded: Long = 0L, streamsFailed: Long = 0L, messagesSent: Long = 0L, messagesReceived: Long = 0L, keepAlivesSent: Long = 0L, lastLocalStreamCreatedTimestamp: Option[Timestamp] = _root_.scala.None, lastRemoteStreamCreatedTimestamp: Option[Timestamp] = _root_.scala.None, lastMessageSentTimestamp: Option[Timestamp] = _root_.scala.None, lastMessageReceivedTimestamp: Option[Timestamp] = _root_.scala.None, localFlowControlWindow: Option[Long] = _root_.scala.None, remoteFlowControlWindow: Option[Long] = _root_.scala.None, option: Seq[SocketOption] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[SocketData] with Product with Serializable

SocketData is data associated for a specific Socket. The fields present are specific to the implementation, so there may be minor differences in the semantics. (e.g. flow control windows)

streamsStarted

The number of streams that have been started.

streamsSucceeded

The number of streams that have ended successfully: On client side, received frame with eos bit set; On server side, sent frame with eos bit set.

streamsFailed

The number of streams that have ended unsuccessfully: On client side, ended without receiving frame with eos bit set; On server side, ended without sending frame with eos bit set.

messagesSent

The number of grpc messages successfully sent on this socket.

messagesReceived

The number of grpc messages received on this socket.

keepAlivesSent

The number of keep alives sent. This is typically implemented with HTTP/2 ping messages.

lastLocalStreamCreatedTimestamp

The last time a stream was created by this endpoint. Usually unset for servers.

lastRemoteStreamCreatedTimestamp

The last time a stream was created by the remote endpoint. Usually unset for clients.

lastMessageSentTimestamp

The last time a message was sent by this endpoint.

lastMessageReceivedTimestamp

The last time a message was received by this endpoint.

localFlowControlWindow

The amount of window, granted to the local endpoint by the remote endpoint. This may be slightly out of date due to network latency. This does NOT include stream level or TCP level flow control info.

remoteFlowControlWindow

The amount of window, granted to the remote endpoint by the local endpoint. This may be slightly out of date due to network latency. This does NOT include stream level or TCP level flow control info.

option

Socket options set on this socket. May be absent if 'summary' is set on GetSocketRequest.

Annotations
@SerialVersionUID()
Source
SocketData.scala
Linear Supertypes
Updatable[SocketData], GeneratedMessage, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SocketData
  2. Updatable
  3. GeneratedMessage
  4. Serializable
  5. Product
  6. Equals
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SocketData(streamsStarted: Long = 0L, streamsSucceeded: Long = 0L, streamsFailed: Long = 0L, messagesSent: Long = 0L, messagesReceived: Long = 0L, keepAlivesSent: Long = 0L, lastLocalStreamCreatedTimestamp: Option[Timestamp] = _root_.scala.None, lastRemoteStreamCreatedTimestamp: Option[Timestamp] = _root_.scala.None, lastMessageSentTimestamp: Option[Timestamp] = _root_.scala.None, lastMessageReceivedTimestamp: Option[Timestamp] = _root_.scala.None, localFlowControlWindow: Option[Long] = _root_.scala.None, remoteFlowControlWindow: Option[Long] = _root_.scala.None, option: Seq[SocketOption] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)

    streamsStarted

    The number of streams that have been started.

    streamsSucceeded

    The number of streams that have ended successfully: On client side, received frame with eos bit set; On server side, sent frame with eos bit set.

    streamsFailed

    The number of streams that have ended unsuccessfully: On client side, ended without receiving frame with eos bit set; On server side, ended without sending frame with eos bit set.

    messagesSent

    The number of grpc messages successfully sent on this socket.

    messagesReceived

    The number of grpc messages received on this socket.

    keepAlivesSent

    The number of keep alives sent. This is typically implemented with HTTP/2 ping messages.

    lastLocalStreamCreatedTimestamp

    The last time a stream was created by this endpoint. Usually unset for servers.

    lastRemoteStreamCreatedTimestamp

    The last time a stream was created by the remote endpoint. Usually unset for clients.

    lastMessageSentTimestamp

    The last time a message was sent by this endpoint.

    lastMessageReceivedTimestamp

    The last time a message was received by this endpoint.

    localFlowControlWindow

    The amount of window, granted to the local endpoint by the remote endpoint. This may be slightly out of date due to network latency. This does NOT include stream level or TCP level flow control info.

    remoteFlowControlWindow

    The amount of window, granted to the remote endpoint by the local endpoint. This may be slightly out of date due to network latency. This does NOT include stream level or TCP level flow control info.

    option

    Socket options set on this socket. May be absent if 'summary' is set on GetSocketRequest.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def addAllOption(__vs: Iterable[SocketOption]): SocketData
  5. def addOption(__vs: SocketOption*): SocketData
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clearLastLocalStreamCreatedTimestamp: SocketData
  8. def clearLastMessageReceivedTimestamp: SocketData
  9. def clearLastMessageSentTimestamp: SocketData
  10. def clearLastRemoteStreamCreatedTimestamp: SocketData
  11. def clearLocalFlowControlWindow: SocketData
  12. def clearOption: SocketData
  13. def clearRemoteFlowControlWindow: SocketData
  14. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  15. def companion: SocketData.type
    Definition Classes
    SocketData → GeneratedMessage
  16. def discardUnknownFields: SocketData
  17. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  19. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. def getField(__field: FieldDescriptor): PValue
    Definition Classes
    SocketData → GeneratedMessage
  21. def getFieldByNumber(__fieldNumber: Int): Any
    Definition Classes
    SocketData → GeneratedMessage
  22. def getLastLocalStreamCreatedTimestamp: Timestamp
  23. def getLastMessageReceivedTimestamp: Timestamp
  24. def getLastMessageSentTimestamp: Timestamp
  25. def getLastRemoteStreamCreatedTimestamp: Timestamp
  26. def getLocalFlowControlWindow: Long
  27. def getRemoteFlowControlWindow: Long
  28. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  29. val keepAlivesSent: Long
  30. val lastLocalStreamCreatedTimestamp: Option[Timestamp]
  31. val lastMessageReceivedTimestamp: Option[Timestamp]
  32. val lastMessageSentTimestamp: Option[Timestamp]
  33. val lastRemoteStreamCreatedTimestamp: Option[Timestamp]
  34. val localFlowControlWindow: Option[Long]
  35. val messagesReceived: Long
  36. val messagesSent: Long
  37. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  38. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  39. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  40. val option: Seq[SocketOption]
  41. def productElementNames: Iterator[String]
    Definition Classes
    Product
  42. val remoteFlowControlWindow: Option[Long]
  43. def serializedSize: Int
    Definition Classes
    SocketData → GeneratedMessage
  44. val streamsFailed: Long
  45. val streamsStarted: Long
  46. val streamsSucceeded: Long
  47. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  48. final def toByteArray: Array[Byte]
    Definition Classes
    GeneratedMessage
  49. final def toByteString: ByteString
    Definition Classes
    GeneratedMessage
  50. final def toPMessage: PMessage
    Definition Classes
    GeneratedMessage
  51. def toProtoString: String
    Definition Classes
    SocketData → GeneratedMessage
  52. val unknownFields: UnknownFieldSet
  53. def update(ms: (Lens[SocketData, SocketData]) => Mutation[SocketData]*): SocketData
    Definition Classes
    Updatable
  54. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  55. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  56. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  57. def withKeepAlivesSent(__v: Long): SocketData
  58. def withLastLocalStreamCreatedTimestamp(__v: Timestamp): SocketData
  59. def withLastMessageReceivedTimestamp(__v: Timestamp): SocketData
  60. def withLastMessageSentTimestamp(__v: Timestamp): SocketData
  61. def withLastRemoteStreamCreatedTimestamp(__v: Timestamp): SocketData
  62. def withLocalFlowControlWindow(__v: Long): SocketData
  63. def withMessagesReceived(__v: Long): SocketData
  64. def withMessagesSent(__v: Long): SocketData
  65. def withOption(__v: Seq[SocketOption]): SocketData
  66. def withRemoteFlowControlWindow(__v: Long): SocketData
  67. def withStreamsFailed(__v: Long): SocketData
  68. def withStreamsStarted(__v: Long): SocketData
  69. def withStreamsSucceeded(__v: Long): SocketData
  70. def withUnknownFields(__v: UnknownFieldSet): SocketData
  71. final def writeDelimitedTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage
  72. def writeTo(_output__: CodedOutputStream): Unit
    Definition Classes
    SocketData → GeneratedMessage
  73. final def writeTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage

Inherited from Updatable[SocketData]

Inherited from GeneratedMessage

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped