List of all items
Structs
- AdapterCallContract
- AdapterConformanceCheck
- AdapterConformanceReport
- AnalyticsEvent
- AppServiceError
- AppliedMigration
- AsyncCancellationToken
- AsyncMemoryRepo
- AsyncQueryContext
- AuthCredentials
- AuthIdentity
- AuthSession
- AxiomTelemetryBridge
- BackgroundJobHandle
- BackgroundJobRequest
- BackgroundJobStatus
- BigQueryDriver
- BigQueryPipelineSink
- BigQueryPipelineSource
- CacheEntry
- Changeset
- ClickHouseDriver
- ClickHousePipelineSink
- ClickHousePipelineSource
- CompactRowsPayload
- DataWindowRequest
- DataWindowResponse
- DatabaseConfig
- EmailMessage
- EmailReceipt
- Field
- FileJsonLineSink
- FileJsonLineSource
- Filter
- IdempotentInMemorySink
- InMemoryAxiomSink
- InMemoryBigQueryAdapter
- InMemoryCacheBackend
- InMemoryCheckpointStore
- InMemoryClickHouseAdapter
- InMemoryDeadLetterStore
- InMemoryIdentityService
- InMemoryJobOrchestrator
- InMemoryObjectStore
- InMemoryOpenSearchAdapter
- InMemoryPipelineEventStore
- InMemoryQueueBackend
- InMemoryRecordSource
- InMemorySingleStoreAdapter
- InMemoryTransactionalEmailService
- IncrementalDiff
- IntegrationError
- JobHandle
- JobOrchestratorBackgroundJobs
- JobRequest
- JobStatus
- KeysetCursor
- KeysetPagination
- LifecycleHooks
- MemoryRepo
- Migration
- MigrationEngine
- MigrationStatus
- MySqlAdapter
- ObjectStoreJsonSink
- ObjectStoreJsonSource
- OpenSearchAdapterDriver
- OpenSearchPipelineSink
- OpenSearchPipelineSource
- OptimisticLock
- Pagination
- PassthroughTransform
- Pipeline
- PipelineBatch
- PipelineConformanceCheck
- PipelineConformanceReport
- PipelineControl
- PipelineDeadLetter
- PipelineDeadLetterInput
- PipelineEvent
- PipelineOperationSnapshot
- PipelineRun
- PipelineRuntime
- PostgresAdapter
- Query
- QueryContext
- QueryObservabilityPolicy
- QueryObservabilityTracker
- QueryObservation
- QueryWindow
- QueueMessage
- RetryPolicy
- Schema
- SearchRequest
- SearchResponse
- SingleStoreDriver
- SingleStorePipelineSink
- SingleStorePipelineSource
- SinkWriteResult
- Sort
- SqlCommand
- SqliteAdapter
- StoredRow
- TenantBackgroundJobQuota
- TenantPolicyContext
- TenantPolicyDecision
- TenantQuotaBackgroundJobs
- TenantRepoConfig
- TenantScopedRepo
- TransformBatch
- ValidationError
- WindowPage
- WindowToken
Enums
- AdapterKind
- AppServiceErrorKind
- BackgroundJobState
- DataError
- FieldType
- FilterOperator
- IntegrationErrorKind
- JobState
- KeysetDirection
- PipelineEventKind
- PipelineRunCommand
- PipelineRunStatus
- PipelineStage
- PipelineTrigger
- SortDirection
- TenantRepoOperation
- WireFormatProfile
Traits
- AdapterDriver
- AnalyticsSink
- AsyncRepo
- BackgroundJobService
- BigQueryAdapter
- CacheBackend
- CheckpointStore
- ClickHouseAdapter
- ConnectionLifecycle
- ConnectionLifecycleHook
- DeadLetterStore
- IdentityService
- JobOrchestrator
- OpenSearchAdapter
- OptimisticLockingRepo
- PipelineEventStore
- QueueBackend
- Repo
- RepoUnitOfWork
- SchemaDefinition
- SingleStoreAdapter
- Sink
- Source
- TransactionalEmailService
- Transform
- TriggerDevAdapter
- TypedQueryBoundary
Functions
- adapter_for
- load_migrations
- map_app_service_error
- map_app_service_result
- map_integration_error
- map_integration_result
- pipeline_records_to_json_lines
- query_from_search
- run_adapter_conformance_suite
- run_pipeline_adapter_conformance_suite
- run_with_contract
- run_with_contract_async
- run_with_retry
- run_with_retry_async
- write_pipeline_records_to_file