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

Interface Summary

Interface	Description
AddressOrBuilder
FromFunction.DelayedInvocationOrBuilder
FromFunction.EgressMessageOrBuilder
FromFunction.ExpirationSpecOrBuilder
FromFunction.IncompleteInvocationContextOrBuilder
FromFunction.InvocationOrBuilder
FromFunction.InvocationResponseOrBuilder
FromFunction.PersistedValueMutationOrBuilder
FromFunction.PersistedValueSpecOrBuilder
FromFunctionOrBuilder
ToFunction.InvocationBatchRequestOrBuilder
ToFunction.InvocationOrBuilder
ToFunction.PersistedValueOrBuilder
ToFunctionOrBuilder
TypedValueOrBuilder

Class Summary

Class	Description
Address	An Address is the unique identity of an individual StatefulFunction, containing a function's type and an unique identifier within the type.
Address.Builder	An Address is the unique identity of an individual StatefulFunction, containing a function's type and an unique identifier within the type.
FromFunction	The following section contains messages sent from a remote function back to Flink.
FromFunction.Builder	The following section contains messages sent from a remote function back to Flink.
FromFunction.DelayedInvocation	DelayedInvocation represents a delayed remote function call with a target address, an argument and a delay in milliseconds, after which this message to be sent.
FromFunction.DelayedInvocation.Builder	DelayedInvocation represents a delayed remote function call with a target address, an argument and a delay in milliseconds, after which this message to be sent.
FromFunction.EgressMessage	EgressMessage an argument to forward to an egress.
FromFunction.EgressMessage.Builder	EgressMessage an argument to forward to an egress.
FromFunction.ExpirationSpec	ExpirationSpec represents TTL (Time-To-Live) configuration for persisted states.
FromFunction.ExpirationSpec.Builder	ExpirationSpec represents TTL (Time-To-Live) configuration for persisted states.
FromFunction.IncompleteInvocationContext	IncompleteInvocationContext represents a result of an io.statefun.sdk.reqreply.ToFunction.InvocationBatchRequest, which should be used as the response if the InvocationBatchRequest provided incomplete information about the invocation, e.g.
FromFunction.IncompleteInvocationContext.Builder	IncompleteInvocationContext represents a result of an io.statefun.sdk.reqreply.ToFunction.InvocationBatchRequest, which should be used as the response if the InvocationBatchRequest provided incomplete information about the invocation, e.g.
FromFunction.Invocation	Invocation represents a remote function call, it associated with a (mandatory) target address, and an argument.
FromFunction.Invocation.Builder	Invocation represents a remote function call, it associated with a (mandatory) target address, and an argument.
FromFunction.InvocationResponse	InvocationResponse represents a result of an io.statefun.sdk.reqreply.ToFunction.InvocationBatchRequest it contains a list of state mutation to preform as a result of computing this batch, and a list of outgoing messages.
FromFunction.InvocationResponse.Builder	InvocationResponse represents a result of an io.statefun.sdk.reqreply.ToFunction.InvocationBatchRequest it contains a list of state mutation to preform as a result of computing this batch, and a list of outgoing messages.
FromFunction.PersistedValueMutation	MutatePersistedValueCommand represents a command sent from a remote function to Flink, requesting a change to a persisted value.
FromFunction.PersistedValueMutation.Builder	MutatePersistedValueCommand represents a command sent from a remote function to Flink, requesting a change to a persisted value.
FromFunction.PersistedValueSpec	PersistedValueSpec represents specifications of a function's persisted value state.
FromFunction.PersistedValueSpec.Builder	PersistedValueSpec represents specifications of a function's persisted value state.
RequestReply
ToFunction	The following section contains all the message types that are sent from Flink to a remote function.
ToFunction.Builder	The following section contains all the message types that are sent from Flink to a remote function.
ToFunction.Invocation	Invocation represents a remote function call, it associated with an (optional) return address, and an argument.
ToFunction.Invocation.Builder	Invocation represents a remote function call, it associated with an (optional) return address, and an argument.
ToFunction.InvocationBatchRequest	InvocationBatchRequest represents a request to invoke a remote function.
ToFunction.InvocationBatchRequest.Builder	InvocationBatchRequest represents a request to invoke a remote function.
ToFunction.PersistedValue	PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.
ToFunction.PersistedValue.Builder	PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.
TypedValue	Protobuf type io.statefun.sdk.reqreply.TypedValue
TypedValue.Builder	Protobuf type io.statefun.sdk.reqreply.TypedValue

Enum Summary

Enum	Description
FromFunction.ExpirationSpec.ExpireMode	Protobuf enum io.statefun.sdk.reqreply.FromFunction.ExpirationSpec.ExpireMode
FromFunction.PersistedValueMutation.MutationType	Protobuf enum io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation.MutationType
FromFunction.ResponseCase
ToFunction.RequestCase