Package com.snowflake.connectors.common.assertions.ingestion

Class IngestionRunAssert

  • All Implemented Interfaces:
    org.assertj.core.api.Assert<IngestionRunAssert,​com.snowflake.connectors.application.observability.IngestionRun>, org.assertj.core.api.Descriptable<IngestionRunAssert>, org.assertj.core.api.ExtensionPoints<IngestionRunAssert,​com.snowflake.connectors.application.observability.IngestionRun>
    public class IngestionRunAssert
extends org.assertj.core.api.AbstractAssert<IngestionRunAssert,​com.snowflake.connectors.application.observability.IngestionRun>
    AssertJ based assertions for IngestionRun.

    • Field Summary

      • Fields inherited from class org.assertj.core.api.AbstractAssert

        actual, info, myself, objects, throwUnsupportedExceptionOnEquals

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      IngestionRunAssert hasCompletedAt​(Instant completedAt)
      Asserts that this ingestion run has a completedAt timestamp equal to the specified value.
      IngestionRunAssert hasCompletedAtBetween​(Instant start, Instant end)
      Asserts that this ingestion run has a completedAt timestamp between to the specified values.
      IngestionRunAssert hasId​(String id)
      Asserts that this ingestion run has an id equal to the specified value.
      IngestionRunAssert hasIngestedRows​(long ingestedRows)
      Asserts that this ingestion run has a number of ingested rows equal to the specified value.
      IngestionRunAssert hasIngestionConfigurationId​(String ingestionConfigurationId)
      Asserts that this ingestion run has an ingestion configuration id equal to the specified value.
      IngestionRunAssert hasIngestionDefinitionId​(String resourceIngestionDefinitionId)
      Asserts that this ingestion run has a resource ingestion definition id equal to the specified value.
      IngestionRunAssert hasIngestionProcessId​(String ingestionProcessId)
      Asserts that this ingestion run has an ingestion process id equal to the specified value.
      IngestionRunAssert hasMetadata​(Variant metadata)
      Asserts that this ingestion run has a metadata equal to the specified value.
      IngestionRunAssert hasStartedAt​(Instant startedAt)
      Asserts that this ingestion run has a startedAt timestamp equal to the specified value.
      IngestionRunAssert hasStartedAtBetween​(Instant start, Instant end)
      Asserts that this ingestion run has a StartedAt timestamp between to the specified values.
      IngestionRunAssert hasStatus​(com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus ingestionStatus)
      Asserts that this ingestion run has an ingestion status equal to the specified value.
      IngestionRunAssert hasUpdatedAt​(Instant updatedAt)
      Asserts that this ingestion run has an updatedAt timestamp equal to the specified value.
      IngestionRunAssert hasUpdatedAtBetween​(Instant start, Instant end)
      Asserts that this ingestion run has a updatedAt timestamp between to the specified values.

      • Methods inherited from class org.assertj.core.api.AbstractAssert

        areEqual, asInstanceOf, asList, assertionError, asString, describedAs, descriptionText, doesNotHave, doesNotHaveSameClassAs, doesNotHaveSameHashCodeAs, doesNotHaveToString, doesNotHaveToString, equals, extracting, extracting, failure, failureWithActualExpected, failWithActualExpectedAndMessage, failWithMessage, getWritableAssertionInfo, has, hashCode, hasSameClassAs, hasSameHashCodeAs, hasToString, hasToString, inBinary, inHexadecimal, is, isElementOfCustomAssert, isEqualTo, isExactlyInstanceOf, isIn, isIn, isInstanceOf, isInstanceOfAny, isInstanceOfSatisfying, isNot, isNotEqualTo, isNotExactlyInstanceOf, isNotIn, isNotIn, isNotInstanceOf, isNotInstanceOfAny, isNotNull, isNotOfAnyClassIn, isNotSameAs, isNull, isOfAnyClassIn, isSameAs, matches, matches, newListAssertInstance, overridingErrorMessage, overridingErrorMessage, satisfies, satisfies, satisfies, satisfiesAnyOf, satisfiesAnyOf, satisfiesAnyOfForProxy, satisfiesForProxy, setCustomRepresentation, setDescriptionConsumer, setPrintAssertionsDescription, throwAssertionError, usingComparator, usingComparator, usingDefaultComparator, usingRecursiveAssertion, usingRecursiveAssertion, usingRecursiveComparison, usingRecursiveComparison, withFailMessage, withFailMessage, withRepresentation, withThreadDumpOnError

      • Methods inherited from interface org.assertj.core.api.Descriptable

        as, as, as, describedAs, describedAs

    • Constructor Detail

      • IngestionRunAssert

        public IngestionRunAssert​(com.snowflake.connectors.application.observability.IngestionRun ingestionRun,
                          Class<IngestionRunAssert> selfType)

    • Method Detail

      • hasId

        public IngestionRunAssert hasId​(String id)
        Asserts that this ingestion run has an id equal to the specified value.
        Parameters:
        id - expected id
        Returns:
        this assertion

      • hasIngestionDefinitionId

        public IngestionRunAssert hasIngestionDefinitionId​(String resourceIngestionDefinitionId)
        Asserts that this ingestion run has a resource ingestion definition id equal to the specified value.
        Parameters:
        resourceIngestionDefinitionId - expected resource ingestion definition id
        Returns:
        this assertion

      • hasIngestionConfigurationId

        public IngestionRunAssert hasIngestionConfigurationId​(String ingestionConfigurationId)
        Asserts that this ingestion run has an ingestion configuration id equal to the specified value.
        Parameters:
        ingestionConfigurationId - expected ingestion configuration id
        Returns:
        this assertion

      • hasIngestionProcessId

        public IngestionRunAssert hasIngestionProcessId​(String ingestionProcessId)
        Asserts that this ingestion run has an ingestion process id equal to the specified value.
        Parameters:
        ingestionProcessId - expected ingestion process id
        Returns:
        this assertion

      • hasStatus

        public IngestionRunAssert hasStatus​(com.snowflake.connectors.application.observability.IngestionRun.IngestionStatus ingestionStatus)
        Asserts that this ingestion run has an ingestion status equal to the specified value.
        Parameters:
        ingestionStatus - expected ingestion status
        Returns:
        this assertion

      • hasStartedAt

        public IngestionRunAssert hasStartedAt​(Instant startedAt)
        Asserts that this ingestion run has a startedAt timestamp equal to the specified value.
        Parameters:
        startedAt - expected startedAt timestamp
        Returns:
        this assertion

      • hasStartedAtBetween

        public IngestionRunAssert hasStartedAtBetween​(Instant start,
                                              Instant end)
        Asserts that this ingestion run has a StartedAt timestamp between to the specified values.
        Parameters:
        start - expected start timestamp
        end - expected end timestamp
        Returns:
        this assertion

      • hasCompletedAt

        public IngestionRunAssert hasCompletedAt​(Instant completedAt)
        Asserts that this ingestion run has a completedAt timestamp equal to the specified value.
        Parameters:
        completedAt - expected completedAt timestamp
        Returns:
        this assertion

      • hasCompletedAtBetween

        public IngestionRunAssert hasCompletedAtBetween​(Instant start,
                                                Instant end)
        Asserts that this ingestion run has a completedAt timestamp between to the specified values.
        Parameters:
        start - expected start timestamp
        end - expected end timestamp
        Returns:
        this assertion

      • hasIngestedRows

        public IngestionRunAssert hasIngestedRows​(long ingestedRows)
        Asserts that this ingestion run has a number of ingested rows equal to the specified value.
        Parameters:
        ingestedRows - expected number of ingested rows
        Returns:
        this assertion

      • hasUpdatedAt

        public IngestionRunAssert hasUpdatedAt​(Instant updatedAt)
        Asserts that this ingestion run has an updatedAt timestamp equal to the specified value.
        Parameters:
        updatedAt - expected updatedAt timestamp
        Returns:
        this assertion

      • hasUpdatedAtBetween

        public IngestionRunAssert hasUpdatedAtBetween​(Instant start,
                                              Instant end)
        Asserts that this ingestion run has a updatedAt timestamp between to the specified values.
        Parameters:
        start - expected start timestamp
        end - expected end timestamp
        Returns:
        this assertion

      • hasMetadata

        public IngestionRunAssert hasMetadata​(Variant metadata)
        Asserts that this ingestion run has a metadata equal to the specified value.
        Parameters:
        metadata - expected metadata
        Returns:
        this assertion