Interface IngestionInvocationOrBuilder

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

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    containsAdditionalHeaders(String key)
    IngestionDefaults::headers + IngestionInvocation::headers size should not exceed a max of 2KiB (keys + values)
    Map<String,String>
    getAdditionalHeaders()
    Deprecated.
    int
    getAdditionalHeadersCount()
    IngestionDefaults::headers + IngestionInvocation::headers size should not exceed a max of 2KiB (keys + values)
    Map<String,String>
    getAdditionalHeadersMap()
    IngestionDefaults::headers + IngestionInvocation::headers size should not exceed a max of 2KiB (keys + values)
    String
    getAdditionalHeadersOrDefault(String key, String defaultValue)
    IngestionDefaults::headers + IngestionInvocation::headers size should not exceed a max of 2KiB (keys + values)
    String
    getAdditionalHeadersOrThrow(String key)
    IngestionDefaults::headers + IngestionInvocation::headers size should not exceed a max of 2KiB (keys + values)
    String
    getHandler()
    optional string handler = 5;
    com.google.protobuf.ByteString
    getHandlerBytes()
    optional string handler = 5;
    String
    getIdempotencyKey()
    optional string idempotency_key = 7;
    com.google.protobuf.ByteString
    getIdempotencyKeyBytes()
    optional string idempotency_key = 7;
    long
    getInvokeTimeTsMs()
    starttime timestamp in ms.
    String
    getKey()
    Required when the target service is a virtual object (VO).
    com.google.protobuf.ByteString
    getKeyBytes()
    Required when the target service is a virtual object (VO).
    String
    getLimitKey()
    optional string limit_key = 3;
    com.google.protobuf.ByteString
    getLimitKeyBytes()
    optional string limit_key = 3;
    long
    getOffset()
    Position of this record within the producer's sequence, and the value deduplication is based on.
    com.google.protobuf.ByteString
    getPayload()
    bytes payload = 13;
    String
    getScope()
    scope is limited to 36 bytes.
    com.google.protobuf.ByteString
    getScopeBytes()
    scope is limited to 36 bytes.
    String
    getService()
    optional string service = 4;
    com.google.protobuf.ByteString
    getServiceBytes()
    optional string service = 4;
    String
    getTraceparent()
    This uses the w3c tracecontext format https://www.w3.org/TR/trace-context/
    com.google.protobuf.ByteString
    getTraceparentBytes()
    This uses the w3c tracecontext format https://www.w3.org/TR/trace-context/
    String
    getTracestate()
    optional string tracestate = 12;
    com.google.protobuf.ByteString
    getTracestateBytes()
    optional string tracestate = 12;
    boolean
    hasHandler()
    optional string handler = 5;
    boolean
    hasIdempotencyKey()
    optional string idempotency_key = 7;
    boolean
    hasInvokeTimeTsMs()
    starttime timestamp in ms.
    boolean
    hasKey()
    Required when the target service is a virtual object (VO).
    boolean
    hasLimitKey()
    optional string limit_key = 3;
    boolean
    hasScope()
    scope is limited to 36 bytes.
    boolean
    hasService()
    optional string service = 4;
    boolean
    hasTraceparent()
    This uses the w3c tracecontext format https://www.w3.org/TR/trace-context/
    boolean
    hasTracestate()
    optional string tracestate = 12;

    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

    • getOffset

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

    • hasScope

      boolean hasScope()
      scope is limited to 36 bytes.
      optional string scope = 2;
      Returns:
      Whether the scope field is set.

    • getScope

      String getScope()
      scope is limited to 36 bytes.
      optional string scope = 2;
      Returns:
      The scope.

    • getScopeBytes

      com.google.protobuf.ByteString getScopeBytes()
      scope is limited to 36 bytes.
      optional string scope = 2;
      Returns:
      The bytes for scope.

    • hasLimitKey

      boolean hasLimitKey()
      optional string limit_key = 3;
      Returns:
      Whether the limitKey field is set.

    • getLimitKey

      String getLimitKey()
      optional string limit_key = 3;
      Returns:
      The limitKey.

    • getLimitKeyBytes

      com.google.protobuf.ByteString getLimitKeyBytes()
      optional string limit_key = 3;
      Returns:
      The bytes for limitKey.

    • hasService

      boolean hasService()
      optional string service = 4;
      Returns:
      Whether the service field is set.

    • getService

      String getService()
      optional string service = 4;
      Returns:
      The service.

    • getServiceBytes

      com.google.protobuf.ByteString getServiceBytes()
      optional string service = 4;
      Returns:
      The bytes for service.

    • hasHandler

      boolean hasHandler()
      optional string handler = 5;
      Returns:
      Whether the handler field is set.

    • getHandler

      String getHandler()
      optional string handler = 5;
      Returns:
      The handler.

    • getHandlerBytes

      com.google.protobuf.ByteString getHandlerBytes()
      optional string handler = 5;
      Returns:
      The bytes for handler.

    • hasKey

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

    • getKey

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

    • getKeyBytes

      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;
      Returns:
      The bytes for key.

    • hasIdempotencyKey

      boolean hasIdempotencyKey()
      optional string idempotency_key = 7;
      Returns:
      Whether the idempotencyKey field is set.

    • getIdempotencyKey

      String getIdempotencyKey()
      optional string idempotency_key = 7;
      Returns:
      The idempotencyKey.

    • getIdempotencyKeyBytes

      com.google.protobuf.ByteString getIdempotencyKeyBytes()
      optional string idempotency_key = 7;
      Returns:
      The bytes for idempotencyKey.

    • getAdditionalHeadersCount

      int getAdditionalHeadersCount()
      IngestionDefaults::headers + IngestionInvocation::headers size
should not exceed a max of 2KiB (keys + values)
      map<string, string> additional_headers = 8;

    • containsAdditionalHeaders

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

    • getAdditionalHeaders

      @Deprecated Map<String,String> getAdditionalHeaders()
      Deprecated.
      Use getAdditionalHeadersMap() instead.

    • getAdditionalHeadersMap

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

    • getAdditionalHeadersOrDefault

      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;

    • getAdditionalHeadersOrThrow

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

    • hasInvokeTimeTsMs

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

    • getInvokeTimeTsMs

      long getInvokeTimeTsMs()
      starttime timestamp in ms.
      optional uint64 invoke_time_ts_ms = 10;
      Returns:
      The invokeTimeTsMs.

    • hasTraceparent

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

    • getTraceparent

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

    • getTraceparentBytes

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

    • hasTracestate

      boolean hasTracestate()
      optional string tracestate = 12;
      Returns:
      Whether the tracestate field is set.

    • getTracestate

      String getTracestate()
      optional string tracestate = 12;
      Returns:
      The tracestate.

    • getTracestateBytes

      com.google.protobuf.ByteString getTracestateBytes()
      optional string tracestate = 12;
      Returns:
      The bytes for tracestate.

    • getPayload

      com.google.protobuf.ByteString getPayload()
      bytes payload = 13;
      Returns:
      The payload.