Uses of Class
io.axoniq.axonserver.grpc.FlowControl

Packages that use FlowControl

Package	Description
io.axoniq.axonserver.connector.event.impl
io.axoniq.axonserver.connector.impl
io.axoniq.axonserver.connector.query.impl
io.axoniq.axonserver.grpc
io.axoniq.axonserver.grpc.command
io.axoniq.axonserver.grpc.query

Uses of FlowControl in io.axoniq.axonserver.connector.event.impl

Methods in io.axoniq.axonserver.connector.event.impl with parameters of type FlowControl

Modifier and Type	Method	Description
protected GetAggregateEventsRequest	BufferedAggregateEventStream.buildFlowControlMessage(FlowControl flowControl)
protected GetEventsRequest	BufferedEventStream.buildFlowControlMessage(FlowControl flowControl)
protected StreamRequest	BufferedPersistentStreamSegment.buildFlowControlMessage(FlowControl flowControl)
protected GetEventsRequest	BufferedEventStream.buildInitialFlowControlMessage(FlowControl flowControl)

Uses of FlowControl in io.axoniq.axonserver.connector.impl

Methods in io.axoniq.axonserver.connector.impl with parameters of type FlowControl

Modifier and Type	Method	Description
protected abstract OUT	FlowControlledStream.buildFlowControlMessage(FlowControl flowControl)	Build a flow control message of type OUT based on the given flowControl.
protected OUT	FlowControlledStream.buildInitialFlowControlMessage(FlowControl flowControl)	Builds the initial flow control message of type OUT based on the given flowControl.

Uses of FlowControl in io.axoniq.axonserver.connector.query.impl

Methods in io.axoniq.axonserver.connector.query.impl with parameters of type FlowControl

Modifier and Type	Method	Description
protected SubscriptionQueryRequest	SubscriptionQueryStream.buildFlowControlMessage(FlowControl flowControl)
protected SubscriptionQueryRequest	SubscriptionQueryUpdateBuffer.buildFlowControlMessage(FlowControl flowControl)

Uses of FlowControl in io.axoniq.axonserver.grpc

Methods in io.axoniq.axonserver.grpc that return FlowControl

Modifier and Type	Method	Description
FlowControl	FlowControl.Builder.build()
FlowControl	FlowControl.Builder.buildPartial()
static FlowControl	FlowControl.getDefaultInstance()
FlowControl	FlowControl.Builder.getDefaultInstanceForType()
FlowControl	FlowControl.getDefaultInstanceForType()
static FlowControl	FlowControl.parseDelimitedFrom(InputStream input)
static FlowControl	FlowControl.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlowControl	FlowControl.parseFrom(byte[] data)
static FlowControl	FlowControl.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlowControl	FlowControl.parseFrom(com.google.protobuf.ByteString data)
static FlowControl	FlowControl.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlowControl	FlowControl.parseFrom(com.google.protobuf.CodedInputStream input)
static FlowControl	FlowControl.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlowControl	FlowControl.parseFrom(InputStream input)
static FlowControl	FlowControl.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlowControl	FlowControl.parseFrom(ByteBuffer data)
static FlowControl	FlowControl.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in io.axoniq.axonserver.grpc that return types with arguments of type FlowControl

Modifier and Type	Method	Description
com.google.protobuf.Parser<FlowControl>	FlowControl.getParserForType()
static com.google.protobuf.Parser<FlowControl>	FlowControl.parser()

Methods in io.axoniq.axonserver.grpc with parameters of type FlowControl

Modifier and Type	Method	Description
FlowControl.Builder	FlowControl.Builder.mergeFrom(FlowControl other)
static FlowControl.Builder	FlowControl.newBuilder(FlowControl prototype)

Uses of FlowControl in io.axoniq.axonserver.grpc.command

Methods in io.axoniq.axonserver.grpc.command that return FlowControl

Modifier and Type	Method	Description
FlowControl	CommandProviderOutbound.Builder.getFlowControl()	Instruction to increase the number of instructions AxonServer may send to this component
FlowControl	CommandProviderOutbound.getFlowControl()	Instruction to increase the number of instructions AxonServer may send to this component
FlowControl	CommandProviderOutboundOrBuilder.getFlowControl()	Instruction to increase the number of instructions AxonServer may send to this component

Methods in io.axoniq.axonserver.grpc.command with parameters of type FlowControl

Modifier and Type	Method	Description
CommandProviderOutbound.Builder	CommandProviderOutbound.Builder.mergeFlowControl(FlowControl value)	Instruction to increase the number of instructions AxonServer may send to this component
CommandProviderOutbound.Builder	CommandProviderOutbound.Builder.setFlowControl(FlowControl value)	Instruction to increase the number of instructions AxonServer may send to this component

Uses of FlowControl in io.axoniq.axonserver.grpc.query

Methods in io.axoniq.axonserver.grpc.query that return FlowControl

Modifier and Type	Method	Description
FlowControl	QueryProviderOutbound.Builder.getFlowControl()	Grant permits to AxonServer to send a number of messages to the client
FlowControl	QueryProviderOutbound.getFlowControl()	Grant permits to AxonServer to send a number of messages to the client
FlowControl	QueryProviderOutboundOrBuilder.getFlowControl()	Grant permits to AxonServer to send a number of messages to the client

Methods in io.axoniq.axonserver.grpc.query with parameters of type FlowControl

Modifier and Type	Method	Description
QueryProviderOutbound.Builder	QueryProviderOutbound.Builder.mergeFlowControl(FlowControl value)	Grant permits to AxonServer to send a number of messages to the client
QueryProviderOutbound.Builder	QueryProviderOutbound.Builder.setFlowControl(FlowControl value)	Grant permits to AxonServer to send a number of messages to the client