public final class EventProcessorInfo extends com.google.protobuf.GeneratedMessageV3 implements EventProcessorInfoOrBuilder
Message containing information about the status of a Tracking Event ProcessorProtobuf type
io.axoniq.axonserver.grpc.control.EventProcessorInfo| Modifier and Type | Class and Description |
|---|---|
static class |
EventProcessorInfo.Builder
Message containing information about the status of a Tracking Event Processor
|
static class |
EventProcessorInfo.SegmentStatus
Message containing information about the status of a Segment of a Tracking Event Processor
|
static interface |
EventProcessorInfo.SegmentStatusOrBuilder |
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable| Modifier and Type | Field and Description |
|---|---|
static int |
ACTIVE_THREADS_FIELD_NUMBER |
static int |
AVAILABLE_THREADS_FIELD_NUMBER |
static int |
ERROR_FIELD_NUMBER |
static int |
MODE_FIELD_NUMBER |
static int |
PROCESSOR_NAME_FIELD_NUMBER |
static int |
RUNNING_FIELD_NUMBER |
static int |
SEGMENT_STATUS_FIELD_NUMBER |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object obj) |
int |
getActiveThreads()
The number of threads currently actively processing Events
|
int |
getAvailableThreads()
The number of threads the processor has available to assign to Segments.
|
static EventProcessorInfo |
getDefaultInstance() |
EventProcessorInfo |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
boolean |
getError()
Flag indicating whether the processor, when stopped, did so because of an irrecoverable Error
|
String |
getMode()
The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
|
com.google.protobuf.ByteString |
getModeBytes()
The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
|
com.google.protobuf.Parser<EventProcessorInfo> |
getParserForType() |
String |
getProcessorName()
The logical name of this processor.
|
com.google.protobuf.ByteString |
getProcessorNameBytes()
The logical name of this processor.
|
boolean |
getRunning()
Flag indicating whether the processor is running
|
EventProcessorInfo.SegmentStatus |
getSegmentStatus(int index)
Status details of each of the Segments for which Events are being processed.
|
int |
getSegmentStatusCount()
Status details of each of the Segments for which Events are being processed.
|
List<EventProcessorInfo.SegmentStatus> |
getSegmentStatusList()
Status details of each of the Segments for which Events are being processed.
|
EventProcessorInfo.SegmentStatusOrBuilder |
getSegmentStatusOrBuilder(int index)
Status details of each of the Segments for which Events are being processed.
|
List<? extends EventProcessorInfo.SegmentStatusOrBuilder> |
getSegmentStatusOrBuilderList()
Status details of each of the Segments for which Events are being processed.
|
int |
getSerializedSize() |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
int |
hashCode() |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static EventProcessorInfo.Builder |
newBuilder() |
static EventProcessorInfo.Builder |
newBuilder(EventProcessorInfo prototype) |
EventProcessorInfo.Builder |
newBuilderForType() |
protected EventProcessorInfo.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
static EventProcessorInfo |
parseDelimitedFrom(InputStream input) |
static EventProcessorInfo |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static EventProcessorInfo |
parseFrom(byte[] data) |
static EventProcessorInfo |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static EventProcessorInfo |
parseFrom(ByteBuffer data) |
static EventProcessorInfo |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static EventProcessorInfo |
parseFrom(com.google.protobuf.ByteString data) |
static EventProcessorInfo |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static EventProcessorInfo |
parseFrom(com.google.protobuf.CodedInputStream input) |
static EventProcessorInfo |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static EventProcessorInfo |
parseFrom(InputStream input) |
static EventProcessorInfo |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<EventProcessorInfo> |
parser() |
EventProcessorInfo.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, makeExtensionsImmutable, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTagfindInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringaddAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToclone, finalize, getClass, notify, notifyAll, wait, wait, waitpublic static final int PROCESSOR_NAME_FIELD_NUMBER
public static final int MODE_FIELD_NUMBER
public static final int ACTIVE_THREADS_FIELD_NUMBER
public static final int RUNNING_FIELD_NUMBER
public static final int ERROR_FIELD_NUMBER
public static final int SEGMENT_STATUS_FIELD_NUMBER
public static final int AVAILABLE_THREADS_FIELD_NUMBER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields in interface com.google.protobuf.MessageOrBuildergetUnknownFields in class com.google.protobuf.GeneratedMessageV3public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3public String getProcessorName()
The logical name of this processor.
string processor_name = 1;getProcessorName in interface EventProcessorInfoOrBuilderpublic com.google.protobuf.ByteString getProcessorNameBytes()
The logical name of this processor.
string processor_name = 1;getProcessorNameBytes in interface EventProcessorInfoOrBuilderpublic String getMode()
The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
string mode = 2;getMode in interface EventProcessorInfoOrBuilderpublic com.google.protobuf.ByteString getModeBytes()
The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
string mode = 2;getModeBytes in interface EventProcessorInfoOrBuilderpublic int getActiveThreads()
The number of threads currently actively processing Events
int32 active_threads = 3;getActiveThreads in interface EventProcessorInfoOrBuilderpublic boolean getRunning()
Flag indicating whether the processor is running
bool running = 4;getRunning in interface EventProcessorInfoOrBuilderpublic boolean getError()
Flag indicating whether the processor, when stopped, did so because of an irrecoverable Error
bool error = 5;getError in interface EventProcessorInfoOrBuilderpublic List<EventProcessorInfo.SegmentStatus> getSegmentStatusList()
Status details of each of the Segments for which Events are being processed. This is only provided by Tracking Event Processors.
repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;getSegmentStatusList in interface EventProcessorInfoOrBuilderpublic List<? extends EventProcessorInfo.SegmentStatusOrBuilder> getSegmentStatusOrBuilderList()
Status details of each of the Segments for which Events are being processed. This is only provided by Tracking Event Processors.
repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;getSegmentStatusOrBuilderList in interface EventProcessorInfoOrBuilderpublic int getSegmentStatusCount()
Status details of each of the Segments for which Events are being processed. This is only provided by Tracking Event Processors.
repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;getSegmentStatusCount in interface EventProcessorInfoOrBuilderpublic EventProcessorInfo.SegmentStatus getSegmentStatus(int index)
Status details of each of the Segments for which Events are being processed. This is only provided by Tracking Event Processors.
repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;getSegmentStatus in interface EventProcessorInfoOrBuilderpublic EventProcessorInfo.SegmentStatusOrBuilder getSegmentStatusOrBuilder(int index)
Status details of each of the Segments for which Events are being processed. This is only provided by Tracking Event Processors.
repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;getSegmentStatusOrBuilder in interface EventProcessorInfoOrBuilderpublic int getAvailableThreads()
The number of threads the processor has available to assign to Segments. Will report 0 if all threads are assigned a Segment.
int32 available_threads = 7;getAvailableThreads in interface EventProcessorInfoOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3public void writeTo(com.google.protobuf.CodedOutputStream output)
throws IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.GeneratedMessageV3IOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.GeneratedMessageV3public boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static EventProcessorInfo parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static EventProcessorInfo parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static EventProcessorInfo parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static EventProcessorInfo parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static EventProcessorInfo parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static EventProcessorInfo parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static EventProcessorInfo parseFrom(InputStream input) throws IOException
IOExceptionpublic static EventProcessorInfo parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static EventProcessorInfo parseDelimitedFrom(InputStream input) throws IOException
IOExceptionpublic static EventProcessorInfo parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static EventProcessorInfo parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOExceptionpublic static EventProcessorInfo parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic EventProcessorInfo.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic static EventProcessorInfo.Builder newBuilder()
public static EventProcessorInfo.Builder newBuilder(EventProcessorInfo prototype)
public EventProcessorInfo.Builder toBuilder()
toBuilder in interface com.google.protobuf.MessagetoBuilder in interface com.google.protobuf.MessageLiteprotected EventProcessorInfo.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType in class com.google.protobuf.GeneratedMessageV3public static EventProcessorInfo getDefaultInstance()
public static com.google.protobuf.Parser<EventProcessorInfo> parser()
public com.google.protobuf.Parser<EventProcessorInfo> getParserForType()
getParserForType in interface com.google.protobuf.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public EventProcessorInfo getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderCopyright © 2010–2020. All rights reserved.