Uses of Class
io.axoniq.axonserver.grpc.control.PlatformInboundInstruction

Packages that use PlatformInboundInstruction

Package	Description
io.axoniq.axonserver.connector.control
io.axoniq.axonserver.connector.impl
io.axoniq.axonserver.grpc.control

Uses of PlatformInboundInstruction in io.axoniq.axonserver.connector.control

Methods in io.axoniq.axonserver.connector.control with parameters of type PlatformInboundInstruction

Modifier and Type	Method	Description
CompletableFuture<Void>	ControlChannel.sendInstruction(PlatformInboundInstruction instruction)	Send a the given instruction over this channel, returning the acknowledgment of the instruction asynchronously.

Method parameters in io.axoniq.axonserver.connector.control with type arguments of type PlatformInboundInstruction

Modifier and Type	Method	Description
Registration	ControlChannel.registerInstructionHandler(PlatformOutboundInstruction.RequestCase type, InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> handler)	Registers the given handler to handle a given type of instruction.

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

Methods in io.axoniq.axonserver.connector.impl that return types with arguments of type PlatformInboundInstruction

Modifier and Type	Method	Description
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	ProcessorInstructions.mergeHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's merge request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	ProcessorInstructions.pauseHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's pause request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	ProcessorInstructions.releaseSegmentHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's release segment request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	ProcessorInstructions.requestInfoHandler(Map<String,Supplier<EventProcessorInfo>> infoSuppliers)	Provides a InstructionHandler which handles a processor's information request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	ProcessorInstructions.splitHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's split request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	ProcessorInstructions.startHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's start request from AxonServer and sends it to the right client(s).

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

Modifier and Type	Method	Description
CompletableFuture<Void>	ControlChannelImpl.sendInstruction(PlatformInboundInstruction instruction)

Method parameters in io.axoniq.axonserver.connector.impl with type arguments of type PlatformInboundInstruction

Modifier and Type	Method	Description
void	HeartbeatMonitor.handleIncomingBeat(ReplyChannel<PlatformInboundInstruction> reply)	Handler of PlatformInboundInstruction requesting a heartbeat from this connector.
Registration	ControlChannelImpl.registerInstructionHandler(PlatformOutboundInstruction.RequestCase type, InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> handler)

Uses of PlatformInboundInstruction in io.axoniq.axonserver.grpc.control

Methods in io.axoniq.axonserver.grpc.control that return PlatformInboundInstruction

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

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

Modifier and Type	Method	Description
static io.grpc.MethodDescriptor<PlatformInboundInstruction,PlatformOutboundInstruction>	PlatformServiceGrpc.getOpenStreamMethod()
com.google.protobuf.Parser<PlatformInboundInstruction>	PlatformInboundInstruction.getParserForType()
default io.grpc.stub.StreamObserver<PlatformInboundInstruction>	PlatformServiceGrpc.AsyncService.openStream(io.grpc.stub.StreamObserver<PlatformOutboundInstruction> responseObserver)	Opens an instruction stream to the Platform, allowing AxonServer to provide management instructions to the application
io.grpc.stub.BlockingClientCall<PlatformInboundInstruction,PlatformOutboundInstruction>	PlatformServiceGrpc.PlatformServiceBlockingV2Stub.openStream()	Opens an instruction stream to the Platform, allowing AxonServer to provide management instructions to the application
io.grpc.stub.StreamObserver<PlatformInboundInstruction>	PlatformServiceGrpc.PlatformServiceStub.openStream(io.grpc.stub.StreamObserver<PlatformOutboundInstruction> responseObserver)	Opens an instruction stream to the Platform, allowing AxonServer to provide management instructions to the application
static com.google.protobuf.Parser<PlatformInboundInstruction>	PlatformInboundInstruction.parser()

Methods in io.axoniq.axonserver.grpc.control with parameters of type PlatformInboundInstruction

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