MCPcopy
hub / github.com/PeerDB-io/peerdb / Connector

Interface Connector

flow/connectors/core.go:31–34  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

29)
30
31type Connector interface {
32 Close() error
33 ConnectionActive(context.Context) error
34}
35
36type ValidationConnector interface {
37 Connector

Callers 14

mainFunction · 0.65
AttachToCdcStreamFunction · 0.65
ReadFileToBytesFunction · 0.65
TestMongoDBAvroSizeComputationFunction · 0.65
runSizeSubtestFunction · 0.65
writeAvroFileCompressedFunction · 0.65
getActualUncompressedSizeFunction · 0.65
GetDestinationTableSchemaFunction · 0.65
CheckConnectionMethod · 0.65
pullAndSyncCoreFunction · 0.65
ValidatePeerMethod · 0.65
TestPostgresSSHReceiveMessageDeadlineRespectsContextDeadlineFunction · 0.65

Implementers 11

BigQueryConnectorflow/connectors/bigquery/bigquery.go
PostgresConnectorflow/connectors/postgres/postgres.go
MongoConnectorflow/connectors/mongo/mongo.go
MySqlConnectorflow/connectors/mysql/mysql.go
S3Connectorflow/connectors/s3/s3.go
KafkaConnectorflow/connectors/kafka/kafka.go
EventHubConnectorflow/connectors/eventhub/eventhub.go
PubSubConnectorflow/connectors/pubsub/pubsub.go
ClickHouseConnectorflow/connectors/clickhouse/clickhouse.
ElasticsearchConnectorflow/connectors/elasticsearch/elastics
SnowflakeConnectorflow/connectors/snowflake/snowflake.go

Calls

no outgoing calls

Tested by

no test coverage detected