Packages

c

com.google.pubsub.v1

IngestionFailureEvent

final class IngestionFailureEvent extends GeneratedMessageV3 with IngestionFailureEventOrBuilder

Payload of the Platform Log entry sent when a failure is encountered while
ingesting.

Protobuf type google.pubsub.v1.IngestionFailureEvent

Source
IngestionFailureEvent.java
Linear Supertypes
IngestionFailureEventOrBuilder, GeneratedMessageV3, Serializable, AbstractMessage, Message, MessageOrBuilder, AbstractMessageLite[MessageType, BuilderType], MessageLite, MessageLiteOrBuilder, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IngestionFailureEvent
  2. IngestionFailureEventOrBuilder
  3. GeneratedMessageV3
  4. Serializable
  5. AbstractMessage
  6. Message
  7. MessageOrBuilder
  8. AbstractMessageLite
  9. MessageLite
  10. MessageLiteOrBuilder
  11. AnyRef
  12. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def equals(obj: AnyRef): Boolean
    Definition Classes
    IngestionFailureEvent → AbstractMessage → Message → AnyRef → Any
    Annotations
    @Override()
  2. def findInitializationErrors(): List[String]
    Definition Classes
    AbstractMessage → MessageOrBuilder
  3. def getAllFields(): Map[FieldDescriptor, AnyRef]
    Definition Classes
    GeneratedMessageV3 → MessageOrBuilder
  4. def getAwsMskFailure(): AwsMskFailureReason

    Optional. Failure when ingesting from Amazon MSK.


    Optional. Failure when ingesting from Amazon MSK.

    .google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason aws_msk_failure = 4 [(.google.api.field_behavior) = OPTIONAL];

    returns

    The awsMskFailure.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  5. def getAwsMskFailureOrBuilder(): AwsMskFailureReasonOrBuilder

    Optional. Failure when ingesting from Amazon MSK.


    Optional. Failure when ingesting from Amazon MSK.

    .google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason aws_msk_failure = 4 [(.google.api.field_behavior) = OPTIONAL];

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  6. def getAzureEventHubsFailure(): AzureEventHubsFailureReason

    Optional. Failure when ingesting from Azure Event Hubs.


    Optional. Failure when ingesting from Azure Event Hubs.

    .google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason azure_event_hubs_failure = 5 [(.google.api.field_behavior) = OPTIONAL];

    returns

    The azureEventHubsFailure.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  7. def getAzureEventHubsFailureOrBuilder(): AzureEventHubsFailureReasonOrBuilder

    Optional. Failure when ingesting from Azure Event Hubs.


    Optional. Failure when ingesting from Azure Event Hubs.

    .google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason azure_event_hubs_failure = 5 [(.google.api.field_behavior) = OPTIONAL];

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  8. def getCloudStorageFailure(): CloudStorageFailure

    Optional. Failure when ingesting from Cloud Storage.


    Optional. Failure when ingesting from Cloud Storage.

    .google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure cloud_storage_failure = 3 [(.google.api.field_behavior) = OPTIONAL];

    returns

    The cloudStorageFailure.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  9. def getCloudStorageFailureOrBuilder(): CloudStorageFailureOrBuilder

    Optional. Failure when ingesting from Cloud Storage.


    Optional. Failure when ingesting from Cloud Storage.

    .google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure cloud_storage_failure = 3 [(.google.api.field_behavior) = OPTIONAL];

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  10. def getConfluentCloudFailure(): ConfluentCloudFailureReason

    Optional. Failure when ingesting from Confluent Cloud.


    Optional. Failure when ingesting from Confluent Cloud.

    .google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason confluent_cloud_failure = 6 [(.google.api.field_behavior) = OPTIONAL];

    returns

    The confluentCloudFailure.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  11. def getConfluentCloudFailureOrBuilder(): ConfluentCloudFailureReasonOrBuilder

    Optional. Failure when ingesting from Confluent Cloud.


    Optional. Failure when ingesting from Confluent Cloud.

    .google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason confluent_cloud_failure = 6 [(.google.api.field_behavior) = OPTIONAL];

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  12. def getDefaultInstanceForType(): IngestionFailureEvent
    Definition Classes
    IngestionFailureEvent → MessageOrBuilder → MessageLiteOrBuilder
    Annotations
    @Override()
  13. def getDescriptorForType(): Descriptor
    Definition Classes
    GeneratedMessageV3 → MessageOrBuilder
  14. def getErrorMessage(): String

    Required. Error details explaining why ingestion to Pub/Sub has failed.


    Required. Error details explaining why ingestion to Pub/Sub has failed.

    string error_message = 2 [(.google.api.field_behavior) = REQUIRED];

    returns

    The errorMessage.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  15. def getErrorMessageBytes(): ByteString

    Required. Error details explaining why ingestion to Pub/Sub has failed.


    Required. Error details explaining why ingestion to Pub/Sub has failed.

    string error_message = 2 [(.google.api.field_behavior) = REQUIRED];

    returns

    The bytes for errorMessage.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  16. def getFailureCase(): FailureCase
    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
  17. def getField(arg0: FieldDescriptor): AnyRef
    Definition Classes
    GeneratedMessageV3 → MessageOrBuilder
  18. def getInitializationErrorString(): String
    Definition Classes
    AbstractMessage → MessageOrBuilder
  19. def getOneofFieldDescriptor(arg0: OneofDescriptor): FieldDescriptor
    Definition Classes
    GeneratedMessageV3 → AbstractMessage → MessageOrBuilder
  20. def getParserForType(): Parser[IngestionFailureEvent]
    Definition Classes
    IngestionFailureEvent → GeneratedMessageV3 → Message → MessageLite
    Annotations
    @Override()
  21. def getRepeatedField(arg0: FieldDescriptor, arg1: Int): AnyRef
    Definition Classes
    GeneratedMessageV3 → MessageOrBuilder
  22. def getRepeatedFieldCount(arg0: FieldDescriptor): Int
    Definition Classes
    GeneratedMessageV3 → MessageOrBuilder
  23. def getSerializedSize(): Int
    Definition Classes
    IngestionFailureEvent → GeneratedMessageV3 → AbstractMessage → MessageLite
    Annotations
    @Override()
  24. def getTopic(): String

    Required. Name of the import topic. Format is:
projects/{project_name}/topics/{topic_name}.


    Required. Name of the import topic. Format is:
projects/{project_name}/topics/{topic_name}.

    string topic = 1 [(.google.api.field_behavior) = REQUIRED];

    returns

    The topic.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  25. def getTopicBytes(): ByteString

    Required. Name of the import topic. Format is:
projects/{project_name}/topics/{topic_name}.


    Required. Name of the import topic. Format is:
projects/{project_name}/topics/{topic_name}.

    string topic = 1 [(.google.api.field_behavior) = REQUIRED];

    returns

    The bytes for topic.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  26. def getUnknownFields(): UnknownFieldSet
    Definition Classes
    GeneratedMessageV3 → MessageOrBuilder
  27. def hasAwsMskFailure(): Boolean

    Optional. Failure when ingesting from Amazon MSK.


    Optional. Failure when ingesting from Amazon MSK.

    .google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason aws_msk_failure = 4 [(.google.api.field_behavior) = OPTIONAL];

    returns

    Whether the awsMskFailure field is set.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  28. def hasAzureEventHubsFailure(): Boolean

    Optional. Failure when ingesting from Azure Event Hubs.


    Optional. Failure when ingesting from Azure Event Hubs.

    .google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason azure_event_hubs_failure = 5 [(.google.api.field_behavior) = OPTIONAL];

    returns

    Whether the azureEventHubsFailure field is set.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  29. def hasCloudStorageFailure(): Boolean

    Optional. Failure when ingesting from Cloud Storage.


    Optional. Failure when ingesting from Cloud Storage.

    .google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure cloud_storage_failure = 3 [(.google.api.field_behavior) = OPTIONAL];

    returns

    Whether the cloudStorageFailure field is set.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  30. def hasConfluentCloudFailure(): Boolean

    Optional. Failure when ingesting from Confluent Cloud.


    Optional. Failure when ingesting from Confluent Cloud.

    .google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason confluent_cloud_failure = 6 [(.google.api.field_behavior) = OPTIONAL];

    returns

    Whether the confluentCloudFailure field is set.

    Definition Classes
    IngestionFailureEvent → IngestionFailureEventOrBuilder
    Annotations
    @Override()
  31. def hasField(arg0: FieldDescriptor): Boolean
    Definition Classes
    GeneratedMessageV3 → MessageOrBuilder
  32. def hasOneof(arg0: OneofDescriptor): Boolean
    Definition Classes
    GeneratedMessageV3 → AbstractMessage → MessageOrBuilder
  33. def hashCode(): Int
    Definition Classes
    IngestionFailureEvent → AbstractMessage → Message → AnyRef → Any
    Annotations
    @Override()
  34. final def isInitialized(): Boolean
    Definition Classes
    IngestionFailureEvent → GeneratedMessageV3 → AbstractMessage → MessageLiteOrBuilder
    Annotations
    @Override()
  35. def newBuilderForType(): Builder
    Definition Classes
    IngestionFailureEvent → Message → MessageLite
    Annotations
    @Override()
  36. def toBuilder(): Builder
    Definition Classes
    IngestionFailureEvent → Message → MessageLite
    Annotations
    @Override()
  37. def toByteArray(): Array[Byte]
    Definition Classes
    AbstractMessageLite → MessageLite
  38. def toByteString(): ByteString
    Definition Classes
    AbstractMessageLite → MessageLite
  39. final def toString(): String
    Definition Classes
    AbstractMessage → Message → AnyRef → Any
  40. def writeDelimitedTo(arg0: OutputStream): Unit
    Definition Classes
    AbstractMessageLite → MessageLite
    Annotations
    @throws(classOf[java.io.IOException])
  41. def writeTo(output: CodedOutputStream): Unit
    Definition Classes
    IngestionFailureEvent → GeneratedMessageV3 → AbstractMessage → MessageLite
    Annotations
    @Override()
  42. def writeTo(arg0: OutputStream): Unit
    Definition Classes
    AbstractMessageLite → MessageLite
    Annotations
    @throws(classOf[java.io.IOException])