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

Class IngestionRunAssert

java.lang.Object

org.assertj.core.api.AbstractAssert<IngestionRunAssert,com.snowflake.connectors.application.observability.IngestionRun>

com.snowflake.connectors.common.assertions.ingestion.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

Constructor Summary

Constructors

Constructor	Description
IngestionRunAssert(com.snowflake.connectors.application.observability.IngestionRun ingestionRun, Class<IngestionRunAssert> selfType)	Creates a new IngestionRunAssert.

Method Summary

Modifier and Type	Method	Description
IngestionRunAssert	hasCompletedAt()	Asserts that ingestion run completed at value is not null.
IngestionRunAssert	hasCompletedAt(Instant completedAt)	Asserts that this ingestion run has a completedAt timestamp equal to the specified value.
IngestionRunAssert	hasCompletedAtAfterStartedAt()	Asserts that ingestion run has started before completion.
IngestionRunAssert	hasCompletedAtBetween(Instant start, Instant end)	Asserts that this ingestion run has a completedAt timestamp between to the specified values.
IngestionRunAssert	hasCompletedState()	Asserts that this ingestion run has ingestion run in STATE COMPLETED and ingested any rows.
IngestionRunAssert	hasId(String id)	Asserts that this ingestion run has an id equal to the specified value.
IngestionRunAssert	hasIdAsUUID()	Asserts that this ingestion run has an id matching UUID.
IngestionRunAssert	hasIngestedRows(long ingestedRows)	Asserts that this ingestion run has a number of ingested rows equal to the specified value.
IngestionRunAssert	hasIngestedRowsGreaterThan(int ingestedRows)	Asserts that this ingestion run has a number of ingested rows grater than the specified value.
IngestionRunAssert	hasIngestionConfigurationId(String ingestionConfigurationId)	Asserts that this ingestion run has an ingestion configuration id equal to the specified value.
IngestionRunAssert	hasIngestionConfigurationIdAsUUID()	Asserts that this ingestion run has a configuration id matching UUID.
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	hasIngestionProcessIdAsUUID()	Asserts that this ingestion run has a process id matching UUID.
IngestionRunAssert	hasMetadata()	Asserts that ingestion run metadata value is not null.
IngestionRunAssert	hasMetadata(Variant metadata)	Asserts that this ingestion run has a metadata equal to the specified value.
IngestionRunAssert	hasStartedAt()	Asserts that ingestion run started at value is not null.
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()	Asserts that ingestion run updated at value is not null.
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 class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

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)

Creates a new IngestionRunAssert.

Parameters:

ingestionRun - asserted ingestion run

selfType - self type

Method Detail

hasIdAsUUID

public IngestionRunAssert hasIdAsUUID()

Asserts that this ingestion run has an id matching UUID.

Returns:

this assertion

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

hasIngestionConfigurationIdAsUUID

public IngestionRunAssert hasIngestionConfigurationIdAsUUID()

Asserts that this ingestion run has a configuration id matching UUID.

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

hasIngestionProcessIdAsUUID

public IngestionRunAssert hasIngestionProcessIdAsUUID()

Asserts that this ingestion run has a process id matching UUID.

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

hasStartedAt

public IngestionRunAssert hasStartedAt()

Asserts that ingestion run started at value is not null.

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

hasCompletedAt

public IngestionRunAssert hasCompletedAt()

Asserts that ingestion run completed at value is not null.

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

hasCompletedAtAfterStartedAt

public IngestionRunAssert hasCompletedAtAfterStartedAt()

Asserts that ingestion run has started before completion.

Returns:

this assertion

hasIngestedRowsGreaterThan

public IngestionRunAssert hasIngestedRowsGreaterThan(int ingestedRows)

Asserts that this ingestion run has a number of ingested rows grater than the specified value.

Parameters:

ingestedRows - expected number of ingested rows

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()

Asserts that ingestion run updated at value is not null.

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()

Asserts that ingestion run metadata value is not null.

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

hasCompletedState

public IngestionRunAssert hasCompletedState()

Asserts that this ingestion run has ingestion run in STATE COMPLETED and ingested any rows.

Returns:

this assertion