Interface IngestionResponseOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
IngestionResponse, IngestionResponse.Builder
public interface IngestionResponseOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Summary

    Modifier and Type
    Method
    Description
    Error
    getError()
    .dev.restate.ingress.ingestion.v1.Error error = 3;
    ErrorOrBuilder
    getErrorOrBuilder()
    .dev.restate.ingress.ingestion.v1.Error error = 3;
    long
    getLastCommitted()
    Acknowledgement.
    IngestionResponse.ResponseCase
    getResponseCase()
     
    WindowUpdate
    getWindowUpdate()
    .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;
    WindowUpdateOrBuilder
    getWindowUpdateOrBuilder()
    .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;
    boolean
    hasError()
    .dev.restate.ingress.ingestion.v1.Error error = 3;
    boolean
    hasLastCommitted()
    Acknowledgement.
    boolean
    hasWindowUpdate()
    .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;

    Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

    isInitialized

    Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

  • Method Details

    • hasLastCommitted

      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;
      Returns:
      Whether the lastCommitted field is set.

    • getLastCommitted

      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;
      Returns:
      The lastCommitted.

    • hasWindowUpdate

      boolean hasWindowUpdate()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;
      Returns:
      Whether the windowUpdate field is set.

    • getWindowUpdate

      WindowUpdate getWindowUpdate()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;
      Returns:
      The windowUpdate.

    • getWindowUpdateOrBuilder

      WindowUpdateOrBuilder getWindowUpdateOrBuilder()
      .dev.restate.ingress.ingestion.v1.WindowUpdate window_update = 2;

    • hasError

      boolean hasError()
      .dev.restate.ingress.ingestion.v1.Error error = 3;
      Returns:
      Whether the error field is set.

    • getError

      Error getError()
      .dev.restate.ingress.ingestion.v1.Error error = 3;
      Returns:
      The error.

    • getErrorOrBuilder

      ErrorOrBuilder getErrorOrBuilder()
      .dev.restate.ingress.ingestion.v1.Error error = 3;

    • getResponseCase

      IngestionResponse.ResponseCase getResponseCase()