Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.event.transformation.impl.grpc

Class GrpcEventTransformationService

java.lang.Object

io.axoniq.axonserver.connector.event.transformation.impl.grpc.GrpcEventTransformationService

All Implemented Interfaces:

EventTransformationService

public class GrpcEventTransformationService
extends Object
implements EventTransformationService

Since:

2023.0.0

Author:

Sara Pellegrini

Nested Class Summary

Nested classes/interfaces inherited from interface io.axoniq.axonserver.connector.event.transformation.impl.EventTransformationService

EventTransformationService.TransformationStream

Constructor Summary

Constructors

Constructor	Description
GrpcEventTransformationService(AxonServerManagedChannel axonServerManagedChannel)
GrpcEventTransformationService(EventTransformationServiceGrpc.EventTransformationServiceStub stub)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	cancel(String transformationId)	Requests to AxonServer to cancel the transformation with the specified identifier.
CompletableFuture<String>	newTransformation(String description)	Creates a new transformation.
CompletableFuture<Void>	startApplying(String transformationId, Long sequence)	Requests to AxonServer to apply the transformation with the specified identifier.
CompletableFuture<Void>	startCompacting()	Requests to AxonServer to compact the event store.
CompletableFuture<EventTransformation>	transformationById(String id)	Returns the Event Transformations with the specified id.
CompletableFuture<Iterable<EventTransformation>>	transformations()	Returns all the existing Event Transformations.
EventTransformationService.TransformationStream	transformationStream(String transformationId)	Opens a EventTransformationService.TransformationStream towards the transformation, that can be used to register the required changes.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcEventTransformationService

public GrpcEventTransformationService(AxonServerManagedChannel axonServerManagedChannel)

GrpcEventTransformationService

public GrpcEventTransformationService(EventTransformationServiceGrpc.EventTransformationServiceStub stub)

Method Detail

transformations

public CompletableFuture<Iterable<EventTransformation>> transformations()

Description copied from interface: EventTransformationService

Returns all the existing Event Transformations.

Specified by:

transformations in interface EventTransformationService

Returns:

a CompletableFuture of the Event Transformations

transformationById

public CompletableFuture<EventTransformation> transformationById(String id)

Description copied from interface: EventTransformationService

Returns the Event Transformations with the specified id.

Specified by:

transformationById in interface EventTransformationService

Parameters:

id - the id of the EventTransformation to be returned.

Returns:

a CompletableFuture of the EventTransformation with the specified id.

newTransformation

public CompletableFuture<String> newTransformation(String description)

Description copied from interface: EventTransformationService

Creates a new transformation.

Specified by:

newTransformation in interface EventTransformationService

Parameters:

description - the description of the transformation to create.

Returns:

a CompletableFuture of the identifier of the newly created transformation.

transformationStream

public EventTransformationService.TransformationStream transformationStream(String transformationId)

Description copied from interface: EventTransformationService

Opens a EventTransformationService.TransformationStream towards the transformation, that can be used to register the required changes.

Specified by:

transformationStream in interface EventTransformationService

Parameters:

transformationId - the identifier of the transformation

Returns:

the EventTransformationService.TransformationStream

startApplying

public CompletableFuture<Void> startApplying(String transformationId,
                                             Long sequence)

Description copied from interface: EventTransformationService

Requests to AxonServer to apply the transformation with the specified identifier.

Specified by:

startApplying in interface EventTransformationService

Parameters:

transformationId - the identifier of the transformation to be applied

sequence - the expected last sequence of the transformation, used to check that no change request has been lost

Returns:

a CompletableFuture that completes when the request has been received by Axon Server.

cancel

public CompletableFuture<Void> cancel(String transformationId)

Description copied from interface: EventTransformationService

Requests to AxonServer to cancel the transformation with the specified identifier.

Specified by:

cancel in interface EventTransformationService

Parameters:

transformationId - the identifier of the transformation to be cancelled

Returns:

a CompletableFuture that completes when the request has been received by Axon Server.

startCompacting

public CompletableFuture<Void> startCompacting()

Description copied from interface: EventTransformationService

Requests to AxonServer to compact the event store. In other words, the request to delete all obsoleted version of the events from the event store.

Specified by:

startCompacting in interface EventTransformationService

Returns:

a CompletableFuture that completes when the request has been received by Axon Server.