org.apache.flink.statefun.sdk.reqreply.generated

Interface FromFunction.DelayedInvocationOrBuilder

All Superinterfaces:

MessageLiteOrBuilder, MessageOrBuilder

All Known Implementing Classes:

FromFunction.DelayedInvocation, FromFunction.DelayedInvocation.Builder

Enclosing class:

FromFunction

public static interface FromFunction.DelayedInvocationOrBuilder
extends MessageOrBuilder

Method Summary

Modifier and Type	Method and Description
TypedValue	getArgument() the invocation argument
TypedValueOrBuilder	getArgumentOrBuilder() the invocation argument
java.lang.String	getCancellationToken() an optional cancellation token that can be used to request the "unsending" of a delayed message.
ByteString	getCancellationTokenBytes() an optional cancellation token that can be used to request the "unsending" of a delayed message.
long	getDelayInMs() the amount of milliseconds to wait before sending this message
boolean	getIsCancellationRequest() a boolean value (default false) that indicates rather this is a regular delayed message, or (true) a message cancellation request.
Address	getTarget() the target address to send this message to
AddressOrBuilder	getTargetOrBuilder() the target address to send this message to
boolean	hasArgument() the invocation argument
boolean	hasTarget() the target address to send this message to

Methods inherited from interface org.apache.flink.statefun.sdk.shaded.com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface org.apache.flink.statefun.sdk.shaded.com.google.protobuf.MessageLiteOrBuilder

isInitialized

Method Detail

getIsCancellationRequest

boolean getIsCancellationRequest()

 a boolean value (default false) that indicates rather this is a regular delayed message, or (true) a message
 cancellation request.
 in case of a regular delayed message all other fields are expected to be preset, otherwise only the
 cancellation_token is expected
 

bool is_cancellation_request = 10;

getCancellationToken

java.lang.String getCancellationToken()

 an optional cancellation token that can be used to request the "unsending" of a delayed message.
 

string cancellation_token = 11;

getCancellationTokenBytes

ByteString getCancellationTokenBytes()

 an optional cancellation token that can be used to request the "unsending" of a delayed message.
 

string cancellation_token = 11;

getDelayInMs

long getDelayInMs()

 the amount of milliseconds to wait before sending this message
 

int64 delay_in_ms = 1;

hasTarget

boolean hasTarget()

 the target address to send this message to
 

.io.statefun.sdk.reqreply.Address target = 2;

getTarget

Address getTarget()

 the target address to send this message to
 

.io.statefun.sdk.reqreply.Address target = 2;

getTargetOrBuilder

AddressOrBuilder getTargetOrBuilder()

 the target address to send this message to
 

.io.statefun.sdk.reqreply.Address target = 2;

hasArgument

boolean hasArgument()

 the invocation argument
 

.io.statefun.sdk.reqreply.TypedValue argument = 3;

getArgument

TypedValue getArgument()

 the invocation argument
 

.io.statefun.sdk.reqreply.TypedValue argument = 3;

getArgumentOrBuilder

TypedValueOrBuilder getArgumentOrBuilder()

 the invocation argument
 

.io.statefun.sdk.reqreply.TypedValue argument = 3;