Class IngestionResponse

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
dev.restate.ingestion.v1.IngestionResponse
All Implemented Interfaces:
com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, IngestionResponseOrBuilder, Serializable
public final class IngestionResponse extends com.google.protobuf.GeneratedMessage implements IngestionResponseOrBuilder
Protobuf type dev.restate.ingress.ingestion.v1.IngestionResponse
See Also:

  • Field Details

    • LAST_COMMITTED_FIELD_NUMBER

      public static final int LAST_COMMITTED_FIELD_NUMBER
      See Also:

    • WINDOW_UPDATE_FIELD_NUMBER

      public static final int WINDOW_UPDATE_FIELD_NUMBER
      See Also:

    • ERROR_FIELD_NUMBER

      public static final int ERROR_FIELD_NUMBER
      See Also:

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

    • getResponseCase

      public IngestionResponse.ResponseCase getResponseCase()
      Specified by:
      getResponseCase in interface IngestionResponseOrBuilder

    • hasLastCommitted

      public boolean hasLastCommitted()
      Acknowledgement. When set, every record up to and
including this offset has been committed.

It is set on every response that has something to ack,
including responses carrying an Error, so a client whose
stream is torn down can always resume from the offset on
the last response it saw.

It is unset only when nothing has been committed yet on
this stream. The field must be optional because offsets
are 0-based: "offset 0 committed" has to stay
distinguishable from "nothing committed", which matters
when an error is returned on the very first ingestion
message.
      optional uint64 last_committed = 1;
      Specified by:
      hasLastCommitted in interface IngestionResponseOrBuilder
      Returns:
      Whether the lastCommitted field is set.

    • getLastCommitted

      public long getLastCommitted()
      Acknowledgement. When set, every record up to and
including this offset has been committed.

It is set on every response that has something to ack,
including responses carrying an Error, so a client whose
stream is torn down can always resume from the offset on
the last response it saw.

It is unset only when nothing has been committed yet on
this stream. The field must be optional because offsets
are 0-based: "offset 0 committed" has to stay
distinguishable from "nothing committed", which matters
when an error is returned on the very first ingestion
message.
      optional uint64 last_committed = 1;
      Specified by:
      getLastCommitted in interface IngestionResponseOrBuilder
      Returns:
      The lastCommitted.

    • hasWindowUpdate

      public boolean hasWindowUpdate()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;
      Specified by:
      hasWindowUpdate in interface IngestionResponseOrBuilder
      Returns:
      Whether the windowUpdate field is set.

    • getWindowUpdate

      public WindowUpdate getWindowUpdate()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;
      Specified by:
      getWindowUpdate in interface IngestionResponseOrBuilder
      Returns:
      The windowUpdate.

    • getWindowUpdateOrBuilder

      public WindowUpdateOrBuilder getWindowUpdateOrBuilder()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;
      Specified by:
      getWindowUpdateOrBuilder in interface IngestionResponseOrBuilder

    • hasError

      public boolean hasError()
      .dev.restate.ingress.ingestion.v1.Error error = 3;
      Specified by:
      hasError in interface IngestionResponseOrBuilder
      Returns:
      Whether the error field is set.

    • getError

      public Error getError()
      .dev.restate.ingress.ingestion.v1.Error error = 3;
      Specified by:
      getError in interface IngestionResponseOrBuilder
      Returns:
      The error.

    • getErrorOrBuilder

      public ErrorOrBuilder getErrorOrBuilder()
      .dev.restate.ingress.ingestion.v1.Error error = 3;
      Specified by:
      getErrorOrBuilder in interface IngestionResponseOrBuilder

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage

    • writeTo

      public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
      Specified by:
      writeTo in interface com.google.protobuf.MessageLite
      Overrides:
      writeTo in class com.google.protobuf.GeneratedMessage
      Throws:
      IOException

    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessage

    • equals

      public boolean equals(Object obj)
      Specified by:
      equals in interface com.google.protobuf.Message
      Overrides:
      equals in class com.google.protobuf.AbstractMessage

    • hashCode

      public int hashCode()
      Specified by:
      hashCode in interface com.google.protobuf.Message
      Overrides:
      hashCode in class com.google.protobuf.AbstractMessage

    • parseFrom

      public static IngestionResponse parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static IngestionResponse parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static IngestionResponse parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static IngestionResponse parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static IngestionResponse parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static IngestionResponse parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static IngestionResponse parseFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static IngestionResponse parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static IngestionResponse parseDelimitedFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static IngestionResponse parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseFrom

      public static IngestionResponse parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static IngestionResponse parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • newBuilderForType

      public IngestionResponse.Builder newBuilderForType()
      Specified by:
      newBuilderForType in interface com.google.protobuf.Message
      Specified by:
      newBuilderForType in interface com.google.protobuf.MessageLite

    • newBuilder

      public static IngestionResponse.Builder newBuilder()

    • newBuilder

      public static IngestionResponse.Builder newBuilder(IngestionResponse prototype)

    • toBuilder

      public IngestionResponse.Builder toBuilder()
      Specified by:
      toBuilder in interface com.google.protobuf.Message
      Specified by:
      toBuilder in interface com.google.protobuf.MessageLite

    • newBuilderForType

      protected IngestionResponse.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
      Overrides:
      newBuilderForType in class com.google.protobuf.AbstractMessage

    • getDefaultInstance

      public static IngestionResponse getDefaultInstance()

    • parser

      public static com.google.protobuf.Parser<IngestionResponse> parser()

    • getParserForType

      public com.google.protobuf.Parser<IngestionResponse> getParserForType()
      Specified by:
      getParserForType in interface com.google.protobuf.Message
      Specified by:
      getParserForType in interface com.google.protobuf.MessageLite
      Overrides:
      getParserForType in class com.google.protobuf.GeneratedMessage

    • getDefaultInstanceForType

      public IngestionResponse getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder