Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.event

Class EventTransformationServiceGrpc.EventTransformationServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<EventTransformationServiceGrpc.EventTransformationServiceStub>

io.axoniq.axonserver.grpc.event.EventTransformationServiceGrpc.EventTransformationServiceStub

Enclosing class:

EventTransformationServiceGrpc

public static final class EventTransformationServiceGrpc.EventTransformationServiceStub
extends io.grpc.stub.AbstractAsyncStub<EventTransformationServiceGrpc.EventTransformationServiceStub>

A stub to allow clients to do asynchronous rpc calls to service EventTransformationService.

 Service to transform events in an event store 
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
void	applyTransformation(ApplyTransformationRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Applies the changes from a transformation in the event store.
protected EventTransformationServiceGrpc.EventTransformationServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	cancelTransformation(TransformationId request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Cancels a transformation before it is applied.
void	compact(CompactionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Deletes old versions of events updated by a transformation.
void	startTransformation(StartTransformationRequest request, io.grpc.stub.StreamObserver<TransformationId> responseObserver)	Starts a new transformation.
void	transformations(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<Transformation> responseObserver)	Returns the list of all transformations.
io.grpc.stub.StreamObserver<TransformRequest>	transformEvents(io.grpc.stub.StreamObserver<TransformRequestAck> responseObserver)	Adds requests to transform an event to a transformation.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected EventTransformationServiceGrpc.EventTransformationServiceStub build(io.grpc.Channel channel,
                                                                              io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<EventTransformationServiceGrpc.EventTransformationServiceStub>

transformations

public void transformations(com.google.protobuf.Empty request,
                            io.grpc.stub.StreamObserver<Transformation> responseObserver)

 Returns the list of all transformations.
 

startTransformation

public void startTransformation(StartTransformationRequest request,
                                io.grpc.stub.StreamObserver<TransformationId> responseObserver)

 Starts a new transformation.
 

transformEvents

public io.grpc.stub.StreamObserver<TransformRequest> transformEvents(io.grpc.stub.StreamObserver<TransformRequestAck> responseObserver)

 Adds requests to transform an event to a transformation.
 

cancelTransformation

public void cancelTransformation(TransformationId request,
                                 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Cancels a transformation before it is applied.
 

applyTransformation

public void applyTransformation(ApplyTransformationRequest request,
                                io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Applies the changes from a transformation in the event store.
 

compact

public void compact(CompactionRequest request,
                    io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Deletes old versions of events updated by a transformation.