Class IngestionStart.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<IngestionStart.Builder>
com.google.protobuf.GeneratedMessage.Builder<IngestionStart.Builder>
dev.restate.ingestion.v1.IngestionStart.Builder
All Implemented Interfaces:
com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, IngestionStartOrBuilder, Cloneable
Enclosing class:
IngestionStart
public static final class IngestionStart.Builder extends com.google.protobuf.GeneratedMessage.Builder<IngestionStart.Builder> implements IngestionStartOrBuilder
Required.
A Start frame must be sent before any IngestionDefaults or
IngestionInvocation frame.
Sending a Start frame again during the lifetime of
the stream is illegal: the server will return an
error and terminate the stream.

Invalid Start message will cause an error
to be returned immediately, and stream to be teared down
immediately
Protobuf type dev.restate.ingress.ingestion.v1.IngestionStart

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

    • clear

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

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • mergeFrom

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

    • mergeFrom

      public IngestionStart.Builder mergeFrom(IngestionStart other)

    • isInitialized

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

    • mergeFrom

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

    • getProducerId

      public String getProducerId()
      Stable identity of the *producer*, not of this particular stream.

The ID is an opaque string: this API is generic, so the server
attaches no format or meaning to it. It is entirely up to the producer
to pick an ID that uniquely identifies a single source of sequential,
ordered messages, since offsets are only meaningful relative to that
source. For a Kafka-based producer, for instance, an ID composed of
cluster + topic + consumer-group + partition would identify such a
source.

Depending on the DedupMode, the same producer must reuse the same
ID across streams (including after reconnects), otherwise deduplication
cannot work: the server tracks committed offsets per producer ID,
so a new ID starts a fresh deduplication state and previously committed
records may be duplicated.

The ID must be unique across producers: two distinct producers
sharing an ID will be treated as one and will shadow each other's
offsets.

Max length is 256 bytes.
      string producer_id = 1;
      Specified by:
      getProducerId in interface IngestionStartOrBuilder
      Returns:
      The producerId.

    • getProducerIdBytes

      public com.google.protobuf.ByteString getProducerIdBytes()
      Stable identity of the *producer*, not of this particular stream.

The ID is an opaque string: this API is generic, so the server
attaches no format or meaning to it. It is entirely up to the producer
to pick an ID that uniquely identifies a single source of sequential,
ordered messages, since offsets are only meaningful relative to that
source. For a Kafka-based producer, for instance, an ID composed of
cluster + topic + consumer-group + partition would identify such a
source.

Depending on the DedupMode, the same producer must reuse the same
ID across streams (including after reconnects), otherwise deduplication
cannot work: the server tracks committed offsets per producer ID,
so a new ID starts a fresh deduplication state and previously committed
records may be duplicated.

The ID must be unique across producers: two distinct producers
sharing an ID will be treated as one and will shadow each other's
offsets.

Max length is 256 bytes.
      string producer_id = 1;
      Specified by:
      getProducerIdBytes in interface IngestionStartOrBuilder
      Returns:
      The bytes for producerId.

    • setProducerId

      public IngestionStart.Builder setProducerId(String value)
      Stable identity of the *producer*, not of this particular stream.

The ID is an opaque string: this API is generic, so the server
attaches no format or meaning to it. It is entirely up to the producer
to pick an ID that uniquely identifies a single source of sequential,
ordered messages, since offsets are only meaningful relative to that
source. For a Kafka-based producer, for instance, an ID composed of
cluster + topic + consumer-group + partition would identify such a
source.

Depending on the DedupMode, the same producer must reuse the same
ID across streams (including after reconnects), otherwise deduplication
cannot work: the server tracks committed offsets per producer ID,
so a new ID starts a fresh deduplication state and previously committed
records may be duplicated.

The ID must be unique across producers: two distinct producers
sharing an ID will be treated as one and will shadow each other's
offsets.

Max length is 256 bytes.
      string producer_id = 1;
      Parameters:
      value - The producerId to set.
      Returns:
      This builder for chaining.

    • clearProducerId

      public IngestionStart.Builder clearProducerId()
      Stable identity of the *producer*, not of this particular stream.

The ID is an opaque string: this API is generic, so the server
attaches no format or meaning to it. It is entirely up to the producer
to pick an ID that uniquely identifies a single source of sequential,
ordered messages, since offsets are only meaningful relative to that
source. For a Kafka-based producer, for instance, an ID composed of
cluster + topic + consumer-group + partition would identify such a
source.

Depending on the DedupMode, the same producer must reuse the same
ID across streams (including after reconnects), otherwise deduplication
cannot work: the server tracks committed offsets per producer ID,
so a new ID starts a fresh deduplication state and previously committed
records may be duplicated.

The ID must be unique across producers: two distinct producers
sharing an ID will be treated as one and will shadow each other's
offsets.

Max length is 256 bytes.
      string producer_id = 1;
      Returns:
      This builder for chaining.

    • setProducerIdBytes

      public IngestionStart.Builder setProducerIdBytes(com.google.protobuf.ByteString value)
      Stable identity of the *producer*, not of this particular stream.

The ID is an opaque string: this API is generic, so the server
attaches no format or meaning to it. It is entirely up to the producer
to pick an ID that uniquely identifies a single source of sequential,
ordered messages, since offsets are only meaningful relative to that
source. For a Kafka-based producer, for instance, an ID composed of
cluster + topic + consumer-group + partition would identify such a
source.

Depending on the DedupMode, the same producer must reuse the same
ID across streams (including after reconnects), otherwise deduplication
cannot work: the server tracks committed offsets per producer ID,
so a new ID starts a fresh deduplication state and previously committed
records may be duplicated.

The ID must be unique across producers: two distinct producers
sharing an ID will be treated as one and will shadow each other's
offsets.

Max length is 256 bytes.
      string producer_id = 1;
      Parameters:
      value - The bytes for producerId to set.
      Returns:
      This builder for chaining.

    • getIntegration

      public String getIntegration()
      Integration identification in format `name/version`
Max length is 64 bytes
      string integration = 2;
      Specified by:
      getIntegration in interface IngestionStartOrBuilder
      Returns:
      The integration.

    • getIntegrationBytes

      public com.google.protobuf.ByteString getIntegrationBytes()
      Integration identification in format `name/version`
Max length is 64 bytes
      string integration = 2;
      Specified by:
      getIntegrationBytes in interface IngestionStartOrBuilder
      Returns:
      The bytes for integration.

    • setIntegration

      public IngestionStart.Builder setIntegration(String value)
      Integration identification in format `name/version`
Max length is 64 bytes
      string integration = 2;
      Parameters:
      value - The integration to set.
      Returns:
      This builder for chaining.

    • clearIntegration

      public IngestionStart.Builder clearIntegration()
      Integration identification in format `name/version`
Max length is 64 bytes
      string integration = 2;
      Returns:
      This builder for chaining.

    • setIntegrationBytes

      public IngestionStart.Builder setIntegrationBytes(com.google.protobuf.ByteString value)
      Integration identification in format `name/version`
Max length is 64 bytes
      string integration = 2;
      Parameters:
      value - The bytes for integration to set.
      Returns:
      This builder for chaining.

    • getDeduplicationModeValue

      public int getDeduplicationModeValue()
      Deduplication strategy for this stream. Defaults to `DISABLED`.
      .dev.restate.ingress.ingestion.v1.DeduplicationMode deduplication_mode = 3;
      Specified by:
      getDeduplicationModeValue in interface IngestionStartOrBuilder
      Returns:
      The enum numeric value on the wire for deduplicationMode.

    • setDeduplicationModeValue

      public IngestionStart.Builder setDeduplicationModeValue(int value)
      Deduplication strategy for this stream. Defaults to `DISABLED`.
      .dev.restate.ingress.ingestion.v1.DeduplicationMode deduplication_mode = 3;
      Parameters:
      value - The enum numeric value on the wire for deduplicationMode to set.
      Returns:
      This builder for chaining.

    • getDeduplicationMode

      public DeduplicationMode getDeduplicationMode()
      Deduplication strategy for this stream. Defaults to `DISABLED`.
      .dev.restate.ingress.ingestion.v1.DeduplicationMode deduplication_mode = 3;
      Specified by:
      getDeduplicationMode in interface IngestionStartOrBuilder
      Returns:
      The deduplicationMode.

    • setDeduplicationMode

      public IngestionStart.Builder setDeduplicationMode(DeduplicationMode value)
      Deduplication strategy for this stream. Defaults to `DISABLED`.
      .dev.restate.ingress.ingestion.v1.DeduplicationMode deduplication_mode = 3;
      Parameters:
      value - The deduplicationMode to set.
      Returns:
      This builder for chaining.

    • clearDeduplicationMode

      public IngestionStart.Builder clearDeduplicationMode()
      Deduplication strategy for this stream. Defaults to `DISABLED`.
      .dev.restate.ingress.ingestion.v1.DeduplicationMode deduplication_mode = 3;
      Returns:
      This builder for chaining.

    • hasDefaults

      public boolean hasDefaults()
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;
      Specified by:
      hasDefaults in interface IngestionStartOrBuilder
      Returns:
      Whether the defaults field is set.

    • getDefaults

      public IngestionDefaults getDefaults()
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;
      Specified by:
      getDefaults in interface IngestionStartOrBuilder
      Returns:
      The defaults.

    • setDefaults

      public IngestionStart.Builder setDefaults(IngestionDefaults value)
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;

    • setDefaults

      public IngestionStart.Builder setDefaults(IngestionDefaults.Builder builderForValue)
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;

    • mergeDefaults

      public IngestionStart.Builder mergeDefaults(IngestionDefaults value)
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;

    • clearDefaults

      public IngestionStart.Builder clearDefaults()
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;

    • getDefaultsBuilder

      public IngestionDefaults.Builder getDefaultsBuilder()
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;

    • getDefaultsOrBuilder

      public IngestionDefaultsOrBuilder getDefaultsOrBuilder()
      Initial ingestion defaults for the stream, letting the client
establish its defaults up front instead of following
the Start frame with a separate IngestionDefaults frame.
Clients can still send further IngestionDefaults frames later
to update these defaults during the stream.
      .dev.restate.ingress.ingestion.v1.IngestionDefaults defaults = 4;
      Specified by:
      getDefaultsOrBuilder in interface IngestionStartOrBuilder