Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.event

Class EventTransformationServiceGrpc.EventTransformationServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<EventTransformationServiceGrpc.EventTransformationServiceBlockingV2Stub>

io.axoniq.axonserver.grpc.event.EventTransformationServiceGrpc.EventTransformationServiceBlockingV2Stub

Enclosing class:

EventTransformationServiceGrpc

public static final class EventTransformationServiceGrpc.EventTransformationServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<EventTransformationServiceGrpc.EventTransformationServiceBlockingV2Stub>

A stub to allow clients to do synchronous 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
io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty>	applyTransformation(ApplyTransformationRequest request)	Applies the changes from a transformation in the event store.
protected EventTransformationServiceGrpc.EventTransformationServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty>	cancelTransformation(TransformationId request)	Cancels a transformation before it is applied.
io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty>	compact(CompactionRequest request)	Deletes old versions of events updated by a transformation.
TransformationId	startTransformation(StartTransformationRequest request)	Starts a new transformation.
io.grpc.stub.BlockingClientCall<?,Transformation>	transformations(com.google.protobuf.Empty request)	Returns the list of all transformations.
io.grpc.stub.BlockingClientCall<TransformRequest,TransformRequestAck>	transformEvents()	Adds requests to transform an event to a transformation.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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.EventTransformationServiceBlockingV2Stub build(io.grpc.Channel channel,
                                                                                        io.grpc.CallOptions callOptions)

Specified by:

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

transformations

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,Transformation> transformations(com.google.protobuf.Empty request)

 Returns the list of all transformations.
 

startTransformation

public TransformationId startTransformation(StartTransformationRequest request)
                                     throws io.grpc.StatusException

 Starts a new transformation.
 

Throws:

io.grpc.StatusException

transformEvents

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<TransformRequest,TransformRequestAck> transformEvents()

 Adds requests to transform an event to a transformation.
 

cancelTransformation

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty> cancelTransformation(TransformationId request)

 Cancels a transformation before it is applied.
 

applyTransformation

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty> applyTransformation(ApplyTransformationRequest request)

 Applies the changes from a transformation in the event store.
 

compact

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,com.google.protobuf.Empty> compact(CompactionRequest request)

 Deletes old versions of events updated by a transformation.