Class IngestionInvocation.Builder

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

  • Method Details

    • getDescriptor

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

    • internalGetMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
      Overrides:
      internalGetMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<IngestionInvocation.Builder>

    • internalGetMutableMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
      Overrides:
      internalGetMutableMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<IngestionInvocation.Builder>

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<IngestionInvocation.Builder>

    • clear

      public IngestionInvocation.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<IngestionInvocation.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<IngestionInvocation.Builder>

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • mergeFrom

      public IngestionInvocation.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<IngestionInvocation.Builder>

    • mergeFrom

      public IngestionInvocation.Builder mergeFrom(IngestionInvocation other)

    • isInitialized

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

    • mergeFrom

      public IngestionInvocation.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<IngestionInvocation.Builder>
      Throws:
      IOException

    • getOffset

      public long getOffset()
      Position of this record within the producer's sequence, and the value
deduplication is based on.

It must increase monotonically for a given producer ID, across the whole
lifetime of that producer and not just within a single stream. On
reconnect, resume from the `Response.last_committed` reported for the
producer rather than restarting the numbering.

Offsets do not have to be contiguous; gaps are allowed, so it is fine to
skip records. Only the ordering matters. Offsets are 0-based, so 0 is a
valid first offset.

Within a single stream the server enforces this: sending an offset lower
than one already sent on the same stream is a protocol violation and
fails the stream with `GO_AWAY`.

Across streams nothing is enforced, since the server does not remember
what a previous stream sent. Reusing an offset already committed by an
earlier stream of the same producer is not reported as an error: the
record is treated as a duplicate and silently dropped, meaning it does
not become an invocation and produces no `Error` frame. A client that
restarts its numbering after a reconnect will therefore see its records
disappear without any signal.
      uint64 offset = 1;
      Specified by:
      getOffset in interface IngestionInvocationOrBuilder
      Returns:
      The offset.

    • setOffset

      public IngestionInvocation.Builder setOffset(long value)
      Position of this record within the producer's sequence, and the value
deduplication is based on.

It must increase monotonically for a given producer ID, across the whole
lifetime of that producer and not just within a single stream. On
reconnect, resume from the `Response.last_committed` reported for the
producer rather than restarting the numbering.

Offsets do not have to be contiguous; gaps are allowed, so it is fine to
skip records. Only the ordering matters. Offsets are 0-based, so 0 is a
valid first offset.

Within a single stream the server enforces this: sending an offset lower
than one already sent on the same stream is a protocol violation and
fails the stream with `GO_AWAY`.

Across streams nothing is enforced, since the server does not remember
what a previous stream sent. Reusing an offset already committed by an
earlier stream of the same producer is not reported as an error: the
record is treated as a duplicate and silently dropped, meaning it does
not become an invocation and produces no `Error` frame. A client that
restarts its numbering after a reconnect will therefore see its records
disappear without any signal.
      uint64 offset = 1;
      Parameters:
      value - The offset to set.
      Returns:
      This builder for chaining.

    • clearOffset

      public IngestionInvocation.Builder clearOffset()
      Position of this record within the producer's sequence, and the value
deduplication is based on.

It must increase monotonically for a given producer ID, across the whole
lifetime of that producer and not just within a single stream. On
reconnect, resume from the `Response.last_committed` reported for the
producer rather than restarting the numbering.

Offsets do not have to be contiguous; gaps are allowed, so it is fine to
skip records. Only the ordering matters. Offsets are 0-based, so 0 is a
valid first offset.

Within a single stream the server enforces this: sending an offset lower
than one already sent on the same stream is a protocol violation and
fails the stream with `GO_AWAY`.

Across streams nothing is enforced, since the server does not remember
what a previous stream sent. Reusing an offset already committed by an
earlier stream of the same producer is not reported as an error: the
record is treated as a duplicate and silently dropped, meaning it does
not become an invocation and produces no `Error` frame. A client that
restarts its numbering after a reconnect will therefore see its records
disappear without any signal.
      uint64 offset = 1;
      Returns:
      This builder for chaining.

    • hasScope

      public boolean hasScope()
      scope is limited to 36 bytes.
      optional string scope = 2;
      Specified by:
      hasScope in interface IngestionInvocationOrBuilder
      Returns:
      Whether the scope field is set.

    • getScope

      public String getScope()
      scope is limited to 36 bytes.
      optional string scope = 2;
      Specified by:
      getScope in interface IngestionInvocationOrBuilder
      Returns:
      The scope.

    • getScopeBytes

      public com.google.protobuf.ByteString getScopeBytes()
      scope is limited to 36 bytes.
      optional string scope = 2;
      Specified by:
      getScopeBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for scope.

    • setScope

      public IngestionInvocation.Builder setScope(String value)
      scope is limited to 36 bytes.
      optional string scope = 2;
      Parameters:
      value - The scope to set.
      Returns:
      This builder for chaining.

    • clearScope

      public IngestionInvocation.Builder clearScope()
      scope is limited to 36 bytes.
      optional string scope = 2;
      Returns:
      This builder for chaining.

    • setScopeBytes

      public IngestionInvocation.Builder setScopeBytes(com.google.protobuf.ByteString value)
      scope is limited to 36 bytes.
      optional string scope = 2;
      Parameters:
      value - The bytes for scope to set.
      Returns:
      This builder for chaining.

    • hasLimitKey

      public boolean hasLimitKey()
      optional string limit_key = 3;
      Specified by:
      hasLimitKey in interface IngestionInvocationOrBuilder
      Returns:
      Whether the limitKey field is set.

    • getLimitKey

      public String getLimitKey()
      optional string limit_key = 3;
      Specified by:
      getLimitKey in interface IngestionInvocationOrBuilder
      Returns:
      The limitKey.

    • getLimitKeyBytes

      public com.google.protobuf.ByteString getLimitKeyBytes()
      optional string limit_key = 3;
      Specified by:
      getLimitKeyBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for limitKey.

    • setLimitKey

      public IngestionInvocation.Builder setLimitKey(String value)
      optional string limit_key = 3;
      Parameters:
      value - The limitKey to set.
      Returns:
      This builder for chaining.

    • clearLimitKey

      public IngestionInvocation.Builder clearLimitKey()
      optional string limit_key = 3;
      Returns:
      This builder for chaining.

    • setLimitKeyBytes

      public IngestionInvocation.Builder setLimitKeyBytes(com.google.protobuf.ByteString value)
      optional string limit_key = 3;
      Parameters:
      value - The bytes for limitKey to set.
      Returns:
      This builder for chaining.

    • hasService

      public boolean hasService()
      optional string service = 4;
      Specified by:
      hasService in interface IngestionInvocationOrBuilder
      Returns:
      Whether the service field is set.

    • getService

      public String getService()
      optional string service = 4;
      Specified by:
      getService in interface IngestionInvocationOrBuilder
      Returns:
      The service.

    • getServiceBytes

      public com.google.protobuf.ByteString getServiceBytes()
      optional string service = 4;
      Specified by:
      getServiceBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for service.

    • setService

      public IngestionInvocation.Builder setService(String value)
      optional string service = 4;
      Parameters:
      value - The service to set.
      Returns:
      This builder for chaining.

    • clearService

      public IngestionInvocation.Builder clearService()
      optional string service = 4;
      Returns:
      This builder for chaining.

    • setServiceBytes

      public IngestionInvocation.Builder setServiceBytes(com.google.protobuf.ByteString value)
      optional string service = 4;
      Parameters:
      value - The bytes for service to set.
      Returns:
      This builder for chaining.

    • hasHandler

      public boolean hasHandler()
      optional string handler = 5;
      Specified by:
      hasHandler in interface IngestionInvocationOrBuilder
      Returns:
      Whether the handler field is set.

    • getHandler

      public String getHandler()
      optional string handler = 5;
      Specified by:
      getHandler in interface IngestionInvocationOrBuilder
      Returns:
      The handler.

    • getHandlerBytes

      public com.google.protobuf.ByteString getHandlerBytes()
      optional string handler = 5;
      Specified by:
      getHandlerBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for handler.

    • setHandler

      public IngestionInvocation.Builder setHandler(String value)
      optional string handler = 5;
      Parameters:
      value - The handler to set.
      Returns:
      This builder for chaining.

    • clearHandler

      public IngestionInvocation.Builder clearHandler()
      optional string handler = 5;
      Returns:
      This builder for chaining.

    • setHandlerBytes

      public IngestionInvocation.Builder setHandlerBytes(com.google.protobuf.ByteString value)
      optional string handler = 5;
      Parameters:
      value - The bytes for handler to set.
      Returns:
      This builder for chaining.

    • hasKey

      public boolean hasKey()
      Required when the target service is a virtual object (VO).
or workflow. This can also be set via a preceding IngestionDefaults message.
      optional string key = 6;
      Specified by:
      hasKey in interface IngestionInvocationOrBuilder
      Returns:
      Whether the key field is set.

    • getKey

      public String getKey()
      Required when the target service is a virtual object (VO).
or workflow. This can also be set via a preceding IngestionDefaults message.
      optional string key = 6;
      Specified by:
      getKey in interface IngestionInvocationOrBuilder
      Returns:
      The key.

    • getKeyBytes

      public com.google.protobuf.ByteString getKeyBytes()
      Required when the target service is a virtual object (VO).
or workflow. This can also be set via a preceding IngestionDefaults message.
      optional string key = 6;
      Specified by:
      getKeyBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for key.

    • setKey

      public IngestionInvocation.Builder setKey(String value)
      Required when the target service is a virtual object (VO).
or workflow. This can also be set via a preceding IngestionDefaults message.
      optional string key = 6;
      Parameters:
      value - The key to set.
      Returns:
      This builder for chaining.

    • clearKey

      public IngestionInvocation.Builder clearKey()
      Required when the target service is a virtual object (VO).
or workflow. This can also be set via a preceding IngestionDefaults message.
      optional string key = 6;
      Returns:
      This builder for chaining.

    • setKeyBytes

      public IngestionInvocation.Builder setKeyBytes(com.google.protobuf.ByteString value)
      Required when the target service is a virtual object (VO).
or workflow. This can also be set via a preceding IngestionDefaults message.
      optional string key = 6;
      Parameters:
      value - The bytes for key to set.
      Returns:
      This builder for chaining.

    • hasIdempotencyKey

      public boolean hasIdempotencyKey()
      optional string idempotency_key = 7;
      Specified by:
      hasIdempotencyKey in interface IngestionInvocationOrBuilder
      Returns:
      Whether the idempotencyKey field is set.

    • getIdempotencyKey

      public String getIdempotencyKey()
      optional string idempotency_key = 7;
      Specified by:
      getIdempotencyKey in interface IngestionInvocationOrBuilder
      Returns:
      The idempotencyKey.

    • getIdempotencyKeyBytes

      public com.google.protobuf.ByteString getIdempotencyKeyBytes()
      optional string idempotency_key = 7;
      Specified by:
      getIdempotencyKeyBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for idempotencyKey.

    • setIdempotencyKey

      public IngestionInvocation.Builder setIdempotencyKey(String value)
      optional string idempotency_key = 7;
      Parameters:
      value - The idempotencyKey to set.
      Returns:
      This builder for chaining.

    • clearIdempotencyKey

      public IngestionInvocation.Builder clearIdempotencyKey()
      optional string idempotency_key = 7;
      Returns:
      This builder for chaining.

    • setIdempotencyKeyBytes

      public IngestionInvocation.Builder setIdempotencyKeyBytes(com.google.protobuf.ByteString value)
      optional string idempotency_key = 7;
      Parameters:
      value - The bytes for idempotencyKey to set.
      Returns:
      This builder for chaining.

    • getAdditionalHeadersCount

      public int getAdditionalHeadersCount()
      Description copied from interface: IngestionInvocationOrBuilder
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;
      Specified by:
      getAdditionalHeadersCount in interface IngestionInvocationOrBuilder

    • containsAdditionalHeaders

      public boolean containsAdditionalHeaders(String key)
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;
      Specified by:
      containsAdditionalHeaders in interface IngestionInvocationOrBuilder

    • getAdditionalHeaders

      @Deprecated public Map<String,String> getAdditionalHeaders()
      Deprecated.
      Use getAdditionalHeadersMap() instead.
      Specified by:
      getAdditionalHeaders in interface IngestionInvocationOrBuilder

    • getAdditionalHeadersMap

      public Map<String,String> getAdditionalHeadersMap()
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;
      Specified by:
      getAdditionalHeadersMap in interface IngestionInvocationOrBuilder

    • getAdditionalHeadersOrDefault

      public String getAdditionalHeadersOrDefault(String key, String defaultValue)
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;
      Specified by:
      getAdditionalHeadersOrDefault in interface IngestionInvocationOrBuilder

    • getAdditionalHeadersOrThrow

      public String getAdditionalHeadersOrThrow(String key)
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;
      Specified by:
      getAdditionalHeadersOrThrow in interface IngestionInvocationOrBuilder

    • clearAdditionalHeaders

      public IngestionInvocation.Builder clearAdditionalHeaders()

    • removeAdditionalHeaders

      public IngestionInvocation.Builder removeAdditionalHeaders(String key)
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;

    • getMutableAdditionalHeaders

      @Deprecated public Map<String,String> getMutableAdditionalHeaders()
      Deprecated.
      Use alternate mutation accessors instead.

    • putAdditionalHeaders

      public IngestionInvocation.Builder putAdditionalHeaders(String key, String value)
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;

    • putAllAdditionalHeaders

      public IngestionInvocation.Builder putAllAdditionalHeaders(Map<String,String> values)
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;

    • hasInvokeTimeTsMs

      public boolean hasInvokeTimeTsMs()
      starttime timestamp in ms.
      optional uint64 invoke_time_ts_ms = 10;
      Specified by:
      hasInvokeTimeTsMs in interface IngestionInvocationOrBuilder
      Returns:
      Whether the invokeTimeTsMs field is set.

    • getInvokeTimeTsMs

      public long getInvokeTimeTsMs()
      starttime timestamp in ms.
      optional uint64 invoke_time_ts_ms = 10;
      Specified by:
      getInvokeTimeTsMs in interface IngestionInvocationOrBuilder
      Returns:
      The invokeTimeTsMs.

    • setInvokeTimeTsMs

      public IngestionInvocation.Builder setInvokeTimeTsMs(long value)
      starttime timestamp in ms.
      optional uint64 invoke_time_ts_ms = 10;
      Parameters:
      value - The invokeTimeTsMs to set.
      Returns:
      This builder for chaining.

    • clearInvokeTimeTsMs

      public IngestionInvocation.Builder clearInvokeTimeTsMs()
      starttime timestamp in ms.
      optional uint64 invoke_time_ts_ms = 10;
      Returns:
      This builder for chaining.

    • hasTraceparent

      public boolean hasTraceparent()
      This uses the w3c tracecontext format
https://www.w3.org/TR/trace-context/
      optional string traceparent = 11;
      Specified by:
      hasTraceparent in interface IngestionInvocationOrBuilder
      Returns:
      Whether the traceparent field is set.

    • getTraceparent

      public String getTraceparent()
      This uses the w3c tracecontext format
https://www.w3.org/TR/trace-context/
      optional string traceparent = 11;
      Specified by:
      getTraceparent in interface IngestionInvocationOrBuilder
      Returns:
      The traceparent.

    • getTraceparentBytes

      public com.google.protobuf.ByteString getTraceparentBytes()
      This uses the w3c tracecontext format
https://www.w3.org/TR/trace-context/
      optional string traceparent = 11;
      Specified by:
      getTraceparentBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for traceparent.

    • setTraceparent

      public IngestionInvocation.Builder setTraceparent(String value)
      This uses the w3c tracecontext format
https://www.w3.org/TR/trace-context/
      optional string traceparent = 11;
      Parameters:
      value - The traceparent to set.
      Returns:
      This builder for chaining.

    • clearTraceparent

      public IngestionInvocation.Builder clearTraceparent()
      This uses the w3c tracecontext format
https://www.w3.org/TR/trace-context/
      optional string traceparent = 11;
      Returns:
      This builder for chaining.

    • setTraceparentBytes

      public IngestionInvocation.Builder setTraceparentBytes(com.google.protobuf.ByteString value)
      This uses the w3c tracecontext format
https://www.w3.org/TR/trace-context/
      optional string traceparent = 11;
      Parameters:
      value - The bytes for traceparent to set.
      Returns:
      This builder for chaining.

    • hasTracestate

      public boolean hasTracestate()
      optional string tracestate = 12;
      Specified by:
      hasTracestate in interface IngestionInvocationOrBuilder
      Returns:
      Whether the tracestate field is set.

    • getTracestate

      public String getTracestate()
      optional string tracestate = 12;
      Specified by:
      getTracestate in interface IngestionInvocationOrBuilder
      Returns:
      The tracestate.

    • getTracestateBytes

      public com.google.protobuf.ByteString getTracestateBytes()
      optional string tracestate = 12;
      Specified by:
      getTracestateBytes in interface IngestionInvocationOrBuilder
      Returns:
      The bytes for tracestate.

    • setTracestate

      public IngestionInvocation.Builder setTracestate(String value)
      optional string tracestate = 12;
      Parameters:
      value - The tracestate to set.
      Returns:
      This builder for chaining.

    • clearTracestate

      public IngestionInvocation.Builder clearTracestate()
      optional string tracestate = 12;
      Returns:
      This builder for chaining.

    • setTracestateBytes

      public IngestionInvocation.Builder setTracestateBytes(com.google.protobuf.ByteString value)
      optional string tracestate = 12;
      Parameters:
      value - The bytes for tracestate to set.
      Returns:
      This builder for chaining.

    • getPayload

      public com.google.protobuf.ByteString getPayload()
      bytes payload = 13;
      Specified by:
      getPayload in interface IngestionInvocationOrBuilder
      Returns:
      The payload.

    • setPayload

      public IngestionInvocation.Builder setPayload(com.google.protobuf.ByteString value)
      bytes payload = 13;
      Parameters:
      value - The payload to set.
      Returns:
      This builder for chaining.

    • clearPayload

      public IngestionInvocation.Builder clearPayload()
      bytes payload = 13;
      Returns:
      This builder for chaining.