Modifier and Type | Class and Description |
---|---|
class |
KafkaProducerRecord
Protobuf type
io.statefun.sdk.egress.KafkaProducerRecord |
class |
KinesisEgressRecord
Protobuf type
io.statefun.sdk.egress.KinesisEgressRecord |
Modifier and Type | Method and Description |
---|---|
KinesisEgressRecord.Builder |
KinesisEgressRecord.Builder.mergeFrom(Message other) |
KafkaProducerRecord.Builder |
KafkaProducerRecord.Builder.mergeFrom(Message other) |
Modifier and Type | Method and Description |
---|---|
static Slice |
SliceProtobufUtil.toSlice(Message message) |
Modifier and Type | Class and Description |
---|---|
class |
Address
An Address is the unique identity of an individual StatefulFunction, containing
a function's type and an unique identifier within the type.
|
class |
FromFunction
The following section contains messages sent from a remote function back to Flink.
|
static class |
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.
|
static class |
FromFunction.EgressMessage
EgressMessage an argument to forward to an egress.
|
static class |
FromFunction.ExpirationSpec
ExpirationSpec represents TTL (Time-To-Live) configuration for persisted states.
|
static class |
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.
|
static class |
FromFunction.Invocation
Invocation represents a remote function call, it associated with a (mandatory) target address,
and an argument.
|
static class |
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.
|
static class |
FromFunction.PersistedValueMutation
MutatePersistedValueCommand represents a command sent from a remote function to Flink,
requesting a change to a persisted value.
|
static class |
FromFunction.PersistedValueSpec
PersistedValueSpec represents specifications of a function's persisted value state.
|
class |
ToFunction
The following section contains all the message types that are sent
from Flink to a remote function.
|
static class |
ToFunction.Invocation
Invocation represents a remote function call, it associated with an (optional) return address,
and an argument.
|
static class |
ToFunction.InvocationBatchRequest
InvocationBatchRequest represents a request to invoke a remote function.
|
static class |
ToFunction.PersistedValue
PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.
|
class |
TypedValue
Protobuf type
io.statefun.sdk.reqreply.TypedValue |
Modifier and Type | Class and Description |
---|---|
static class |
GeneratedMessage.GeneratedExtension<ContainingType extends Message,Type>
Type used to represent generated extensions.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessage
A partial implementation of the
Message interface which implements as many methods of
that interface as possible in terms of other methods. |
class |
Any
`Any` contains an arbitrary serialized protocol buffer message along with a
URL that describes the type of the serialized message.
|
class |
Api
Api is a light-weight descriptor for an API Interface.
|
class |
BoolValue
Wrapper message for `bool`.
|
class |
BytesValue
Wrapper message for `bytes`.
|
static class |
DescriptorProtos.DescriptorProto
Describes a message type.
|
static class |
DescriptorProtos.DescriptorProto.ExtensionRange
Protobuf type
google.protobuf.DescriptorProto.ExtensionRange |
static class |
DescriptorProtos.DescriptorProto.ReservedRange
Range of reserved tag numbers.
|
static class |
DescriptorProtos.EnumDescriptorProto
Describes an enum type.
|
static class |
DescriptorProtos.EnumDescriptorProto.EnumReservedRange
Range of reserved numeric values.
|
static class |
DescriptorProtos.EnumOptions
Protobuf type
google.protobuf.EnumOptions |
static class |
DescriptorProtos.EnumValueDescriptorProto
Describes a value within an enum.
|
static class |
DescriptorProtos.EnumValueOptions
Protobuf type
google.protobuf.EnumValueOptions |
static class |
DescriptorProtos.ExtensionRangeOptions
Protobuf type
google.protobuf.ExtensionRangeOptions |
static class |
DescriptorProtos.FieldDescriptorProto
Describes a field within a message.
|
static class |
DescriptorProtos.FieldOptions
Protobuf type
google.protobuf.FieldOptions |
static class |
DescriptorProtos.FileDescriptorProto
Describes a complete .proto file.
|
static class |
DescriptorProtos.FileDescriptorSet
The protocol compiler can output a FileDescriptorSet containing the .proto
files it parses.
|
static class |
DescriptorProtos.FileOptions
Protobuf type
google.protobuf.FileOptions |
static class |
DescriptorProtos.GeneratedCodeInfo
Describes the relationship between generated code and its original source
file.
|
static class |
DescriptorProtos.GeneratedCodeInfo.Annotation
Protobuf type
google.protobuf.GeneratedCodeInfo.Annotation |
static class |
DescriptorProtos.MessageOptions
Protobuf type
google.protobuf.MessageOptions |
static class |
DescriptorProtos.MethodDescriptorProto
Describes a method of a service.
|
static class |
DescriptorProtos.MethodOptions
Protobuf type
google.protobuf.MethodOptions |
static class |
DescriptorProtos.OneofDescriptorProto
Describes a oneof.
|
static class |
DescriptorProtos.OneofOptions
Protobuf type
google.protobuf.OneofOptions |
static class |
DescriptorProtos.ServiceDescriptorProto
Describes a service.
|
static class |
DescriptorProtos.ServiceOptions
Protobuf type
google.protobuf.ServiceOptions |
static class |
DescriptorProtos.SourceCodeInfo
Encapsulates information about the original source file from which a
FileDescriptorProto was generated.
|
static class |
DescriptorProtos.SourceCodeInfo.Location
Protobuf type
google.protobuf.SourceCodeInfo.Location |
static class |
DescriptorProtos.UninterpretedOption
A message representing a option the parser does not recognize.
|
static class |
DescriptorProtos.UninterpretedOption.NamePart
The name of the uninterpreted option.
|
class |
DoubleValue
Wrapper message for `double`.
|
class |
Duration
A Duration represents a signed, fixed-length span of time represented
as a count of seconds and fractions of seconds at nanosecond
resolution.
|
class |
DynamicMessage
An implementation of
Message that can represent arbitrary types, given a Descriptors.Descriptor . |
class |
Empty
A generic empty message that you can re-use to avoid defining duplicated
empty messages in your APIs.
|
class |
Enum
Enum type definition.
|
class |
EnumValue
Enum value definition.
|
class |
Field
A single field of a message type.
|
class |
FieldMask
`FieldMask` represents a set of symbolic field paths, for example:
paths: "f.a"
paths: "f.b.d"
Here `f` represents a field in some root message, `a` and `b`
fields in the message found in `f`, and `d` a field found in the
message in `f.b`.
|
class |
FloatValue
Wrapper message for `float`.
|
class |
GeneratedMessage
All generated protocol message classes extend this class.
|
static class |
GeneratedMessage.ExtendableMessage<MessageType extends GeneratedMessage.ExtendableMessage>
Generated message classes for message types that contain extension ranges
subclass this.
|
class |
GeneratedMessageV3
All generated protocol message classes extend this class.
|
static class |
GeneratedMessageV3.ExtendableMessage<MessageType extends GeneratedMessageV3.ExtendableMessage>
Generated message classes for message types that contain extension ranges
subclass this.
|
class |
Int32Value
Wrapper message for `int32`.
|
class |
Int64Value
Wrapper message for `int64`.
|
class |
ListValue
`ListValue` is a wrapper around a repeated field of values.
|
class |
MapEntry<K,V>
Implements MapEntry messages.
|
class |
Method
Method represents a method of an API interface.
|
class |
Mixin
Declares an API Interface to be included in this interface.
|
class |
Option
A protocol buffer option, which can be attached to a message, field,
enumeration, etc.
|
class |
SourceContext
`SourceContext` represents information about the source of a
protobuf element, like the file in which it is defined.
|
class |
StringValue
Wrapper message for `string`.
|
class |
Struct
`Struct` represents a structured data value, consisting of fields
which map to dynamically typed values.
|
class |
Timestamp
A Timestamp represents a point in time independent of any time zone or local
calendar, encoded as a count of seconds and fractions of seconds at
nanosecond resolution.
|
class |
Type
A protocol buffer message type.
|
class |
UInt32Value
Wrapper message for `uint32`.
|
class |
UInt64Value
Wrapper message for `uint64`.
|
class |
Value
`Value` represents a dynamically typed value which can be either
null, a number, a string, a boolean, a recursive struct value, or a
list of values.
|
Modifier and Type | Field and Description |
---|---|
Message |
ExtensionRegistry.ExtensionInfo.defaultInstance
A default instance of the extension's type, if it has a message type.
|
Modifier and Type | Method and Description |
---|---|
static <Type extends Message> |
RpcUtil.generalizeCallback(RpcCallback<Type> originalCallback,
java.lang.Class<Type> originalClass,
Type defaultInstance)
Take an
RpcCallback accepting a specific message type and convert it to an RpcCallback<Message> . |
<T extends Message> |
Any.is(java.lang.Class<T> clazz) |
static <ContainingType extends Message,Type> |
GeneratedMessage.newFileScopedGeneratedExtension(java.lang.Class singularType,
Message defaultInstance)
For use by generated code only.
|
static <ContainingType extends Message,Type> |
GeneratedMessage.newFileScopedGeneratedExtension(java.lang.Class singularType,
Message defaultInstance,
java.lang.String descriptorOuterClass,
java.lang.String extensionName)
Used in proto1 generated code only.
|
static <ContainingType extends Message,Type> |
GeneratedMessage.newMessageScopedGeneratedExtension(Message scope,
int descriptorIndex,
java.lang.Class singularType,
Message defaultInstance)
For use by generated code only.
|
static <ContainingType extends Message,Type> |
GeneratedMessage.newMessageScopedGeneratedExtension(Message scope,
java.lang.String name,
java.lang.Class singularType,
Message defaultInstance)
Used in proto1 generated code only.
|
static <T extends Message> |
Any.pack(T message) |
static <T extends Message> |
Any.pack(T message,
java.lang.String typeUrlPrefix)
Packs a message using the given type URL prefix.
|
static <T extends Message> |
TextFormat.parse(java.lang.CharSequence input,
java.lang.Class<T> protoClass)
Parse a text-format message from
input . |
static <T extends Message> |
TextFormat.parse(java.lang.CharSequence input,
ExtensionRegistry extensionRegistry,
java.lang.Class<T> protoClass)
Parse a text-format message from
input . |
protected static <M extends Message> |
GeneratedMessageV3.parseDelimitedWithIOException(Parser<M> parser,
java.io.InputStream input) |
protected static <M extends Message> |
GeneratedMessage.parseDelimitedWithIOException(Parser<M> parser,
java.io.InputStream input) |
protected static <M extends Message> |
GeneratedMessageV3.parseDelimitedWithIOException(Parser<M> parser,
java.io.InputStream input,
ExtensionRegistryLite extensions) |
protected static <M extends Message> |
GeneratedMessage.parseDelimitedWithIOException(Parser<M> parser,
java.io.InputStream input,
ExtensionRegistryLite extensions) |
protected static <M extends Message> |
GeneratedMessageV3.parseWithIOException(Parser<M> parser,
CodedInputStream input) |
protected static <M extends Message> |
GeneratedMessage.parseWithIOException(Parser<M> parser,
CodedInputStream input) |
protected static <M extends Message> |
GeneratedMessageV3.parseWithIOException(Parser<M> parser,
CodedInputStream input,
ExtensionRegistryLite extensions) |
protected static <M extends Message> |
GeneratedMessage.parseWithIOException(Parser<M> parser,
CodedInputStream input,
ExtensionRegistryLite extensions) |
protected static <M extends Message> |
GeneratedMessageV3.parseWithIOException(Parser<M> parser,
java.io.InputStream input) |
protected static <M extends Message> |
GeneratedMessage.parseWithIOException(Parser<M> parser,
java.io.InputStream input) |
protected static <M extends Message> |
GeneratedMessageV3.parseWithIOException(Parser<M> parser,
java.io.InputStream input,
ExtensionRegistryLite extensions) |
protected static <M extends Message> |
GeneratedMessage.parseWithIOException(Parser<M> parser,
java.io.InputStream input,
ExtensionRegistryLite extensions) |
static <Type extends Message> |
RpcUtil.specializeCallback(RpcCallback<Message> originalCallback)
Take an
RpcCallback<Message> and convert it to an RpcCallback accepting a
specific message type. |
<T extends Message> |
Any.unpack(java.lang.Class<T> clazz) |
static <T extends Message> |
DiscardUnknownFieldsParser.wrap(Parser<T> parser)
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.Builder.build() |
Message |
Message.Builder.buildPartial() |
Message |
BlockingService.callBlockingMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request)
Equivalent to
Service.callMethod(org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Descriptors.MethodDescriptor, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcController, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcCallback<org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message>) , except that callBlockingMethod() returns the
result of the RPC or throws a ServiceException if there is a failure, rather than
passing the information to a callback. |
Message |
BlockingRpcChannel.callBlockingMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
Message responsePrototype)
Call the given method of the remote service and blocks until it returns.
|
Message |
GeneratedMessageV3.ExtendableMessageOrBuilder.getDefaultInstanceForType() |
Message |
MessageOrBuilder.getDefaultInstanceForType() |
Message |
GeneratedMessage.ExtendableMessageOrBuilder.getDefaultInstanceForType() |
Message |
GeneratedMessage.GeneratedExtension.getMessageDefaultInstance()
If the extension is an embedded message or group, returns the default
instance of the message.
|
Message |
Descriptors.DescriptorValidationException.getProblemProto()
Gets the protocol message representation of the invalid descriptor.
|
Message |
BlockingService.getRequestPrototype(Descriptors.MethodDescriptor method)
|
Message |
Service.getRequestPrototype(Descriptors.MethodDescriptor method)
callMethod() requires that the request passed in is of a particular subclass of Message . |
Message |
BlockingService.getResponsePrototype(Descriptors.MethodDescriptor method)
|
Message |
Service.getResponsePrototype(Descriptors.MethodDescriptor method)
Like
getRequestPrototype() , but gets a prototype of the response message. |
abstract Message |
Descriptors.GenericDescriptor.toProto() |
Modifier and Type | Method and Description |
---|---|
static <Type extends Message> |
RpcUtil.generalizeCallback(RpcCallback<Type> originalCallback,
java.lang.Class<Type> originalClass,
Type defaultInstance)
Take an
RpcCallback accepting a specific message type and convert it to an RpcCallback<Message> . |
Parser<? extends Message> |
Message.getParserForType() |
Modifier and Type | Method and Description |
---|---|
void |
ExtensionRegistry.add(Descriptors.FieldDescriptor type,
Message defaultInstance)
Add a message-type extension to the registry by descriptor.
|
Message |
BlockingService.callBlockingMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request)
Equivalent to
Service.callMethod(org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Descriptors.MethodDescriptor, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcController, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.RpcCallback<org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message>) , except that callBlockingMethod() returns the
result of the RPC or throws a ServiceException if there is a failure, rather than
passing the information to a callback. |
Message |
BlockingRpcChannel.callBlockingMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
Message responsePrototype)
Call the given method of the remote service and blocks until it returns.
|
void |
RpcChannel.callMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
Message responsePrototype,
RpcCallback<Message> done)
Call the given method of the remote service.
|
void |
Service.callMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
RpcCallback<Message> done)
Call a method of the service specified by MethodDescriptor.
|
Int64Value.Builder |
Int64Value.Builder.mergeFrom(Message other) |
Any.Builder |
Any.Builder.mergeFrom(Message other) |
Empty.Builder |
Empty.Builder.mergeFrom(Message other) |
Message.Builder |
Message.Builder.mergeFrom(Message other)
Merge
other into the message being built. |
FieldMask.Builder |
FieldMask.Builder.mergeFrom(Message other) |
Mixin.Builder |
Mixin.Builder.mergeFrom(Message other) |
BuilderType |
AbstractMessage.Builder.mergeFrom(Message other) |
DescriptorProtos.FileDescriptorSet.Builder |
DescriptorProtos.FileDescriptorSet.Builder.mergeFrom(Message other) |
DescriptorProtos.FileDescriptorProto.Builder |
DescriptorProtos.FileDescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.DescriptorProto.ExtensionRange.Builder |
DescriptorProtos.DescriptorProto.ExtensionRange.Builder.mergeFrom(Message other) |
DescriptorProtos.DescriptorProto.ReservedRange.Builder |
DescriptorProtos.DescriptorProto.ReservedRange.Builder.mergeFrom(Message other) |
DescriptorProtos.DescriptorProto.Builder |
DescriptorProtos.DescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.ExtensionRangeOptions.Builder |
DescriptorProtos.ExtensionRangeOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.FieldDescriptorProto.Builder |
DescriptorProtos.FieldDescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.OneofDescriptorProto.Builder |
DescriptorProtos.OneofDescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.EnumDescriptorProto.EnumReservedRange.Builder |
DescriptorProtos.EnumDescriptorProto.EnumReservedRange.Builder.mergeFrom(Message other) |
DescriptorProtos.EnumDescriptorProto.Builder |
DescriptorProtos.EnumDescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.EnumValueDescriptorProto.Builder |
DescriptorProtos.EnumValueDescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.ServiceDescriptorProto.Builder |
DescriptorProtos.ServiceDescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.MethodDescriptorProto.Builder |
DescriptorProtos.MethodDescriptorProto.Builder.mergeFrom(Message other) |
DescriptorProtos.FileOptions.Builder |
DescriptorProtos.FileOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.MessageOptions.Builder |
DescriptorProtos.MessageOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.FieldOptions.Builder |
DescriptorProtos.FieldOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.OneofOptions.Builder |
DescriptorProtos.OneofOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.EnumOptions.Builder |
DescriptorProtos.EnumOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.EnumValueOptions.Builder |
DescriptorProtos.EnumValueOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.ServiceOptions.Builder |
DescriptorProtos.ServiceOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.MethodOptions.Builder |
DescriptorProtos.MethodOptions.Builder.mergeFrom(Message other) |
DescriptorProtos.UninterpretedOption.NamePart.Builder |
DescriptorProtos.UninterpretedOption.NamePart.Builder.mergeFrom(Message other) |
DescriptorProtos.UninterpretedOption.Builder |
DescriptorProtos.UninterpretedOption.Builder.mergeFrom(Message other) |
DescriptorProtos.SourceCodeInfo.Location.Builder |
DescriptorProtos.SourceCodeInfo.Location.Builder.mergeFrom(Message other) |
DescriptorProtos.SourceCodeInfo.Builder |
DescriptorProtos.SourceCodeInfo.Builder.mergeFrom(Message other) |
DescriptorProtos.GeneratedCodeInfo.Annotation.Builder |
DescriptorProtos.GeneratedCodeInfo.Annotation.Builder.mergeFrom(Message other) |
DescriptorProtos.GeneratedCodeInfo.Builder |
DescriptorProtos.GeneratedCodeInfo.Builder.mergeFrom(Message other) |
Value.Builder |
Value.Builder.mergeFrom(Message other) |
Struct.Builder |
Struct.Builder.mergeFrom(Message other) |
DoubleValue.Builder |
DoubleValue.Builder.mergeFrom(Message other) |
EnumValue.Builder |
EnumValue.Builder.mergeFrom(Message other) |
Enum.Builder |
Enum.Builder.mergeFrom(Message other) |
Timestamp.Builder |
Timestamp.Builder.mergeFrom(Message other) |
BytesValue.Builder |
BytesValue.Builder.mergeFrom(Message other) |
Method.Builder |
Method.Builder.mergeFrom(Message other) |
StringValue.Builder |
StringValue.Builder.mergeFrom(Message other) |
SourceContext.Builder |
SourceContext.Builder.mergeFrom(Message other) |
Int32Value.Builder |
Int32Value.Builder.mergeFrom(Message other) |
Duration.Builder |
Duration.Builder.mergeFrom(Message other) |
BoolValue.Builder |
BoolValue.Builder.mergeFrom(Message other) |
DynamicMessage.Builder |
DynamicMessage.Builder.mergeFrom(Message other) |
Api.Builder |
Api.Builder.mergeFrom(Message other) |
UInt32Value.Builder |
UInt32Value.Builder.mergeFrom(Message other) |
UInt64Value.Builder |
UInt64Value.Builder.mergeFrom(Message other) |
ListValue.Builder |
ListValue.Builder.mergeFrom(Message other) |
FloatValue.Builder |
FloatValue.Builder.mergeFrom(Message other) |
Option.Builder |
Option.Builder.mergeFrom(Message other) |
Field.Builder |
Field.Builder.mergeFrom(Message other) |
Type.Builder |
Type.Builder.mergeFrom(Message other) |
static DynamicMessage.Builder |
DynamicMessage.newBuilder(Message prototype)
Construct a
Message.Builder for a message of the same type as prototype , and
initialize it with prototype 's contents. |
static <ContainingType extends Message,Type> |
GeneratedMessage.newFileScopedGeneratedExtension(java.lang.Class singularType,
Message defaultInstance)
For use by generated code only.
|
static <ContainingType extends Message,Type> |
GeneratedMessage.newFileScopedGeneratedExtension(java.lang.Class singularType,
Message defaultInstance,
java.lang.String descriptorOuterClass,
java.lang.String extensionName)
Used in proto1 generated code only.
|
static <ContainingType extends Message,Type> |
GeneratedMessage.newMessageScopedGeneratedExtension(Message scope,
int descriptorIndex,
java.lang.Class singularType,
Message defaultInstance)
For use by generated code only.
|
static <ContainingType extends Message,Type> |
GeneratedMessage.newMessageScopedGeneratedExtension(Message scope,
java.lang.String name,
java.lang.Class singularType,
Message defaultInstance)
Used in proto1 generated code only.
|
protected static UninitializedMessageException |
AbstractMessage.Builder.newUninitializedMessageException(Message message)
Construct an UninitializedMessageException reporting missing fields in the given message.
|
Modifier and Type | Method and Description |
---|---|
void |
RpcChannel.callMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
Message responsePrototype,
RpcCallback<Message> done)
Call the given method of the remote service.
|
void |
Service.callMethod(Descriptors.MethodDescriptor method,
RpcController controller,
Message request,
RpcCallback<Message> done)
Call a method of the service specified by MethodDescriptor.
|
static <Type extends Message> |
RpcUtil.specializeCallback(RpcCallback<Message> originalCallback)
Take an
RpcCallback<Message> and convert it to an RpcCallback accepting a
specific message type. |
Modifier and Type | Class and Description |
---|---|
static class |
PluginProtos.CodeGeneratorRequest
An encoded CodeGeneratorRequest is written to the plugin's stdin.
|
static class |
PluginProtos.CodeGeneratorResponse
The plugin writes an encoded CodeGeneratorResponse to stdout.
|
static class |
PluginProtos.CodeGeneratorResponse.File
Represents a single generated file.
|
static class |
PluginProtos.Version
The version number of protocol compiler.
|
Modifier and Type | Method and Description |
---|---|
PluginProtos.Version.Builder |
PluginProtos.Version.Builder.mergeFrom(Message other) |
PluginProtos.CodeGeneratorRequest.Builder |
PluginProtos.CodeGeneratorRequest.Builder.mergeFrom(Message other) |
PluginProtos.CodeGeneratorResponse.File.Builder |
PluginProtos.CodeGeneratorResponse.File.Builder.mergeFrom(Message other) |
PluginProtos.CodeGeneratorResponse.Builder |
PluginProtos.CodeGeneratorResponse.Builder.mergeFrom(Message other) |
Modifier and Type | Class and Description |
---|---|
class |
BooleanWrapper
BooleanWrapper represents a StateFun primitive type of a boolean value.
|
class |
DoubleWrapper
DoubleWrapper represents a StateFun primitive type of a double value.
|
class |
FloatWrapper
FloatWrapper represents a StateFun primitive type of a signed float value.
|
class |
IntWrapper
IntWrapper represents a StateFun primitive type of an signed 32 bit integer value.
|
class |
LongWrapper
LongWrapper represents a StateFun primitive type of a signed 64 bit long value.
|
class |
StringWrapper
StringWrapper represents a StateFun string.
|
Modifier and Type | Method and Description |
---|---|
BooleanWrapper.Builder |
BooleanWrapper.Builder.mergeFrom(Message other) |
StringWrapper.Builder |
StringWrapper.Builder.mergeFrom(Message other) |
IntWrapper.Builder |
IntWrapper.Builder.mergeFrom(Message other) |
LongWrapper.Builder |
LongWrapper.Builder.mergeFrom(Message other) |
FloatWrapper.Builder |
FloatWrapper.Builder.mergeFrom(Message other) |
DoubleWrapper.Builder |
DoubleWrapper.Builder.mergeFrom(Message other) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.