Class IngestionResponse.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<IngestionResponse.Builder>
com.google.protobuf.GeneratedMessage.Builder<IngestionResponse.Builder>
dev.restate.ingestion.v1.IngestionResponse.Builder
All Implemented Interfaces:
com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, IngestionResponseOrBuilder, Cloneable
Enclosing class:
IngestionResponse
public static final class IngestionResponse.Builder extends com.google.protobuf.GeneratedMessage.Builder<IngestionResponse.Builder> implements IngestionResponseOrBuilder
Protobuf type dev.restate.ingress.ingestion.v1.IngestionResponse

  • 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.Builder<IngestionResponse.Builder>

    • clear

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

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<IngestionResponse.Builder>

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • mergeFrom

      public IngestionResponse.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<IngestionResponse.Builder>

    • mergeFrom

      public IngestionResponse.Builder mergeFrom(IngestionResponse other)

    • isInitialized

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

    • mergeFrom

      public IngestionResponse.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<IngestionResponse.Builder>
      Throws:
      IOException

    • getResponseCase

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

    • clearResponse

      public IngestionResponse.Builder clearResponse()

    • 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.

    • setLastCommitted

      public IngestionResponse.Builder setLastCommitted(long value)
      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;
      Parameters:
      value - The lastCommitted to set.
      Returns:
      This builder for chaining.

    • clearLastCommitted

      public IngestionResponse.Builder clearLastCommitted()
      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;
      Returns:
      This builder for chaining.

    • 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.

    • setWindowUpdate

      public IngestionResponse.Builder setWindowUpdate(WindowUpdate value)
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;

    • setWindowUpdate

      public IngestionResponse.Builder setWindowUpdate(WindowUpdate.Builder builderForValue)
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;

    • mergeWindowUpdate

      public IngestionResponse.Builder mergeWindowUpdate(WindowUpdate value)
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;

    • clearWindowUpdate

      public IngestionResponse.Builder clearWindowUpdate()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;

    • getWindowUpdateBuilder

      public WindowUpdate.Builder getWindowUpdateBuilder()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;

    • 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.

    • setError

      public IngestionResponse.Builder setError(Error value)
      .dev.restate.ingress.ingestion.v1.Error error = 3;

    • setError

      public IngestionResponse.Builder setError(Error.Builder builderForValue)
      .dev.restate.ingress.ingestion.v1.Error error = 3;

    • mergeError

      public IngestionResponse.Builder mergeError(Error value)
      .dev.restate.ingress.ingestion.v1.Error error = 3;

    • clearError

      public IngestionResponse.Builder clearError()
      .dev.restate.ingress.ingestion.v1.Error error = 3;

    • getErrorBuilder

      public Error.Builder getErrorBuilder()
      .dev.restate.ingress.ingestion.v1.Error error = 3;

    • getErrorOrBuilder

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