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

Packages that use FlowControl

Package	Description
io.axoniq.axonserver.grpc
io.axoniq.axonserver.grpc.command
io.axoniq.axonserver.grpc.query
org.axonframework.axonserver.connector.util

Uses of FlowControl in io.axoniq.axonserver.grpc

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

Modifier and Type	Method and Description
FlowControl	FlowControl.Builder.build()
FlowControl	FlowControl.Builder.buildPartial()
static FlowControl	FlowControl.getDefaultInstance()
FlowControl	FlowControl.getDefaultInstanceForType()
FlowControl	FlowControl.Builder.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(ByteBuffer data)
static FlowControl	FlowControl.parseFrom(ByteBuffer 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)

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

Modifier and Type	Method and 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 and 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 and Description
FlowControl	CommandProviderOutboundOrBuilder.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	CommandProviderOutbound.Builder.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 and 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 and Description
FlowControl	QueryProviderOutboundOrBuilder.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	QueryProviderOutbound.Builder.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 and 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

Uses of FlowControl in org.axonframework.axonserver.connector.util

Constructor parameters in org.axonframework.axonserver.connector.util with type arguments of type FlowControl

Constructor and Description
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver, AxonServerConfiguration configuration, Function<FlowControl,T> requestWrapper, Predicate<T> isConfirmationMessage)
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver, String clientId, AxonServerConfiguration.FlowControlConfiguration flowControlConfiguration, Function<FlowControl,T> requestWrapper, Predicate<T> isConfirmationMessage)