testapp

package

v0.1.9 Latest Latest Go to latest Published: Mar 3, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation ¶

Index ¶

func EnsurePersistedTxStatus(ctx context.Context, t *testing.T, r StatusRetriever, txIDs []string, ...)
func RequireStatus(t require.TestingT, expected *committerpb.TxStatus, ...)
type StatusRetriever

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EnsurePersistedTxStatus ¶

func EnsurePersistedTxStatus(
	ctx context.Context,
	t *testing.T,
	r StatusRetriever,
	txIDs []string,
	expected []*committerpb.TxStatus,
)

EnsurePersistedTxStatus fails the test if the given TX IDs does not match the expected status.

func RequireStatus ¶

func RequireStatus(t require.TestingT, expected *committerpb.TxStatus, statuses []*committerpb.TxStatus)

RequireStatus fails if the expected status does not appear in the statuses list.

Types ¶

type StatusRetriever ¶

type StatusRetriever interface {
	GetTransactionsStatus(context.Context, *committerpb.TxIDsBatch, ...grpc.CallOption) (
		*committerpb.TxStatusBatch, error,
	)
}

StatusRetriever provides implementation retrieve status of given transaction identifiers.

Source Files ¶

View all Source files

apptest.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL