Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.admin

Class EventProcessorInstance.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.Builder<EventProcessorInstance.Builder>

io.axoniq.axonserver.grpc.admin.EventProcessorInstance.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, EventProcessorInstanceOrBuilder, Cloneable

Enclosing class:

EventProcessorInstance

public static final class EventProcessorInstance.Builder
extends com.google.protobuf.GeneratedMessage.Builder<EventProcessorInstance.Builder>
implements EventProcessorInstanceOrBuilder

Protobuf type io.axoniq.axonserver.grpc.admin.EventProcessorInstance

Method Summary

Modifier and Type	Method	Description
EventProcessorInstance.Builder	addAllClaimedSegment(Iterable<? extends EventProcessorSegment> values)	status of all segments claimed by the client
EventProcessorInstance.Builder	addClaimedSegment(int index, EventProcessorSegment value)	status of all segments claimed by the client
EventProcessorInstance.Builder	addClaimedSegment(int index, EventProcessorSegment.Builder builderForValue)	status of all segments claimed by the client
EventProcessorInstance.Builder	addClaimedSegment(EventProcessorSegment value)	status of all segments claimed by the client
EventProcessorInstance.Builder	addClaimedSegment(EventProcessorSegment.Builder builderForValue)	status of all segments claimed by the client
EventProcessorSegment.Builder	addClaimedSegmentBuilder()	status of all segments claimed by the client
EventProcessorSegment.Builder	addClaimedSegmentBuilder(int index)	status of all segments claimed by the client
EventProcessorInstance	build()
EventProcessorInstance	buildPartial()
EventProcessorInstance.Builder	clear()
EventProcessorInstance.Builder	clearClaimedSegment()	status of all segments claimed by the client
EventProcessorInstance.Builder	clearClientId()	the client identifier
EventProcessorInstance.Builder	clearIsRunning()	true if the client instance of the event processor is running, false otherwise
EventProcessorInstance.Builder	clearMaxCapacity()	the max number of segments that this client can claim
EventProcessorSegment	getClaimedSegment(int index)	status of all segments claimed by the client
EventProcessorSegment.Builder	getClaimedSegmentBuilder(int index)	status of all segments claimed by the client
List<EventProcessorSegment.Builder>	getClaimedSegmentBuilderList()	status of all segments claimed by the client
int	getClaimedSegmentCount()	status of all segments claimed by the client
List<EventProcessorSegment>	getClaimedSegmentList()	status of all segments claimed by the client
EventProcessorSegmentOrBuilder	getClaimedSegmentOrBuilder(int index)	status of all segments claimed by the client
List<? extends EventProcessorSegmentOrBuilder>	getClaimedSegmentOrBuilderList()	status of all segments claimed by the client
String	getClientId()	the client identifier
com.google.protobuf.ByteString	getClientIdBytes()	the client identifier
EventProcessorInstance	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
boolean	getIsRunning()	true if the client instance of the event processor is running, false otherwise
int	getMaxCapacity()	the max number of segments that this client can claim
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
EventProcessorInstance.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
EventProcessorInstance.Builder	mergeFrom(com.google.protobuf.Message other)
EventProcessorInstance.Builder	mergeFrom(EventProcessorInstance other)
EventProcessorInstance.Builder	removeClaimedSegment(int index)	status of all segments claimed by the client
EventProcessorInstance.Builder	setClaimedSegment(int index, EventProcessorSegment value)	status of all segments claimed by the client
EventProcessorInstance.Builder	setClaimedSegment(int index, EventProcessorSegment.Builder builderForValue)	status of all segments claimed by the client
EventProcessorInstance.Builder	setClientId(String value)	the client identifier
EventProcessorInstance.Builder	setClientIdBytes(com.google.protobuf.ByteString value)	the client identifier
EventProcessorInstance.Builder	setIsRunning(boolean value)	true if the client instance of the event processor is running, false otherwise
EventProcessorInstance.Builder	setMaxCapacity(int value)	the max number of segments that this client can claim

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, internalGetMutableMapField, internalGetMutableMapFieldReflection, isClean, markClean, mergeUnknownFields, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFields, setUnknownFieldSetBuilder, setUnknownFieldsProto3

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageException

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.Message.Builder

mergeDelimitedFrom, mergeDelimitedFrom

Methods inherited from interface com.google.protobuf.MessageLite.Builder

mergeFrom

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Method Detail

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<EventProcessorInstance.Builder>

clear

public EventProcessorInstance.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<EventProcessorInstance.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<EventProcessorInstance.Builder>

getDefaultInstanceForType

public EventProcessorInstance getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public EventProcessorInstance build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public EventProcessorInstance buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public EventProcessorInstance.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<EventProcessorInstance.Builder>

mergeFrom

public EventProcessorInstance.Builder mergeFrom(EventProcessorInstance other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<EventProcessorInstance.Builder>

mergeFrom

public EventProcessorInstance.Builder mergeFrom(com.google.protobuf.CodedInputStream input,
                                                com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                         throws IOException

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<EventProcessorInstance.Builder>

Throws:

IOException

getClientId

public String getClientId()

 the client identifier 
 

string client_id = 1;

Specified by:

getClientId in interface EventProcessorInstanceOrBuilder

Returns:

The clientId.

getClientIdBytes

public com.google.protobuf.ByteString getClientIdBytes()

 the client identifier 
 

string client_id = 1;

Specified by:

getClientIdBytes in interface EventProcessorInstanceOrBuilder

Returns:

The bytes for clientId.

setClientId

public EventProcessorInstance.Builder setClientId(String value)

 the client identifier 
 

string client_id = 1;

Parameters:

value - The clientId to set.

Returns:

This builder for chaining.

clearClientId

public EventProcessorInstance.Builder clearClientId()

 the client identifier 
 

string client_id = 1;

Returns:

This builder for chaining.

setClientIdBytes

public EventProcessorInstance.Builder setClientIdBytes(com.google.protobuf.ByteString value)

 the client identifier 
 

string client_id = 1;

Parameters:

value - The bytes for clientId to set.

Returns:

This builder for chaining.

getIsRunning

public boolean getIsRunning()

 true if the client instance of the event processor is running, false otherwise 
 

bool isRunning = 2;

Specified by:

getIsRunning in interface EventProcessorInstanceOrBuilder

Returns:

The isRunning.

setIsRunning

public EventProcessorInstance.Builder setIsRunning(boolean value)

 true if the client instance of the event processor is running, false otherwise 
 

bool isRunning = 2;

Parameters:

value - The isRunning to set.

Returns:

This builder for chaining.

clearIsRunning

public EventProcessorInstance.Builder clearIsRunning()

 true if the client instance of the event processor is running, false otherwise 
 

bool isRunning = 2;

Returns:

This builder for chaining.

getMaxCapacity

public int getMaxCapacity()

 the max number of segments that this client can claim
 

int32 max_capacity = 3;

Specified by:

getMaxCapacity in interface EventProcessorInstanceOrBuilder

Returns:

The maxCapacity.

setMaxCapacity

public EventProcessorInstance.Builder setMaxCapacity(int value)

 the max number of segments that this client can claim
 

int32 max_capacity = 3;

Parameters:

value - The maxCapacity to set.

Returns:

This builder for chaining.

clearMaxCapacity

public EventProcessorInstance.Builder clearMaxCapacity()

 the max number of segments that this client can claim
 

int32 max_capacity = 3;

Returns:

This builder for chaining.

getClaimedSegmentList

public List<EventProcessorSegment> getClaimedSegmentList()

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

Specified by:

getClaimedSegmentList in interface EventProcessorInstanceOrBuilder

getClaimedSegmentCount

public int getClaimedSegmentCount()

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

Specified by:

getClaimedSegmentCount in interface EventProcessorInstanceOrBuilder

getClaimedSegment

public EventProcessorSegment getClaimedSegment(int index)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

Specified by:

getClaimedSegment in interface EventProcessorInstanceOrBuilder

setClaimedSegment

public EventProcessorInstance.Builder setClaimedSegment(int index,
                                                        EventProcessorSegment value)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

setClaimedSegment

public EventProcessorInstance.Builder setClaimedSegment(int index,
                                                        EventProcessorSegment.Builder builderForValue)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

addClaimedSegment

public EventProcessorInstance.Builder addClaimedSegment(EventProcessorSegment value)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

addClaimedSegment

public EventProcessorInstance.Builder addClaimedSegment(int index,
                                                        EventProcessorSegment value)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

addClaimedSegment

public EventProcessorInstance.Builder addClaimedSegment(EventProcessorSegment.Builder builderForValue)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

addClaimedSegment

public EventProcessorInstance.Builder addClaimedSegment(int index,
                                                        EventProcessorSegment.Builder builderForValue)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

addAllClaimedSegment

public EventProcessorInstance.Builder addAllClaimedSegment(Iterable<? extends EventProcessorSegment> values)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

clearClaimedSegment

public EventProcessorInstance.Builder clearClaimedSegment()

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

removeClaimedSegment

public EventProcessorInstance.Builder removeClaimedSegment(int index)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

getClaimedSegmentBuilder

public EventProcessorSegment.Builder getClaimedSegmentBuilder(int index)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

getClaimedSegmentOrBuilder

public EventProcessorSegmentOrBuilder getClaimedSegmentOrBuilder(int index)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

Specified by:

getClaimedSegmentOrBuilder in interface EventProcessorInstanceOrBuilder

getClaimedSegmentOrBuilderList

public List<? extends EventProcessorSegmentOrBuilder> getClaimedSegmentOrBuilderList()

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

Specified by:

getClaimedSegmentOrBuilderList in interface EventProcessorInstanceOrBuilder

addClaimedSegmentBuilder

public EventProcessorSegment.Builder addClaimedSegmentBuilder()

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

addClaimedSegmentBuilder

public EventProcessorSegment.Builder addClaimedSegmentBuilder(int index)

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;

getClaimedSegmentBuilderList

public List<EventProcessorSegment.Builder> getClaimedSegmentBuilderList()

 status of all segments claimed by the client 
 

repeated .io.axoniq.axonserver.grpc.admin.EventProcessorSegment claimed_segment = 4;