Documentation
¶
Overview ¶
Package testhelpers provides test utilities for workflow-plugin-data-engineering. It re-exports the registry helpers, mock constructors, and types from the internal packages so that external test suites (e.g. workflow-scenarios/e2e) can perform full lifecycle tests without importing internal packages directly.
Index ¶
- func CDCLookupMemoryProvider(sourceID string) (*cdc.MemoryProvider, bool)
- func CDCUnregisterSource(sourceID string)
- func CatalogUnregisterModule(name string)
- func LakehouseUnregisterCatalog(name string)
- func MigrateUnregisterModule(name string)
- func NewNeo4jModuleForTest(name string, driver Neo4jDriver) *graph.Neo4jModule
- func NewPlugin(version string) sdk.PluginProvider
- func QualityNewModuleWithExecutor(name string, exec DBQuerier) error
- func QualitySetExecutor(name string, exec DBQuerier)
- func QualityUnregisterChecksModule(name string)
- func RegisterNeo4jModule(name string, m *graph.Neo4jModule) error
- func TSUnregister(name string)
- func UnregisterNeo4jModule(name string)
- type CDCSchemaVersion
- type DBQuerier
- type GraphResult
- type GraphSession
- type Neo4jDriver
- type Neo4jRecord
- type Neo4jSessionConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CDCLookupMemoryProvider ¶
func CDCLookupMemoryProvider(sourceID string) (*cdc.MemoryProvider, bool)
CDCLookupMemoryProvider returns the MemoryProvider for sourceID, if registered.
func CDCUnregisterSource ¶
func CDCUnregisterSource(sourceID string)
CDCUnregisterSource removes a CDC source from the global registry.
func CatalogUnregisterModule ¶
func CatalogUnregisterModule(name string)
CatalogUnregisterModule removes a catalog module (DataHub/OpenMetadata) from the registry.
func LakehouseUnregisterCatalog ¶
func LakehouseUnregisterCatalog(name string)
LakehouseUnregisterCatalog removes a catalog from the lakehouse registry.
func MigrateUnregisterModule ¶
func MigrateUnregisterModule(name string)
MigrateUnregisterModule removes a migrate.schema module from the registry.
func NewNeo4jModuleForTest ¶
func NewNeo4jModuleForTest(name string, driver Neo4jDriver) *graph.Neo4jModule
NewNeo4jModuleForTest creates a Neo4jModule wired with a mock driver.
func NewPlugin ¶
func NewPlugin(version string) sdk.PluginProvider
NewPlugin returns a new data-engineering plugin instance, cast to the full provider interface used in tests.
func QualityNewModuleWithExecutor ¶
QualityNewModuleWithExecutor creates a quality.checks ChecksModule pre-wired with the given executor and registers it under name. The caller must call QualityUnregisterChecksModule(name) in t.Cleanup.
func QualitySetExecutor ¶
QualitySetExecutor injects a DBQuerier into the named quality.checks module. It is a no-op if the module is not found in the registry.
func QualityUnregisterChecksModule ¶
func QualityUnregisterChecksModule(name string)
QualityUnregisterChecksModule removes a quality.checks module from the registry.
func RegisterNeo4jModule ¶
func RegisterNeo4jModule(name string, m *graph.Neo4jModule) error
RegisterNeo4jModule registers a pre-wired Neo4j module.
func TSUnregister ¶
func TSUnregister(name string)
TSUnregister removes a time-series module from the registry.
func UnregisterNeo4jModule ¶
func UnregisterNeo4jModule(name string)
UnregisterNeo4jModule removes a Neo4j module from the registry.
Types ¶
type CDCSchemaVersion ¶
type CDCSchemaVersion = cdc.SchemaVersion
CDCSchemaVersion re-exports cdc.SchemaVersion.
type GraphResult ¶
type GraphResult = graph.GraphResult
GraphResult is the narrow interface over neo4j.ResultWithContext.
type GraphSession ¶
type GraphSession = graph.GraphSession
GraphSession is the narrow interface over neo4j.SessionWithContext.
type Neo4jDriver ¶
type Neo4jDriver = graph.Neo4jDriver
Neo4jDriver is the narrow interface over neo4j.DriverWithContext.
type Neo4jRecord ¶
Neo4jRecord re-exports neo4j.Record for use in mock implementations.
type Neo4jSessionConfig ¶
type Neo4jSessionConfig = neo4j.SessionConfig
Neo4jSessionConfig re-exports neo4j.SessionConfig.
Source Files