Uses of Class
io.axoniq.axonserver.grpc.event.dcb.SourceEventsRequest

Packages that use SourceEventsRequest

Package	Description
io.axoniq.axonserver.connector.event
io.axoniq.axonserver.connector.event.impl
io.axoniq.axonserver.grpc.event.dcb

Uses of SourceEventsRequest in io.axoniq.axonserver.connector.event

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

Modifier and Type	Method	Description
ResultStream<SourceEventsResponse>	DcbEventChannel.source(SourceEventsRequest request)	Provides a finite stream of events used to eventsource a model.

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

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

Modifier and Type	Method	Description
ResultStream<SourceEventsResponse>	DcbEventChannelImpl.source(SourceEventsRequest request)

Uses of SourceEventsRequest in io.axoniq.axonserver.grpc.event.dcb

Methods in io.axoniq.axonserver.grpc.event.dcb that return SourceEventsRequest

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

Methods in io.axoniq.axonserver.grpc.event.dcb that return types with arguments of type SourceEventsRequest

Modifier and Type	Method	Description
com.google.protobuf.Parser<SourceEventsRequest>	SourceEventsRequest.getParserForType()
static io.grpc.MethodDescriptor<SourceEventsRequest,SourceEventsResponse>	DcbEventStoreGrpc.getSourceMethod()
static com.google.protobuf.Parser<SourceEventsRequest>	SourceEventsRequest.parser()

Methods in io.axoniq.axonserver.grpc.event.dcb with parameters of type SourceEventsRequest

Modifier and Type	Method	Description
SourceEventsRequest.Builder	SourceEventsRequest.Builder.mergeFrom(SourceEventsRequest other)
static SourceEventsRequest.Builder	SourceEventsRequest.newBuilder(SourceEventsRequest prototype)
default void	DcbEventStoreGrpc.AsyncService.source(SourceEventsRequest request, io.grpc.stub.StreamObserver<SourceEventsResponse> responseObserver)	Provides a finite stream of events based on the passed SourceEventsRequest.
Iterator<SourceEventsResponse>	DcbEventStoreGrpc.DcbEventStoreBlockingStub.source(SourceEventsRequest request)	Provides a finite stream of events based on the passed SourceEventsRequest.
io.grpc.stub.BlockingClientCall<?,SourceEventsResponse>	DcbEventStoreGrpc.DcbEventStoreBlockingV2Stub.source(SourceEventsRequest request)	Provides a finite stream of events based on the passed SourceEventsRequest.
void	DcbEventStoreGrpc.DcbEventStoreStub.source(SourceEventsRequest request, io.grpc.stub.StreamObserver<SourceEventsResponse> responseObserver)	Provides a finite stream of events based on the passed SourceEventsRequest.