Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.event

Interface EventTransformationServiceGrpc.AsyncService

All Known Implementing Classes:

EventTransformationServiceGrpc.EventTransformationServiceImplBase

Enclosing class:

EventTransformationServiceGrpc

public static interface EventTransformationServiceGrpc.AsyncService

 Service to transform events in an event store 
 

Method Summary

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

Method Detail

transformations

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

 Returns the list of all transformations.
 

startTransformation

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

 Starts a new transformation.
 

transformEvents

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

 Adds requests to transform an event to a transformation.
 

cancelTransformation

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

 Cancels a transformation before it is applied.
 

applyTransformation

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

 Applies the changes from a transformation in the event store.
 

compact

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

 Deletes old versions of events updated by a transformation.