String host
int port
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
StreamEntryID id
Map<K,V> fields
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
long time
long sequence
String name
long consumers
long pending
StreamEntryID lastDeliveredId
Map<K,V> groupInfo
long length
long radixTreeKeys
long radixTreeNodes
long groups
StreamEntryID lastGeneratedId
StreamEntry firstEntry
StreamEntry lastEntry
Map<K,V> streamInfo
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
StreamEntryID id
String consumerName
long idleTime
long deliveredTimes
long total
StreamEntryID minId
StreamEntryID maxId
Map<K,V> consumerMessageCount
HostAndPort targetNode
int slot
Copyright © 2021. All rights reserved.